pgcapture

type BounceHandler interface {
	Initialize(ctx context.Context, mh ModelAsyncHandlers) error
	Handle(fn ModelAsyncHandlerFunc, checkpoint cursor.Checkpoint, change Change)
}

type Change struct {
	Op         pb.Change_Operation
	Checkpoint cursor.Checkpoint
	New        interface{}
	Old        interface{}
}

type Consumer struct {
	Source  source.RequeueSource
	Bouncer BounceHandler
	// contains filtered or unexported fields
}

type ConsumerOption struct {
	URI              string
	TableRegex       string
	DebounceInterval time.Duration
	OnDecodeError    OnDecodeError
}

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

type DebounceHandler struct {
	Interval time.Duration
	// contains filtered or unexported fields
}

type DebounceModel interface {
	Model
	DebounceKey() string
}

type Model interface {
	TableName() (schema, table string)
}

type ModelAsyncHandlerFunc func(change Change, done func(err error))

type ModelAsyncHandlers map[Model]ModelAsyncHandlerFunc

type ModelHandlerFunc func(change Change) error

type ModelHandlers map[Model]ModelHandlerFunc

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

type OnDecodeError func(source source.Change, err error)