etcd

Documentation

Index

• Constants
• type Client
  • func NewClient() *Client
  • func (c *Client) Close(key string)
  • func (c *Client) Connect(conf Config) error
  • func (c *Client) Delete(key string, isPrefix bool) error
  • func (c *Client) Get(key string, isPrefix bool) (Values, error)
  • func (c *Client) Grant(ttl int64) (clientv3.LeaseID, error)
  • func (c *Client) KeepAlive(leaseId clientv3.LeaseID) (<-chan *clientv3.LeaseKeepAliveResponse, error)
  • func (c *Client) KeepAliveOnce(leaseId clientv3.LeaseID) (*clientv3.LeaseKeepAliveResponse, error)
  • func (c *Client) Put(key, value string, opts ...clientv3.OpOption) error
  • func (c *Client) Revoke(leaseId clientv3.LeaseID) error
  • func (c *Client) Shutdown()
  • func (c *Client) Watch(e IEvent, opts ...clientv3.OpOption) error
• type Config
• type IEvent
• type Values
  • func (v Values) Add(key, value string)
  • func (v Values) Get(key string) string

Constants

const (
	Req_Timeout time.Duration = 30
)

Types

type Client

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

func NewClient

func NewClient() *Client

func (*Client) Close

func (c *Client) Close(key string)

func (*Client) Connect

func (c *Client) Connect(conf Config) error

func (*Client) Delete

func (c *Client) Delete(key string, isPrefix bool) error

func (*Client) Get

func (c *Client) Get(key string, isPrefix bool) (Values, error)

func (*Client) Grant

func (c *Client) Grant(ttl int64) (clientv3.LeaseID, error)

func (*Client) KeepAlive

func (c *Client) KeepAlive(leaseId clientv3.LeaseID) (<-chan *clientv3.LeaseKeepAliveResponse, error)

func (*Client) KeepAliveOnce

func (c *Client) KeepAliveOnce(leaseId clientv3.LeaseID) (*clientv3.LeaseKeepAliveResponse, error)

func (*Client) Put

func (c *Client) Put(key, value string, opts ...clientv3.OpOption) error

func (*Client) Revoke

func (c *Client) Revoke(leaseId clientv3.LeaseID) error

func (*Client) Shutdown

func (c *Client) Shutdown()

func (*Client) Watch

func (c *Client) Watch(e IEvent, opts ...clientv3.OpOption) error

type Config

type Config struct {
	Endpoints   []string `yaml:"endpoints" json:"endpoints"`
	DialTimeout int      `yaml:"timeout" json:"timeout"`
	Username    string   `yaml:"username" json:"username"`
	Password    string   `yaml:"password" json:"password"`
	Namespace   string   `yaml:"namespace" json:"namespace"`
}

type IEvent

type IEvent interface {
	Create(key, value string) error
	Modify(key, value string) error
	Delete(key, value string) error
	Key() string
	IsPrefix() bool
	Tick(t time.Time) error
}

type Values

type Values map[string]string

func (Values) Add

func (v Values) Add(key, value string)

func (Values) Get

func (v Values) Get(key string) string