cfgpltfm

Documentation

Index

• type CfgpltfmClient
  • func New(cfgpltAddr, selfAddr string, grpcServer *grpc.Server) *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) Push(ctx context.Context, req *cfgpltrpcpb.PushReq) (*cfgpltrpcpb.PushResp, error)
  • func (cli *CfgpltfmClient) Regist() bool

Types

type CfgpltfmClient

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

func New

func New(cfgpltAddr, selfAddr string, grpcServer *grpc.Server) *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) Push

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

func (*CfgpltfmClient) Regist

func (cli *CfgpltfmClient) Regist() bool