kvstore

Documentation

Index

• Constants
• Variables
• type PutOption
  • func WithTtl(ttl int64) PutOption
  • func WithVersion(version int64) PutOption
• type Store
  • func NewEtcdKVStore(cli *clientv3.Client) Store

Constants

const DefaultRetentionPeriod = 60 * 60 * 12

12 hrs would be the default one

Variables

var (
	ErrNotFound         = errors.New("record  not found")
	ErrConcurrentUpdate = errors.New("concurrent update")
)

Types

type PutOption

type PutOption func(c *putConfig)

func WithTtl

func WithTtl(ttl int64) PutOption

func WithVersion

func WithVersion(version int64) PutOption

type Store

type Store interface {
	Get(ctx context.Context, key string) (*stream.FlowKeyValue, error)
	Put(ctx context.Context, key, value string, opts ...PutOption) error
	Delete(ctx context.Context, key string) error
}

func NewEtcdKVStore

func NewEtcdKVStore(cli *clientv3.Client) Store