pr

package
v0.0.0-...-f7687f2 Latest Latest
Warning

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

 Go to latest Published: Jan 2, 2018 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package pr is a generated protocol buffer package.

It is generated from these files: 

github.com/emsihyo/go.im/comps/pr/message.proto

It has these top-level messages: 

ReqLogin
RespLogin
ReqLogout
RespLogout
ReqSubscribe
RespSubscribe
ReqUnsubscribe
RespUnsubscribe
EmitSend
ReqDeliver
RespDeliver
ReqPing
RespPing
Consumer
Topic
Message

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Err_name = map[int32]string{
	0: "UserIDWrong",
	1: "PasswordWrong",
	2: "NotLogin",
}
View Source 
var Err_value = map[string]int32{
	"UserIDWrong":   0,
	"PasswordWrong": 1,
	"NotLogin":      2,
}
View Source 
var Type_name = map[int32]string{
	0: "Ping",
	1: "Login",
	2: "Logout",
	3: "Subscribe",
	4: "Unsubscribe",
	5: "Send",
	6: "Deliver",
}
View Source 
var Type_value = map[string]int32{
	"Ping":        0,
	"Login":       1,
	"Logout":      2,
	"Subscribe":   3,
	"Unsubscribe": 4,
	"Send":        5,
	"Deliver":     6,
}

Functions

This section is empty.

Types

type Consumer 

type Consumer struct {
	ID       string `protobuf:"bytes,1,opt,name=ID,proto3" json:"id,omitempty" bson:"id,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=Name,proto3" json:"name,omitempty" bson:"name,omitempty"`
	Avartar  string `protobuf:"bytes,3,opt,name=Avartar,proto3" json:"avartar,omitempty" bson:"avartar,omitempty"`
	UpdateAt int64  `protobuf:"varint,4,opt,name=UpdateAt,proto3" json:"update_at,omitempty" bson:"update_at,omitempty"`
}

func (*Consumer) Descriptor 

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

func (*Consumer) GetAvartar 

func (m *Consumer) GetAvartar() string

func (*Consumer) GetID 

func (m *Consumer) GetID() string

func (*Consumer) GetName 

func (m *Consumer) GetName() string

func (*Consumer) GetUpdateAt 

func (m *Consumer) GetUpdateAt() int64

func (*Consumer) Marshal 

func (m *Consumer) Marshal() (dAtA []byte, err error)

func (*Consumer) MarshalTo 

func (m *Consumer) MarshalTo(dAtA []byte) (int, error)

func (*Consumer) ProtoMessage 

func (*Consumer) ProtoMessage()

func (*Consumer) Reset 

func (m *Consumer) Reset()

func (*Consumer) Size 

func (m *Consumer) Size() (n int)

func (*Consumer) String 

func (this *Consumer) String() string

func (*Consumer) Unmarshal 

func (m *Consumer) Unmarshal(dAtA []byte) error

type EmitSend 

type EmitSend struct {
	Message *Message `protobuf:"bytes,1,opt,name=Message" json:"Message,omitempty"`
}

func (*EmitSend) Descriptor 

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

func (*EmitSend) GetMessage 

func (m *EmitSend) GetMessage() *Message

func (*EmitSend) Marshal 

func (m *EmitSend) Marshal() (dAtA []byte, err error)

func (*EmitSend) MarshalTo 

func (m *EmitSend) MarshalTo(dAtA []byte) (int, error)

func (*EmitSend) ProtoMessage 

func (*EmitSend) ProtoMessage()

func (*EmitSend) Reset 

func (m *EmitSend) Reset()

func (*EmitSend) Size 

func (m *EmitSend) Size() (n int)

func (*EmitSend) String 

func (this *EmitSend) String() string

func (*EmitSend) Unmarshal 

func (m *EmitSend) Unmarshal(dAtA []byte) error

type Err 

type Err int32
const (
	Err_UserIDWrong   Err = 0
	Err_PasswordWrong Err = 1
	Err_NotLogin      Err = 2
)

func (Err) EnumDescriptor 

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

func (Err) String 

func (x Err) String() string

type Message 

