common_rpc

Documentation

Index

• Variables
• func CustomCtx(options map[string]any) context.Context
• func DefaultCtx() context.Context
• func R(rpcResult *rpc_pbs.RpcResult, err error) *response.Response

Variables

var (
	CtxOptionsTimeOut = "timeout"
	CtxOptionsShowLog = "showLog"
)

var CronJobServiceClientImpl = func() rpc_pbs.CronJobServiceClient {
	return rpc_pbs.NewCronJobServiceClient(nacos_grpc.GetGrpcConn(rpc_pbs.CronJobService_ServiceDesc.ServiceName))
}

CronJobServiceClientImpl 定时任务 服务

var MsgPushServiceClientImpl = func() rpc_pbs.MsgPushServiceClient {
	return rpc_pbs.NewMsgPushServiceClient(nacos_grpc.GetGrpcConn(rpc_pbs.MsgPushService_ServiceDesc.ServiceName))
}

MsgPushServiceClientImpl 消息推送

var ShortUrlServiceClientImpl = func() rpc_pbs.ShortUrlServiceClient {
	return rpc_pbs.NewShortUrlServiceClient(nacos_grpc.GetGrpcConn(rpc_pbs.ShortUrlService_ServiceDesc.ServiceName))
}

ShortUrlServiceClientImpl 短链接

var UniversalServiceClientImpl = func() rpc_pbs.UniversalServiceClient {
	return rpc_pbs.NewUniversalServiceClient(nacos_grpc.GetGrpcConn(rpc_pbs.UniversalService_ServiceDesc.ServiceName))
}

UniversalServiceClientImpl 通用服务

var UserCenterServiceClientImpl = func() rpc_pbs.UserCenterServiceClient {
	return rpc_pbs.NewUserCenterServiceClient(nacos_grpc.GetGrpcConn(rpc_pbs.UserCenterService_ServiceDesc.ServiceName))
}

UserCenterServiceClientImpl 用户中心 服务

var XMQServiceClientImpl = func() rpc_pbs.XMQServiceClient {
	return rpc_pbs.NewXMQServiceClient(nacos_grpc.GetGrpcConn(rpc_pbs.XMQService_ServiceDesc.ServiceName))
}

XMQServiceClientImpl XMQ 服务

Functions

func CustomCtx

func CustomCtx(options map[string]any) context.Context

func DefaultCtx

func DefaultCtx() context.Context

func R

func R(rpcResult *rpc_pbs.RpcResult, err error) *response.Response