storage

Documentation

Index

• Constants
• type Client
  • func NewClient(prefix string, logger *zap.Logger, debug bool, endpoints ...string) *Client
  • func (c *Client) Config() clientv3.Config
  • func (c *Client) Delete(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error)
  • func (c *Client) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)
  • func (c *Client) Key(parts ...string) *Key
  • func (c *Client) Put(ctx context.Context, key string, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)
  • func (c *Client) WithHooks(hooks ...StorageHook) *Client
• type Key
  • func (k *Key) Add(parts ...string) *Key
  • func (k *Key) Copy() *Key
  • func (k *Key) IsPrefix() bool
  • func (k *Key) Prefix(val bool) *Key
  • func (k *Key) String() string
• type StorageHook

Constants

const SEP = '/'

Types

type Client

type Client struct {
	*clientv3.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient(prefix string, logger *zap.Logger, debug bool, endpoints ...string) *Client

func (*Client) Config

func (c *Client) Config() clientv3.Config

func (*Client) Delete

func (c *Client) Delete(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error)

func (*Client) Get

func (c *Client) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)

func (*Client) Key

func (c *Client) Key(parts ...string) *Key

func (*Client) Put

func (c *Client) Put(ctx context.Context, key string, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)

func (*Client) WithHooks

func (c *Client) WithHooks(hooks ...StorageHook) *Client

type Key

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

func (*Key) Add

func (k *Key) Add(parts ...string) *Key

func (*Key) Copy

func (k *Key) Copy() *Key

func (*Key) IsPrefix

func (k *Key) IsPrefix() bool

func (*Key) Prefix

func (k *Key) Prefix(val bool) *Key

func (*Key) String

func (k *Key) String() string

type StorageHook

type StorageHook struct {
	GetPre    func(ctx context.Context, key string, opts ...clientv3.OpOption) error
	PutPre    func(ctx context.Context, key string, val string, opts ...clientv3.OpOption) error
	DeletePre func(ctx context.Context, key string, opts ...clientv3.OpOption) error

	GetPost    func(ctx context.Context, key string, res *clientv3.GetResponse, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)
	PutPost    func(ctx context.Context, key string, val string, res *clientv3.PutResponse, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)
	DeletePost func(ctx context.Context, key string, res *clientv3.DeleteResponse, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error)
}