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, addr, version string) *ClientOpts
  • func (opt *ClientOpts) WithWeight(w int32) *ClientOpts
• type RegistrarClient
  • func NewRegistrarClient(opts *ClientOpts) RegistrarClient

Constants

const (
	HEARTBEATOFFSET = 1
	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, addr, version string) *ClientOpts

func (*ClientOpts) WithWeight

func (opt *ClientOpts) WithWeight(w int32) *ClientOpts

type RegistrarClient

type RegistrarClient interface {
	Register(ctx context.Context) error
	Close()
	Discover(ctx context.Context, name string) (string, error)
	Subscribe(ctx context.Context, name string) (chan *pb.SubscribeResponse, error)
}

func NewRegistrarClient

func NewRegistrarClient(opts *ClientOpts) RegistrarClient