pkt

package
v0.0.0-...-e7f8777 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 20, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CodePing = uint16(1)
	CodePong = uint16(2)
)

basic pkt code

Variables

View Source 
var (
	Status_name = map[int32]string{
		0:   "Success",
		100: "NoDestination",
		101: "InvalidPacketBody",
		103: "InvalidCommand",
		105: "Unauthorized",
		300: "SystemException",
		301: "NotImplemented",
		404: "SessionNotFound",
	}
	Status_value = map[string]int32{
		"Success":           0,
		"NoDestination":     100,
		"InvalidPacketBody": 101,
		"InvalidCommand":    103,
		"Unauthorized":      105,
		"SystemException":   300,
		"NotImplemented":    301,
		"SessionNotFound":   404,
	}
)

Enum value maps for Status.

View Source 
var (
	MetaType_name = map[int32]string{
		0: "int",
		1: "string",
		2: "float",
	}
	MetaType_value = map[string]int32{
		"int":    0,
		"string": 1,
		"float":  2,
	}
)

Enum value maps for MetaType.

View Source 
var (
	ContentType_name = map[int32]string{
		0: "Protobuf",
		1: "Json",
	}
	ContentType_value = map[string]int32{
		"Protobuf": 0,
		"Json":     1,
	}
)

Enum value maps for ContentType.

View Source 
var (
	Flag_name = map[int32]string{
		0: "Request",
		1: "Response",
		2: "Push",
	}
	Flag_value = map[string]int32{
		"Request":  0,
		"Response": 1,
		"Push":     2,
	}
)

Enum value maps for Flag.

View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_protocol_proto protoreflect.FileDescriptor

Functions

func FindMeta 

func FindMeta(meta []*Meta, key string) (interface{}, bool)

func Marshal 

func Marshal(p Packet) []byte

func Read 

func Read(r io.Reader) (interface{}, error)

Types

type BasicPkt 

type BasicPkt struct {
	Code   uint16
	Length uint16
	Body   []byte
}

func MustReadBasicPkt 

func MustReadBasicPkt(r io.Reader) (*BasicPkt, error)

func (*BasicPkt) Decode 

func (p *BasicPkt) Decode(r io.Reader) error

Decode implements Packet

func (*BasicPkt) Encode 

func (p *BasicPkt) Encode(w io.Writer) error

Encode implements Packet

type ContentType 

type ContentType int32
const (
	ContentType_Protobuf ContentType = 0
	ContentType_Json     ContentType = 1
)

func (ContentType) Descriptor 

func (ContentType) Descriptor() protoreflect.EnumDescriptor

func (ContentType) Enum 

func (x ContentType) Enum() *ContentType

func (ContentType) EnumDescriptor deprecated 

func (ContentType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ContentType.Descriptor instead.

func (ContentType) Number 

func (x ContentType) Number() protoreflect.EnumNumber

func (ContentType) String 

func (x ContentType) String() string

func (ContentType) Type 

func (ContentType) Type() protoreflect.EnumType

type ErrorResp 

type ErrorResp struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorResp) Descriptor deprecated 

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

Deprecated: Use ErrorResp.ProtoReflect.Descriptor instead.

func (*ErrorResp) GetMessage 

func (x *ErrorResp) GetMessage() string

func (*ErrorResp) ProtoMessage 

func (*ErrorResp) ProtoMessage()

func (*ErrorResp) ProtoReflect 

func (x *ErrorResp) ProtoReflect() protoreflect.Message

func (*ErrorResp) Reset 

func (x *ErrorResp) Reset()

func (*ErrorResp) String 

func (x *ErrorResp) String() string

type Flag 

type Flag int32
const (
	Flag_Request  Flag = 0
	Flag_Response Flag = 1
	Flag_Push     Flag = 2
)

func (Flag) Descriptor 

func (Flag) Descriptor() protoreflect.EnumDescriptor

func (Flag) Enum 

func (x Flag) Enum() *Flag

func (Flag) EnumDescriptor deprecated 

func (Flag) EnumDescriptor() ([]byte, []int)

Deprecated: Use Flag.Descriptor instead.

func (Flag) Number 

func (x Flag) Number() protoreflect.EnumNumber

func (Flag) String 

func (x Flag) String() string

func (Flag) Type 

func (Flag) Type() protoreflect.EnumType

type GroupCreateNotify 

