grpc

package
v0.0.0-...-e621399 Latest Latest
Warning

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

 Go to latest Published: Dec 11, 2020 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// OpHandshake handshake
	OpHandshake = int32(0)
	// OpHandshakeReply handshake reply
	OpHandshakeReply = int32(1)

	// OpHeartbeat heartbeat
	OpHeartbeat = int32(2)
	// OpHeartbeatReply heartbeat reply
	OpHeartbeatReply = int32(3)

	// OpSendMsg send message.
	OpSendMsg = int32(4)
	// OpSendMsgReply  send message reply
	OpSendMsgReply = int32(5)

	// OpDisconnectReply disconnect reply
	OpDisconnectReply = int32(6)

	// OpAuth auth connnect
	OpAuth = int32(7)
	// OpAuthReply auth connect reply
	OpAuthReply = int32(8)

	// OpRaw raw message
	OpRaw = int32(9)

	// OpProtoReady proto ready
	OpProtoReady = int32(10)
	// OpProtoFinish proto finish
	OpProtoFinish = int32(11)

	// OpChangeRoom change room
	OpChangeRoom = int32(12)
	// OpChangeRoomReply change room reply
	OpChangeRoomReply = int32(13)

	// OpSub subscribe operation
	OpSub = int32(14)
	// OpSubReply subscribe operation
	OpSubReply = int32(15)

	// OpUnsub unsubscribe operation
	OpUnsub = int32(16)
	// OpUnsubReply unsubscribe operation reply
	OpUnsubReply = int32(17)
)
View Source 
const (
	// MaxBodySize max proto body size
	MaxBodySize = int32(1 << 12)
)

Variables

View Source 
var (
	// ErrProtoPackLen proto packet len error
	ErrProtoPackLen = errors.New("default server codec pack length error")
	// ErrProtoHeaderLen proto header len error
	ErrProtoHeaderLen = errors.New("default server codec header length error")
)
View Source 
var (
	// ProtoReady proto ready
	ProtoReady = &Proto{Op: OpProtoReady}
	// ProtoFinish proto finish
	ProtoFinish = &Proto{Op: OpProtoFinish}
)

Functions

func RegisterCometServer 

func RegisterCometServer(s *grpc.Server, srv CometServer)

Types

type BroadcastReply 

type BroadcastReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BroadcastReply) Descriptor 

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

func (*BroadcastReply) ProtoMessage 

func (*BroadcastReply) ProtoMessage()

func (*BroadcastReply) Reset 

func (m *BroadcastReply) Reset()

func (*BroadcastReply) String 

func (m *BroadcastReply) String() string

func (*BroadcastReply) XXX_DiscardUnknown 

func (m *BroadcastReply) XXX_DiscardUnknown()

func (*BroadcastReply) XXX_Marshal 

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

func (*BroadcastReply) XXX_Merge 

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

func (*BroadcastReply) XXX_Size 

func (m *BroadcastReply) XXX_Size() int

func (*BroadcastReply) XXX_Unmarshal 

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

type BroadcastReq 

type BroadcastReq struct {
	ProtoOp              int32    `protobuf:"varint,1,opt,name=protoOp,proto3" json:"protoOp,omitempty"`
	Proto                *Proto   `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"`
	Speed                int32    `protobuf:"varint,3,opt,name=speed,proto3" json:"speed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BroadcastReq) Descriptor 

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

func (*BroadcastReq) GetProto 

func (m *BroadcastReq) GetProto() *Proto

func (*BroadcastReq) GetProtoOp 

func (m *BroadcastReq) GetProtoOp() int32

func (*BroadcastReq) GetSpeed 

func (m *BroadcastReq) GetSpeed() int32

func (*BroadcastReq) ProtoMessage 

func (*BroadcastReq) ProtoMessage()

func (*BroadcastReq) Reset 

func (m *BroadcastReq) Reset()

func (*BroadcastReq) String 

func (m *BroadcastReq) String() string

func (*BroadcastReq) XXX_DiscardUnknown 

func (m *BroadcastReq) XXX_DiscardUnknown()

func (*BroadcastReq) XXX_Marshal 

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

func (*BroadcastReq) XXX_Merge 

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

func (*BroadcastReq) XXX_Size 

func (m *BroadcastReq) XXX_Size() int

func (*BroadcastReq) XXX_Unmarshal 

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

type BroadcastRoomReply 

type BroadcastRoomReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BroadcastRoomReply) Descriptor 

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

func (*BroadcastRoomReply) ProtoMessage 

func (*BroadcastRoomReply) ProtoMessage()

func (*BroadcastRoomReply) Reset 

func (m *BroadcastRoomReply) Reset()

func (*BroadcastRoomReply) String 

func (m *BroadcastRoomReply) String() string

func (*BroadcastRoomReply) XXX_DiscardUnknown 

func (m *BroadcastRoomReply) XXX_DiscardUnknown()

func (*BroadcastRoomReply) XXX_Marshal 

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

func (*BroadcastRoomReply) XXX_Merge 

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

func (*BroadcastRoomReply) XXX_Size 

func (m *BroadcastRoomReply) XXX_Size() int

func (*BroadcastRoomReply) XXX_Unmarshal 

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

type BroadcastRoomReq 

type BroadcastRoomReq struct {
	RoomID               string   `protobuf:"bytes,1,opt,name=roomID,proto3" json:"roomID,omitempty"`
	Proto                *Proto   `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BroadcastRoomReq) Descriptor 

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

