cfgpltfm

Documentation

Index

• type CfgpltfmClient
  • func New(cfgpltAddr, selfAddr, env string) *CfgpltfmClient
  • func (cli *CfgpltfmClient) Get(key string, camp int32) *cfgpltrpcpb.GetResp
  • func (cli *CfgpltfmClient) GetAndWatch(key string, camp int32, callback func(*cfgpltrpcpb.GetResp)) bool
  • func (cli *CfgpltfmClient) Ping() bool
  • func (cli *CfgpltfmClient) Push(ctx context.Context, req *cfgpltrpcpb.PushReq) (*cfgpltrpcpb.PushResp, error)

Types

type CfgpltfmClient

type CfgpltfmClient struct {
	cfgpltrpcpb.UnimplementedCfgpltClientRpcServer
	// contains filtered or unexported fields
}

func New

func New(cfgpltAddr, selfAddr, env string) *CfgpltfmClient

func (*CfgpltfmClient) Get

func (cli *CfgpltfmClient) Get(key string, camp int32) *cfgpltrpcpb.GetResp

客户端 => 中心 请求

func (*CfgpltfmClient) GetAndWatch

func (cli *CfgpltfmClient) GetAndWatch(key string, camp int32, callback func(*cfgpltrpcpb.GetResp)) bool

客户端 => 中心 请求

func (*CfgpltfmClient) Ping

func (cli *CfgpltfmClient) Ping() bool

客户端 => 中心 心跳

func (*CfgpltfmClient) Push

func (cli *CfgpltfmClient) Push(ctx context.Context, req *cfgpltrpcpb.PushReq) (*cfgpltrpcpb.PushResp, error)

中心 => 客户端