service

Documentation

Index

• func NewServiceDiscovery(endpoints []string) resolver.Builder
• type ServiceDiscovery
  • func (s *ServiceDiscovery) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOption) (resolver.Resolver, error)
  • func (s *ServiceDiscovery) Close()
  • func (s *ServiceDiscovery) DelServiceList(key string)
  • func (s *ServiceDiscovery) ResolveNow(rn resolver.ResolveNowOption)
  • func (s *ServiceDiscovery) SetServiceList(key, val string)
• type ServiceRegister
  • func NewServiceRegister(endpoints []string, name, addr string, lease int64) (*ServiceRegister, error)
  • func (s *ServiceRegister) Close() error
  • func (s *ServiceRegister) ListenLeaseRespC()

Functions

func NewServiceDiscovery

func NewServiceDiscovery(endpoints []string) resolver.Builder

Types

type ServiceDiscovery

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

func (*ServiceDiscovery) Build

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

func (*ServiceDiscovery) Close

func (s *ServiceDiscovery) Close()

func (*ServiceDiscovery) DelServiceList

func (s *ServiceDiscovery) DelServiceList(key string)

func (*ServiceDiscovery) ResolveNow

func (s *ServiceDiscovery) ResolveNow(rn resolver.ResolveNowOption)

func (*ServiceDiscovery) SetServiceList

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

type ServiceRegister

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

func NewServiceRegister

func NewServiceRegister(endpoints []string, name, addr string, lease int64) (*ServiceRegister, error)

func (*ServiceRegister) Close

func (s *ServiceRegister) Close() error

func (*ServiceRegister) ListenLeaseRespC

func (s *ServiceRegister) ListenLeaseRespC()