func (*BroadcastRoomReq) GetProto 

func (m *BroadcastRoomReq) GetProto() *Proto

func (*BroadcastRoomReq) GetRoomID 

func (m *BroadcastRoomReq) GetRoomID() string

func (*BroadcastRoomReq) ProtoMessage 

func (*BroadcastRoomReq) ProtoMessage()

func (*BroadcastRoomReq) Reset 

func (m *BroadcastRoomReq) Reset()

func (*BroadcastRoomReq) String 

func (m *BroadcastRoomReq) String() string

func (*BroadcastRoomReq) XXX_DiscardUnknown 

func (m *BroadcastRoomReq) XXX_DiscardUnknown()

func (*BroadcastRoomReq) XXX_Marshal 

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

func (*BroadcastRoomReq) XXX_Merge 

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

func (*BroadcastRoomReq) XXX_Size 

func (m *BroadcastRoomReq) XXX_Size() int

func (*BroadcastRoomReq) XXX_Unmarshal 

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

type CometClient 

type CometClient interface {
	// Ping Service
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// Close Service
	Close(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// PushMsg push by key or mid
	PushMsg(ctx context.Context, in *PushMsgReq, opts ...grpc.CallOption) (*PushMsgReply, error)
	// Broadcast send to every enrity
	Broadcast(ctx context.Context, in *BroadcastReq, opts ...grpc.CallOption) (*BroadcastReply, error)
	// BroadcastRoom broadcast to one room
	BroadcastRoom(ctx context.Context, in *BroadcastRoomReq, opts ...grpc.CallOption) (*BroadcastRoomReply, error)
	// Rooms get all rooms
	Rooms(ctx context.Context, in *RoomsReq, opts ...grpc.CallOption) (*RoomsReply, error)
	// Online stats
	Onlines(ctx context.Context, in *OnlinesReq, opts ...grpc.CallOption) (*OnlinesReply, error)
	// Message stats
	Messages(ctx context.Context, in *MessagesReq, opts ...grpc.CallOption) (*MessagesReply, error)
}

CometClient is the client API for Comet service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCometClient 

func NewCometClient(cc *grpc.ClientConn) CometClient

type CometServer 

type CometServer interface {
	// Ping Service
	Ping(context.Context, *Empty) (*Empty, error)
	// Close Service
	Close(context.Context, *Empty) (*Empty, error)
	// PushMsg push by key or mid
	PushMsg(context.Context, *PushMsgReq) (*PushMsgReply, error)
	// Broadcast send to every enrity
	Broadcast(context.Context, *BroadcastReq) (*BroadcastReply, error)
	// BroadcastRoom broadcast to one room
	BroadcastRoom(context.Context, *BroadcastRoomReq) (*BroadcastRoomReply, error)
	// Rooms get all rooms
	Rooms(context.Context, *RoomsReq) (*RoomsReply, error)
	// Online stats
	Onlines(context.Context, *OnlinesReq) (*OnlinesReply, error)
	// Message stats
	Messages(context.Context, *MessagesReq) (*MessagesReply, error)
}

CometServer is the server API for Comet service.

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type MessagesReply 

type MessagesReply struct {
	MsgStats             []*MsgStat `protobuf:"bytes,1,rep,name=msgStats,proto3" json:"msgStats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*MessagesReply) Descriptor 

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

func (*MessagesReply) GetMsgStats 

func (m *MessagesReply) GetMsgStats() []*MsgStat

func (*MessagesReply) ProtoMessage 

func (*MessagesReply) ProtoMessage()

func (*MessagesReply) Reset 

func (m *MessagesReply) Reset()

func (*MessagesReply) String 

func (m *MessagesReply) String() string

func (*MessagesReply) XXX_DiscardUnknown 

func (m *MessagesReply) XXX_DiscardUnknown()

func (*MessagesReply) XXX_Marshal 

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

func (*MessagesReply) XXX_Merge 

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

func (*MessagesReply) XXX_Size 

func (m *MessagesReply) XXX_Size() int

func (*MessagesReply) XXX_Unmarshal 

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

type MessagesReq 

type MessagesReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessagesReq) Descriptor 

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

func (*MessagesReq) ProtoMessage 

func (*MessagesReq) ProtoMessage()

func (*MessagesReq) Reset 

func (m *MessagesReq) Reset()

func (*MessagesReq) String 

func (m *MessagesReq) String() string

func (*MessagesReq) XXX_DiscardUnknown 

func (m *MessagesReq) XXX_DiscardUnknown()

func (*MessagesReq) XXX_Marshal 

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

func (*MessagesReq) XXX_Merge 

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

func (*MessagesReq) XXX_Size 

func (m *MessagesReq) XXX_Size() int

func (*MessagesReq) XXX_Unmarshal 

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

type MsgStat 

type MsgStat struct {
	MsgType              int32    `protobuf:"varint,1,opt,name=msgType,proto3" json:"msgType,omitempty"`
	Count                uint64   `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Speed                float64  `protobuf:"fixed64,3,opt,name=speed,proto3" json:"speed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MsgStat) Descriptor 

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

func (*MsgStat) GetCount 

func (m *MsgStat) GetCount() uint64

func (*MsgStat) GetMsgType 

func (m *MsgStat) GetMsgType() int32

func (*MsgStat) GetSpeed 

func (m *MsgStat) GetSpeed() float64

func (*MsgStat) ProtoMessage 

func (*MsgStat) ProtoMessage()

func (*MsgStat) Reset 

func (m *MsgStat) Reset()

func (*MsgStat) String 

func (m *MsgStat) String() string

func (*MsgStat) XXX_DiscardUnknown 

func (m *MsgStat) XXX_DiscardUnknown()

func (*MsgStat) XXX_Marshal 

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

func (*MsgStat) XXX_Merge 

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

func (*MsgStat) XXX_Size 

func (m *MsgStat) XXX_Size() int

func (*MsgStat) XXX_Unmarshal 

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

type OnlinesReply 

type OnlinesReply struct {
	HostOnline           int64            `protobuf:"varint,1,opt,name=hostOnline,proto3" json:"hostOnline,omitempty"`
	TcpOnline            int64            `protobuf:"varint,2,opt,name=tcpOnline,proto3" json:"tcpOnline,omitempty"`
	WsOnline             int64            `protobuf:"varint,3,opt,name=wsOnline,proto3" json:"wsOnline,omitempty"`
	RoomOnlines          map[string]int64 `` /* 164-byte string literal not displayed */
	MidOnlines           map[int64]int64  `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*OnlinesReply) Descriptor 

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

func (*OnlinesReply) GetHostOnline 

func (m *OnlinesReply) GetHostOnline() int64

func (*OnlinesReply) GetMidOnlines 

func (m *OnlinesReply) GetMidOnlines() map[int64]int64

func (*OnlinesReply) GetRoomOnlines 

func (m *OnlinesReply) GetRoomOnlines() map[string]int64

func (*OnlinesReply) GetTcpOnline 

func (m *OnlinesReply) GetTcpOnline() int64

func (*OnlinesReply) GetWsOnline 

func (m *OnlinesReply) GetWsOnline() int64

func (*OnlinesReply) ProtoMessage 

func (*OnlinesReply) ProtoMessage()

func (*OnlinesReply) Reset 

func (m *OnlinesReply) Reset()

func (*OnlinesReply) String 

func (m *OnlinesReply) String() string

func (*OnlinesReply) XXX_DiscardUnknown 

func (m *OnlinesReply) XXX_DiscardUnknown()

func (*OnlinesReply) XXX_Marshal 

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

func (*OnlinesReply) XXX_Merge 

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

func (*OnlinesReply) XXX_Size 

func (m *OnlinesReply) XXX_Size() int

func (*OnlinesReply) XXX_Unmarshal 

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

type OnlinesReq 

type OnlinesReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OnlinesReq) Descriptor 

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

