yrpcmsg

package module
v1.2.6 Latest Latest
Warning

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

 Go to latest Published: Mar 30, 2022 License: MIT Imports: 7 Imported by: 2

README

yrpcmsg

ymsg of yrpc

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthYrpcmsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowYrpcmsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupYrpcmsg = fmt.Errorf("proto: unexpected end of group")
)

Functions

func YrpcMeta2GrpcMD added in v1.2.0 

func YrpcMeta2GrpcMD(meta *Meta) metadata.MD

yrpcmsg.meta to metadata.MD

Types

type GrpcMeta added in v1.1.2 

type GrpcMeta struct {
	Header  *Meta `protobuf:"bytes,1,opt,name=Header,proto3" json:"Header,omitempty"`
	Trailer *Meta `protobuf:"bytes,2,opt,name=Trailer,proto3" json:"Trailer,omitempty"`
}

grpc Header Trailer meta

func (*GrpcMeta) Descriptor added in v1.1.2 

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

func (*GrpcMeta) GetHeader added in v1.1.2 

func (m *GrpcMeta) GetHeader() *Meta

func (*GrpcMeta) GetTrailer added in v1.1.2 

func (m *GrpcMeta) GetTrailer() *Meta

func (*GrpcMeta) Marshal added in v1.1.2 

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

func (*GrpcMeta) MarshalTo added in v1.1.2 

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

func (*GrpcMeta) MarshalToSizedBuffer added in v1.2.6 

func (m *GrpcMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GrpcMeta) ProtoMessage added in v1.1.2 

func (*GrpcMeta) ProtoMessage()

func (*GrpcMeta) Reset added in v1.1.2 

func (m *GrpcMeta) Reset()

func (*GrpcMeta) Size added in v1.1.2 

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

func (*GrpcMeta) String added in v1.1.2 

func (m *GrpcMeta) String() string

func (*GrpcMeta) Unmarshal added in v1.1.2 

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

func (*GrpcMeta) XXX_DiscardUnknown added in v1.2.6 

func (m *GrpcMeta) XXX_DiscardUnknown()

func (*GrpcMeta) XXX_Marshal added in v1.2.6 

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

func (*GrpcMeta) XXX_Merge added in v1.2.6 

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

func (*GrpcMeta) XXX_Size added in v1.2.6 

func (m *GrpcMeta) XXX_Size() int

func (*GrpcMeta) XXX_Unmarshal added in v1.2.6 

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

type Meta added in v1.1.2 

type Meta struct {
	Val []*MetaItem `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"`
}

grpc meta

func GrpcMD2YrpcMeta added in v1.2.0 

func GrpcMD2YrpcMeta(md metadata.MD) Meta

metadata.MD to yrpcmsg.meta

func (*Meta) Descriptor added in v1.1.2 

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

func (*Meta) GetVal added in v1.1.2 

func (m *Meta) GetVal() []*MetaItem

func (*Meta) Marshal added in v1.1.2 

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

func (*Meta) MarshalTo added in v1.1.2 

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

func (*Meta) MarshalToSizedBuffer added in v1.2.6 

func (m *Meta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Meta) ProtoMessage added in v1.1.2 

func (*Meta) ProtoMessage()

func (*Meta) Reset added in v1.1.2 

func (m *Meta) Reset()

func (*Meta) Size added in v1.1.2 

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

func (*Meta) String added in v1.1.2 

func (m *Meta) String() string

func (*Meta) Unmarshal added in v1.1.2 

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

func (*Meta) XXX_DiscardUnknown added in v1.2.6 

func (m *Meta) XXX_DiscardUnknown()

func (*Meta) XXX_Marshal added in v1.2.6 

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

func (*Meta) XXX_Merge added in v1.2.6 

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

func (*Meta) XXX_Size added in v1.2.6 

func (m *Meta) XXX_Size() int

func (*Meta) XXX_Unmarshal added in v1.2.6 

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

type MetaItem added in v1.1.2 

type MetaItem struct {
	Key  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Vals []string `protobuf:"bytes,2,rep,name=vals,proto3" json:"vals,omitempty"`
}

grpc meta data item

func (*MetaItem) Descriptor added in v1.1.2 

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

func (*MetaItem) GetKey added in v1.1.2 

func (m *MetaItem) GetKey() string

func (*MetaItem) GetVals added in v1.1.2 

func (m *MetaItem) GetVals() []string

func (*MetaItem) Marshal added in v1.1.2 

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

func (*MetaItem) MarshalTo added in v1.1.2 

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

func (*MetaItem) MarshalToSizedBuffer added in v1.2.6 

func (m *MetaItem) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetaItem) ProtoMessage added in v1.1.2 

func (*MetaItem) ProtoMessage()

func (*MetaItem) Reset added in v1.1.2 

