etcd

Documentation

Index

• Constants
• type EtcdV3Wrapper
  • func NewEtcdV3Wrapper(endpoints string, dialTimeout int64, timeout int64) (*EtcdV3Wrapper, error)
• type ServiceDiscovery
  • func NewServiceDiscovery(endpoints string, dialTimeout int64) (*ServiceDiscovery, error)
  • func (sdv *ServiceDiscovery) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (sdv *ServiceDiscovery) Close()
  • func (sdv *ServiceDiscovery) ResolveNow(options resolver.ResolveNowOptions)
  • func (sdv *ServiceDiscovery) Scheme() string
• type ServiceRegister
  • func RegisterService(endpoints string, srName string, srConnect string, leaseTime int64) *ServiceRegister
  • func (srr *ServiceRegister) Close()
  • func (srr *ServiceRegister) ListenLease()
• type ServiceRegisterInfo
  • func NewRegisterInfo() *ServiceRegisterInfo
  • func (r *ServiceRegisterInfo) Parse(s string) error
  • func (r *ServiceRegisterInfo) String() string

Constants

const RegisterPrefix = "/srv/reg"

const TIME_LAYOUT = "2006-01-02 15:04:05"

Types

type EtcdV3Wrapper

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

func NewEtcdV3Wrapper

func NewEtcdV3Wrapper(endpoints string, dialTimeout int64, timeout int64) (*EtcdV3Wrapper, error)

type ServiceDiscovery

type ServiceDiscovery struct {
	*EtcdV3Wrapper
	// contains filtered or unexported fields
}

func NewServiceDiscovery

func NewServiceDiscovery(endpoints string, dialTimeout int64) (*ServiceDiscovery, error)

func (*ServiceDiscovery) Build

func (sdv *ServiceDiscovery) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*ServiceDiscovery) Close

func (sdv *ServiceDiscovery) Close()

Close closes the resolver.

func (*ServiceDiscovery) ResolveNow

func (sdv *ServiceDiscovery) ResolveNow(options resolver.ResolveNowOptions)

func (*ServiceDiscovery) Scheme

func (sdv *ServiceDiscovery) Scheme() string

type ServiceRegister

type ServiceRegister struct {
	*EtcdV3Wrapper
	// contains filtered or unexported fields
}

func RegisterService

func RegisterService(endpoints string, srName string, srConnect string, leaseTime int64) *ServiceRegister

func (*ServiceRegister) Close

func (srr *ServiceRegister) Close()

func (*ServiceRegister) ListenLease

func (srr *ServiceRegister) ListenLease()

type ServiceRegisterInfo

type ServiceRegisterInfo struct {
	SrName           string `json:"sr_name"`
	SrInvoke         string `json:"sr_invoke"`
	CreateTime       int64  `json:"create_time"`
	CreateTimeFormat string `json:"create_time_format"`
	LeaseTime        int64  `json:"lease_time"`
	HostName         string `json:"hostname"`
}

func NewRegisterInfo

func NewRegisterInfo() *ServiceRegisterInfo

func (*ServiceRegisterInfo) Parse

func (r *ServiceRegisterInfo) Parse(s string) error

func (*ServiceRegisterInfo) String

func (r *ServiceRegisterInfo) String() string