protos

Mar 19, 2019

Changes in this version

type BindMsg

+ XXX_unrecognized []byte

type Doc

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

type DocMsg

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

type Error

+ XXX_unrecognized []byte

type KickAnswer

+ XXX_unrecognized []byte

type KickMsg

+ XXX_unrecognized []byte

type Msg

+ XXX_unrecognized []byte

type ProtoDescriptor

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

type ProtoDescriptors

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

type ProtoName

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

type ProtoNames

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

type Push

+ XXX_unrecognized []byte

type Request

+ XXX_unrecognized []byte

type Response

+ XXX_unrecognized []byte

type Session

+ XXX_unrecognized []byte

Jan 30, 2019

Changes in this version

+ var ErrIntOverflowDoc = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowDocmsg = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowProtodescriptor = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthDoc = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthDocmsg = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthProtodescriptor = fmt.Errorf("proto: negative length found during unmarshaling")

+ type Doc struct

+ Doc string

+ func (*Doc) Descriptor() ([]byte, []int)

+ func (*Doc) ProtoMessage()

+ func (dst *Doc) XXX_Merge(src proto.Message)

+ func (m *Doc) GetDoc() string

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

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

+ func (m *Doc) Reset()

+ func (m *Doc) Size() (n int)

+ func (m *Doc) String() string

+ func (m *Doc) Unmarshal(dAtA []byte) error

+ 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

+ func (*DocMsg) Descriptor() ([]byte, []int)

+ func (*DocMsg) ProtoMessage()

+ func (dst *DocMsg) XXX_Merge(src proto.Message)

+ func (m *DocMsg) GetGetProtos() bool

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

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

+ func (m *DocMsg) Reset()

+ func (m *DocMsg) Size() (n int)

+ func (m *DocMsg) String() string

+ func (m *DocMsg) Unmarshal(dAtA []byte) error

+ 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 PitayaClient

+ KickUser func(ctx context.Context, in *KickMsg, opts ...grpc.CallOption) (*KickAnswer, error)

type PitayaServer

+ KickUser func(context.Context, *KickMsg) (*KickAnswer, error)

+ type ProtoDescriptor struct

+ Desc []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) Marshal() (dAtA []byte, err error)

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

+ func (m *ProtoDescriptor) Reset()

+ func (m *ProtoDescriptor) Size() (n int)

+ func (m *ProtoDescriptor) String() string

+ func (m *ProtoDescriptor) Unmarshal(dAtA []byte) error

+ 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

+ func (*ProtoDescriptors) Descriptor() ([]byte, []int)

+ func (*ProtoDescriptors) ProtoMessage()

+ func (dst *ProtoDescriptors) XXX_Merge(src proto.Message)

+ func (m *ProtoDescriptors) GetDesc() [][]byte

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

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

+ func (m *ProtoDescriptors) Reset()

+ func (m *ProtoDescriptors) Size() (n int)

+ func (m *ProtoDescriptors) String() string

+ func (m *ProtoDescriptors) Unmarshal(dAtA []byte) error

+ 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

+ func (*ProtoName) Descriptor() ([]byte, []int)

+ func (*ProtoName) ProtoMessage()

+ func (dst *ProtoName) XXX_Merge(src proto.Message)

+ func (m *ProtoName) GetName() string

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

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

+ func (m *ProtoName) Reset()

+ func (m *ProtoName) Size() (n int)

+ func (m *ProtoName) String() string

+ func (m *ProtoName) Unmarshal(dAtA []byte) error

+ 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

+ func (*ProtoNames) Descriptor() ([]byte, []int)

+ func (*ProtoNames) ProtoMessage()

+ func (dst *ProtoNames) XXX_Merge(src proto.Message)

+ func (m *ProtoNames) GetName() []string

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

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

+ func (m *ProtoNames) Reset()

+ func (m *ProtoNames) Size() (n int)

+ func (m *ProtoNames) String() string

+ func (m *ProtoNames) Unmarshal(dAtA []byte) error

+ 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

Jul 31, 2018

Changes in this version

+ var ErrIntOverflowBind = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowError = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowKick = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowMsg = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowPush = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowRequest = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowResponse = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowSession = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthBind = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthError = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthKick = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthMsg = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthPush = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthRequest = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthResponse = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthSession = fmt.Errorf("proto: negative length found during unmarshaling")

+ 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

+ 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) Marshal() (dAtA []byte, err error)

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

+ func (m *BindMsg) Reset()

+ func (m *BindMsg) Size() (n int)

+ func (m *BindMsg) String() string

+ func (m *BindMsg) Unmarshal(dAtA []byte) error

+ 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 Error struct

+ Code string

+ Metadata map[string]string

+ Msg string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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) Marshal() (dAtA []byte, err error)

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

+ func (m *Error) Reset()

+ func (m *Error) Size() (n int)

+ func (m *Error) String() string

+ func (m *Error) Unmarshal(dAtA []byte) error

+ 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

+ func (*KickAnswer) Descriptor() ([]byte, []int)

+ func (*KickAnswer) ProtoMessage()

+ func (dst *KickAnswer) XXX_Merge(src proto.Message)

+ func (m *KickAnswer) GetKicked() bool

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

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

+ func (m *KickAnswer) Reset()

+ func (m *KickAnswer) Size() (n int)

+ func (m *KickAnswer) String() string

+ func (m *KickAnswer) Unmarshal(dAtA []byte) error

+ 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

+ func (*KickMsg) Descriptor() ([]byte, []int)

+ func (*KickMsg) ProtoMessage()

+ func (dst *KickMsg) XXX_Merge(src proto.Message)

+ func (m *KickMsg) GetUserId() string

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

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

+ func (m *KickMsg) Reset()

+ func (m *KickMsg) Size() (n int)

+ func (m *KickMsg) String() string

+ func (m *KickMsg) Unmarshal(dAtA []byte) error

+ 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

+ 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) Marshal() (dAtA []byte, err error)

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

+ func (m *Msg) Reset()

+ func (m *Msg) Size() (n int)

+ func (m *Msg) String() string

+ func (m *Msg) Unmarshal(dAtA []byte) error

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

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

+ PushToUser func(context.Context, *Push) (*Response, error)

+ SessionBindRemote func(context.Context, *BindMsg) (*Response, error)

+ type Push struct

+ Data []byte

+ Route string

+ Uid string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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) Marshal() (dAtA []byte, err error)

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

+ func (m *Push) Reset()

+ func (m *Push) Size() (n int)

+ func (m *Push) String() string

+ func (m *Push) Unmarshal(dAtA []byte) error

+ 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

+ 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) Marshal() (dAtA []byte, err error)

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

+ func (m *Request) Reset()

+ func (m *Request) Size() (n int)

+ func (m *Request) String() string

+ func (m *Request) Unmarshal(dAtA []byte) error

+ 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

+ 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) Marshal() (dAtA []byte, err error)

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

+ func (m *Response) Reset()

+ func (m *Response) Size() (n int)

+ func (m *Response) String() string

+ func (m *Response) Unmarshal(dAtA []byte) error

+ 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

+ 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) Marshal() (dAtA []byte, err error)

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

+ func (m *Session) Reset()

+ func (m *Session) Size() (n int)

+ func (m *Session) String() string

+ func (m *Session) Unmarshal(dAtA []byte) error

+ 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