reconcilers

type Connector interface {
	AcquireRead(ctx context.Context) (*pgxpool.Conn, error)
	AcquireWrite(ctx context.Context) (*pgxpool.Conn, error)
}

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

type Logger interface {
	InfofCtx(ctx context.Context, template string, args ...any)
	ErrorfCtx(ctx context.Context, template string, args ...any)
}

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

type Processor interface {
	Process(ctx context.Context, stream es.StreamReference) error
}

type Reconciler interface {
	Reconcile(ctx context.Context, p Processor) error
}

type Schema interface {
	SelectOutboxStreamIDs(ctx context.Context, db dbtx.DBTX, graceWindow time.Duration, partitions []uint32, token string, limit int) ([]es.StreamReference, error)
	Listen(ctx context.Context, db dbtx.DBTX, partitions []uint32) error
	Unlisten(ctx context.Context, db dbtx.DBTX, partitions []uint32) error
}

type Valuer interface {
	Values() []uint32
}