type Message struct {
	CID  string    `protobuf:"bytes,1,opt,name=CID,proto3" json:"cid,omitempty" bson:"cid,omitempty"`
	SID  int64     `protobuf:"varint,2,opt,name=SID,proto3" json:"sid,omitempty" bson:"sid,omitempty"`
	From *Consumer `protobuf:"bytes,3,opt,name=From" json:"from,omitempty" bson:"from,omitempty"`
	To   *Topic    `protobuf:"bytes,4,opt,name=To" json:"to,omitempty" bson:"to,omitempty"`
	At   int64     `protobuf:"varint,5,opt,name=At,proto3" json:"at,omitempty" bson:"at,omitempty"`
	Body string    `protobuf:"bytes,6,opt,name=Body,proto3" json:"body,omitempty" bson:"content,omitempty"`
}

func (*Message) Descriptor 

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

func (*Message) GetAt 

func (m *Message) GetAt() int64

func (*Message) GetBody 

func (m *Message) GetBody() string

func (*Message) GetCID 

func (m *Message) GetCID() string

func (*Message) GetFrom 

func (m *Message) GetFrom() *Consumer

func (*Message) GetSID 

func (m *Message) GetSID() int64

func (*Message) GetTo 

func (m *Message) GetTo() *Topic

func (*Message) Marshal 

func (m *Message) Marshal() (dAtA []byte, err error)

func (*Message) MarshalTo 

func (m *Message) MarshalTo(dAtA []byte) (int, error)

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

func (m *Message) Size() (n int)

func (*Message) String 

func (this *Message) String() string

func (*Message) Unmarshal 

func (m *Message) Unmarshal(dAtA []byte) error

type ReqDeliver 

type ReqDeliver struct {
	Message *Message `protobuf:"bytes,1,opt,name=Message" json:"Message,omitempty"`
}

func (*ReqDeliver) Descriptor 

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

func (*ReqDeliver) GetMessage 

func (m *ReqDeliver) GetMessage() *Message

func (*ReqDeliver) Marshal 

func (m *ReqDeliver) Marshal() (dAtA []byte, err error)

func (*ReqDeliver) MarshalTo 

func (m *ReqDeliver) MarshalTo(dAtA []byte) (int, error)

func (*ReqDeliver) ProtoMessage 

func (*ReqDeliver) ProtoMessage()

func (*ReqDeliver) Reset 

func (m *ReqDeliver) Reset()

func (*ReqDeliver) Size 

func (m *ReqDeliver) Size() (n int)

func (*ReqDeliver) String 

func (this *ReqDeliver) String() string

func (*ReqDeliver) Unmarshal 

func (m *ReqDeliver) Unmarshal(dAtA []byte) error

type ReqLogin 

type ReqLogin struct {
	UserID   string `protobuf:"bytes,1,opt,name=UserID,proto3" json:"UserID,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=Password,proto3" json:"Password,omitempty"`
	Platform string `protobuf:"bytes,3,opt,name=Platform,proto3" json:"Platform,omitempty"`
}

func (*ReqLogin) Descriptor 

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

func (*ReqLogin) GetPassword 

func (m *ReqLogin) GetPassword() string

func (*ReqLogin) GetPlatform 

func (m *ReqLogin) GetPlatform() string

func (*ReqLogin) GetUserID 

func (m *ReqLogin) GetUserID() string

func (*ReqLogin) Marshal 

func (m *ReqLogin) Marshal() (dAtA []byte, err error)

func (*ReqLogin) MarshalTo 

func (m *ReqLogin) MarshalTo(dAtA []byte) (int, error)

func (*ReqLogin) ProtoMessage 

func (*ReqLogin) ProtoMessage()

func (*ReqLogin) Reset 

func (m *ReqLogin) Reset()

func (*ReqLogin) Size 

func (m *ReqLogin) Size() (n int)

func (*ReqLogin) String 

func (this *ReqLogin) String() string

func (*ReqLogin) Unmarshal 

func (m *ReqLogin) Unmarshal(dAtA []byte) error

type ReqLogout 

type ReqLogout struct {
}

func (*ReqLogout) Descriptor 

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

func (*ReqLogout) Marshal 

func (m *ReqLogout) Marshal() (dAtA []byte, err error)

func (*ReqLogout) MarshalTo 

func (m *ReqLogout) MarshalTo(dAtA []byte) (int, error)

func (*ReqLogout) ProtoMessage 

func (*ReqLogout) ProtoMessage()

