store

Documentation

Index

• Constants
• type Etcd
  • func NewEtcd(kv *clientv3.Client) (*Etcd, error)
  • func (s *Etcd) Close() error
  • func (s *Etcd) KV(path string) (map[string]string, error)
  • func (s *Etcd) Set(path string, kv map[string]string) error
  • func (c *Etcd) SetRoot(root string)
  • func (s *Etcd) Watch(path string) (chan Event, chan error)
• type Event
• type EventType
• type Store

Constants

const (
	EventTypePut    = kvpb.Event_PUT
	EventTypeDelete = kvpb.Event_DELETE
)

Types

type Etcd

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

func NewEtcd

func NewEtcd(kv *clientv3.Client) (*Etcd, error)

func (*Etcd) Close

func (s *Etcd) Close() error

func (*Etcd) KV

func (s *Etcd) KV(path string) (map[string]string, error)

func (*Etcd) Set

func (s *Etcd) Set(path string, kv map[string]string) error

func (*Etcd) SetRoot

func (c *Etcd) SetRoot(root string)

func (*Etcd) Watch

func (s *Etcd) Watch(path string) (chan Event, chan error)

type Event

type Event struct {
	Type  EventType
	Key   string
	Value string
}

type EventType

type EventType = kvpb.Event_EventType

type Store

type Store interface {
	KV(path string) (map[string]string, error)
	Set(path string, kv map[string]string) error
	Watch(path string) (chan Event, chan error)
	Close() error
}