Versions in this module Expand all Collapse all v2 v2.0.9 Sep 17, 2020 v2.0.8 Sep 17, 2020 v2.0.6 Jul 24, 2020 v2.0.5 Jul 16, 2020 v2.0.4 Jul 16, 2020 v2.0.3 Jul 15, 2020 v2.0.1 Jul 15, 2020 Changes in this version + var MsgType_name = map[int32]string + var MsgType_value = map[string]int32 + var RPCType_name = map[int32]string + var RPCType_value = map[string]int32 + func RegisterPitayaServer(s *grpc.Server, srv PitayaServer) + type BindMsg struct + Fid string + Uid string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BindMsg) Descriptor() ([]byte, []int) + func (*BindMsg) ProtoMessage() + func (dst *BindMsg) XXX_Merge(src proto.Message) + func (m *BindMsg) GetFid() string + func (m *BindMsg) GetUid() string + func (m *BindMsg) Reset() + func (m *BindMsg) String() string + func (m *BindMsg) XXX_DiscardUnknown() + func (m *BindMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BindMsg) XXX_Size() int + func (m *BindMsg) XXX_Unmarshal(b []byte) error + type Doc struct + Doc string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Doc) Descriptor() ([]byte, []int) + func (*Doc) ProtoMessage() + func (dst *Doc) XXX_Merge(src proto.Message) + func (m *Doc) GetDoc() string + func (m *Doc) Reset() + func (m *Doc) String() string + func (m *Doc) XXX_DiscardUnknown() + func (m *Doc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Doc) XXX_Size() int + func (m *Doc) XXX_Unmarshal(b []byte) error + type DocMsg struct + GetProtos bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DocMsg) Descriptor() ([]byte, []int) + func (*DocMsg) ProtoMessage() + func (dst *DocMsg) XXX_Merge(src proto.Message) + func (m *DocMsg) GetGetProtos() bool + func (m *DocMsg) Reset() + func (m *DocMsg) String() string + func (m *DocMsg) XXX_DiscardUnknown() + func (m *DocMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DocMsg) XXX_Size() int + func (m *DocMsg) XXX_Unmarshal(b []byte) error + type Error struct + Code string + Metadata map[string]string + Msg string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (dst *Error) XXX_Merge(src proto.Message) + func (m *Error) GetCode() string + func (m *Error) GetMetadata() map[string]string + func (m *Error) GetMsg() string + func (m *Error) Reset() + func (m *Error) String() string + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type KickAnswer struct + Kicked bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KickAnswer) Descriptor() ([]byte, []int) + func (*KickAnswer) ProtoMessage() + func (dst *KickAnswer) XXX_Merge(src proto.Message) + func (m *KickAnswer) GetKicked() bool + func (m *KickAnswer) Reset() + func (m *KickAnswer) String() string + func (m *KickAnswer) XXX_DiscardUnknown() + func (m *KickAnswer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KickAnswer) XXX_Size() int + func (m *KickAnswer) XXX_Unmarshal(b []byte) error + type KickMsg struct + UserId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KickMsg) Descriptor() ([]byte, []int) + func (*KickMsg) ProtoMessage() + func (dst *KickMsg) XXX_Merge(src proto.Message) + func (m *KickMsg) GetUserId() string + func (m *KickMsg) Reset() + func (m *KickMsg) String() string + func (m *KickMsg) XXX_DiscardUnknown() + func (m *KickMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KickMsg) XXX_Size() int + func (m *KickMsg) XXX_Unmarshal(b []byte) error + type Msg struct + Data []byte + Id uint64 + Reply string + Route string + Type MsgType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Msg) Descriptor() ([]byte, []int) + func (*Msg) ProtoMessage() + func (dst *Msg) XXX_Merge(src proto.Message) + func (m *Msg) GetData() []byte + func (m *Msg) GetId() uint64 + func (m *Msg) GetReply() string + func (m *Msg) GetRoute() string + func (m *Msg) GetType() MsgType + func (m *Msg) Reset() + func (m *Msg) String() string + func (m *Msg) XXX_DiscardUnknown() + func (m *Msg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Msg) XXX_Size() int + func (m *Msg) XXX_Unmarshal(b []byte) error + type MsgType int32 + const MsgType_MsgNotify + const MsgType_MsgPush + const MsgType_MsgRequest + const MsgType_MsgResponse + func (MsgType) EnumDescriptor() ([]byte, []int) + func (x MsgType) String() string + type PitayaClient interface + Call func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + KickUser func(ctx context.Context, in *KickMsg, opts ...grpc.CallOption) (*KickAnswer, error) + PushToUser func(ctx context.Context, in *Push, opts ...grpc.CallOption) (*Response, error) + SessionBindRemote func(ctx context.Context, in *BindMsg, opts ...grpc.CallOption) (*Response, error) + func NewPitayaClient(cc *grpc.ClientConn) PitayaClient + type PitayaServer interface + Call func(context.Context, *Request) (*Response, error) + KickUser func(context.Context, *KickMsg) (*KickAnswer, error) + PushToUser func(context.Context, *Push) (*Response, error) + SessionBindRemote func(context.Context, *BindMsg) (*Response, error) + type ProtoDescriptor struct + Desc []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ProtoDescriptor) Descriptor() ([]byte, []int) + func (*ProtoDescriptor) ProtoMessage() + func (dst *ProtoDescriptor) XXX_Merge(src proto.Message) + func (m *ProtoDescriptor) GetDesc() []byte + func (m *ProtoDescriptor) Reset() + func (m *ProtoDescriptor) String() string + func (m *ProtoDescriptor) XXX_DiscardUnknown() + func (m *ProtoDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ProtoDescriptor) XXX_Size() int + func (m *ProtoDescriptor) XXX_Unmarshal(b []byte) error + type ProtoDescriptors struct + Desc [][]byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ProtoDescriptors) Descriptor() ([]byte, []int) + func (*ProtoDescriptors) ProtoMessage() + func (dst *ProtoDescriptors) XXX_Merge(src proto.Message) + func (m *ProtoDescriptors) GetDesc() [][]byte + func (m *ProtoDescriptors) Reset() + func (m *ProtoDescriptors) String() string + func (m *ProtoDescriptors) XXX_DiscardUnknown() + func (m *ProtoDescriptors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ProtoDescriptors) XXX_Size() int + func (m *ProtoDescriptors) XXX_Unmarshal(b []byte) error + type ProtoName struct + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ProtoName) Descriptor() ([]byte, []int) + func (*ProtoName) ProtoMessage() + func (dst *ProtoName) XXX_Merge(src proto.Message) + func (m *ProtoName) GetName() string + func (m *ProtoName) Reset() + func (m *ProtoName) String() string + func (m *ProtoName) XXX_DiscardUnknown() + func (m *ProtoName) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ProtoName) XXX_Size() int + func (m *ProtoName) XXX_Unmarshal(b []byte) error + type ProtoNames struct + Name []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ProtoNames) Descriptor() ([]byte, []int) + func (*ProtoNames) ProtoMessage() + func (dst *ProtoNames) XXX_Merge(src proto.Message) + func (m *ProtoNames) GetName() []string + func (m *ProtoNames) Reset() + func (m *ProtoNames) String() string + func (m *ProtoNames) XXX_DiscardUnknown() + func (m *ProtoNames) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ProtoNames) XXX_Size() int + func (m *ProtoNames) XXX_Unmarshal(b []byte) error + type Push struct + Data []byte + Route string + Uid string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Push) Descriptor() ([]byte, []int) + func (*Push) ProtoMessage() + func (dst *Push) XXX_Merge(src proto.Message) + func (m *Push) GetData() []byte + func (m *Push) GetRoute() string + func (m *Push) GetUid() string + func (m *Push) Reset() + func (m *Push) String() string + func (m *Push) XXX_DiscardUnknown() + func (m *Push) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Push) XXX_Size() int + func (m *Push) XXX_Unmarshal(b []byte) error + type RPCType int32 + const RPCType_Sys + const RPCType_User + func (RPCType) EnumDescriptor() ([]byte, []int) + func (x RPCType) String() string + type Request struct + FrontendID string + Metadata []byte + Msg *Msg + Session *Session + Type RPCType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (dst *Request) XXX_Merge(src proto.Message) + func (m *Request) GetFrontendID() string + func (m *Request) GetMetadata() []byte + func (m *Request) GetMsg() *Msg + func (m *Request) GetSession() *Session + func (m *Request) GetType() RPCType + func (m *Request) Reset() + func (m *Request) String() string + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + type Response struct + Data []byte + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (dst *Response) XXX_Merge(src proto.Message) + func (m *Response) GetData() []byte + func (m *Response) GetError() *Error + func (m *Response) Reset() + func (m *Response) String() string + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type Session struct + Data []byte + Id int64 + Uid string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Session) Descriptor() ([]byte, []int) + func (*Session) ProtoMessage() + func (dst *Session) XXX_Merge(src proto.Message) + func (m *Session) GetData() []byte + func (m *Session) GetId() int64 + func (m *Session) GetUid() string + func (m *Session) Reset() + func (m *Session) String() string + func (m *Session) XXX_DiscardUnknown() + func (m *Session) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Session) XXX_Size() int + func (m *Session) XXX_Unmarshal(b []byte) error Other modules containing this package github.com/felippeduran/pitaya
Go to main page