protos

package
v0.0.0-...-4e7898a Latest Latest
Warning

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

 Go to latest Published: Sep 6, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var MsgType_name = map[int32]string{
	0: "MsgRequest",
	1: "MsgNotify",
	2: "MsgResponse",
	3: "MsgPush",
}
View Source 
var MsgType_value = map[string]int32{
	"MsgRequest":  0,
	"MsgNotify":   1,
	"MsgResponse": 2,
	"MsgPush":     3,
}
View Source 
var RPCType_name = map[int32]string{
	0: "Sys",
	1: "User",
}
View Source 
var RPCType_value = map[string]int32{
	"Sys":  0,
	"User": 1,
}

Functions

func RegisterPitayaServer 

func RegisterPitayaServer(s *grpc.Server, srv PitayaServer)

Types

type BindMsg 

type BindMsg struct {
	Uid                  uint32   `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Fid                  string   `protobuf:"bytes,2,opt,name=fid,proto3" json:"fid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BindMsg) Descriptor 

func (*BindMsg) Descriptor() ([]byte, []int)

func (*BindMsg) GetFid 

func (m *BindMsg) GetFid() string

func (*BindMsg) GetUid 

func (m *BindMsg) GetUid() uint32

func (*BindMsg) ProtoMessage 

func (*BindMsg) ProtoMessage()

func (*BindMsg) Reset 

func (m *BindMsg) Reset()

func (*BindMsg) String 

func (m *BindMsg) String() string

func (*BindMsg) XXX_DiscardUnknown 

func (m *BindMsg) XXX_DiscardUnknown()

func (*BindMsg) XXX_Marshal 

func (m *BindMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BindMsg) XXX_Merge 

func (m *BindMsg) XXX_Merge(src proto.Message)

func (*BindMsg) XXX_Size 

func (m *BindMsg) XXX_Size() int

func (*BindMsg) XXX_Unmarshal 

func (m *BindMsg) XXX_Unmarshal(b []byte) error

type Doc 

type Doc struct {
	Doc                  string   `protobuf:"bytes,1,opt,name=doc,proto3" json:"doc,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Doc) Descriptor 

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

func (*Doc) GetDoc 

func (m *Doc) GetDoc() string

func (*Doc) ProtoMessage 

func (*Doc) ProtoMessage()

func (*Doc) Reset 

func (m *Doc) Reset()

func (*Doc) String 

func (m *Doc) String() string

func (*Doc) XXX_DiscardUnknown 

func (m *Doc) XXX_DiscardUnknown()

func (*Doc) XXX_Marshal 

func (m *Doc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Doc) XXX_Merge 

func (m *Doc) XXX_Merge(src proto.Message)

func (*Doc) XXX_Size 

func (m *Doc) XXX_Size() int

func (*Doc) XXX_Unmarshal 

func (m *Doc) XXX_Unmarshal(b []byte) error

type DocMsg 

type DocMsg struct {
	GetProtos            bool     `protobuf:"varint,1,opt,name=getProtos,proto3" json:"getProtos,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DocMsg) Descriptor 

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

func (*DocMsg) GetGetProtos 

func (m *DocMsg) GetGetProtos() bool

func (*DocMsg) ProtoMessage 

func (*DocMsg) ProtoMessage()

func (*DocMsg) Reset 

func (m *DocMsg) Reset()

func (*DocMsg) String 

func (m *DocMsg) String() string

func (*DocMsg) XXX_DiscardUnknown 

func (m *DocMsg) XXX_DiscardUnknown()

func (*DocMsg) XXX_Marshal 

func (m *DocMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocMsg) XXX_Merge 

func (m *DocMsg) XXX_Merge(src proto.Message)

func (*DocMsg) XXX_Size 

func (m *DocMsg) XXX_Size() int

func (*DocMsg) XXX_Unmarshal 

func (m *DocMsg) XXX_Unmarshal(b []byte) error

type Error 

type Error struct {
	Code                 uint32            `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg                  string            `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Error) Descriptor 

func (*Error) Descriptor() ([]byte, []int)

func (*Error) GetCode 

func (m *Error) GetCode() uint32

func (*Error) GetMetadata 

func (m *Error) GetMetadata() map[string]string

func (*Error) GetMsg 

func (m *Error) GetMsg() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge 

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

func (m *Error) XXX_Unmarshal(b []byte) error

type KickAnswer 

type KickAnswer struct {
	Kicked               bool     `protobuf:"varint,1,opt,name=kicked,proto3" json:"kicked,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KickAnswer) Descriptor 

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

func (*KickAnswer) GetKicked 

func (m *KickAnswer) GetKicked() bool

func (*KickAnswer) ProtoMessage 

func (*KickAnswer) ProtoMessage()

func (*KickAnswer) Reset 

func (m *KickAnswer) Reset()

func (*KickAnswer) String 

func (m *KickAnswer) String() string

func (*KickAnswer) XXX_DiscardUnknown 

func (m *KickAnswer) XXX_DiscardUnknown()

func (*KickAnswer) XXX_Marshal 

func (m *KickAnswer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KickAnswer) XXX_Merge 

func (m *KickAnswer) XXX_Merge(src proto.Message)

func (*KickAnswer) XXX_Size 

func (m *KickAnswer) XXX_Size() int

func (*KickAnswer) XXX_Unmarshal 

func (m *KickAnswer) XXX_Unmarshal(b []byte) error

type KickMsg 

type KickMsg struct {
	UserId               uint32   `protobuf:"varint,1,opt,name=userId,proto3" json:"userId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KickMsg) Descriptor 

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

func (*KickMsg) GetUserId 

func (m *KickMsg) GetUserId() uint32

func (*KickMsg) ProtoMessage 

func (*KickMsg) ProtoMessage()

func (*KickMsg) Reset 

func (m *KickMsg) Reset()

func (*KickMsg) String 

func (m *KickMsg) String() string

func (*KickMsg) XXX_DiscardUnknown 

func (m *KickMsg) XXX_DiscardUnknown()

func (*KickMsg) XXX_Marshal 

func (m *KickMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KickMsg) XXX_Merge 

func (m *KickMsg) XXX_Merge(src proto.Message)

func (*KickMsg) XXX_Size 

func (m *KickMsg) XXX_Size() int

func (*KickMsg) XXX_Unmarshal 

func (m *KickMsg) XXX_Unmarshal(b []byte) error

type Msg 

type Msg struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Route                string   `protobuf:"bytes,2,opt,name=route,proto3" json:"route,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Reply                string   `protobuf:"bytes,4,opt,name=reply,proto3" json:"reply,omitempty"`
	Type                 MsgType  `protobuf:"varint,5,opt,name=type,proto3,enum=protos.MsgType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Msg) Descriptor 

func (*Msg) Descriptor() ([]byte, []int)

func (*Msg) GetData 

func (m *Msg) GetData() []byte

func (*Msg) GetId 

func (m *Msg) GetId() uint64

func (*Msg) GetReply 

func (m *Msg) GetReply() string

func (*Msg) GetRoute 

func (m *Msg) GetRoute() string

func (*Msg) GetType 

func (m *Msg) GetType() MsgType

func (*Msg) ProtoMessage 

func (*Msg) ProtoMessage()

func (*Msg) Reset 

func (m *Msg) Reset()

func (*Msg) String 

func (m *Msg) String() string

func (*Msg) XXX_DiscardUnknown 

func (m *Msg) XXX_DiscardUnknown()

func (*Msg) XXX_Marshal 

func (m *Msg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Msg) XXX_Merge 

func (m *Msg) XXX_Merge(src proto.Message)

func (*Msg) XXX_Size 

func (m *Msg) XXX_Size() int

func (*Msg) XXX_Unmarshal 

func (m *Msg) XXX_Unmarshal(b []byte) error

type MsgType 

type MsgType int32
const (
	MsgType_MsgRequest  MsgType = 0
	MsgType_MsgNotify   MsgType = 1
	MsgType_MsgResponse MsgType = 2
	MsgType_MsgPush     MsgType = 3
)

func (MsgType) EnumDescriptor 

func (MsgType) EnumDescriptor() ([]byte, []int)

func (MsgType) String 

func (x MsgType) String() string

type PitayaClient 

type PitayaClient interface {
	Call(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	PushToUser(ctx context.Context, in *Push, opts ...grpc.CallOption) (*Response, error)
	SessionBindRemote(ctx context.Context, in *BindMsg, opts ...grpc.CallOption) (*Response, error)
	KickUser(ctx context.Context, in *KickMsg, opts ...grpc.CallOption) (*KickAnswer, error)
}

PitayaClient is the client API for Pitaya service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPitayaClient 

func NewPitayaClient(cc *grpc.ClientConn) PitayaClient

type PitayaServer 

type PitayaServer interface {
	Call(context.Context, *Request) (*Response, error)
	PushToUser(context.Context, *Push) (*Response, error)
	SessionBindRemote(context.Context, *BindMsg) (*Response, error)
	KickUser(context.Context, *KickMsg) (*KickAnswer, error)
}

PitayaServer is the server API for Pitaya service.

type ProtoDescriptor 

type ProtoDescriptor struct {
	Desc                 []byte   `protobuf:"bytes,1,opt,name=desc,proto3" json:"desc,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Descriptor proto used to retrieve zipped proto descriptors remotely

func (*ProtoDescriptor) Descriptor 

func (*ProtoDescriptor) Descriptor() ([]byte, []int)

func (*ProtoDescriptor) GetDesc 

func (m *ProtoDescriptor) GetDesc() []byte

func (*ProtoDescriptor) ProtoMessage 

func (*ProtoDescriptor) ProtoMessage()

func (*ProtoDescriptor) Reset 

func (m *ProtoDescriptor) Reset()

func (*ProtoDescriptor) String 

func (m *ProtoDescriptor) String() string

func (*ProtoDescriptor) XXX_DiscardUnknown 

func (m *ProtoDescriptor) XXX_DiscardUnknown()

func (*ProtoDescriptor) XXX_Marshal 

func (m *ProtoDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtoDescriptor) XXX_Merge 

func (m *ProtoDescriptor) XXX_Merge(src proto.Message)

func (*ProtoDescriptor) XXX_Size 

func (m *ProtoDescriptor) XXX_Size() int

func (*ProtoDescriptor) XXX_Unmarshal 

func (m *ProtoDescriptor) XXX_Unmarshal(b []byte) error

type ProtoDescriptors 

type ProtoDescriptors struct {
	Desc                 [][]byte `protobuf:"bytes,1,rep,name=desc,proto3" json:"desc,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProtoDescriptors) Descriptor 

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

func (*ProtoDescriptors) GetDesc 

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

func (*ProtoDescriptors) ProtoMessage 

func (*ProtoDescriptors) ProtoMessage()

func (*ProtoDescriptors) Reset 

func (m *ProtoDescriptors) Reset()

func (*ProtoDescriptors) String 

func (m *ProtoDescriptors) String() string

func (*ProtoDescriptors) XXX_DiscardUnknown 

func (m *ProtoDescriptors) XXX_DiscardUnknown()

func (*ProtoDescriptors) XXX_Marshal 

func (m *ProtoDescriptors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtoDescriptors) XXX_Merge 

func (m *ProtoDescriptors) XXX_Merge(src proto.Message)

func (*ProtoDescriptors) XXX_Size 

func (m *ProtoDescriptors) XXX_Size() int

func (*ProtoDescriptors) XXX_Unmarshal 

func (m *ProtoDescriptors) XXX_Unmarshal(b []byte) error

type ProtoName 

type ProtoName struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProtoName) Descriptor 

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

func (*ProtoName) GetName 

func (m *ProtoName) GetName() string

func (*ProtoName) ProtoMessage 

func (*ProtoName) ProtoMessage()

func (*ProtoName) Reset 

func (m *ProtoName) Reset()

func (*ProtoName) String 

func (m *ProtoName) String() string

func (*ProtoName) XXX_DiscardUnknown 

func (m *ProtoName) XXX_DiscardUnknown()

func (*ProtoName) XXX_Marshal 

func (m *ProtoName) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtoName) XXX_Merge 

func (m *ProtoName) XXX_Merge(src proto.Message)

func (*ProtoName) XXX_Size 

func (m *ProtoName) XXX_Size() int

func (*ProtoName) XXX_Unmarshal 

func (m *ProtoName) XXX_Unmarshal(b []byte) error

type ProtoNames 

type ProtoNames struct {
	Name                 []string `protobuf:"bytes,1,rep,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProtoNames) Descriptor 

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

func (*ProtoNames) GetName 

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

func (*ProtoNames) ProtoMessage 

func (*ProtoNames) ProtoMessage()

func (*ProtoNames) Reset 

func (m *ProtoNames) Reset()

func (*ProtoNames) String 

func (m *ProtoNames) String() string

func (*ProtoNames) XXX_DiscardUnknown 

func (m *ProtoNames) XXX_DiscardUnknown()

func (*ProtoNames) XXX_Marshal 

func (m *ProtoNames) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtoNames) XXX_Merge 

func (m *ProtoNames) XXX_Merge(src proto.Message)

func (*ProtoNames) XXX_Size 

func (m *ProtoNames) XXX_Size() int

func (*ProtoNames) XXX_Unmarshal 

func (m *ProtoNames) XXX_Unmarshal(b []byte) error

type Push 

type Push struct {
	Route                string   `protobuf:"bytes,1,opt,name=route,proto3" json:"route,omitempty"`
	Uid                  uint32   `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Push) Descriptor 

func (*Push) Descriptor() ([]byte, []int)

func (*Push) GetData 

func (m *Push) GetData() []byte

func (*Push) GetRoute 

func (m *Push) GetRoute() string

func (*Push) GetUid 

func (m *Push) GetUid() uint32

func (*Push) ProtoMessage 

func (*Push) ProtoMessage()

func (*Push) Reset 

func (m *Push) Reset()

func (*Push) String 

func (m *Push) String() string

func (*Push) XXX_DiscardUnknown 

func (m *Push) XXX_DiscardUnknown()

func (*Push) XXX_Marshal 

func (m *Push) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Push) XXX_Merge 

func (m *Push) XXX_Merge(src proto.Message)

func (*Push) XXX_Size 

func (m *Push) XXX_Size() int

func (*Push) XXX_Unmarshal 

func (m *Push) XXX_Unmarshal(b []byte) error

type RPCType 

type RPCType int32
const (
	RPCType_Sys  RPCType = 0
	RPCType_User RPCType = 1
)

func (RPCType) EnumDescriptor 

func (RPCType) EnumDescriptor() ([]byte, []int)

func (RPCType) String 

func (x RPCType) String() string

type Request 

type Request struct {
	Type                 RPCType  `protobuf:"varint,1,opt,name=type,proto3,enum=protos.RPCType" json:"type,omitempty"`
	Session              *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	Msg                  *Msg     `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	FrontendID           string   `protobuf:"bytes,4,opt,name=frontendID,proto3" json:"frontendID,omitempty"`
	Metadata             []byte   `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Request) Descriptor 

func (*Request) Descriptor() ([]byte, []int)

func (*Request) GetFrontendID 

func (m *Request) GetFrontendID() string

func (*Request) GetMetadata 

func (m *Request) GetMetadata() []byte

func (*Request) GetMsg 

func (m *Request) GetMsg() *Msg

func (*Request) GetSession 

func (m *Request) GetSession() *Session

func (*Request) GetType 

func (m *Request) GetType() RPCType

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Request) XXX_Merge 

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

func (m *Request) XXX_Unmarshal(b []byte) error

type Response 

type Response struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Error                *Error   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Response) Descriptor 

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetData 

