message

package
v0.0.0-...-3d3caa2 Latest Latest
Warning

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

Go to latest
Published: Nov 1, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_gateway_proto protoreflect.FileDescriptor
View Source
var File_query_proto protoreflect.FileDescriptor

Functions

func RegisterGatewayProtocolServer

func RegisterGatewayProtocolServer(s *grpc.Server, srv GatewayProtocolServer)

Types

type GatewayProtocolClient

type GatewayProtocolClient interface {
	RequestService(ctx context.Context, in *ReqMsg, opts ...grpc.CallOption) (*ResMsg, error)
}

GatewayProtocolClient is the client API for GatewayProtocol service.

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

type GatewayProtocolServer

type GatewayProtocolServer interface {
	RequestService(context.Context, *ReqMsg) (*ResMsg, error)
}

GatewayProtocolServer is the server API for GatewayProtocol service.

type QueryParam

type QueryParam struct {
	Key   string            `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Param map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*QueryParam) Descriptor deprecated

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

Deprecated: Use QueryParam.ProtoReflect.Descriptor instead.

func (*QueryParam) GetKey

func (x *QueryParam) GetKey() string

func (*QueryParam) GetParam

func (x *QueryParam) GetParam() map[string]string

func (*QueryParam) ProtoMessage

func (*QueryParam) ProtoMessage()

func (*QueryParam) ProtoReflect

func (x *QueryParam) ProtoReflect() protoreflect.Message

func (*QueryParam) Reset

func (x *QueryParam) Reset()

func (*QueryParam) String

func (x *QueryParam) String() string

type ReqDataMsg

type ReqDataMsg struct {
	RequestData []byte `protobuf:"bytes,1,opt,name=requestData,proto3" json:"requestData,omitempty"`
	UserId      int64  `protobuf:"varint,2,opt,name=userId,proto3" json:"userId,omitempty"`
	// contains filtered or unexported fields
}

func (*ReqDataMsg) Descriptor deprecated

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

Deprecated: Use ReqDataMsg.ProtoReflect.Descriptor instead.

func (*ReqDataMsg) GetRequestData

func (x *ReqDataMsg) GetRequestData() []byte

func (*ReqDataMsg) GetUserId

func (x *ReqDataMsg) GetUserId() int64

func (*ReqDataMsg) ProtoMessage

func (*ReqDataMsg) ProtoMessage()

func (*ReqDataMsg) ProtoReflect

func (x *ReqDataMsg) ProtoReflect() protoreflect.Message

func (*ReqDataMsg) Reset

func (x *ReqDataMsg) Reset()

func (*ReqDataMsg) String

func (x *ReqDataMsg) String() string

type ReqMsg

type ReqMsg struct {
	Version     int32  `protobuf:"zigzag32,1,opt,name=version,proto3" json:"version,omitempty"`
	T           int64  `protobuf:"varint,2,opt,name=t,proto3" json:"t,omitempty"`
	MsgId       int64  `protobuf:"varint,3,opt,name=msgId,proto3" json:"msgId,omitempty"`
	RequestData []byte `protobuf:"bytes,4,opt,name=requestData,proto3" json:"requestData,omitempty"` //请求参数
	UserId      int64  `protobuf:"varint,5,opt,name=userId,proto3" json:"userId,omitempty"`
	Source      uint32 `protobuf:"varint,6,opt,name=source,proto3" json:"source,omitempty"` //调用来源 api gateway or 内部rpc
	Token       string `protobuf:"bytes,7,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*ReqMsg) Descriptor deprecated

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

Deprecated: Use ReqMsg.ProtoReflect.Descriptor instead.

func (*ReqMsg) GetMsgId

func (x *ReqMsg) GetMsgId() int64

func (*ReqMsg) GetRequestData

func (x *ReqMsg) GetRequestData() []byte

func (*ReqMsg) GetSource

func (x *ReqMsg) GetSource() uint32

func (*ReqMsg) GetT

func (x *ReqMsg) GetT() int64

func (*ReqMsg) GetToken

func (x *ReqMsg) GetToken() string

func (*ReqMsg) GetUserId

func (x *ReqMsg) GetUserId() int64

func (*ReqMsg) GetVersion

func (x *ReqMsg) GetVersion() int32

func (*ReqMsg) ProtoMessage

func (*ReqMsg) ProtoMessage()

func (*ReqMsg) ProtoReflect

func (x *ReqMsg) ProtoReflect() protoreflect.Message

func (*ReqMsg) Reset

func (x *ReqMsg) Reset()

func (*ReqMsg) String

func (x *ReqMsg) String() string

type ResMsg

type ResMsg struct {
	MsgId        int64  `protobuf:"varint,1,opt,name=msgId,proto3" json:"msgId,omitempty"`
	T            int64  `protobuf:"varint,2,opt,name=t,proto3" json:"t,omitempty"`
	ResponseData []byte `protobuf:"bytes,3,opt,name=responseData,proto3" json:"responseData,omitempty"` //相应数据
	// contains filtered or unexported fields
}

func (*ResMsg) Descriptor deprecated

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

Deprecated: Use ResMsg.ProtoReflect.Descriptor instead.

func (*ResMsg) GetMsgId

func (x *ResMsg) GetMsgId() int64

func (*ResMsg) GetResponseData

func (x *ResMsg) GetResponseData() []byte

func (*ResMsg) GetT

func (x *ResMsg) GetT() int64

func (*ResMsg) ProtoMessage

func (*ResMsg) ProtoMessage()

func (*ResMsg) ProtoReflect

func (x *ResMsg) ProtoReflect() protoreflect.Message

func (*ResMsg) Reset

func (x *ResMsg) Reset()

func (*ResMsg) String

func (x *ResMsg) String() string

type UnimplementedGatewayProtocolServer

type UnimplementedGatewayProtocolServer struct {
}

UnimplementedGatewayProtocolServer can be embedded to have forward compatible implementations.

func (*UnimplementedGatewayProtocolServer) RequestService

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL