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_base_proto protoreflect.FileDescriptor
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.

func NewGatewayProtocolClient 

func NewGatewayProtocolClient(cc grpc.ClientConnInterface) GatewayProtocolClient

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 

func (*UnimplementedGatewayProtocolServer) RequestService(context.Context, *ReqMsg) (*ResMsg, error)

Source Files

View all Source files

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.