kv

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

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

type KeyStore interface {
	Get(ctx context.Context, key string, version uint64) (types.DBValue, error) // TODO add metaOnly
	Upsert(ctx context.Context, key string, version uint64, val types.DBValue) error
	Remove(ctx context.Context, key string, version uint64) error
	RemoveIf(ctx context.Context, key string, version uint64, pred func(prev types.DBValue) error) error
	UpdateFlag(ctx context.Context, key string, version uint64, newFlag uint8) error
	Floor(ctx context.Context, key string, upperVersion uint64) (types.DBValue, uint64, error)
	Close() error
}

type KeyStoreEx interface {
	ReadModifyWriteKey(ctx context.Context, key string, version uint64, modifyFlag func(val types.DBValue) types.DBValue, onNotExists func(err error) error) error
}

type Server struct {
	Port int

	Done chan struct{}
	// contains filtered or unexported fields
}

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

type TxnRecordStore interface {
	GetTxnRecord(ctx context.Context, version uint64) (types.DBValue, error)
	UpsertTxnRecord(ctx context.Context, version uint64, val types.DBValue) error
	RemoveTxnRecord(ctx context.Context, version uint64) error
	Close() error
}