func (*ReqLogout) Reset 

func (m *ReqLogout) Reset()

func (*ReqLogout) Size 

func (m *ReqLogout) Size() (n int)

func (*ReqLogout) String 

func (this *ReqLogout) String() string

func (*ReqLogout) Unmarshal 

func (m *ReqLogout) Unmarshal(dAtA []byte) error

type ReqPing 

type ReqPing struct {
}

func (*ReqPing) Descriptor 

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

func (*ReqPing) Marshal 

func (m *ReqPing) Marshal() (dAtA []byte, err error)

func (*ReqPing) MarshalTo 

func (m *ReqPing) MarshalTo(dAtA []byte) (int, error)

func (*ReqPing) ProtoMessage 

func (*ReqPing) ProtoMessage()

func (*ReqPing) Reset 

func (m *ReqPing) Reset()

func (*ReqPing) Size 

func (m *ReqPing) Size() (n int)

func (*ReqPing) String 

func (this *ReqPing) String() string

func (*ReqPing) Unmarshal 

func (m *ReqPing) Unmarshal(dAtA []byte) error

type ReqSubscribe 

type ReqSubscribe struct {
	TopicID  string `protobuf:"bytes,1,opt,name=TopicID,proto3" json:"TopicID,omitempty"`
	MinSID   int64  `protobuf:"varint,2,opt,name=MinSID,proto3" json:"MinSID,omitempty"`
	MaxCount int64  `protobuf:"varint,3,opt,name=MaxCount,proto3" json:"MaxCount,omitempty"`
}

func (*ReqSubscribe) Descriptor 

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

func (*ReqSubscribe) GetMaxCount 

func (m *ReqSubscribe) GetMaxCount() int64

func (*ReqSubscribe) GetMinSID 

func (m *ReqSubscribe) GetMinSID() int64

func (*ReqSubscribe) GetTopicID 

func (m *ReqSubscribe) GetTopicID() string

func (*ReqSubscribe) Marshal 

func (m *ReqSubscribe) Marshal() (dAtA []byte, err error)

func (*ReqSubscribe) MarshalTo 

func (m *ReqSubscribe) MarshalTo(dAtA []byte) (int, error)

func (*ReqSubscribe) ProtoMessage 

func (*ReqSubscribe) ProtoMessage()

func (*ReqSubscribe) Reset 

func (m *ReqSubscribe) Reset()

func (*ReqSubscribe) Size 

func (m *ReqSubscribe) Size() (n int)

func (*ReqSubscribe) String 

func (this *ReqSubscribe) String() string

func (*ReqSubscribe) Unmarshal 

func (m *ReqSubscribe) Unmarshal(dAtA []byte) error

type ReqUnsubscribe 

type ReqUnsubscribe struct {
	TopicID string `protobuf:"bytes,1,opt,name=TopicID,proto3" json:"TopicID,omitempty"`
}

func (*ReqUnsubscribe) Descriptor 

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

func (*ReqUnsubscribe) GetTopicID 

func (m *ReqUnsubscribe) GetTopicID() string

func (*ReqUnsubscribe) Marshal 

func (m *ReqUnsubscribe) Marshal() (dAtA []byte, err error)

func (*ReqUnsubscribe) MarshalTo 

func (m *ReqUnsubscribe) MarshalTo(dAtA []byte) (int, error)

func (*ReqUnsubscribe) ProtoMessage 

func (*ReqUnsubscribe) ProtoMessage()

func (*ReqUnsubscribe) Reset 

func (m *ReqUnsubscribe) Reset()

func (*ReqUnsubscribe) Size 

func (m *ReqUnsubscribe) Size() (n int)

func (*ReqUnsubscribe) String 

func (this *ReqUnsubscribe) String() string

func (*ReqUnsubscribe) Unmarshal 

func (m *ReqUnsubscribe) Unmarshal(dAtA []byte) error

type RespDeliver 

