store

type KVWatchOp int64

type WatermarkKVEntry interface {
	// Key is the key that was retrieved.
	Key() string
	// Value is the retrieved value.
	Value() []byte
	// Operation returns `KVWatchOp`.
	Operation() KVWatchOp
}

type WatermarkKVStorer interface {
	// GetAllKeys the keys from KV store.
	GetAllKeys(context.Context) ([]string, error)
	// DeleteKey deletes the key from KV store.
	DeleteKey(context.Context, string) error
	// PutKV inserts a key-value pair into the KV store.
	PutKV(context.Context, string, []byte) error
	// GetValue gets the value of the given key.
	GetValue(context.Context, string) ([]byte, error)
	// GetStoreName returns the bucket name of the KV store.
	GetStoreName() string
	// Close closes the backend connection
	Close()
}

type WatermarkKVWatcher interface {
	// Watch starts the watermark kv watcher and returns a kv updates channel and a watcher stopped channel.
	Watch(context.Context) (<-chan WatermarkKVEntry, <-chan struct{})
	GetKVName() string
	Close()
}

type WatermarkStoreWatcher interface {
	HeartbeatWatcher() WatermarkKVWatcher
	OffsetTimelineWatcher() WatermarkKVWatcher
}

type WatermarkStorer interface {
	HeartbeatStore() WatermarkKVStorer
	OffsetTimelineStore() WatermarkKVStorer
}