sink

type Factory func(name string, primCfg PrimitiveConfig, logger Logger) (Sink, error)

type Logger interface {
	Fatalf(format string, args ...interface{})
	Panicf(format string, args ...interface{})
	Printf(format string, args ...interface{})
	Debugf(format string, args ...interface{})
	Errorf(format string, args ...interface{})
	Infof(format string, args ...interface{})
	Warnf(format string, args ...interface{})
}

type PrimitiveConfig toml.Primitive

type Sink interface {
	canal.EventHandler
	// Checkpoint will be called periodically, sink need to expose
	// it's progress and corresponding ctx, and these info will
	// be persisted in ZooKeeper
	ckp.Checkpointer

	// Initialize will be called at process start, you need to
	// recover state from the point that checkpointed last time
	Initialize(ctx context.Context, checkpoint *ckp.Checkpoint) error

	// You need to report error by this channel.
	Err() <-chan error

	Close() error
}