type GroupCreateNotify struct {
	GroupId string   `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Members []string `protobuf:"bytes,2,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupCreateNotify) Descriptor deprecated 

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

Deprecated: Use GroupCreateNotify.ProtoReflect.Descriptor instead.

func (*GroupCreateNotify) GetGroupId 

func (x *GroupCreateNotify) GetGroupId() string

func (*GroupCreateNotify) GetMembers 

func (x *GroupCreateNotify) GetMembers() []string

func (*GroupCreateNotify) ProtoMessage 

func (*GroupCreateNotify) ProtoMessage()

func (*GroupCreateNotify) ProtoReflect 

func (x *GroupCreateNotify) ProtoReflect() protoreflect.Message

func (*GroupCreateNotify) Reset 

func (x *GroupCreateNotify) Reset()

func (*GroupCreateNotify) String 

func (x *GroupCreateNotify) String() string

type GroupCreateReq 

type GroupCreateReq struct {
	Name         string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Avatar       string   `protobuf:"bytes,2,opt,name=avatar,proto3" json:"avatar,omitempty"`
	Introduction string   `protobuf:"bytes,3,opt,name=introduction,proto3" json:"introduction,omitempty"`
	Owner        string   `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"`
	Members      []string `protobuf:"bytes,5,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupCreateReq) Descriptor deprecated 

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

Deprecated: Use GroupCreateReq.ProtoReflect.Descriptor instead.

func (*GroupCreateReq) GetAvatar 

func (x *GroupCreateReq) GetAvatar() string

func (*GroupCreateReq) GetIntroduction 

func (x *GroupCreateReq) GetIntroduction() string

func (*GroupCreateReq) GetMembers 

func (x *GroupCreateReq) GetMembers() []string

func (*GroupCreateReq) GetName 

func (x *GroupCreateReq) GetName() string

func (*GroupCreateReq) GetOwner 

func (x *GroupCreateReq) GetOwner() string

func (*GroupCreateReq) ProtoMessage 

func (*GroupCreateReq) ProtoMessage()

func (*GroupCreateReq) ProtoReflect 

func (x *GroupCreateReq) ProtoReflect() protoreflect.Message

func (*GroupCreateReq) Reset 

func (x *GroupCreateReq) Reset()

func (*GroupCreateReq) String 

func (x *GroupCreateReq) String() string

type GroupCreateResp 

type GroupCreateResp struct {
	GroupId string `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupCreateResp) Descriptor deprecated 

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

Deprecated: Use GroupCreateResp.ProtoReflect.Descriptor instead.

func (*GroupCreateResp) GetGroupId 

func (x *GroupCreateResp) GetGroupId() string

func (*GroupCreateResp) ProtoMessage 

func (*GroupCreateResp) ProtoMessage()

func (*GroupCreateResp) ProtoReflect 

func (x *GroupCreateResp) ProtoReflect() protoreflect.Message

func (*GroupCreateResp) Reset 

func (x *GroupCreateResp) Reset()

func (*GroupCreateResp) String 

func (x *GroupCreateResp) String() string

type GroupGetReq 

type GroupGetReq struct {
	GroupId string `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupGetReq) Descriptor deprecated 

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

Deprecated: Use GroupGetReq.ProtoReflect.Descriptor instead.

func (*GroupGetReq) GetGroupId 

func (x *GroupGetReq) GetGroupId() string

func (*GroupGetReq) ProtoMessage 

func (*GroupGetReq) ProtoMessage()

func (*GroupGetReq) ProtoReflect 

func (x *GroupGetReq) ProtoReflect() protoreflect.Message

func (*GroupGetReq) Reset 

func (x *GroupGetReq) Reset()

func (*GroupGetReq) String 

func (x *GroupGetReq) String() string

type GroupGetResp 

type GroupGetResp struct {
	Id           string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name         string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Avatar       string    `protobuf:"bytes,3,opt,name=avatar,proto3" json:"avatar,omitempty"`
	Introduction string    `protobuf:"bytes,4,opt,name=introduction,proto3" json:"introduction,omitempty"`
	Owner        string    `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"`
	Members      []*Member `protobuf:"bytes,6,rep,name=members,proto3" json:"members,omitempty"`
	CreatedAt    int64     `protobuf:"varint,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupGetResp) Descriptor deprecated 

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

Deprecated: Use GroupGetResp.ProtoReflect.Descriptor instead.

func (*GroupGetResp) GetAvatar 

func (x *GroupGetResp) GetAvatar() string

func (*GroupGetResp) GetCreatedAt 

func (x *GroupGetResp) GetCreatedAt() int64

func (*GroupGetResp) GetId 

func (x *GroupGetResp) GetId() string

func (*GroupGetResp) GetIntroduction 

func (x *GroupGetResp) GetIntroduction() string

func (*GroupGetResp) GetMembers 

func (x *GroupGetResp) GetMembers() []*Member

func (*GroupGetResp) GetName 

func (x *GroupGetResp) GetName() string

func (*GroupGetResp) GetOwner 

func (x *GroupGetResp) GetOwner() string

func (*GroupGetResp) ProtoMessage 

func (*GroupGetResp) ProtoMessage()

func (*GroupGetResp) ProtoReflect 

func (x *GroupGetResp) ProtoReflect() protoreflect.Message

func (*GroupGetResp) Reset 

func (x *GroupGetResp) Reset()

func (*GroupGetResp) String 

func (x *GroupGetResp) String() string

type GroupJoinNotify 

type GroupJoinNotify struct {
	GroupId string `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Account string `protobuf:"bytes,2,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupJoinNotify) Descriptor deprecated 

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

Deprecated: Use GroupJoinNotify.ProtoReflect.Descriptor instead.

func (*GroupJoinNotify) GetAccount 

func (x *GroupJoinNotify) GetAccount() string

func (*GroupJoinNotify) GetGroupId 

func (x *GroupJoinNotify) GetGroupId() string

func (*GroupJoinNotify) ProtoMessage 

func (*GroupJoinNotify) ProtoMessage()

func (*GroupJoinNotify) ProtoReflect 

func (x *GroupJoinNotify) ProtoReflect() protoreflect.Message

func (*GroupJoinNotify) Reset 

func (x *GroupJoinNotify) Reset()

func (*GroupJoinNotify) String 

func (x *GroupJoinNotify) String() string

type GroupJoinReq 

type GroupJoinReq struct {
	Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	GroupId string `protobuf:"bytes,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupJoinReq) Descriptor deprecated 

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

Deprecated: Use GroupJoinReq.ProtoReflect.Descriptor instead.

func (*GroupJoinReq) GetAccount 

func (x *GroupJoinReq) GetAccount() string

func (*GroupJoinReq) GetGroupId 

func (x *GroupJoinReq) GetGroupId() string

func (*GroupJoinReq) ProtoMessage 

func (*GroupJoinReq) ProtoMessage()

func (*GroupJoinReq) ProtoReflect 

func (x *GroupJoinReq) ProtoReflect() protoreflect.Message

func (*GroupJoinReq) Reset 

func (x *GroupJoinReq) Reset()

func (*GroupJoinReq) String 

func (x *GroupJoinReq) String() string

type GroupQuitNotify 

type GroupQuitNotify struct {
	GroupId string `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Account string `protobuf:"bytes,2,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupQuitNotify) Descriptor deprecated 

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

Deprecated: Use GroupQuitNotify.ProtoReflect.Descriptor instead.

func (*GroupQuitNotify) GetAccount 

func (x *GroupQuitNotify) GetAccount() string

func (*GroupQuitNotify) GetGroupId 

func (x *GroupQuitNotify) GetGroupId() string

func (*GroupQuitNotify) ProtoMessage 

func (*GroupQuitNotify) ProtoMessage()

func (*GroupQuitNotify) ProtoReflect 

func (x *GroupQuitNotify) ProtoReflect() protoreflect.Message

func (*GroupQuitNotify) Reset 

func (x *GroupQuitNotify) Reset()

func (*GroupQuitNotify) String 

func (x *GroupQuitNotify) String() string

type GroupQuitReq 

type GroupQuitReq struct {
	Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	GroupId string `protobuf:"bytes,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupQuitReq) Descriptor deprecated 

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

Deprecated: Use GroupQuitReq.ProtoReflect.Descriptor instead.

func (*GroupQuitReq) GetAccount 

func (x *GroupQuitReq) GetAccount() string

func (*GroupQuitReq) GetGroupId 

func (x *GroupQuitReq) GetGroupId() string

func (*GroupQuitReq) ProtoMessage 

func (*GroupQuitReq) ProtoMessage()

func (*GroupQuitReq) ProtoReflect 

func (x *GroupQuitReq) ProtoReflect() protoreflect.Message

func (*GroupQuitReq) Reset 

func (x *GroupQuitReq) Reset()

func (*GroupQuitReq) String 

func (x *GroupQuitReq) String() string
type Header struct {
	Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// sender channel id
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	Sequence  uint32 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Flag      Flag   `protobuf:"varint,4,opt,name=flag,proto3,enum=pkt.Flag" json:"flag,omitempty"`
	Status    Status `protobuf:"varint,5,opt,name=status,proto3,enum=pkt.Status" json:"status,omitempty"`
	// destination is defined as a account, group or room
	Dest string  `protobuf:"bytes,6,opt,name=dest,proto3" json:"dest,omitempty"`
	Meta []*Meta `protobuf:"bytes,7,rep,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetChannelId 

func (x *Header) GetChannelId() string

func (*Header) GetCommand 

func (x *Header) GetCommand() string

func (*Header) GetDest 

func (x *Header) GetDest() string

func (*Header) GetFlag 

func (x *Header) GetFlag() Flag

func (*Header) GetMeta 

func (x *Header) GetMeta() []*Meta

func (*Header) GetSequence 

func (x *Header) GetSequence() uint32

func (*Header) GetStatus 

func (x *Header) GetStatus() Status

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

func (x *Header) ProtoReflect() protoreflect.Message

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) ServiceName 

func (h *Header) ServiceName() string

func (*Header) String 

func (x *Header) String() string

type HeaderOption 

type HeaderOption func(*Header)

func WithChannel 

func WithChannel(channelID string) HeaderOption

func WithDest 

func WithDest(dest string) HeaderOption

func WithSeq 

func WithSeq(seq uint32) HeaderOption

func WithStatus 

func WithStatus(status Status) HeaderOption

type InnerHandshakeReq 

type InnerHandshakeReq struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// contains filtered or unexported fields
}

func (*InnerHandshakeReq) Descriptor deprecated 

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

Deprecated: Use InnerHandshakeReq.ProtoReflect.Descriptor instead.

func (*InnerHandshakeReq) GetServiceId 

func (x *InnerHandshakeReq) GetServiceId() string

func (*InnerHandshakeReq) ProtoMessage 

func (*InnerHandshakeReq) ProtoMessage()

func (*InnerHandshakeReq) ProtoReflect 

func (x *InnerHandshakeReq) ProtoReflect() protoreflect.Message

func (*InnerHandshakeReq) Reset 

func (x *InnerHandshakeReq) Reset()

func (*InnerHandshakeReq) String 

func (x *InnerHandshakeReq) String() string

type InnerHandshakeResp 

type InnerHandshakeResp struct {
	Code  uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*InnerHandshakeResp) Descriptor deprecated 

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

Deprecated: Use InnerHandshakeResp.ProtoReflect.Descriptor instead.

func (*InnerHandshakeResp) GetCode 

func (x *InnerHandshakeResp) GetCode() uint32

func (*InnerHandshakeResp) GetError 

func (x *InnerHandshakeResp) GetError() string

func (*InnerHandshakeResp) ProtoMessage 

func (*InnerHandshakeResp) ProtoMessage()

func (*InnerHandshakeResp) ProtoReflect 

func (x *InnerHandshakeResp) ProtoReflect() protoreflect.Message

func (*InnerHandshakeResp) Reset 

func (x *InnerHandshakeResp) Reset()

func (*InnerHandshakeResp) String 

func (x *InnerHandshakeResp) String() string

type KickoutNotify 

type KickoutNotify struct {
	ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// contains filtered or unexported fields
}

func (*KickoutNotify) Descriptor deprecated 

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

Deprecated: Use KickoutNotify.ProtoReflect.Descriptor instead.

func (*KickoutNotify) GetChannelId 

func (x *KickoutNotify) GetChannelId() string

func (*KickoutNotify) ProtoMessage 

func (*KickoutNotify) ProtoMessage()

func (*KickoutNotify) ProtoReflect 

func (x *KickoutNotify) ProtoReflect() protoreflect.Message

func (*KickoutNotify) Reset 

func (x *KickoutNotify) Reset()

func (*KickoutNotify) String 

func (x *KickoutNotify) String() string

type LogicPkt 

type LogicPkt struct {
	Header
	Body []byte `json:"body,omitempty"`
}

LogicPkt 定义了网关对外的client消息结构

func MustReadLogicPkt 

func MustReadLogicPkt(r io.Reader) (*LogicPkt, error)

func New 

func New(command string, options ...HeaderOption) *LogicPkt

func NewFrom 

func NewFrom(header *Header) *LogicPkt

func (*LogicPkt) AddMeta 

func (p *LogicPkt) AddMeta(m ...*Meta)

func (*LogicPkt) AddStringMeta 

func (p *LogicPkt) AddStringMeta(key, value string)

func (*LogicPkt) Decode 

func (p *LogicPkt) Decode(r io.Reader) error

Decode implements Packet

func (*LogicPkt) DelMeta 

func (p *LogicPkt) DelMeta(key string)

func (*LogicPkt) Encode 

func (p *LogicPkt) Encode(w io.Writer) error

Encode implements Packet

func (*LogicPkt) GetMeta 

func (p *LogicPkt) GetMeta(key string) (interface{}, bool)

func (*LogicPkt) ReadBody 

func (p *LogicPkt) ReadBody(val proto.Message) error

func (*LogicPkt) String 

func (p *LogicPkt) String() string

func (*LogicPkt) StringBody 

func (p *LogicPkt) StringBody() string

func (*LogicPkt) WriteBody 

func (p *LogicPkt) WriteBody(val proto.Message) *LogicPkt

type LoginReq 

type LoginReq struct {
	Token string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Isp   string   `protobuf:"bytes,2,opt,name=isp,proto3" json:"isp,omitempty"`
	Zone  string   `protobuf:"bytes,3,opt,name=zone,proto3" json:"zone,omitempty"` // location code
	Tags  []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginReq) Descriptor deprecated 

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

Deprecated: Use LoginReq.ProtoReflect.Descriptor instead.

func (*LoginReq) GetIsp 

func (x *LoginReq) GetIsp() string

func (*LoginReq) GetTags 

func (x *LoginReq) GetTags() []string

func (*LoginReq) GetToken 

func (x *LoginReq) GetToken() string

func (*LoginReq) GetZone 

func (x *LoginReq) GetZone() string

func (*LoginReq) ProtoMessage 

func (*LoginReq) ProtoMessage()

func (*LoginReq) ProtoReflect 

func (x *LoginReq) ProtoReflect() protoreflect.Message

func (*LoginReq) Reset 

func (x *LoginReq) Reset()

func (*LoginReq) String 

func (x *LoginReq) String() string

type LoginResp 

type LoginResp struct {
	ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	Account   string `protobuf:"bytes,2,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginResp) Descriptor deprecated 

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

Deprecated: Use LoginResp.ProtoReflect.Descriptor instead.

func (*LoginResp) GetAccount 

func (x *LoginResp) GetAccount() string

func (*LoginResp) GetChannelId 

func (x *LoginResp) GetChannelId() string

func (*LoginResp) ProtoMessage 

func (*LoginResp) ProtoMessage()

func (*LoginResp) ProtoReflect 

func (x *LoginResp) ProtoReflect() protoreflect.Message

func (*LoginResp) Reset 

func (x *LoginResp) Reset()

func (*LoginResp) String 

func (x *LoginResp) String() string

type Member 

type Member struct {
	Account  string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Alias    string `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	Avatar   string `protobuf:"bytes,3,opt,name=avatar,proto3" json:"avatar,omitempty"`
	JoinTime int64  `protobuf:"varint,4,opt,name=join_time,json=joinTime,proto3" json:"join_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Member) Descriptor deprecated 

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

Deprecated: Use Member.ProtoReflect.Descriptor instead.

func (*Member) GetAccount 

func (x *Member) GetAccount() string

func (*Member) GetAlias 

func (x *Member) GetAlias() string

func (*Member) GetAvatar 

func (x *Member) GetAvatar() string

func (*Member) GetJoinTime 

func (x *Member) GetJoinTime() int64

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) ProtoReflect 

func (x *Member) ProtoReflect() protoreflect.Message

func (*Member) Reset 

func (x *Member) Reset()

func (*Member) String 

func (x *Member) String() string

type MessageAckReq 

type MessageAckReq struct {
	MessageId int64 `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageAckReq) Descriptor deprecated 

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

Deprecated: Use MessageAckReq.ProtoReflect.Descriptor instead.

func (*MessageAckReq) GetMessageId 

func (x *MessageAckReq) GetMessageId() int64

func (*MessageAckReq) ProtoMessage 

func (*MessageAckReq) ProtoMessage()

func (*MessageAckReq) ProtoReflect 

func (x *MessageAckReq) ProtoReflect() protoreflect.Message

func (*MessageAckReq) Reset 

func (x *MessageAckReq) Reset()

func (*MessageAckReq) String 

func (x *MessageAckReq) String() string

type MessageContent 

type MessageContent struct {
	MessageId int64  `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Type      int32  `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	Body      string `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	Extra     string `protobuf:"bytes,4,opt,name=extra,proto3" json:"extra,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageContent) Descriptor deprecated 

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

Deprecated: Use MessageContent.ProtoReflect.Descriptor instead.

func (*MessageContent) GetBody 

func (x *MessageContent) GetBody() string

func (*MessageContent) GetExtra 

func (x *MessageContent) GetExtra() string

func (*MessageContent) GetMessageId 

func (x *MessageContent) GetMessageId() int64

func (*MessageContent) GetType 

func (x *MessageContent) GetType() int32

func (*MessageContent) ProtoMessage 

func (*MessageContent) ProtoMessage()

func (*MessageContent) ProtoReflect 

func (x *MessageContent) ProtoReflect() protoreflect.Message

func (*MessageContent) Reset 

func (x *MessageContent) Reset()

func (*MessageContent) String 

func (x *MessageContent) String() string

type MessageContentReq 

type MessageContentReq struct {
	MessageIds []int64 `protobuf:"varint,1,rep,packed,name=message_ids,json=messageIds,proto3" json:"message_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageContentReq) Descriptor deprecated 

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

Deprecated: Use MessageContentReq.ProtoReflect.Descriptor instead.

func (*MessageContentReq) GetMessageIds 

func (x *MessageContentReq) GetMessageIds() []int64

func (*MessageContentReq) ProtoMessage 

func (*MessageContentReq) ProtoMessage()

func (*MessageContentReq) ProtoReflect 

func (x *MessageContentReq) ProtoReflect() protoreflect.Message

func (*MessageContentReq) Reset 

func (x *MessageContentReq) Reset()

func (*MessageContentReq) String 

func (x *MessageContentReq) String() string

type MessageContentResp 

type MessageContentResp struct {
	Contents []*MessageContent `protobuf:"bytes,1,rep,name=contents,proto3" json:"contents,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageContentResp) Descriptor deprecated 

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

Deprecated: Use MessageContentResp.ProtoReflect.Descriptor instead.

func (*MessageContentResp) GetContents 

func (x *MessageContentResp) GetContents() []*MessageContent

func (*MessageContentResp) ProtoMessage 

func (*MessageContentResp) ProtoMessage()

func (*MessageContentResp) ProtoReflect 

func (x *MessageContentResp) ProtoReflect() protoreflect.Message

func (*MessageContentResp) Reset 

func (x *MessageContentResp) Reset()

func (*MessageContentResp) String 

func (x *MessageContentResp) String() string

type MessageIndex 

type MessageIndex struct {
	MessageId int64  `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Direction int32  `protobuf:"varint,2,opt,name=direction,proto3" json:"direction,omitempty"`
	SendTime  int64  `protobuf:"varint,3,opt,name=send_time,json=sendTime,proto3" json:"send_time,omitempty"`
	Account   string `protobuf:"bytes,4,opt,name=account,proto3" json:"account,omitempty"`
	Group     string `protobuf:"bytes,5,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageIndex) Descriptor deprecated 

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

Deprecated: Use MessageIndex.ProtoReflect.Descriptor instead.

func (*MessageIndex) GetAccount 

func (x *MessageIndex) GetAccount() string

func (*MessageIndex) GetDirection 

func (x *MessageIndex) GetDirection() int32

func (*MessageIndex) GetGroup 

func (x *MessageIndex) GetGroup() string

func (*MessageIndex) GetMessageId 

func (x *MessageIndex) GetMessageId() int64

func (*MessageIndex) GetSendTime 

func (x *MessageIndex) GetSendTime() int64

func (*MessageIndex) ProtoMessage 

func (*MessageIndex) ProtoMessage()

func (*MessageIndex) ProtoReflect 

func (x *MessageIndex) ProtoReflect() protoreflect.Message

func (*MessageIndex) Reset 

func (x *MessageIndex) Reset()

func (*MessageIndex) String 

func (x *MessageIndex) String() string

type MessageIndexReq 

type MessageIndexReq struct {
	MessageId int64 `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageIndexReq) Descriptor deprecated 

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

Deprecated: Use MessageIndexReq.ProtoReflect.Descriptor instead.

func (*MessageIndexReq) GetMessageId 

func (x *MessageIndexReq) GetMessageId() int64

func (*MessageIndexReq) ProtoMessage 

func (*MessageIndexReq) ProtoMessage()

func (*MessageIndexReq) ProtoReflect 

func (x *MessageIndexReq) ProtoReflect() protoreflect.Message

func (*MessageIndexReq) Reset 

func (x *MessageIndexReq) Reset()

func (*MessageIndexReq) String 

func (x *MessageIndexReq) String() string

type MessageIndexResp 

type MessageIndexResp struct {
	Indexes []*MessageIndex `protobuf:"bytes,1,rep,name=indexes,proto3" json:"indexes,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageIndexResp) Descriptor deprecated 

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

Deprecated: Use MessageIndexResp.ProtoReflect.Descriptor instead.

func (*MessageIndexResp) GetIndexes 

func (x *MessageIndexResp) GetIndexes() []*MessageIndex

func (*MessageIndexResp) ProtoMessage 

func (*MessageIndexResp) ProtoMessage()

func (*MessageIndexResp) ProtoReflect 

func (x *MessageIndexResp) ProtoReflect() protoreflect.Message

func (*MessageIndexResp) Reset 

func (x *MessageIndexResp) Reset()

func (*MessageIndexResp) String 

func (x *MessageIndexResp) String() string

type MessagePush 

type MessagePush struct {
	MessageId int64  `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Type      int32  `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	Body      string `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	Extra     string `protobuf:"bytes,4,opt,name=extra,proto3" json:"extra,omitempty"`
	Sender    string `protobuf:"bytes,5,opt,name=sender,proto3" json:"sender,omitempty"`
	SendTime  int64  `protobuf:"varint,6,opt,name=send_time,json=sendTime,proto3" json:"send_time,omitempty"`
	// contains filtered or unexported fields
}

func (*MessagePush) Descriptor deprecated 

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

Deprecated: Use MessagePush.ProtoReflect.Descriptor instead.

func (*MessagePush) GetBody 

func (x *MessagePush) GetBody() string

func (*MessagePush) GetExtra 

func (x *MessagePush) GetExtra() string

func (*MessagePush) GetMessageId 

func (x *MessagePush) GetMessageId() int64

func (*MessagePush) GetSendTime 

func (x *MessagePush) GetSendTime() int64

func (*MessagePush) GetSender 

func (x *MessagePush) GetSender() string

func (*MessagePush) GetType 

func (x *MessagePush) GetType() int32

func (*MessagePush) ProtoMessage 

func (*MessagePush) ProtoMessage()

func (*MessagePush) ProtoReflect 

func (x *MessagePush) ProtoReflect() protoreflect.Message

func (*MessagePush) Reset 

func (x *MessagePush) Reset()

func (*MessagePush) String 

func (x *MessagePush) String() string

type MessageReq 

type MessageReq struct {
	Type  int32  `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	Body  string `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	Extra string `protobuf:"bytes,3,opt,name=extra,proto3" json:"extra,omitempty"`
	// contains filtered or unexported fields
}

chat message

func (*MessageReq) Descriptor deprecated 

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

Deprecated: Use MessageReq.ProtoReflect.Descriptor instead.

func (*MessageReq) GetBody 

func (x *MessageReq) GetBody() string

func (*MessageReq) GetExtra 

func (x *MessageReq) GetExtra() string

func (*MessageReq) GetType 

func (x *MessageReq) GetType() int32

func (*MessageReq) ProtoMessage 

func (*MessageReq) ProtoMessage()

func (*MessageReq) ProtoReflect 

func (x *MessageReq) ProtoReflect() protoreflect.Message

func (*MessageReq) Reset 

func (x *MessageReq) Reset()

func (*MessageReq) String 

func (x *MessageReq) String() string

type MessageResp 

type MessageResp struct {
	MessageId int64 `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	SendTime  int64 `protobuf:"varint,2,opt,name=send_time,json=sendTime,proto3" json:"send_time,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageResp) Descriptor deprecated 

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

Deprecated: Use MessageResp.ProtoReflect.Descriptor instead.

func (*MessageResp) GetMessageId 

func (x *MessageResp) GetMessageId() int64

func (*MessageResp) GetSendTime 

func (x *MessageResp) GetSendTime() int64

func (*MessageResp) ProtoMessage 

func (*MessageResp) ProtoMessage()

func (*MessageResp) ProtoReflect 

func (x *MessageResp) ProtoReflect() protoreflect.Message

func (*MessageResp) Reset 

func (x *MessageResp) Reset()

func (*MessageResp) String 

func (x *MessageResp) String() string

type Meta 

type Meta struct {
	Key   string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Type  MetaType `protobuf:"varint,3,opt,name=type,proto3,enum=pkt.MetaType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Meta) Descriptor deprecated 

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

Deprecated: Use Meta.ProtoReflect.Descriptor instead.

func (*Meta) GetKey 

func (x *Meta) GetKey() string

func (*Meta) GetType 

func (x *Meta) GetType() MetaType

func (*Meta) GetValue 

func (x *Meta) GetValue() string

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) ProtoReflect 

func (x *Meta) ProtoReflect() protoreflect.Message

func (*Meta) Reset 

func (x *Meta) Reset()

func (*Meta) String 

func (x *Meta) String() string

type MetaType 

type MetaType int32
const (
	MetaType_int    MetaType = 0
	MetaType_string MetaType = 1
	MetaType_float  MetaType = 2
)

func (MetaType) Descriptor 

func (MetaType) Descriptor() protoreflect.EnumDescriptor

func (MetaType) Enum 

func (x MetaType) Enum() *MetaType

func (MetaType) EnumDescriptor deprecated 

func (MetaType) EnumDescriptor() ([]byte, []int)

Deprecated: Use MetaType.Descriptor instead.

func (MetaType) Number 

func (x MetaType) Number() protoreflect.EnumNumber

func (MetaType) String 

func (x MetaType) String() string

func (MetaType) Type 

func (MetaType) Type() protoreflect.EnumType

type Packet 

type Packet interface {
	Decode(r io.Reader) error
	Encode(w io.Writer) error
}

type Session 

type Session struct {
	ChannelId string   `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // session id
	GateId    string   `protobuf:"bytes,2,opt,name=gate_id,json=gateId,proto3" json:"gate_id,omitempty"`          // gateway id
	Account   string   `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
	Zone      string   `protobuf:"bytes,4,opt,name=zone,proto3" json:"zone,omitempty"`
	Isp       string   `protobuf:"bytes,5,opt,name=isp,proto3" json:"isp,omitempty"`
	RemoteIp  string   `protobuf:"bytes,6,opt,name=remote_ip,json=remoteIp,proto3" json:"remote_ip,omitempty"`
	Device    string   `protobuf:"bytes,7,opt,name=device,proto3" json:"device,omitempty"`
	App       string   `protobuf:"bytes,8,opt,name=app,proto3" json:"app,omitempty"`
	Tags      []string `protobuf:"bytes,9,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*Session) Descriptor deprecated 

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetAccount 

func (x *Session) GetAccount() string

func (*Session) GetApp 

func (x *Session) GetApp() string

func (*Session) GetChannelId 

func (x *Session) GetChannelId() string

func (*Session) GetDevice 

func (x *Session) GetDevice() string

func (*Session) GetGateId 

func (x *Session) GetGateId() string

func (*Session) GetIsp 

func (x *Session) GetIsp() string

func (*Session) GetRemoteIp 

func (x *Session) GetRemoteIp() string

func (*Session) GetTags 

func (x *Session) GetTags() []string

func (*Session) GetZone 

func (x *Session) GetZone() string

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect 

func (x *Session) ProtoReflect() protoreflect.Message

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) String 

func (x *Session) String() string

type Status 

type Status int32

status is a uint16 value 

const (
	Status_Success Status = 0 // client defined
	// client error 100-200
	Status_NoDestination     Status = 100
	Status_InvalidPacketBody Status = 101
	Status_InvalidCommand    Status = 103
	Status_Unauthorized      Status = 105
	// server error 300-400
	Status_SystemException Status = 300
	Status_NotImplemented  Status = 301
	// specific error
	Status_SessionNotFound Status = 404 // session lost
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

func (Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.