db

Documentation

Index

• Constants
• Variables
• func InitKV() error
• type EtcdClient
  • func NewEtcdClient(endpoints []string) (*EtcdClient, error)
  • func (c *EtcdClient) Delete(key string) (string, error)
  • func (c *EtcdClient) Get(key string) (string, error)
  • func (c *EtcdClient) List(key string, withPrefix bool) (map[string]string, error)
  • func (c *EtcdClient) Lock(ctx context.Context, key string) error
  • func (c *EtcdClient) Range(begin string, end string) (map[string]string, error)
  • func (c *EtcdClient) Set(key string, value string) error
  • func (c *EtcdClient) Unlock(ctx context.Context, key string) error
  • func (c *EtcdClient) Watch(ctx context.Context, key string, withPrefix bool) <-chan KVAction
• type KVAction
• type KVMutex
• type KVStorage

Constants

const (
	KVActionTypeSet    = "set"
	KVActionTypeDelete = "delete"
)

Variables

var ClientV3 *clientv3.Client

Functions

func InitKV

func InitKV() error

Types

type EtcdClient

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

func NewEtcdClient

func NewEtcdClient(endpoints []string) (*EtcdClient, error)

func (*EtcdClient) Delete

func (c *EtcdClient) Delete(key string) (string, error)

func (*EtcdClient) Get

func (c *EtcdClient) Get(key string) (string, error)

func (*EtcdClient) List

func (c *EtcdClient) List(key string, withPrefix bool) (map[string]string, error)

func (*EtcdClient) Lock

func (c *EtcdClient) Lock(ctx context.Context, key string) error

func (*EtcdClient) Range

func (c *EtcdClient) Range(begin string, end string) (map[string]string, error)

func (*EtcdClient) Set

func (c *EtcdClient) Set(key string, value string) error

func (*EtcdClient) Unlock

func (c *EtcdClient) Unlock(ctx context.Context, key string) error

func (*EtcdClient) Watch

func (c *EtcdClient) Watch(ctx context.Context, key string, withPrefix bool) <-chan KVAction

type KVAction

type KVAction struct {
	Key        string
	Value      string
	ActionType string
}

type KVMutex

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

type KVStorage

type KVStorage interface {
	Get(string) (string, error)
	Set(string, string) error
	List(string, bool) (map[string]string, error)
	Delete(string) (string, error)
	Range(string, string) (map[string]string, error)
	Watch(context.Context, string, bool) <-chan KVAction
	Lock(context.Context, string) error
	Unlock(context.Context, string) error
}

var KV KVStorage