func (m *MetaItem) Reset()

func (*MetaItem) Size added in v1.1.2 

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

func (*MetaItem) String added in v1.1.2 

func (m *MetaItem) String() string

func (*MetaItem) Unmarshal added in v1.1.2 

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

func (*MetaItem) XXX_DiscardUnknown added in v1.2.6 

func (m *MetaItem) XXX_DiscardUnknown()

func (*MetaItem) XXX_Marshal added in v1.2.6 

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

func (*MetaItem) XXX_Merge added in v1.2.6 

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

func (*MetaItem) XXX_Size added in v1.2.6 

func (m *MetaItem) XXX_Size() int

func (*MetaItem) XXX_Unmarshal added in v1.2.6 

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

type UnixTime 

type UnixTime struct {
	// Unix time, the number of miliseconds elapsed since January 1, 1970 UTC
	TimeUnix int64 `protobuf:"zigzag64,1,opt,name=TimeUnix,proto3" json:"TimeUnix,omitempty"`
	// utc time yyyy-MM-dd hh:mm:ss.zzz
	TimeStr string `protobuf:"bytes,2,opt,name=TimeStr,proto3" json:"TimeStr,omitempty"`
}

func (*UnixTime) Descriptor 

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

func (*UnixTime) GetTimeStr 

func (m *UnixTime) GetTimeStr() string

func (*UnixTime) GetTimeUnix 

func (m *UnixTime) GetTimeUnix() int64

func (*UnixTime) Marshal 

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

func (*UnixTime) MarshalTo 

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

func (*UnixTime) MarshalToSizedBuffer added in v1.2.6 

func (m *UnixTime) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnixTime) ProtoMessage 

func (*UnixTime) ProtoMessage()

func (*UnixTime) Reset 

func (m *UnixTime) Reset()

func (*UnixTime) Size 

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

func (*UnixTime) String 

func (m *UnixTime) String() string

func (*UnixTime) Unmarshal 

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

func (*UnixTime) XXX_DiscardUnknown added in v1.2.6 

func (m *UnixTime) XXX_DiscardUnknown()

func (*UnixTime) XXX_Marshal added in v1.2.6 

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

func (*UnixTime) XXX_Merge added in v1.2.6 

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

func (*UnixTime) XXX_Size added in v1.2.6 

func (m *UnixTime) XXX_Size() int

func (*UnixTime) XXX_Unmarshal added in v1.2.6 

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

type Yempty 

type Yempty struct {
}

func (*Yempty) Descriptor 

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

func (*Yempty) Marshal 

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

func (*Yempty) MarshalTo 

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

func (*Yempty) MarshalToSizedBuffer added in v1.2.6 

func (m *Yempty) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Yempty) ProtoMessage 

func (*Yempty) ProtoMessage()

func (*Yempty) Reset 

func (m *Yempty) Reset()

func (*Yempty) Size 

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

func (*Yempty) String 

func (m *Yempty) String() string

func (*Yempty) Unmarshal 

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

func (*Yempty) XXX_DiscardUnknown added in v1.2.6 

func (m *Yempty) XXX_DiscardUnknown()

func (*Yempty) XXX_Marshal added in v1.2.6 

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

func (*Yempty) XXX_Merge added in v1.2.6 

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

func (*Yempty) XXX_Size added in v1.2.6 

func (m *Yempty) XXX_Size() int

func (*Yempty) XXX_Unmarshal added in v1.2.6 

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

type Ymsg 

type Ymsg struct {
	///整个rpc msg的长度，不包含此字段
	///虽然这个长度可以很长，但是为了避免大包阻塞其它操作，通常都要限制长度,采用分包多发机制
	///当使用基于包的传输通道时(udp/kcp/websocket)，此值可能为0(此时长度为收到的整个包的长度)
	Len uint32 `protobuf:"fixed32,1,opt,name=Len,proto3" json:"Len,omitempty"`
	// rpc command,rpc的命令和option
	// b15-b0(uint16):低16为rpc命令
	// b19-b16:body压缩方式 0:无压缩 1:lz4 2:zlib inflate/deflate
	// b23-b20:optbin压缩方式 0:无压缩 1:lz4 2:zlib inflate/deflate
	// b31-b24: not used
	Cmd uint32 `protobuf:"fixed32,2,opt,name=Cmd,proto3" json:"Cmd,omitempty"`
	/// session id，登录后一定会有,用于后台区分不同的用户请求
	Sid []byte `protobuf:"bytes,3,opt,name=Sid,proto3" json:"Sid,omitempty"`
	/// rpc call id,给分辨不同的rpc调用使用,调用方增1循环使用
	Cid uint32 `protobuf:"varint,4,opt,name=Cid,proto3" json:"Cid,omitempty"`
	// rpc no,从0开始增1使用,用于区分收到重复的包,特别是udp的情况下
	No uint32 `protobuf:"varint,5,opt,name=No,proto3" json:"No,omitempty"`
	// response code
	Res int32 `protobuf:"zigzag32,9,opt,name=Res,proto3" json:"Res,omitempty"`
	// msg body
	Body []byte `protobuf:"bytes,10,opt,name=Body,proto3" json:"Body,omitempty"`
	// optional str parameter,额外的信息,一般不会有,有些特殊命令里面可能用到
	Optstr string `protobuf:"bytes,11,opt,name=Optstr,proto3" json:"Optstr,omitempty"`
	// optional binary parameter,额外的信息,一般不会有,有些特殊命令里面可能用到
	Optbin []byte `protobuf:"bytes,12,opt,name=Optbin,proto3" json:"Optbin,omitempty"`
	// optional grpc meta
	MetaInfo *Meta `protobuf:"bytes,13,opt,name=MetaInfo,proto3" json:"MetaInfo,omitempty"`
}

