etcdclient

Documentation

Index

• func Set(econf *ETCDConfigs) (err error)
• type ETCDClient
  • func Get() *ETCDClient
  • func (ec *ETCDClient) AddEndpoints(ctx context.Context, service string, address string) (err error)
  • func (ec *ETCDClient) Close() (err error)
  • func (ec *ETCDClient) GetServices(ctx context.Context, servicePrefix string) (services []*Service, err error)
  • func (ec *ETCDClient) GetValueByKey(ctx context.Context, key string) (val []string, err error)
  • func (ec *ETCDClient) RemoveEndpoints(ctx context.Context, service string, address string) (err error)
  • func (ec *ETCDClient) Resolver() *etcdnaming.GRPCResolver
  • func (ec *ETCDClient) SaveKeyValue(ctx context.Context, key string, val string) (err error)
• type ETCDConfigs
• type Service

Functions

func Set

func Set(econf *ETCDConfigs) (err error)

Types

type ETCDClient

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

func Get

func Get() *ETCDClient

func (*ETCDClient) AddEndpoints

func (ec *ETCDClient) AddEndpoints(ctx context.Context, service string, address string) (err error)

func (*ETCDClient) Close

func (ec *ETCDClient) Close() (err error)

func (*ETCDClient) GetServices

func (ec *ETCDClient) GetServices(ctx context.Context, servicePrefix string) (services []*Service, err error)

func (*ETCDClient) GetValueByKey

func (ec *ETCDClient) GetValueByKey(ctx context.Context, key string) (val []string, err error)

func (*ETCDClient) RemoveEndpoints

func (ec *ETCDClient) RemoveEndpoints(ctx context.Context, service string, address string) (err error)

func (*ETCDClient) Resolver

func (ec *ETCDClient) Resolver() *etcdnaming.GRPCResolver

func (*ETCDClient) SaveKeyValue

func (ec *ETCDClient) SaveKeyValue(ctx context.Context, key string, val string) (err error)

type ETCDConfigs

type ETCDConfigs struct {
	Endpoints []string `mapstructure:"endpoints"`
	Timeout   int      `mapstructure:"timeout"`
}

type Service

type Service struct {
	Name string `json:"-"`
	Addr string `json:"addr"`
}