protoc

Documentation

Index

• func RegisterDispatchSvcServer(s *grpc.Server, srv DispatchSvcServer)
• type DispatchReq
  • func (*DispatchReq) Descriptor() ([]byte, []int)
  • func (m *DispatchReq) GetHeader() *RouteHeader
  • func (m *DispatchReq) GetPbdata() []byte
  • func (*DispatchReq) ProtoMessage()
  • func (m *DispatchReq) Reset()
  • func (m *DispatchReq) String() string
  • func (m *DispatchReq) XXX_DiscardUnknown()
  • func (m *DispatchReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DispatchReq) XXX_Merge(src proto.Message)
  • func (m *DispatchReq) XXX_Size() int
  • func (m *DispatchReq) XXX_Unmarshal(b []byte) error
• type DispatchResp
  • func (*DispatchResp) Descriptor() ([]byte, []int)
  • func (m *DispatchResp) GetCmd() int32
  • func (m *DispatchResp) GetHeader() *RouteHeader
  • func (m *DispatchResp) GetPbdata() []byte
  • func (m *DispatchResp) GetRetCode() int32
  • func (*DispatchResp) ProtoMessage()
  • func (m *DispatchResp) Reset()
  • func (m *DispatchResp) String() string
  • func (m *DispatchResp) XXX_DiscardUnknown()
  • func (m *DispatchResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DispatchResp) XXX_Merge(src proto.Message)
  • func (m *DispatchResp) XXX_Size() int
  • func (m *DispatchResp) XXX_Unmarshal(b []byte) error
• type DispatchSvcClient
  • func NewDispatchSvcClient(cc *grpc.ClientConn) DispatchSvcClient
• type DispatchSvcServer
• type RouteHeader
  • func (*RouteHeader) Descriptor() ([]byte, []int)
  • func (m *RouteHeader) GetAppid() string
  • func (m *RouteHeader) GetCmd() int32
  • func (m *RouteHeader) GetReqId() string
  • func (m *RouteHeader) GetUid() string
  • func (*RouteHeader) ProtoMessage()
  • func (m *RouteHeader) Reset()
  • func (m *RouteHeader) String() string
  • func (m *RouteHeader) XXX_DiscardUnknown()
  • func (m *RouteHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RouteHeader) XXX_Merge(src proto.Message)
  • func (m *RouteHeader) XXX_Size() int
  • func (m *RouteHeader) XXX_Unmarshal(b []byte) error
• type UnimplementedDispatchSvcServer
  • func (*UnimplementedDispatchSvcServer) Dispatch(ctx context.Context, req *DispatchReq) (*DispatchResp, error)

Functions

func RegisterDispatchSvcServer

func RegisterDispatchSvcServer(s *grpc.Server, srv DispatchSvcServer)

Types

type DispatchReq

type DispatchReq struct {
	Header               *RouteHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Pbdata               []byte       `protobuf:"bytes,2,opt,name=pbdata,proto3" json:"pbdata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DispatchReq) Descriptor

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

func (*DispatchReq) GetHeader

func (m *DispatchReq) GetHeader() *RouteHeader

func (*DispatchReq) GetPbdata

func (m *DispatchReq) GetPbdata() []byte

func (*DispatchReq) ProtoMessage

func (*DispatchReq) ProtoMessage()

func (*DispatchReq) Reset

func (m *DispatchReq) Reset()

func (*DispatchReq) String

func (m *DispatchReq) String() string

func (*DispatchReq) XXX_DiscardUnknown

func (m *DispatchReq) XXX_DiscardUnknown()

func (*DispatchReq) XXX_Marshal

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

func (*DispatchReq) XXX_Merge

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

func (*DispatchReq) XXX_Size

func (m *DispatchReq) XXX_Size() int

func (*DispatchReq) XXX_Unmarshal

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

type DispatchResp

type DispatchResp struct {
	Header               *RouteHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Cmd                  int32        `protobuf:"varint,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	RetCode              int32        `protobuf:"varint,3,opt,name=ret_code,json=retCode,proto3" json:"ret_code,omitempty"`
	Pbdata               []byte       `protobuf:"bytes,4,opt,name=pbdata,proto3" json:"pbdata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DispatchResp) Descriptor

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

func (*DispatchResp) GetCmd

func (m *DispatchResp) GetCmd() int32

func (*DispatchResp) GetHeader

func (m *DispatchResp) GetHeader() *RouteHeader

func (*DispatchResp) GetPbdata

func (m *DispatchResp) GetPbdata() []byte

func (*DispatchResp) GetRetCode

func (m *DispatchResp) GetRetCode() int32

func (*DispatchResp) ProtoMessage

func (*DispatchResp) ProtoMessage()

func (*DispatchResp) Reset

func (m *DispatchResp) Reset()

func (*DispatchResp) String

func (m *DispatchResp) String() string

func (*DispatchResp) XXX_DiscardUnknown

func (m *DispatchResp) XXX_DiscardUnknown()

func (*DispatchResp) XXX_Marshal

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

func (*DispatchResp) XXX_Merge

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

func (*DispatchResp) XXX_Size

func (m *DispatchResp) XXX_Size() int

func (*DispatchResp) XXX_Unmarshal

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

type DispatchSvcClient

type DispatchSvcClient interface {
	Dispatch(ctx context.Context, in *DispatchReq, opts ...grpc.CallOption) (*DispatchResp, error)
}

DispatchSvcClient is the client API for DispatchSvc service.

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

func NewDispatchSvcClient

func NewDispatchSvcClient(cc *grpc.ClientConn) DispatchSvcClient

type DispatchSvcServer

type DispatchSvcServer interface {
	Dispatch(context.Context, *DispatchReq) (*DispatchResp, error)
}

DispatchSvcServer is the server API for DispatchSvc service.

type RouteHeader

type RouteHeader struct {
	ReqId                string   `protobuf:"bytes,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	Uid                  string   `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Appid                string   `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"`
	Cmd                  int32    `protobuf:"varint,4,opt,name=cmd,proto3" json:"cmd,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RouteHeader) Descriptor

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

func (*RouteHeader) GetAppid

func (m *RouteHeader) GetAppid() string

func (*RouteHeader) GetCmd

func (m *RouteHeader) GetCmd() int32

func (*RouteHeader) GetReqId

func (m *RouteHeader) GetReqId() string

func (*RouteHeader) GetUid

func (m *RouteHeader) GetUid() string

func (*RouteHeader) ProtoMessage

func (*RouteHeader) ProtoMessage()

func (*RouteHeader) Reset

func (m *RouteHeader) Reset()

func (*RouteHeader) String

func (m *RouteHeader) String() string

func (*RouteHeader) XXX_DiscardUnknown

func (m *RouteHeader) XXX_DiscardUnknown()

func (*RouteHeader) XXX_Marshal

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

func (*RouteHeader) XXX_Merge

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

func (*RouteHeader) XXX_Size

func (m *RouteHeader) XXX_Size() int

func (*RouteHeader) XXX_Unmarshal

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

type UnimplementedDispatchSvcServer

type UnimplementedDispatchSvcServer struct {
}

UnimplementedDispatchSvcServer can be embedded to have forward compatible implementations.

func (*UnimplementedDispatchSvcServer) Dispatch

func (*UnimplementedDispatchSvcServer) Dispatch(ctx context.Context, req *DispatchReq) (*DispatchResp, error)