mqpb

Documentation

Overview

Package mqpb is a generated protocol buffer package.

It is generated from these files:

github.com/molon/gomsg/internal/pb/mqpb/mq.proto

It has these top-level messages:

ToUid
KickoutSession
SendOfflineToSession
Notification
Payload

Index

• type KickoutSession
  • func (*KickoutSession) Descriptor() ([]byte, []int)
  • func (m *KickoutSession) GetCode() errorpb.Code
  • func (m *KickoutSession) GetSid() string
  • func (m *KickoutSession) GetUid() string
  • func (*KickoutSession) ProtoMessage()
  • func (m *KickoutSession) Reset()
  • func (m *KickoutSession) String() string
• type Notification
  • func (*Notification) Descriptor() ([]byte, []int)
  • func (m *Notification) GetMsg() *msgpb.Message
  • func (m *Notification) GetPlatform() string
  • func (m *Notification) GetUid() string
  • func (*Notification) ProtoMessage()
  • func (m *Notification) Reset()
  • func (m *Notification) String() string
• type Payload
  • func (*Payload) Descriptor() ([]byte, []int)
  • func (m *Payload) GetBody() isPayload_Body
  • func (m *Payload) GetKickoutSession() *KickoutSession
  • func (m *Payload) GetLastAttemptAt() *google_protobuf1.Timestamp
  • func (m *Payload) GetNotification() *Notification
  • func (m *Payload) GetRetryCount() int64
  • func (m *Payload) GetSendOfflineToSession() *SendOfflineToSession
  • func (m *Payload) GetSeq() string
  • func (m *Payload) GetTimestamp() *google_protobuf1.Timestamp
  • func (m *Payload) GetToUid() *ToUid
  • func (*Payload) ProtoMessage()
  • func (m *Payload) Reset()
  • func (m *Payload) String() string
  • func (*Payload) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
• type Payload_KickoutSession
• type Payload_Notification
• type Payload_SendOfflineToSession
• type Payload_ToUid
• type SendOfflineToSession
  • func (*SendOfflineToSession) Descriptor() ([]byte, []int)
  • func (m *SendOfflineToSession) GetSid() string
  • func (m *SendOfflineToSession) GetUid() string
  • func (*SendOfflineToSession) ProtoMessage()
  • func (m *SendOfflineToSession) Reset()
  • func (m *SendOfflineToSession) String() string
• type ToUid
  • func (*ToUid) Descriptor() ([]byte, []int)
  • func (m *ToUid) GetMsgs() []*msgpb.Message
  • func (m *ToUid) GetPlatformConfig() *pushpb.PlatformConfig
  • func (m *ToUid) GetReserve() *google_protobuf.Any
  • func (m *ToUid) GetUid() string
  • func (*ToUid) ProtoMessage()
  • func (m *ToUid) Reset()
  • func (m *ToUid) String() string

Types

type KickoutSession

type KickoutSession struct {
	// 接收目标
	Uid string `protobuf:"bytes,1,opt,name=uid" json:"uid,omitempty"`
	// 接收会话
	Sid string `protobuf:"bytes,2,opt,name=sid" json:"sid,omitempty"`
	// 踢出原因
	Code errorpb.Code `protobuf:"varint,3,opt,name=code,enum=errorpb.Code" json:"code,omitempty"`
}

踢出某会话

func (*KickoutSession) Descriptor

func (*KickoutSession) Descriptor() ([]byte, []int)

func (*KickoutSession) GetCode

func (m *KickoutSession) GetCode() errorpb.Code

func (*KickoutSession) GetSid

func (m *KickoutSession) GetSid() string

func (*KickoutSession) GetUid

func (m *KickoutSession) GetUid() string

func (*KickoutSession) ProtoMessage

func (*KickoutSession) ProtoMessage()

func (*KickoutSession) Reset

func (m *KickoutSession) Reset()

func (*KickoutSession) String

func (m *KickoutSession) String() string

type Notification

type Notification struct {
	// 接收目标
	Uid string `protobuf:"bytes,1,opt,name=uid" json:"uid,omitempty"`
	// 接收平台
	Platform string `protobuf:"bytes,2,opt,name=platform" json:"platform,omitempty"`
	// 消息内容
	Msg *msgpb.Message `protobuf:"bytes,3,opt,name=msg" json:"msg,omitempty"`
}

向某用户的某平台发通知提醒消息

func (*Notification) Descriptor

func (*Notification) Descriptor() ([]byte, []int)

func (*Notification) GetMsg

func (m *Notification) GetMsg() *msgpb.Message

func (*Notification) GetPlatform

func (m *Notification) GetPlatform() string

func (*Notification) GetUid

func (m *Notification) GetUid() string

func (*Notification) ProtoMessage

func (*Notification) ProtoMessage()

func (*Notification) Reset

func (m *Notification) Reset()

func (*Notification) String

func (m *Notification) String() string

type Payload

