Struct EtcdStore

pkg/store/store_etcd.go:41–61

EtcdStore etcd store impl

// EtcdStore etcd store impl
type EtcdStore struct {
	sync.RWMutex

	prefix      string
	clustersDir string
	serversDir  string
	bindsDir    string
	apisDir     string
	proxiesDir  string
	routingsDir string
	idPath      string

	idLock sync.Mutex
	base   uint64
	end    uint64

	evtCh              chan *Evt
	watchMethodMapping map[EvtSrc]func(EvtType, *mvccpb.KeyValue) *Evt

	rawClient *clientv3.Client
}

// NewEtcdStore create a etcd store
func NewEtcdStore(etcdAddrs []string, prefix string, basicAuth BasicAuth) (Store, error) {