etcdService

Documentation

Index

• type ServerBuilder
  • func NewServerBuilder() *ServerBuilder
  • func (a *ServerBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOption) (resolver.Resolver, error)
  • func (a *ServerBuilder) Scheme() string
• type ServerRegister
  • func NewServerRegister(addrs []string, ttl int64) *ServerRegister
  • func (a *ServerRegister) Close()
  • func (a *ServerRegister) PutServer(key, val string) error
  • func (a *ServerRegister) RevokeLease()
  • func (a *ServerRegister) SetKeepalive()
  • func (a *ServerRegister) SetLease(ttl int64)
• type ServerResolver
  • func (a *ServerResolver) Close()
  • func (a *ServerResolver) GetAddr(prefix string)
  • func (a *ServerResolver) ResolveNow(resolver.ResolveNowOption)

Types

type ServerBuilder

type ServerBuilder struct {
}

func NewServerBuilder

func NewServerBuilder() *ServerBuilder

func (*ServerBuilder) Build

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

etcdService://authority1,authority2/endpoint

func (*ServerBuilder) Scheme

func (a *ServerBuilder) Scheme() string

type ServerRegister

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

func NewServerRegister

func NewServerRegister(addrs []string, ttl int64) *ServerRegister

func (*ServerRegister) Close

func (a *ServerRegister) Close()

func (*ServerRegister) PutServer

func (a *ServerRegister) PutServer(key, val string) error

func (*ServerRegister) RevokeLease

func (a *ServerRegister) RevokeLease()

func (*ServerRegister) SetKeepalive

func (a *ServerRegister) SetKeepalive()

func (*ServerRegister) SetLease

func (a *ServerRegister) SetLease(ttl int64)

type ServerResolver

type ServerResolver struct {
	AddrMap map[string]string
	// contains filtered or unexported fields
}

func (*ServerResolver) Close

func (a *ServerResolver) Close()

func (*ServerResolver) GetAddr

func (a *ServerResolver) GetAddr(prefix string)

func (*ServerResolver) ResolveNow

func (a *ServerResolver) ResolveNow(resolver.ResolveNowOption)