kvs

Documentation

Index

• type KVEntry
• type KVStorer
• type KVWatchOp
  • func (kvOp KVWatchOp) String() string

Types

type KVEntry

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

KVEntry defines what can be read on the Watch stream.

type KVStorer

type KVStorer 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
	// Watch starts watching the KV store for changes. It returns a channel of KVEntry.
	// The KVEntry channel is used to read the KVEntry and will be closed when the store is closed.
	Watch(context.Context) <-chan KVEntry
	// Close closes the backend connection
	Close()
}

KVStorer defines the storage for publishing the watermark and sideinput

type KVWatchOp

type KVWatchOp int64

KVWatchOp is the operation as detected by the KV watcher.

const (
	// KVPut indicates an element has been put/added into the KV store.
	KVPut KVWatchOp = iota
	// KVDelete represents a delete.
	KVDelete
	// KVPurge is when the kv bucket is purged.
	// This value is only for JetStream.
	KVPurge
)

func (KVWatchOp) String

func (kvOp KVWatchOp) String() string