type RespDeliver struct {
	Code int32  `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Desc string `protobuf:"bytes,2,opt,name=Desc,proto3" json:"Desc,omitempty"`
	SID  int64  `protobuf:"varint,3,opt,name=SID,proto3" json:"SID,omitempty"`
	At   int64  `protobuf:"varint,4,opt,name=At,proto3" json:"At,omitempty"`
}

func (*RespDeliver) Descriptor 

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

func (*RespDeliver) GetAt 

func (m *RespDeliver) GetAt() int64

func (*RespDeliver) GetCode 

func (m *RespDeliver) GetCode() int32

func (*RespDeliver) GetDesc 

func (m *RespDeliver) GetDesc() string

func (*RespDeliver) GetSID 

func (m *RespDeliver) GetSID() int64

func (*RespDeliver) Marshal 

func (m *RespDeliver) Marshal() (dAtA []byte, err error)

func (*RespDeliver) MarshalTo 

func (m *RespDeliver) MarshalTo(dAtA []byte) (int, error)

func (*RespDeliver) ProtoMessage 

func (*RespDeliver) ProtoMessage()

func (*RespDeliver) Reset 

func (m *RespDeliver) Reset()

func (*RespDeliver) Size 

func (m *RespDeliver) Size() (n int)

func (*RespDeliver) String 

func (this *RespDeliver) String() string

func (*RespDeliver) Unmarshal 

func (m *RespDeliver) Unmarshal(dAtA []byte) error

type RespLogin 

type RespLogin struct {
	Code int32  `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Desc string `protobuf:"bytes,2,opt,name=Desc,proto3" json:"Desc,omitempty"`
}

func (*RespLogin) Descriptor 

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

func (*RespLogin) GetCode 

func (m *RespLogin) GetCode() int32

func (*RespLogin) GetDesc 

func (m *RespLogin) GetDesc() string

func (*RespLogin) Marshal 

func (m *RespLogin) Marshal() (dAtA []byte, err error)

func (*RespLogin) MarshalTo 

func (m *RespLogin) MarshalTo(dAtA []byte) (int, error)

func (*RespLogin) ProtoMessage 

func (*RespLogin) ProtoMessage()

func (*RespLogin) Reset 

func (m *RespLogin) Reset()

func (*RespLogin) Size 

func (m *RespLogin) Size() (n int)

func (*RespLogin) String 

func (this *RespLogin) String() string

func (*RespLogin) Unmarshal 

func (m *RespLogin) Unmarshal(dAtA []byte) error

type RespLogout 

type RespLogout struct {
	Code int32  `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Desc string `protobuf:"bytes,2,opt,name=Desc,proto3" json:"Desc,omitempty"`
}

func (*RespLogout) Descriptor 

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

func (*RespLogout) GetCode 

func (m *RespLogout) GetCode() int32

func (*RespLogout) GetDesc 

func (m *RespLogout) GetDesc() string

func (*RespLogout) Marshal 

func (m *RespLogout) Marshal() (dAtA []byte, err error)

func (*RespLogout) MarshalTo 

func (m *RespLogout) MarshalTo(dAtA []byte) (int, error)

func (*RespLogout) ProtoMessage 

func (*RespLogout) ProtoMessage()

func (*RespLogout) Reset 

func (m *RespLogout) Reset()

func (*RespLogout) Size 

func (m *RespLogout) Size() (n int)

func (*RespLogout) String 

func (this *RespLogout) String() string

func (*RespLogout) Unmarshal 

func (m *RespLogout) Unmarshal(dAtA []byte) error

type RespPing 

type RespPing struct {
}

func (*RespPing) Descriptor 

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

func (*RespPing) Marshal 

func (m *RespPing) Marshal() (dAtA []byte, err error)

func (*RespPing) MarshalTo 

func (m *RespPing) MarshalTo(dAtA []byte) (int, error)

func (*RespPing) ProtoMessage 

func (*RespPing) ProtoMessage()

func (*RespPing) Reset 

func (m *RespPing) Reset()

func (*RespPing) Size 

func (m *RespPing) Size() (n int)

func (*RespPing) String 

func (this *RespPing) String() string

func (*RespPing) Unmarshal 

func (m *RespPing) Unmarshal(dAtA []byte) error

type RespSubscribe 

type RespSubscribe struct {
	Code      int32      `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Desc      string     `protobuf:"bytes,2,opt,name=Desc,proto3" json:"Desc,omitempty"`
	Histories []*Message `protobuf:"bytes,3,rep,name=histories" json:"histories,omitempty"`
}

func (*RespSubscribe) Descriptor 

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

func (*RespSubscribe) GetCode 

