cfgpltfm

Documentation

Index

• type CfgpltfmClient
  • func New(cfgpltAddr, selfAddr string) *CfgpltfmClient
  • func (cli *CfgpltfmClient) Bind(grpcServer *grpc.Server) bool
  • 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)

Types

type CfgpltfmClient

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

func New

func New(cfgpltAddr, selfAddr string) *CfgpltfmClient

func (*CfgpltfmClient) Bind

func (cli *CfgpltfmClient) Bind(grpcServer *grpc.Server) bool

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)