proto

package
v0.0.0-...-f6d4ea8 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2019 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidMessage = errors.New("invalid message")
)
View Source 
var MessageAck_Status_name = map[int32]string{
	0: "OK",
	1: "BlackList",
	2: "NotFriend",
	3: "NotInGroup",
	4: "NotInRoom",
}
View Source 
var MessageAck_Status_value = map[string]int32{
	"OK":         0,
	"BlackList":  1,
	"NotFriend":  2,
	"NotInGroup": 3,
	"NotInRoom":  4,
}
View Source 
var Message_Type_name = map[int32]string{
	0:    "Undefined",
	1001: "AuthRequest",
	1002: "AuthResponse",
	1003: "ContentMessage",
	1004: "GroupContentMessage",
	1005: "RoomContentMessage",
	1006: "MessageAck",
	1007: "Notification",
}
View Source 
var Message_Type_value = map[string]int32{
	"Undefined":           0,
	"AuthRequest":         1001,
	"AuthResponse":        1002,
	"ContentMessage":      1003,
	"GroupContentMessage": 1004,
	"RoomContentMessage":  1005,
	"MessageAck":          1006,
	"Notification":        1007,
}
View Source 
var Version_name = map[int32]string{
	0: "Undefined",
	1: "V1",
}
View Source 
var Version_value = map[string]int32{
	"Undefined": 0,
	"V1":        1,
}

Functions

This section is empty.

Types

type Conn 

type Conn interface {
	Read() (*Message, error)
	Write(*Message) error
	Close() error
	SetReadDeadline(time.Time) error
}

func NewTCPConn 

func NewTCPConn(c net.Conn) Conn

func NewWSConn 

func NewWSConn(c *websocket.Conn) Conn

type Message 

type Message struct {
	Version              Version      `protobuf:"varint,1,opt,name=version,proto3,enum=proto.Version" json:"version,omitempty"`
	Id                   string       `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	AppId                string       `protobuf:"bytes,3,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	FromUserId           string       `protobuf:"bytes,4,opt,name=from_user_id,json=fromUserId,proto3" json:"from_user_id,omitempty"`
	ToUserId             string       `protobuf:"bytes,5,opt,name=to_user_id,json=toUserId,proto3" json:"to_user_id,omitempty"`
	Type                 Message_Type `protobuf:"varint,6,opt,name=type,proto3,enum=proto.Message_Type" json:"type,omitempty"`
	Ctime                int64        `protobuf:"varint,7,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Content              string       `protobuf:"bytes,8,opt,name=content,proto3" json:"content,omitempty"`
	NeedAck              bool         `protobuf:"varint,9,opt,name=need_ack,json=needAck,proto3" json:"need_ack,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetAppId 

func (m *Message) GetAppId() string

func (*Message) GetContent 

func (m *Message) GetContent() string

func (*Message) GetCtime 

func (m *Message) GetCtime() int64

func (*Message) GetFromUserId 

func (m *Message) GetFromUserId() string

func (*Message) GetId 

func (m *Message) GetId() string

func (*Message) GetNeedAck 

func (m *Message) GetNeedAck() bool

func (*Message) GetToUserId 

func (m *Message) GetToUserId() string

func (*Message) GetType 

func (m *Message) GetType() Message_Type

func (*Message) GetVersion 

func (m *Message) GetVersion() Version

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge 

func (m *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

func (m *Message) XXX_Unmarshal(b []byte) error

type MessageAck 

type MessageAck struct {
	Status               MessageAck_Status `protobuf:"varint,1,opt,name=status,proto3,enum=proto.MessageAck_Status" json:"status,omitempty"`
	MsgId                string            `protobuf:"bytes,2,opt,name=msgId,proto3" json:"msgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*MessageAck) Descriptor 

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

func (*MessageAck) GetMsgId 

func (m *MessageAck) GetMsgId() string

func (*MessageAck) GetStatus 

func (m *MessageAck) GetStatus() MessageAck_Status

func (*MessageAck) ProtoMessage 

func (*MessageAck) ProtoMessage()

func (*MessageAck) Reset 

func (m *MessageAck) Reset()

func (*MessageAck) String 

func (m *MessageAck) String() string

func (*MessageAck) XXX_DiscardUnknown 

func (m *MessageAck) XXX_DiscardUnknown()

func (*MessageAck) XXX_Marshal 

func (m *MessageAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageAck) XXX_Merge 

func (m *MessageAck) XXX_Merge(src proto.Message)

func (*MessageAck) XXX_Size 

func (m *MessageAck) XXX_Size() int

func (*MessageAck) XXX_Unmarshal 

func (m *MessageAck) XXX_Unmarshal(b []byte) error

type MessageAck_Status 

type MessageAck_Status int32
const (
	MessageAck_OK         MessageAck_Status = 0
	MessageAck_BlackList  MessageAck_Status = 1
	MessageAck_NotFriend  MessageAck_Status = 2
	MessageAck_NotInGroup MessageAck_Status = 3
	MessageAck_NotInRoom  MessageAck_Status = 4
)

func (MessageAck_Status) EnumDescriptor 

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

func (MessageAck_Status) String 

func (x MessageAck_Status) String() string

type Message_Type 

type Message_Type int32
const (
	Message_Undefined           Message_Type = 0
	Message_AuthRequest         Message_Type = 1001
	Message_AuthResponse        Message_Type = 1002
	Message_ContentMessage      Message_Type = 1003
	Message_GroupContentMessage Message_Type = 1004
	Message_RoomContentMessage  Message_Type = 1005
	Message_MessageAck          Message_Type = 1006
	Message_Notification        Message_Type = 1007
)

func (Message_Type) EnumDescriptor 

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

func (Message_Type) String 

func (x Message_Type) String() string

type TCPConn 

type TCPConn struct {
	net.Conn
	sync.Mutex
}

func (*TCPConn) Read 

func (c *TCPConn) Read() (*Message, error)

func (*TCPConn) Write 

func (c *TCPConn) Write(m *Message) error

func (*TCPConn) WriteBytes 

func (c *TCPConn) WriteBytes(data []byte) error

type Version 

type Version int32
const (
	Version_Undefined Version = 0
	Version_V1        Version = 1
)

func (Version) EnumDescriptor 

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

func (Version) String 

func (x Version) String() string

type WSConn 

type WSConn struct {
	*websocket.Conn
}

func (*WSConn) Read 

func (c *WSConn) Read() (*Message, error)

func (*WSConn) SetReadDeadline 

func (c *WSConn) SetReadDeadline(t time.Time) error

func (*WSConn) Write 

func (c *WSConn) Write(m *Message) error

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.