func (*OnlinesReq) ProtoMessage 

func (*OnlinesReq) ProtoMessage()

func (*OnlinesReq) Reset 

func (m *OnlinesReq) Reset()

func (*OnlinesReq) String 

func (m *OnlinesReq) String() string

func (*OnlinesReq) XXX_DiscardUnknown 

func (m *OnlinesReq) XXX_DiscardUnknown()

func (*OnlinesReq) XXX_Marshal 

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

func (*OnlinesReq) XXX_Merge 

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

func (*OnlinesReq) XXX_Size 

func (m *OnlinesReq) XXX_Size() int

func (*OnlinesReq) XXX_Unmarshal 

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

type Proto 

type Proto struct {
	Ver                  int32    `protobuf:"varint,1,opt,name=ver,proto3" json:"ver"`
	Op                   int32    `protobuf:"varint,2,opt,name=op,proto3" json:"op"`
	Seq                  int32    `protobuf:"varint,3,opt,name=seq,proto3" json:"seq"`
	Body                 []byte   `protobuf:"bytes,4,opt,name=body,proto3" json:"body"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

v1.0.0 protocol

func (*Proto) Descriptor 

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

func (*Proto) GetBody 

func (m *Proto) GetBody() []byte

func (*Proto) GetOp 

func (m *Proto) GetOp() int32

func (*Proto) GetSeq 

func (m *Proto) GetSeq() int32

func (*Proto) GetVer 

func (m *Proto) GetVer() int32

func (*Proto) ProtoMessage 

func (*Proto) ProtoMessage()

func (*Proto) ReadTCP 

func (p *Proto) ReadTCP(rr *bufio.Reader) (err error)

ReadTCP read a proto from TCP reader.

func (*Proto) ReadWebsocket 

func (p *Proto) ReadWebsocket(ws *websocket.Conn) (err error)

ReadWebsocket read a proto from websocket connection.

func (*Proto) Reset 

func (m *Proto) Reset()

func (*Proto) String 

func (m *Proto) String() string

func (*Proto) WriteTCP 

func (p *Proto) WriteTCP(wr *bufio.Writer) (err error)

WriteTCP write a proto to TCP writer.

func (*Proto) WriteTCPHeart 

func (p *Proto) WriteTCPHeart(wr *bufio.Writer, online int32) (err error)

WriteTCPHeart write TCP heartbeat with room online.

func (*Proto) WriteTo 

func (p *Proto) WriteTo(b *bytes.Writer)

WriteTo write a proto to bytes writer.

func (*Proto) WriteWebsocket 

func (p *Proto) WriteWebsocket(ws *websocket.Conn) (err error)

WriteWebsocket write a proto to websocket connection.

func (*Proto) WriteWebsocketHeart 

func (p *Proto) WriteWebsocketHeart(wr *websocket.Conn, online int32) (err error)

WriteWebsocketHeart write websocket heartbeat with room online.

func (*Proto) XXX_DiscardUnknown 

func (m *Proto) XXX_DiscardUnknown()

func (*Proto) XXX_Marshal 

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

func (*Proto) XXX_Merge 

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

func (*Proto) XXX_Size 

func (m *Proto) XXX_Size() int

func (*Proto) XXX_Unmarshal 

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

type PushMsgReply 

type PushMsgReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushMsgReply) Descriptor 

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

func (*PushMsgReply) ProtoMessage 

func (*PushMsgReply) ProtoMessage()

func (*PushMsgReply) Reset 

func (m *PushMsgReply) Reset()

func (*PushMsgReply) String 

func (m *PushMsgReply) String() string

func (*PushMsgReply) XXX_DiscardUnknown 

func (m *PushMsgReply) XXX_DiscardUnknown()

func (*PushMsgReply) XXX_Marshal 

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

func (*PushMsgReply) XXX_Merge 

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

func (*PushMsgReply) XXX_Size 

func (m *PushMsgReply) XXX_Size() int

func (*PushMsgReply) XXX_Unmarshal 

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

type PushMsgReq 

type PushMsgReq struct {
	Keys                 []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	ProtoOp              int32    `protobuf:"varint,3,opt,name=protoOp,proto3" json:"protoOp,omitempty"`
	Proto                *Proto   `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushMsgReq) Descriptor 

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