/系统中所有的消息交互底层都以此为包装 /ymsg multiline comment

func (*Ymsg) CopyMeta added in v1.1.0 

func (this *Ymsg) CopyMeta(md *metadata.MD)

copy meta data from this:ymsg to md:metadata

func (*Ymsg) Descriptor 

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

func (*Ymsg) GetBody 

func (m *Ymsg) GetBody() []byte

func (*Ymsg) GetCid 

func (m *Ymsg) GetCid() uint32

func (*Ymsg) GetCmd 

func (m *Ymsg) GetCmd() uint32

func (*Ymsg) GetLen 

func (m *Ymsg) GetLen() uint32

func (*Ymsg) GetMetaInfo added in v1.1.2 

func (m *Ymsg) GetMetaInfo() *Meta

func (*Ymsg) GetNo 

func (m *Ymsg) GetNo() uint32

func (*Ymsg) GetOptbin 

func (m *Ymsg) GetOptbin() []byte

func (*Ymsg) GetOptstr 

func (m *Ymsg) GetOptstr() string

func (*Ymsg) GetRes 

func (m *Ymsg) GetRes() int32

func (*Ymsg) GetSid 

func (m *Ymsg) GetSid() []byte

func (*Ymsg) GrpcMeta added in v1.1.2 

func (this *Ymsg) GrpcMeta() metadata.MD

ymsg metainfo to metadata MD

func (*Ymsg) Marshal 

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

func (*Ymsg) MarshalTo 

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

func (*Ymsg) MarshalToSizedBuffer added in v1.2.6 

func (m *Ymsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ymsg) MetaVer added in v1.1.0 

func (this *Ymsg) MetaVer() string

the api ver in ymsg meta

func (*Ymsg) ProtoMessage 

func (*Ymsg) ProtoMessage()

func (*Ymsg) Reset 

func (m *Ymsg) Reset()

func (*Ymsg) Size 

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

func (*Ymsg) String 

func (m *Ymsg) String() string

func (*Ymsg) Unmarshal 

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

func (*Ymsg) XXX_DiscardUnknown added in v1.2.6 

func (m *Ymsg) XXX_DiscardUnknown()

func (*Ymsg) XXX_Marshal added in v1.2.6 

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

func (*Ymsg) XXX_Merge added in v1.2.6 

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

func (*Ymsg) XXX_Size added in v1.2.6 

func (m *Ymsg) XXX_Size() int

func (*Ymsg) XXX_Unmarshal added in v1.2.6 

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

type Ynocare 

type Ynocare struct {
}

A generic nocare message that you can use to info the call is not important and no care the result. A typical example is to use it in report log/trace. For instance: 

service Log {
  rpc Log(infos) returns (yrpc.Ynocare);
}

func (*Ynocare) Descriptor 

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

func (*Ynocare) Marshal 

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

func (*Ynocare) MarshalTo 

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

func (*Ynocare) MarshalToSizedBuffer added in v1.2.6 

func (m *Ynocare) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ynocare) ProtoMessage 

func (*Ynocare) ProtoMessage()

func (*Ynocare) Reset 

func (m *Ynocare) Reset()

func (*Ynocare) Size 

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

func (*Ynocare) String 

func (m *Ynocare) String() string

func (*Ynocare) Unmarshal 

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

func (*Ynocare) XXX_DiscardUnknown added in v1.2.6 

func (m *Ynocare) XXX_DiscardUnknown()

func (*Ynocare) XXX_Marshal added in v1.2.6 

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

func (*Ynocare) XXX_Merge added in v1.2.6 

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

func (*Ynocare) XXX_Size added in v1.2.6 

func (m *Ynocare) XXX_Size() int

func (*Ynocare) XXX_Unmarshal added in v1.2.6 

func (m *Ynocare) XXX_Unmarshal(b []byte) 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.