eventsio

type Codec interface {
	Encode(event es.Event) ([]byte, error)
	Decode(streamType, contentName string, b []byte) (es.Content, error)
	Register(streamType string, contentTypes ...es.Content) error
}

type Connector interface {
	AcquireReadStream(ctx context.Context, streamType, streamID string) (*pgxpool.Conn, error)
}

type Reader struct {
	// contains filtered or unexported fields
}

type Schema interface {
	WriteEvent(ctx context.Context, db dbtx.DBTX, event es.Event, content, metadata []byte) error
	InsertOutbox(ctx context.Context, tx dbtx.DBTX, streamType, streamID, storeStreamID string, eventNumber, watermark int64, partition uint32) (int64, error)
	UpdateOutbox(ctx context.Context, tx dbtx.DBTX, streamType, streamID string, eventNumber, lastEventNumber int64) (int64, error)
	SelectEvents(ctx context.Context, db dbtx.DBTX, streamType string, streamID string, eventNumber int64) (pgx.Rows, error)
	Notify(ctx context.Context, db dbtx.DBTX, partition uint32, payload string) error
}

type Validator interface {
	Validate(streamType string, events iter.Seq2[es.Event, error]) iter.Seq2[es.Event, error]
}

type ValidatorFunc func(streamType string, events iter.Seq2[es.Event, error]) iter.Seq2[es.Event, error]

type Writer struct {
	// contains filtered or unexported fields
}