func (m *RespSubscribe) GetCode() int32

func (*RespSubscribe) GetDesc 

func (m *RespSubscribe) GetDesc() string

func (*RespSubscribe) GetHistories 

func (m *RespSubscribe) GetHistories() []*Message

func (*RespSubscribe) Marshal 

func (m *RespSubscribe) Marshal() (dAtA []byte, err error)

func (*RespSubscribe) MarshalTo 

func (m *RespSubscribe) MarshalTo(dAtA []byte) (int, error)

func (*RespSubscribe) ProtoMessage 

func (*RespSubscribe) ProtoMessage()

func (*RespSubscribe) Reset 

func (m *RespSubscribe) Reset()

func (*RespSubscribe) Size 

func (m *RespSubscribe) Size() (n int)

func (*RespSubscribe) String 

func (this *RespSubscribe) String() string

func (*RespSubscribe) Unmarshal 

func (m *RespSubscribe) Unmarshal(dAtA []byte) error

type RespUnsubscribe 

type RespUnsubscribe struct {
	Code int32  `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Desc string `protobuf:"bytes,2,opt,name=Desc,proto3" json:"Desc,omitempty"`
}

func (*RespUnsubscribe) Descriptor 

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

func (*RespUnsubscribe) GetCode 

func (m *RespUnsubscribe) GetCode() int32

func (*RespUnsubscribe) GetDesc 

func (m *RespUnsubscribe) GetDesc() string

func (*RespUnsubscribe) Marshal 

func (m *RespUnsubscribe) Marshal() (dAtA []byte, err error)

func (*RespUnsubscribe) MarshalTo 

func (m *RespUnsubscribe) MarshalTo(dAtA []byte) (int, error)

func (*RespUnsubscribe) ProtoMessage 

func (*RespUnsubscribe) ProtoMessage()

func (*RespUnsubscribe) Reset 

func (m *RespUnsubscribe) Reset()

func (*RespUnsubscribe) Size 

func (m *RespUnsubscribe) Size() (n int)

func (*RespUnsubscribe) String 

func (this *RespUnsubscribe) String() string

func (*RespUnsubscribe) Unmarshal 

func (m *RespUnsubscribe) Unmarshal(dAtA []byte) error

type Topic 

type Topic struct {
	ID       string `protobuf:"bytes,1,opt,name=ID,proto3" json:"id,omitempty" bson:"id,omitempty"`
	Title    string `protobuf:"bytes,2,opt,name=Title,proto3" json:"title,omitempty" bson:"title,omitempty"`
	Avartar  string `protobuf:"bytes,3,opt,name=Avartar,proto3" json:"avartar,omitempty" bson:"avartar,omitempty"`
	UpdateAt int64  `protobuf:"varint,4,opt,name=UpdateAt,proto3" json:"update_at,omitempty" bson:"update_at,omitempty"`
	Group    bool   `protobuf:"varint,5,opt,name=Group,proto3" json:"group,omitempty" bson:"group,omitempty"`
}

func (*Topic) Descriptor 

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

func (*Topic) GetAvartar 

func (m *Topic) GetAvartar() string

func (*Topic) GetGroup 

func (m *Topic) GetGroup() bool

func (*Topic) GetID 

func (m *Topic) GetID() string

func (*Topic) GetTitle 

func (m *Topic) GetTitle() string

func (*Topic) GetUpdateAt 

func (m *Topic) GetUpdateAt() int64

func (*Topic) Marshal 

func (m *Topic) Marshal() (dAtA []byte, err error)

func (*Topic) MarshalTo 

func (m *Topic) MarshalTo(dAtA []byte) (int, error)

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) Reset 

func (m *Topic) Reset()

func (*Topic) Size 

func (m *Topic) Size() (n int)

func (*Topic) String 

func (this *Topic) String() string

func (*Topic) Unmarshal 

func (m *Topic) Unmarshal(dAtA []byte) error

type Type 

type Type int32
const (
	Type_Ping        Type = 0
	Type_Login       Type = 1
	Type_Logout      Type = 2
	Type_Subscribe   Type = 3
	Type_Unsubscribe Type = 4
	Type_Send        Type = 5
	Type_Deliver     Type = 6
)

func (Type) EnumDescriptor 

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

func (Type) String 

func (x Type) String() string

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.