Versions in this module Expand all Collapse all v2 v2.7.1 Jan 15, 2024 v2.7.0 Jan 12, 2024 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
Go to main page