service

Documentation

Overview

*

*
* @author liangjf
* @create on 2020/6/4
* @version 1.0

Index

• Variables
• type MessageRpc
  • func NewMessageRpc(models models.IModels) *MessageRpc
  • func (m *MessageRpc) DeleteAppUUID(ctx context.Context, in *pb.DeleteAppUUIDRequest) (out *pb.Respond, err error)
  • func (m *MessageRpc) DeleteExpireMsg(ctx context.Context, in *pb.DeleteExpireMsgRequest) (out *pb.Respond, err error)
  • func (m *MessageRpc) DeleteGatewayUUID(ctx context.Context, in *pb.DeleteGatewayUUIDRequest) (out *pb.Respond, err error)
  • func (m *MessageRpc) GetAppUUID(ctx context.Context, in *pb.GetAppUUIDRequest) (out *pb.GetAppUUIDRespond, err error)
  • func (m *MessageRpc) GetGatewayUUID(ctx context.Context, in *pb.GetGatewayUUIDRequest) (out *pb.GetGatewayUUIDRespond, err error)
  • func (m *MessageRpc) SaveAppUUID(ctx context.Context, in *pb.SaveAppUUIDRequest) (out *pb.Respond, err error)
  • func (m *MessageRpc) SaveExpireMsg(ctx context.Context, in *pb.SaveExpireMsgRequest) (out *pb.Respond, err error)
  • func (m *MessageRpc) SaveGatewayUUID(ctx context.Context, in *pb.SaveGatewayUUIDRequest) (out *pb.Respond, err error)

Variables

var (
	ErrCtxDone = errors.New("ctx done")
)

Types

type MessageRpc

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

MessageRpc message rpc服务

func NewMessageRpc

func NewMessageRpc(models models.IModels) *MessageRpc

func (*MessageRpc) DeleteAppUUID

func (m *MessageRpc) DeleteAppUUID(ctx context.Context, in *pb.DeleteAppUUIDRequest) (out *pb.Respond, err error)

func (*MessageRpc) DeleteExpireMsg

func (m *MessageRpc) DeleteExpireMsg(ctx context.Context, in *pb.DeleteExpireMsgRequest) (out *pb.Respond, err error)

func (*MessageRpc) DeleteGatewayUUID

func (m *MessageRpc) DeleteGatewayUUID(ctx context.Context, in *pb.DeleteGatewayUUIDRequest) (out *pb.Respond, err error)

func (*MessageRpc) GetAppUUID

func (m *MessageRpc) GetAppUUID(ctx context.Context, in *pb.GetAppUUIDRequest) (out *pb.GetAppUUIDRespond, err error)

func (*MessageRpc) GetGatewayUUID

func (m *MessageRpc) GetGatewayUUID(ctx context.Context, in *pb.GetGatewayUUIDRequest) (out *pb.GetGatewayUUIDRespond, err error)

func (*MessageRpc) SaveAppUUID

func (m *MessageRpc) SaveAppUUID(ctx context.Context, in *pb.SaveAppUUIDRequest) (out *pb.Respond, err error)

func (*MessageRpc) SaveExpireMsg

func (m *MessageRpc) SaveExpireMsg(ctx context.Context, in *pb.SaveExpireMsgRequest) (out *pb.Respond, err error)

func (*MessageRpc) SaveGatewayUUID

func (m *MessageRpc) SaveGatewayUUID(ctx context.Context, in *pb.SaveGatewayUUIDRequest) (out *pb.Respond, err error)