registrarclient

Documentation

Index

• Constants
• type ClientOption
  • func WithFileOption(filepath string) ClientOption
  • func WithLeaseTime(t int64) ClientOption
  • func WithPassive(b bool) ClientOption
  • func WithRegistrarAddr(addr []string) ClientOption
  • func WithService(name, addr string) ClientOption
• type ClientOpts
  • func NewDefaultOptions() *ClientOpts
  • func (opt *ClientOpts) ApplyOpts(option []ClientOption)
  • func (opt *ClientOpts) WithLeaseTime(leaseTime int64) *ClientOpts
  • func (opt *ClientOpts) WithPassive(b bool) *ClientOpts
  • func (opt *ClientOpts) WithRegistrarAddress(addr []string) *ClientOpts
  • func (opt *ClientOpts) WithService(name string, addr string) *ClientOpts
• type RegistrarClient
  • func NewRegistrarClient(opts *ClientOpts) *RegistrarClient
  • func (c *RegistrarClient) Close()
  • func (c *RegistrarClient) Discover(ctx context.Context, name string) (string, error)
  • func (c *RegistrarClient) Register(ctx context.Context) error
  • func (c *RegistrarClient) Subscribe(ctx context.Context, name string) (chan *pb.SubscribeResponse, error)

Constants

const (
	HEARTBEATOFFSET  = 1
	MAXRETRY         = 2
	DEFAULTLEASETIME = 10
	BufSize          = 10
)

const (
	DEFAULT_LEASE_TIME = 10
)

Types

type ClientOption

type ClientOption interface {
	// contains filtered or unexported methods
}

func WithFileOption

func WithFileOption(filepath string) ClientOption

func WithLeaseTime

func WithLeaseTime(t int64) ClientOption

func WithPassive

func WithPassive(b bool) ClientOption

func WithRegistrarAddr

func WithRegistrarAddr(addr []string) ClientOption

func WithService

func WithService(name, addr string) ClientOption

type ClientOpts

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

func NewDefaultOptions

func NewDefaultOptions() *ClientOpts

func (*ClientOpts) ApplyOpts

func (opt *ClientOpts) ApplyOpts(option []ClientOption)

func (*ClientOpts) WithLeaseTime

func (opt *ClientOpts) WithLeaseTime(leaseTime int64) *ClientOpts

func (*ClientOpts) WithPassive

func (opt *ClientOpts) WithPassive(b bool) *ClientOpts

func (*ClientOpts) WithRegistrarAddress

func (opt *ClientOpts) WithRegistrarAddress(addr []string) *ClientOpts

func (*ClientOpts) WithService

func (opt *ClientOpts) WithService(name string, addr string) *ClientOpts

type RegistrarClient

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

func NewRegistrarClient

func NewRegistrarClient(opts *ClientOpts) *RegistrarClient

func (*RegistrarClient) Close

func (c *RegistrarClient) Close()

TODO new了但没注册

func (*RegistrarClient) Discover

func (c *RegistrarClient) Discover(ctx context.Context, name string) (string, error)

func (*RegistrarClient) Register

func (c *RegistrarClient) Register(ctx context.Context) error

func (*RegistrarClient) Subscribe

func (c *RegistrarClient) Subscribe(ctx context.Context, name string) (chan *pb.SubscribeResponse, error)