xclient

Documentation

Index

• type Discovery
• type MultiServersDiscovery
  • func NewMultiServerDiscovery(servers []string) *MultiServersDiscovery
  • func (d *MultiServersDiscovery) Get(mode SelectMode) (string, error)
  • func (d *MultiServersDiscovery) GetAll() ([]string, error)
  • func (d *MultiServersDiscovery) Refresh() error
  • func (d *MultiServersDiscovery) Update(servers []string) error
• type SelectMode
• type XClient
  • func NewXClient(d Discovery, mode SelectMode, opt *rpc.Option) *XClient
  • func (c *XClient) Broadcast(ctx context.Context, serviceMethod string, args, reply any) error
  • func (c *XClient) Call(ctx context.Context, serviceMethod string, args, reply any) error
  • func (c *XClient) Close() error
  • func (c *XClient) Go(serviceMethod string, args, reply any, done chan *rpc.Call) *rpc.Call

Types

type Discovery

type Discovery interface {
	Refresh() error                // 刷新服务列表
	Update(servers []string) error // 更新服务列表
	Get(mode SelectMode) (string, error)
	GetAll() ([]string, error)
}

type MultiServersDiscovery

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

func NewMultiServerDiscovery

func NewMultiServerDiscovery(servers []string) *MultiServersDiscovery

func (*MultiServersDiscovery) Get

func (d *MultiServersDiscovery) Get(mode SelectMode) (string, error)

func (*MultiServersDiscovery) GetAll

func (d *MultiServersDiscovery) GetAll() ([]string, error)

func (*MultiServersDiscovery) Refresh

func (d *MultiServersDiscovery) Refresh() error

func (*MultiServersDiscovery) Update

func (d *MultiServersDiscovery) Update(servers []string) error

type SelectMode

type SelectMode int

const (
	RandomSelect SelectMode = iota
	RoundRobinSelect
)

type XClient

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

func NewXClient

func NewXClient(d Discovery, mode SelectMode, opt *rpc.Option) *XClient

func (*XClient) Broadcast

func (c *XClient) Broadcast(ctx context.Context, serviceMethod string, args, reply any) error

func (*XClient) Call

func (c *XClient) Call(ctx context.Context, serviceMethod string, args, reply any) error

func (*XClient) Close

func (c *XClient) Close() error

func (*XClient) Go

func (c *XClient) Go(serviceMethod string, args, reply any, done chan *rpc.Call) *rpc.Call