rpc

Documentation

Index

• func New(c *conf.Config, s *v1.Service, s2 *v2.Service) (svr *rpc.Server)
• type RPC
  • func (r *RPC) ClearHost(c context.Context, svr string, res *struct{}) error
  • func (r *RPC) Force(c context.Context, a *model.ArgConf, res *struct{}) (err error)
  • func (r *RPC) Hosts(c context.Context, svr string, res *[]*model.Host) (err error)
  • func (r *RPC) Ping(c context.Context, arg *struct{}, res *struct{}) (err error)
  • func (r *RPC) Push(c context.Context, a *model.ArgConf, res *struct{}) (err error)
  • func (r *RPC) PushV4(c context.Context, a *model.ArgConf, res *struct{}) (err error)
  • func (r *RPC) SetToken(c context.Context, a *model.ArgToken, res *struct{}) (err error)
  • func (r *RPC) SetTokenV4(c context.Context, a *model.ArgToken, res *struct{}) (err error)

Functions

func New

func New(c *conf.Config, s *v1.Service, s2 *v2.Service) (svr *rpc.Server)

New new rpc server.

Types

type RPC

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

RPC export rpc service

func (*RPC) ClearHost

func (r *RPC) ClearHost(c context.Context, svr string, res *struct{}) error

ClearHost clear host.

func (*RPC) Force

func (r *RPC) Force(c context.Context, a *model.ArgConf, res *struct{}) (err error)

Force push new host config change to config-service

func (*RPC) Hosts

func (r *RPC) Hosts(c context.Context, svr string, res *[]*model.Host) (err error)

Hosts get host list.

func (*RPC) Ping

func (r *RPC) Ping(c context.Context, arg *struct{}, res *struct{}) (err error)

Ping check connection success.

func (*RPC) Push

func (r *RPC) Push(c context.Context, a *model.ArgConf, res *struct{}) (err error)

Push push new config change to config-service

func (*RPC) PushV4

func (r *RPC) PushV4(c context.Context, a *model.ArgConf, res *struct{}) (err error)

PushV4 push new config change to config-service

func (*RPC) SetToken

func (r *RPC) SetToken(c context.Context, a *model.ArgToken, res *struct{}) (err error)

SetToken update Token

func (*RPC) SetTokenV4

func (r *RPC) SetTokenV4(c context.Context, a *model.ArgToken, res *struct{}) (err error)

SetTokenV4 update Token