grpc

package
v0.0.0-...-9b43e00 Latest Latest
Warning

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

Go to latest
Published: Sep 27, 2020 License: MIT Imports: 13 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 (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)
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) Marshal

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

func (*BroadcastReply) MarshalTo

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

func (*BroadcastReply) ProtoMessage

func (*BroadcastReply) ProtoMessage()

func (*BroadcastReply) Reset

func (m *BroadcastReply) Reset()

func (*BroadcastReply) Size

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

func (*BroadcastReply) String

func (m *BroadcastReply) String() string

func (*BroadcastReply) Unmarshal

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

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 (dst *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" 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) Marshal

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

func (*BroadcastReq) MarshalTo

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

func (*BroadcastReq) ProtoMessage

func (*BroadcastReq) ProtoMessage()

func (*BroadcastReq) Reset

func (m *BroadcastReq) Reset()

func (*BroadcastReq) Size

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

func (*BroadcastReq) String

func (m *BroadcastReq) String() string

func (*BroadcastReq) Unmarshal

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

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 (dst *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) Marshal

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

func (*BroadcastRoomReply) MarshalTo

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

func (*BroadcastRoomReply) ProtoMessage

func (*BroadcastRoomReply) ProtoMessage()

func (*BroadcastRoomReply) Reset

func (m *BroadcastRoomReply) Reset()

func (*BroadcastRoomReply) Size

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

func (*BroadcastRoomReply) String

func (m *BroadcastRoomReply) String() string

func (*BroadcastRoomReply) Unmarshal

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

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 (dst *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" 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) Marshal

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

func (*BroadcastRoomReq) MarshalTo

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

func (*BroadcastRoomReq) ProtoMessage

func (*BroadcastRoomReq) ProtoMessage()

func (*BroadcastRoomReq) Reset

func (m *BroadcastRoomReq) Reset()

func (*BroadcastRoomReq) Size

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

func (*BroadcastRoomReq) String

func (m *BroadcastRoomReq) String() string

func (*BroadcastRoomReq) Unmarshal

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

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 (dst *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)
}

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)
}

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) Marshal

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

func (*Empty) MarshalTo

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

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) Reset

func (m *Empty) Reset()

func (*Empty) Size

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

func (*Empty) String

func (m *Empty) String() string

func (*Empty) Unmarshal

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

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 (dst *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 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) Marshal

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

func (*Proto) MarshalTo

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

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) Size

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

func (*Proto) String

func (m *Proto) String() string

func (*Proto) Unmarshal

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

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 (dst *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) Marshal

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

func (*PushMsgReply) MarshalTo

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

func (*PushMsgReply) ProtoMessage

func (*PushMsgReply) ProtoMessage()

func (*PushMsgReply) Reset

func (m *PushMsgReply) Reset()

func (*PushMsgReply) Size

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

func (*PushMsgReply) String

func (m *PushMsgReply) String() string

func (*PushMsgReply) Unmarshal

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

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 (dst *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" json:"keys,omitempty"`
	ProtoOp              int32    `protobuf:"varint,3,opt,name=protoOp,proto3" json:"protoOp,omitempty"`
	Proto                *Proto   `protobuf:"bytes,2,opt,name=proto" 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) Marshal

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

func (*PushMsgReq) MarshalTo

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

func (*PushMsgReq) ProtoMessage

func (*PushMsgReq) ProtoMessage()

func (*PushMsgReq) Reset

func (m *PushMsgReq) Reset()

func (*PushMsgReq) Size

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

func (*PushMsgReq) String

func (m *PushMsgReq) String() string

func (*PushMsgReq) Unmarshal

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

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 (dst *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 `` /* 145-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) Marshal

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

func (*RoomsReply) MarshalTo

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

func (*RoomsReply) ProtoMessage

func (*RoomsReply) ProtoMessage()

func (*RoomsReply) Reset

func (m *RoomsReply) Reset()

func (*RoomsReply) Size

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

func (*RoomsReply) String

func (r *RoomsReply) String() string

func (*RoomsReply) Unmarshal

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

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 (dst *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) Marshal

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

func (*RoomsReq) MarshalTo

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

func (*RoomsReq) ProtoMessage

func (*RoomsReq) ProtoMessage()

func (*RoomsReq) Reset

func (m *RoomsReq) Reset()

func (*RoomsReq) Size

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

func (*RoomsReq) String

func (m *RoomsReq) String() string

func (*RoomsReq) Unmarshal

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

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 (dst *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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL