etcdv3

Documentation

Index

• func NewStore() configstores.Store
• type EtcdV3ConfigStore
  • func (c *EtcdV3ConfigStore) Delete(ctx context.Context, req *configstores.DeleteRequest) error
  • func (c *EtcdV3ConfigStore) Get(ctx context.Context, req *configstores.GetRequest) ([]*configstores.ConfigurationItem, error)
  • func (c *EtcdV3ConfigStore) GetDefaultGroup() string
  • func (c *EtcdV3ConfigStore) GetDefaultLabel() string
  • func (c *EtcdV3ConfigStore) GetItemsFromAllKeys(kvs []*mvccpb.KeyValue, targetString []string) []*configstores.ConfigurationItem
  • func (c *EtcdV3ConfigStore) GetPrimaryKeyWithoutTag(s string) string
  • func (c *EtcdV3ConfigStore) Init(config *configstores.StoreConfig) error
  • func (c *EtcdV3ConfigStore) OnLogLevelChanged(outputLevel log.LogLevel)
  • func (c *EtcdV3ConfigStore) ParseKey(appId string, req *configstores.ConfigurationItem) []string
  • func (c *EtcdV3ConfigStore) Set(ctx context.Context, req *configstores.SetRequest) error
  • func (c *EtcdV3ConfigStore) StopSubscribe()
  • func (c *EtcdV3ConfigStore) Subscribe(req *configstores.SubscribeReq, ch chan *configstores.SubscribeResp) error

Functions

func NewStore

func NewStore() configstores.Store

Types

type EtcdV3ConfigStore

type EtcdV3ConfigStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*EtcdV3ConfigStore) Delete

func (c *EtcdV3ConfigStore) Delete(ctx context.Context, req *configstores.DeleteRequest) error

Delete deletes configuration from configuration store.

func (*EtcdV3ConfigStore) Get

func (c *EtcdV3ConfigStore) Get(ctx context.Context, req *configstores.GetRequest) ([]*configstores.ConfigurationItem, error)

Get gets configuration from configuration store.

func (*EtcdV3ConfigStore) GetDefaultGroup

func (c *EtcdV3ConfigStore) GetDefaultGroup() string

func (*EtcdV3ConfigStore) GetDefaultLabel

func (c *EtcdV3ConfigStore) GetDefaultLabel() string

func (*EtcdV3ConfigStore) GetItemsFromAllKeys

func (c *EtcdV3ConfigStore) GetItemsFromAllKeys(kvs []*mvccpb.KeyValue, targetString []string) []*configstores.ConfigurationItem

func (*EtcdV3ConfigStore) GetPrimaryKeyWithoutTag

func (c *EtcdV3ConfigStore) GetPrimaryKeyWithoutTag(s string) string

func (*EtcdV3ConfigStore) Init

func (c *EtcdV3ConfigStore) Init(config *configstores.StoreConfig) error

Init init the configuration store.

func (*EtcdV3ConfigStore) OnLogLevelChanged

func (c *EtcdV3ConfigStore) OnLogLevelChanged(outputLevel log.LogLevel)

func (*EtcdV3ConfigStore) ParseKey

func (c *EtcdV3ConfigStore) ParseKey(appId string, req *configstores.ConfigurationItem) []string

func (*EtcdV3ConfigStore) Set

func (c *EtcdV3ConfigStore) Set(ctx context.Context, req *configstores.SetRequest) error

Set saves configuration into configuration store.

func (*EtcdV3ConfigStore) StopSubscribe

func (c *EtcdV3ConfigStore) StopSubscribe()

func (*EtcdV3ConfigStore) Subscribe

func (c *EtcdV3ConfigStore) Subscribe(req *configstores.SubscribeReq, ch chan *configstores.SubscribeResp) error

Subscribe gets configuration from configuration store and subscribe the updates.