func (m *Response) GetData() []byte

func (*Response) GetError 

func (m *Response) GetError() *Error

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

func (m *Response) XXX_Unmarshal(b []byte) error

type Session 

type Session struct {
	Id                   int64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Uid                  uint32   `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Session) Descriptor 

func (*Session) Descriptor() ([]byte, []int)

func (*Session) GetData 

func (m *Session) GetData() []byte

func (*Session) GetId 

func (m *Session) GetId() int64

func (*Session) GetUid 

func (m *Session) GetUid() uint32

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) String 

func (m *Session) String() string

func (*Session) XXX_DiscardUnknown 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal 

func (m *Session) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Session) XXX_Merge 

func (m *Session) XXX_Merge(src proto.Message)

func (*Session) XXX_Size 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal 

func (m *Session) XXX_Unmarshal(b []byte) error

type UnimplementedPitayaServer 

type UnimplementedPitayaServer struct {
}

UnimplementedPitayaServer can be embedded to have forward compatible implementations.

func (*UnimplementedPitayaServer) Call 

func (*UnimplementedPitayaServer) Call(ctx context.Context, req *Request) (*Response, error)

func (*UnimplementedPitayaServer) KickUser 

func (*UnimplementedPitayaServer) KickUser(ctx context.Context, req *KickMsg) (*KickAnswer, error)

func (*UnimplementedPitayaServer) PushToUser 

func (*UnimplementedPitayaServer) PushToUser(ctx context.Context, req *Push) (*Response, error)

func (*UnimplementedPitayaServer) SessionBindRemote 

func (*UnimplementedPitayaServer) SessionBindRemote(ctx context.Context, req *BindMsg) (*Response, error)

Source Files

View all Source files

Directories

Path Synopsis
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

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.