protos

package
v0.7.6 Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2019 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 (
	ErrInvalidLengthDoc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDoc   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthDocmsg = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDocmsg   = 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 (
	ErrInvalidLengthProtodescriptor = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProtodescriptor   = 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"`
}

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 Doc added in v0.7.6 

type Doc struct {
	Doc string `protobuf:"bytes,1,opt,name=doc,proto3" json:"doc,omitempty"`
}

func (*Doc) Descriptor added in v0.7.6 

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

func (*Doc) GetDoc added in v0.7.6 

func (m *Doc) GetDoc() string

func (*Doc) Marshal added in v0.7.6 

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

func (*Doc) MarshalTo added in v0.7.6 

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

func (*Doc) ProtoMessage added in v0.7.6 

func (*Doc) ProtoMessage()

func (*Doc) Reset added in v0.7.6 

func (m *Doc) Reset()

func (*Doc) Size added in v0.7.6 

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

func (*Doc) String added in v0.7.6 

func (m *Doc) String() string

func (*Doc) Unmarshal added in v0.7.6 

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

func (*Doc) XXX_DiscardUnknown added in v0.7.6 

func (m *Doc) XXX_DiscardUnknown()

func (*Doc) XXX_Marshal added in v0.7.6 

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

func (*Doc) XXX_Merge added in v0.7.6 

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

func (*Doc) XXX_Size added in v0.7.6 

func (m *Doc) XXX_Size() int

func (*Doc) XXX_Unmarshal added in v0.7.6 

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

type DocMsg added in v0.7.6 

type DocMsg struct {
	GetProtos bool `protobuf:"varint,1,opt,name=getProtos,proto3" json:"getProtos,omitempty"`
}

func (*DocMsg) Descriptor added in v0.7.6 

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

func (*DocMsg) GetGetProtos added in v0.7.6 

func (m *DocMsg) GetGetProtos() bool

func (*DocMsg) Marshal added in v0.7.6 

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

func (*DocMsg) MarshalTo added in v0.7.6 

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

func (*DocMsg) ProtoMessage added in v0.7.6 

func (*DocMsg) ProtoMessage()

func (*DocMsg) Reset added in v0.7.6 

func (m *DocMsg) Reset()

func (*DocMsg) Size added in v0.7.6 

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

func (*DocMsg) String added in v0.7.6 

func (m *DocMsg) String() string

func (*DocMsg) Unmarshal added in v0.7.6 

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

func (*DocMsg) XXX_DiscardUnknown added in v0.7.6 

func (m *DocMsg) XXX_DiscardUnknown()

func (*DocMsg) XXX_Marshal added in v0.7.6 

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

func (*DocMsg) XXX_Merge added in v0.7.6 

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

func (*DocMsg) XXX_Size added in v0.7.6 

func (m *DocMsg) XXX_Size() int

func (*DocMsg) XXX_Unmarshal added in v0.7.6 

func (m *DocMsg) 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 `` /* 157-byte string literal not displayed */
}

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"`
}

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"`
}

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"`
}

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)
	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 added in v0.7.6 

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

Descriptor proto used to retrieve zipped proto descriptors remotely

func (*ProtoDescriptor) Descriptor added in v0.7.6 

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

func (*ProtoDescriptor) GetDesc added in v0.7.6 

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

func (*ProtoDescriptor) Marshal added in v0.7.6 

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

func (*ProtoDescriptor) MarshalTo added in v0.7.6 

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

func (*ProtoDescriptor) ProtoMessage added in v0.7.6 

func (*ProtoDescriptor) ProtoMessage()

func (*ProtoDescriptor) Reset added in v0.7.6 

func (m *ProtoDescriptor) Reset()

func (*ProtoDescriptor) Size added in v0.7.6 

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

func (*ProtoDescriptor) String added in v0.7.6 

func (m *ProtoDescriptor) String() string

func (*ProtoDescriptor) Unmarshal added in v0.7.6 

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

func (*ProtoDescriptor) XXX_DiscardUnknown added in v0.7.6 

func (m *ProtoDescriptor) XXX_DiscardUnknown()

func (*ProtoDescriptor) XXX_Marshal added in v0.7.6 

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

func (*ProtoDescriptor) XXX_Merge added in v0.7.6 

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

func (*ProtoDescriptor) XXX_Size added in v0.7.6 

