protos

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2018 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBind = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBind   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthError = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowError   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthKick = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKick   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthMsg = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsg   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthPush = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPush   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRequest = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRequest   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthResponse = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResponse   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSession = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSession   = fmt.Errorf("proto: integer overflow")
)
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                  string   `protobuf:"bytes,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_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() string

func (*BindMsg) Marshal 

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

func (*BindMsg) MarshalTo 

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

func (*BindMsg) ProtoMessage 

func (*BindMsg) ProtoMessage()

func (*BindMsg) Reset 

func (m *BindMsg) Reset()

func (*BindMsg) Size 

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

func (*BindMsg) String 

func (m *BindMsg) String() string

func (*BindMsg) Unmarshal 

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

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 (dst *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 Error 

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

func (*Error) Descriptor 

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

func (*Error) GetCode 

func (m *Error) GetCode() string

func (*Error) GetMetadata 

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

func (*Error) GetMsg 

func (m *Error) GetMsg() string

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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

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 (dst *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_sizecache        int32    `json:"-"`
}

func (*KickAnswer) Descriptor 

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

func (*KickAnswer) GetKicked 

func (m *KickAnswer) GetKicked() bool

func (*KickAnswer) Marshal 

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

func (*KickAnswer) MarshalTo 

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

func (*KickAnswer) ProtoMessage 

func (*KickAnswer) ProtoMessage()

func (*KickAnswer) Reset 

func (m *KickAnswer) Reset()

func (*KickAnswer) Size 

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

func (*KickAnswer) String 

func (m *KickAnswer) String() string

func (*KickAnswer) Unmarshal 

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

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 (dst *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               string   `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KickMsg) Descriptor 

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

func (*KickMsg) GetUserId 

func (m *KickMsg) GetUserId() string

func (*KickMsg) Marshal 

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

func (*KickMsg) MarshalTo 

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

func (*KickMsg) ProtoMessage 

func (*KickMsg) ProtoMessage()

func (*KickMsg) Reset 

func (m *KickMsg) Reset()

func (*KickMsg) Size 

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

func (*KickMsg) String 

func (m *KickMsg) String() string

func (*KickMsg) Unmarshal 

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

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 (dst *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_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) Marshal 

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

func (*Msg) MarshalTo 

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

func (*Msg) ProtoMessage 

func (*Msg) ProtoMessage()

func (*Msg) Reset 

func (m *Msg) Reset()

func (*Msg) Size 

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

func (*Msg) String 

func (m *Msg) String() string

func (*Msg) Unmarshal 

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

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 (dst *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)
}

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

type Push 

type Push struct {
	Route                string   `protobuf:"bytes,1,opt,name=route,proto3" json:"route,omitempty"`
	Uid                  string   `protobuf:"bytes,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_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() string

func (*Push) Marshal 

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

func (*Push) MarshalTo 

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

func (*Push) ProtoMessage 

func (*Push) ProtoMessage()

func (*Push) Reset 

func (m *Push) Reset()

func (*Push) Size 

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

func (*Push) String 

func (m *Push) String() string

func (*Push) Unmarshal 

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

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 (dst *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" json:"session,omitempty"`
	Msg                  *Msg     `protobuf:"bytes,3,opt,name=msg" 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_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) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

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 (dst *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" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `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) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

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 (dst *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                  string   `protobuf:"bytes,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_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() string

func (*Session) Marshal 

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

func (*Session) MarshalTo 

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

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) Size 

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

func (*Session) String 

func (m *Session) String() string

func (*Session) Unmarshal 

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

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 (dst *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

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.