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

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.