func (m *ProtoDescriptor) XXX_Size() int

func (*ProtoDescriptor) XXX_Unmarshal added in v0.7.6 

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

type ProtoDescriptors added in v0.7.6 

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

func (*ProtoDescriptors) Descriptor added in v0.7.6 

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

func (*ProtoDescriptors) GetDesc added in v0.7.6 

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

func (*ProtoDescriptors) Marshal added in v0.7.6 

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

func (*ProtoDescriptors) MarshalTo added in v0.7.6 

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

func (*ProtoDescriptors) ProtoMessage added in v0.7.6 

func (*ProtoDescriptors) ProtoMessage()

func (*ProtoDescriptors) Reset added in v0.7.6 

func (m *ProtoDescriptors) Reset()

func (*ProtoDescriptors) Size added in v0.7.6 

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

func (*ProtoDescriptors) String added in v0.7.6 

func (m *ProtoDescriptors) String() string

func (*ProtoDescriptors) Unmarshal added in v0.7.6 

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

func (*ProtoDescriptors) XXX_DiscardUnknown added in v0.7.6 

func (m *ProtoDescriptors) XXX_DiscardUnknown()

func (*ProtoDescriptors) XXX_Marshal added in v0.7.6 

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

func (*ProtoDescriptors) XXX_Merge added in v0.7.6 

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

func (*ProtoDescriptors) XXX_Size added in v0.7.6 

func (m *ProtoDescriptors) XXX_Size() int

func (*ProtoDescriptors) XXX_Unmarshal added in v0.7.6 

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

type ProtoName added in v0.7.6 

type ProtoName struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*ProtoName) Descriptor added in v0.7.6 

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

func (*ProtoName) GetName added in v0.7.6 

func (m *ProtoName) GetName() string

func (*ProtoName) Marshal added in v0.7.6 

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

func (*ProtoName) MarshalTo added in v0.7.6 

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

func (*ProtoName) ProtoMessage added in v0.7.6 

func (*ProtoName) ProtoMessage()

func (*ProtoName) Reset added in v0.7.6 

func (m *ProtoName) Reset()

func (*ProtoName) Size added in v0.7.6 

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

func (*ProtoName) String added in v0.7.6 

func (m *ProtoName) String() string

func (*ProtoName) Unmarshal added in v0.7.6 

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

func (*ProtoName) XXX_DiscardUnknown added in v0.7.6 

func (m *ProtoName) XXX_DiscardUnknown()

func (*ProtoName) XXX_Marshal added in v0.7.6 

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

func (*ProtoName) XXX_Merge added in v0.7.6 

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

func (*ProtoName) XXX_Size added in v0.7.6 

func (m *ProtoName) XXX_Size() int

func (*ProtoName) XXX_Unmarshal added in v0.7.6 

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

type ProtoNames added in v0.7.6 

type ProtoNames struct {
	Name []string `protobuf:"bytes,1,rep,name=name,proto3" json:"name,omitempty"`
}

func (*ProtoNames) Descriptor added in v0.7.6 

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

func (*ProtoNames) GetName added in v0.7.6 

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

func (*ProtoNames) Marshal added in v0.7.6 

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

func (*ProtoNames) MarshalTo added in v0.7.6 

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

func (*ProtoNames) ProtoMessage added in v0.7.6 

func (*ProtoNames) ProtoMessage()

func (*ProtoNames) Reset added in v0.7.6 

func (m *ProtoNames) Reset()

func (*ProtoNames) Size added in v0.7.6 

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

func (*ProtoNames) String added in v0.7.6 

func (m *ProtoNames) String() string

func (*ProtoNames) Unmarshal added in v0.7.6 

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

func (*ProtoNames) XXX_DiscardUnknown added in v0.7.6 

func (m *ProtoNames) XXX_DiscardUnknown()

func (*ProtoNames) XXX_Marshal added in v0.7.6 

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

func (*ProtoNames) XXX_Merge added in v0.7.6 

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

func (*ProtoNames) XXX_Size added in v0.7.6 

func (m *ProtoNames) XXX_Size() int

func (*ProtoNames) XXX_Unmarshal added in v0.7.6 

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   string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Data  []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

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,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"`
}

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,proto3" json:"error,omitempty"`
}

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"`
}

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.