func (*PushMsgReq) GetKeys 

func (m *PushMsgReq) GetKeys() []string

func (*PushMsgReq) GetProto 

func (m *PushMsgReq) GetProto() *Proto

func (*PushMsgReq) GetProtoOp 

func (m *PushMsgReq) GetProtoOp() int32

func (*PushMsgReq) ProtoMessage 

func (*PushMsgReq) ProtoMessage()

func (*PushMsgReq) Reset 

func (m *PushMsgReq) Reset()

func (*PushMsgReq) String 

func (m *PushMsgReq) String() string

func (*PushMsgReq) XXX_DiscardUnknown 

func (m *PushMsgReq) XXX_DiscardUnknown()

func (*PushMsgReq) XXX_Marshal 

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

func (*PushMsgReq) XXX_Merge 

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

func (*PushMsgReq) XXX_Size 

func (m *PushMsgReq) XXX_Size() int

func (*PushMsgReq) XXX_Unmarshal 

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

type RoomsReply 

type RoomsReply struct {
	Rooms                map[string]bool `` /* 152-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RoomsReply) Descriptor 

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

func (*RoomsReply) GetRooms 

func (m *RoomsReply) GetRooms() map[string]bool

func (*RoomsReply) ProtoMessage 

func (*RoomsReply) ProtoMessage()

func (*RoomsReply) Reset 

func (m *RoomsReply) Reset()

func (*RoomsReply) String 

func (r *RoomsReply) String() string

func (*RoomsReply) XXX_DiscardUnknown 

func (m *RoomsReply) XXX_DiscardUnknown()

func (*RoomsReply) XXX_Marshal 

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

func (*RoomsReply) XXX_Merge 

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

func (*RoomsReply) XXX_Size 

func (m *RoomsReply) XXX_Size() int

func (*RoomsReply) XXX_Unmarshal 

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

type RoomsReq 

type RoomsReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RoomsReq) Descriptor 

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

func (*RoomsReq) ProtoMessage 

func (*RoomsReq) ProtoMessage()

func (*RoomsReq) Reset 

func (m *RoomsReq) Reset()

func (*RoomsReq) String 

func (m *RoomsReq) String() string

func (*RoomsReq) XXX_DiscardUnknown 

func (m *RoomsReq) XXX_DiscardUnknown()

func (*RoomsReq) XXX_Marshal 

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

func (*RoomsReq) XXX_Merge 

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

func (*RoomsReq) XXX_Size 

func (m *RoomsReq) XXX_Size() int

func (*RoomsReq) XXX_Unmarshal 

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

type UnimplementedCometServer 

type UnimplementedCometServer struct {
}

UnimplementedCometServer can be embedded to have forward compatible implementations.

func (*UnimplementedCometServer) Broadcast 

func (*UnimplementedCometServer) Broadcast(ctx context.Context, req *BroadcastReq) (*BroadcastReply, error)

func (*UnimplementedCometServer) BroadcastRoom 

func (*UnimplementedCometServer) BroadcastRoom(ctx context.Context, req *BroadcastRoomReq) (*BroadcastRoomReply, error)

func (*UnimplementedCometServer) Close 

func (*UnimplementedCometServer) Close(ctx context.Context, req *Empty) (*Empty, error)

func (*UnimplementedCometServer) Messages 

func (*UnimplementedCometServer) Messages(ctx context.Context, req *MessagesReq) (*MessagesReply, error)

func (*UnimplementedCometServer) Onlines 

func (*UnimplementedCometServer) Onlines(ctx context.Context, req *OnlinesReq) (*OnlinesReply, error)

func (*UnimplementedCometServer) Ping 

func (*UnimplementedCometServer) Ping(ctx context.Context, req *Empty) (*Empty, error)

func (*UnimplementedCometServer) PushMsg 

func (*UnimplementedCometServer) PushMsg(ctx context.Context, req *PushMsgReq) (*PushMsgReply, error)

func (*UnimplementedCometServer) Rooms 

func (*UnimplementedCometServer) Rooms(ctx context.Context, req *RoomsReq) (*RoomsReply, 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.