rd

README

rd

服务的注册与发现

Documentation

Index

• func GetLocalIP() (string, error)
• type RoundRobin
  • func (r *RoundRobin) Add(s string)
  • func (r *RoundRobin) Clear()
  • func (r *RoundRobin) Pick() string
• type ServiceDiscovery
  • func NewClientDiscovery(serviceName string, endpoints []string) (*ServiceDiscovery, error)
  • func (s *ServiceDiscovery) Build() error
  • func (s *ServiceDiscovery) Close()
  • func (s *ServiceDiscovery) DelServiceList(key string)
  • func (s *ServiceDiscovery) GetServerAddr() (string, error)
  • func (s *ServiceDiscovery) SetServiceList(key, val string)
• type ServiceOption
• type ServiceRegister
  • func NewServiceRegister(opt *ServiceOption) (*ServiceRegister, error)
  • func (s *ServiceRegister) Close() error
  • func (s *ServiceRegister) ListenLeaseRespChan()

Functions

func GetLocalIP

func GetLocalIP() (string, error)

GetLocalIP get the IP address of the current system

physical or virtual machine

Types

type RoundRobin

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

func (*RoundRobin) Add

func (r *RoundRobin) Add(s string)

func (*RoundRobin) Clear

func (r *RoundRobin) Clear()

func (*RoundRobin) Pick

func (r *RoundRobin) Pick() string

type ServiceDiscovery

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

func NewClientDiscovery

func NewClientDiscovery(serviceName string, endpoints []string) (*ServiceDiscovery, error)

func (*ServiceDiscovery) Build

func (s *ServiceDiscovery) Build() error

func (*ServiceDiscovery) Close

func (s *ServiceDiscovery) Close()

Close 关闭

func (*ServiceDiscovery) DelServiceList

func (s *ServiceDiscovery) DelServiceList(key string)

func (*ServiceDiscovery) GetServerAddr

func (s *ServiceDiscovery) GetServerAddr() (string, error)

GetServerAddr return grpc server ip

func (*ServiceDiscovery) SetServiceList

func (s *ServiceDiscovery) SetServiceList(key, val string)

type ServiceOption

type ServiceOption struct {
	Endpoints   []string      // etcd host
	Lease       int64         // etcd lease
	Prefix      string        // prefix,ex:serviceName
	Port        int           // grpc server port
	DialTimeout time.Duration // DialTimeout second
}

ServiceOption service register options

type ServiceRegister

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

func NewServiceRegister

func NewServiceRegister(opt *ServiceOption) (*ServiceRegister, error)

NewServiceRegister return a *ServiceRegister and error

func (*ServiceRegister) Close

func (s *ServiceRegister) Close() error

Close initiative close the lease

func (*ServiceRegister) ListenLeaseRespChan

func (s *ServiceRegister) ListenLeaseRespChan()

ListenLeaseRespChan listen the lease chan