type Payload struct {
	Seq           string                      `protobuf:"bytes,1,opt,name=seq" json:"seq,omitempty"`
	Timestamp     *google_protobuf1.Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"`
	RetryCount    int64                       `protobuf:"varint,3,opt,name=retry_count,json=retryCount" json:"retry_count,omitempty"`
	LastAttemptAt *google_protobuf1.Timestamp `protobuf:"bytes,4,opt,name=last_attempt_at,json=lastAttemptAt" json:"last_attempt_at,omitempty"`
	// Types that are valid to be assigned to Body:
	//	*Payload_ToUid
	//	*Payload_KickoutSession
	//	*Payload_SendOfflineToSession
	//	*Payload_Notification
	Body isPayload_Body `protobuf_oneof:"Body"`
}

mq消息wrap

func (*Payload) Descriptor

func (*Payload) Descriptor() ([]byte, []int)

func (*Payload) GetBody

func (m *Payload) GetBody() isPayload_Body

func (*Payload) GetKickoutSession

func (m *Payload) GetKickoutSession() *KickoutSession

func (*Payload) GetLastAttemptAt

func (m *Payload) GetLastAttemptAt() *google_protobuf1.Timestamp

func (*Payload) GetNotification

func (m *Payload) GetNotification() *Notification

func (*Payload) GetRetryCount

func (m *Payload) GetRetryCount() int64

func (*Payload) GetSendOfflineToSession

func (m *Payload) GetSendOfflineToSession() *SendOfflineToSession

func (*Payload) GetSeq

func (m *Payload) GetSeq() string

func (*Payload) GetTimestamp

func (m *Payload) GetTimestamp() *google_protobuf1.Timestamp

func (*Payload) GetToUid

func (m *Payload) GetToUid() *ToUid

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) Reset

func (m *Payload) Reset()

func (*Payload) String

func (m *Payload) String() string

func (*Payload) XXX_OneofFuncs

func (*Payload) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Payload_KickoutSession

type Payload_KickoutSession struct {
	KickoutSession *KickoutSession `protobuf:"bytes,12,opt,name=kickout_session,json=kickoutSession,oneof"`
}

type Payload_Notification

type Payload_Notification struct {
	Notification *Notification `protobuf:"bytes,14,opt,name=notification,oneof"`
}

type Payload_SendOfflineToSession

type Payload_SendOfflineToSession struct {
	SendOfflineToSession *SendOfflineToSession `protobuf:"bytes,13,opt,name=send_offline_to_session,json=sendOfflineToSession,oneof"`
}

type Payload_ToUid

type Payload_ToUid struct {
	ToUid *ToUid `protobuf:"bytes,11,opt,name=to_uid,json=toUid,oneof"`
}

type SendOfflineToSession

type SendOfflineToSession struct {
	// 接收目标
	Uid string `protobuf:"bytes,1,opt,name=uid" json:"uid,omitempty"`
	// 接收会话
	Sid string `protobuf:"bytes,2,opt,name=sid" json:"sid,omitempty"`
}

下发离线消息

func (*SendOfflineToSession) Descriptor

func (*SendOfflineToSession) Descriptor() ([]byte, []int)

func (*SendOfflineToSession) GetSid

func (m *SendOfflineToSession) GetSid() string

func (*SendOfflineToSession) GetUid

func (m *SendOfflineToSession) GetUid() string

func (*SendOfflineToSession) ProtoMessage

func (*SendOfflineToSession) ProtoMessage()

func (*SendOfflineToSession) Reset

func (m *SendOfflineToSession) Reset()

func (*SendOfflineToSession) String

func (m *SendOfflineToSession) String() string

type ToUid

type ToUid struct {
	// 接收目标
	Uid string `protobuf:"bytes,1,opt,name=uid" json:"uid,omitempty"`
	// 平台配置，置空则表示全发送
	PlatformConfig *pushpb.PlatformConfig `protobuf:"bytes,11,opt,name=platform_config,json=platformConfig" json:"platform_config,omitempty"`
	// 消息列表
	Msgs []*msgpb.Message `protobuf:"bytes,21,rep,name=msgs" json:"msgs,omitempty"`
	// 保留给一些特殊业务使用的项目
	Reserve *google_protobuf.Any `protobuf:"bytes,88,opt,name=reserve" json:"reserve,omitempty"`
}

发给uid的常规消息

func (*ToUid) Descriptor

func (*ToUid) Descriptor() ([]byte, []int)

func (*ToUid) GetMsgs

func (m *ToUid) GetMsgs() []*msgpb.Message

func (*ToUid) GetPlatformConfig

func (m *ToUid) GetPlatformConfig() *pushpb.PlatformConfig

func (*ToUid) GetReserve

func (m *ToUid) GetReserve() *google_protobuf.Any

func (*ToUid) GetUid

func (m *ToUid) GetUid() string

func (*ToUid) ProtoMessage

func (*ToUid) ProtoMessage()

func (*ToUid) Reset

func (m *ToUid) Reset()

func (*ToUid) String

func (m *ToUid) String() string