pbgo

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 11, 2025 License: Apache-2.0, MIT Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTglogV3        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTglogV3          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTglogV3 = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Flag_name = map[int32]string{
	0: "FLAG_NONE",
	1: "FLAG_COMPRESSED",
	2: "FLAG_ENCRYPTED",
	4: "FLAG_COMPRESSED_HEADER",
	8: "FLAG_ENCRYPTED_HEADER",
}
View Source 
var Flag_value = map[string]int32{
	"FLAG_NONE":              0,
	"FLAG_COMPRESSED":        1,
	"FLAG_ENCRYPTED":         2,
	"FLAG_COMPRESSED_HEADER": 4,
	"FLAG_ENCRYPTED_HEADER":  8,
}
View Source 
var Len_name = map[int32]string{
	0: "LEN_USELESS",
	2: "MAGIC",
	4: "PACKAGE",
	1: "FLAGS",
}
View Source 
var Len_value = map[string]int32{
	"LEN_USELESS": 0,
	"MAGIC":       2,
	"PACKAGE":     4,
	"FLAGS":       1,
	"HEADER":      2,
	"RESERVE":     1,
}
View Source 
var Magic_name = map[int32]string{
	0:    "MAGIC_USELESS",
	1537: "VAL",
}
View Source 
var Magic_value = map[string]int32{
	"MAGIC_USELESS": 0,
	"VAL":           1537,
}
View Source 
var Max_name = map[int32]string{
	0:      "MAX_USELESS",
	100:    "LOG_COUNT",
	64512:  "UDP_LOG_SIZE",
	65507:  "RAW_UDP_LOG_SIZE",
	524288: "TCP_LOG_SIZE",
}
View Source 
var Max_value = map[string]int32{
	"MAX_USELESS":      0,
	"LOG_COUNT":        100,
	"UDP_LOG_SIZE":     64512,
	"RAW_UDP_LOG_SIZE": 65507,
	"TCP_LOG_SIZE":     524288,
}
View Source 
var ProtoVer_name = map[int32]string{
	0: "VER_USELESS",

	2: "MINOR",
}
View Source 
var ProtoVer_value = map[string]int32{
	"VER_USELESS": 0,
	"MAJOR":       0,
	"MINOR":       2,
	"PATCH":       0,
}

Functions

This section is empty.

Types

type AuthReq 

type AuthReq struct {
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	Annotations          map[string]string `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

鉴权请求

func (*AuthReq) Descriptor 

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

func (*AuthReq) GetAnnotations 

func (m *AuthReq) GetAnnotations() map[string]string

func (*AuthReq) GetLabels 

func (m *AuthReq) GetLabels() map[string]string

func (*AuthReq) Marshal 

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

func (*AuthReq) MarshalTo 

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

func (*AuthReq) MarshalToSizedBuffer 

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

func (*AuthReq) ProtoMessage 

func (*AuthReq) ProtoMessage()

func (*AuthReq) Reset 

func (m *AuthReq) Reset()

func (*AuthReq) Size 

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

func (*AuthReq) String 

func (m *AuthReq) String() string

func (*AuthReq) Unmarshal 

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

func (*AuthReq) XXX_DiscardUnknown 

func (m *AuthReq) XXX_DiscardUnknown()

func (*AuthReq) XXX_Marshal 

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

func (*AuthReq) XXX_Merge 

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

func (*AuthReq) XXX_Size 

func (m *AuthReq) XXX_Size() int

func (*AuthReq) XXX_Unmarshal 

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

type AuthRsp 

type AuthRsp struct {
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

鉴权响应

func (*AuthRsp) Descriptor 

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

func (*AuthRsp) GetToken 

func (m *AuthRsp) GetToken() string

func (*AuthRsp) Marshal 

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

func (*AuthRsp) MarshalTo 

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

func (*AuthRsp) MarshalToSizedBuffer 

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

func (*AuthRsp) ProtoMessage 

func (*AuthRsp) ProtoMessage()

func (*AuthRsp) Reset 

func (m *AuthRsp) Reset()

func (*AuthRsp) Size 

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

func (*AuthRsp) String 

func (m *AuthRsp) String() string

func (*AuthRsp) Unmarshal 

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

func (*AuthRsp) XXX_DiscardUnknown 

func (m *AuthRsp) XXX_DiscardUnknown()

func (*AuthRsp) XXX_Marshal 

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

func (*AuthRsp) XXX_Merge 

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

func (*AuthRsp) XXX_Size 

func (m *AuthRsp) XXX_Size() int

func (*AuthRsp) XXX_Unmarshal 

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

type Flag 

type Flag int32

标记位 

const (
	Flag_FLAG_NONE              Flag = 0
	Flag_FLAG_COMPRESSED        Flag = 1
	Flag_FLAG_ENCRYPTED         Flag = 2
	Flag_FLAG_COMPRESSED_HEADER Flag = 4
	Flag_FLAG_ENCRYPTED_HEADER  Flag = 8
)

func (Flag) EnumDescriptor 

func (Flag) EnumDescriptor() ([]byte, []int)

func (Flag) String 

func (x Flag) String() string

type HeartbeatReq 

type HeartbeatReq struct {
	Ping                 *types.Timestamp `protobuf:"bytes,1,opt,name=ping,proto3" json:"ping,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

心跳请求

func (*HeartbeatReq) Descriptor 

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

func (*HeartbeatReq) GetPing 

func (m *HeartbeatReq) GetPing() *types.Timestamp

func (*HeartbeatReq) Marshal 

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

func (*HeartbeatReq) MarshalTo 

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

func (*HeartbeatReq) MarshalToSizedBuffer 

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

func (*HeartbeatReq) ProtoMessage 

func (*HeartbeatReq) ProtoMessage()

func (*HeartbeatReq) Reset 

func (m *HeartbeatReq) Reset()

func (*HeartbeatReq) Size 

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

func (*HeartbeatReq) String 

func (m *HeartbeatReq) String() string

func (*HeartbeatReq) Unmarshal 

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

func (*HeartbeatReq) XXX_DiscardUnknown 

func (m *HeartbeatReq) XXX_DiscardUnknown()

func (*HeartbeatReq) XXX_Marshal 

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

func (*HeartbeatReq) XXX_Merge 

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

func (*HeartbeatReq) XXX_Size 

func (m *HeartbeatReq) XXX_Size() int

func (*HeartbeatReq) XXX_Unmarshal 

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

type HeartbeatRsp 

type HeartbeatRsp struct {
	Pong                 *types.Timestamp `protobuf:"bytes,1,opt,name=pong,proto3" json:"pong,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

心跳响应

func (*HeartbeatRsp) Descriptor 

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

func (*HeartbeatRsp) GetPong 

func (m *HeartbeatRsp) GetPong() *types.Timestamp

func (*HeartbeatRsp) Marshal 

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

func (*HeartbeatRsp) MarshalTo 

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

func (*HeartbeatRsp) MarshalToSizedBuffer 

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

func (*HeartbeatRsp) ProtoMessage 

func (*HeartbeatRsp) ProtoMessage()

func (*HeartbeatRsp) Reset 

func (m *HeartbeatRsp) Reset()

func (*HeartbeatRsp) Size 

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

func (*HeartbeatRsp) String 

func (m *HeartbeatRsp) String() string

func (*HeartbeatRsp) Unmarshal 

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

func (*HeartbeatRsp) XXX_DiscardUnknown 

func (m *HeartbeatRsp) XXX_DiscardUnknown()

func (*HeartbeatRsp) XXX_Marshal 

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

func (*HeartbeatRsp) XXX_Merge 

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

func (*HeartbeatRsp) XXX_Size 

func (m *HeartbeatRsp) XXX_Size() int

func (*HeartbeatRsp) XXX_Unmarshal 

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

type Len 

type Len int32
const (
	Len_LEN_USELESS Len = 0
	Len_MAGIC       Len = 2
	Len_PACKAGE     Len = 4
	Len_FLAGS       Len = 1
	Len_HEADER      Len = 2
	Len_RESERVE     Len = 1
)

func (Len) EnumDescriptor 

func (Len) EnumDescriptor() ([]byte, []int)

func (Len) String 

func (x Len) String() string

type Log 

type Log struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Content              string   `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	Seq                  uint64   `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

单条日志

func (*Log) Descriptor 

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

func (*Log) GetContent 

func (m *Log) GetContent() string

func (*Log) GetName 

func (m *Log) GetName() string

func (*Log) GetSeq 

func (m *Log) GetSeq() uint64

func (*Log) Marshal 

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

func (*Log) MarshalTo 

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

func (*Log) MarshalToSizedBuffer 

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

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) Reset 

func (m *Log) Reset()

func (*Log) Size 

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

func (*Log) String 

func (m *Log) String() string

func (*Log) Unmarshal 

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

func (*Log) XXX_DiscardUnknown 

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal 

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

func (*Log) XXX_Merge 

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

func (*Log) XXX_Size 

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal 

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

type LogReq 

type LogReq struct {
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	Annotations          map[string]string `` /* 163-byte string literal not displayed */
	Logs                 []*Log            `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

日志上报请求

func (*LogReq) Descriptor 

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

func (*LogReq) GetAnnotations 

func (m *LogReq) GetAnnotations() map[string]string

func (*LogReq) GetLabels 

func (m *LogReq) GetLabels() map[string]string

func (*LogReq) GetLogs 

func (m *LogReq) GetLogs() []*Log

func (*LogReq) Marshal 

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

func (*LogReq) MarshalTo 

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

func (*LogReq) MarshalToSizedBuffer 

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

func (*LogReq) ProtoMessage 

func (*LogReq) ProtoMessage()

func (*LogReq) Reset 

func (m *LogReq) Reset()

func (*LogReq) Size 

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

func (*LogReq) String 

func (m *LogReq) String() string

func (*LogReq) Unmarshal 

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

func (*LogReq) XXX_DiscardUnknown 

func (m *LogReq) XXX_DiscardUnknown()

func (*LogReq) XXX_Marshal 

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

func (*LogReq) XXX_Merge 

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

func (*LogReq) XXX_Size 

func (m *LogReq) XXX_Size() int

func (*LogReq) XXX_Unmarshal 

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

type LogRsp 

type LogRsp struct {
	Seqs                 []uint64 `protobuf:"varint,1,rep,packed,name=seqs,proto3" json:"seqs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

日志上报响应

func (*LogRsp) Descriptor 

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

func (*LogRsp) GetSeqs 

func (m *LogRsp) GetSeqs() []uint64

func (*LogRsp) Marshal 

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

func (*LogRsp) MarshalTo 

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

func (*LogRsp) MarshalToSizedBuffer 

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

func (*LogRsp) ProtoMessage 

func (*LogRsp) ProtoMessage()

func (*LogRsp) Reset 

func (m *LogRsp) Reset()

func (*LogRsp) Size 

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

func (*LogRsp) String 

func (m *LogRsp) String() string

func (*LogRsp) Unmarshal 

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

func (*LogRsp) XXX_DiscardUnknown 

func (m *LogRsp) XXX_DiscardUnknown()

func (*LogRsp) XXX_Marshal 

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

func (*LogRsp) XXX_Merge 

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

func (*LogRsp) XXX_Size 

func (m *LogRsp) XXX_Size() int

func (*LogRsp) XXX_Unmarshal 

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

type Magic 

type Magic int32

魔数 

const (
	Magic_MAGIC_USELESS Magic = 0
	Magic_VAL           Magic = 1537
)

func (Magic) EnumDescriptor 

func (Magic) EnumDescriptor() ([]byte, []int)

func (Magic) String 

func (x Magic) String() string

type Max 

type Max int32

最大值 

const (
	Max_MAX_USELESS      Max = 0
	Max_LOG_COUNT        Max = 100
	Max_UDP_LOG_SIZE     Max = 64512
	Max_RAW_UDP_LOG_SIZE Max = 65507
	Max_TCP_LOG_SIZE     Max = 524288
)

func (Max) EnumDescriptor 

func (Max) EnumDescriptor() ([]byte, []int)

func (Max) String 

func (x Max) String() string

type ProtoVer 

type ProtoVer int32

协议版本号 

const (
	ProtoVer_VER_USELESS ProtoVer = 0
	ProtoVer_MAJOR       ProtoVer = 0
	ProtoVer_MINOR       ProtoVer = 2
	ProtoVer_PATCH       ProtoVer = 0
)

func (ProtoVer) EnumDescriptor 

func (ProtoVer) EnumDescriptor() ([]byte, []int)

func (ProtoVer) String 

func (x ProtoVer) String() string

type Req 

type Req struct {
	ReqID       string `protobuf:"bytes,1,opt,name=reqID,proto3" json:"reqID,omitempty"`
	AppMetaData []byte `protobuf:"bytes,2,opt,name=appMetaData,proto3" json:"appMetaData,omitempty"`
	// Types that are valid to be assigned to Req:
	//	*Req_AuthReq
	//	*Req_LogReq
	//	*Req_HeartbeatReq
	Req                  isReq_Req `protobuf_oneof:"req"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

请求 请求因为涉及到鉴权、签名，将请求头和请求包体分开， 客户端构造请求包体，压缩、加密、签名，再构造请求头， 服务器先解析请求头，鉴权、校验签名，再处理请求包体。

func (*Req) Descriptor 

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

func (*Req) GetAppMetaData 

func (m *Req) GetAppMetaData() []byte

func (*Req) GetAuthReq 

func (m *Req) GetAuthReq() *AuthReq

func (*Req) GetHeartbeatReq 

func (m *Req) GetHeartbeatReq() *HeartbeatReq

func (*Req) GetLogReq 

func (m *Req) GetLogReq() *LogReq

func (*Req) GetReq 

func (m *Req) GetReq() isReq_Req

func (*Req) GetReqID 

func (m *Req) GetReqID() string

func (*Req) Marshal 

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

func (*Req) MarshalTo 

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

func (*Req) MarshalToSizedBuffer 

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

func (*Req) ProtoMessage 

func (*Req) ProtoMessage()

func (*Req) Reset 

func (m *Req) Reset()

func (*Req) Size 

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

func (*Req) String 

func (m *Req) String() string

func (*Req) Unmarshal 

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

func (*Req) XXX_DiscardUnknown 

func (m *Req) XXX_DiscardUnknown()

func (*Req) XXX_Marshal 

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

func (*Req) XXX_Merge 

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

func (*Req) XXX_OneofWrappers 

func (*Req) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Req) XXX_Size 

func (m *Req) XXX_Size() int

func (*Req) XXX_Unmarshal 

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

type ReqHeader 

type ReqHeader struct {
	AppID                string           `protobuf:"bytes,1,opt,name=appID,proto3" json:"appID,omitempty"`
	AppName              string           `protobuf:"bytes,2,opt,name=appName,proto3" json:"appName,omitempty"`
	AppVer               string           `protobuf:"bytes,3,opt,name=appVer,proto3" json:"appVer,omitempty"`
	SdkLang              string           `protobuf:"bytes,4,opt,name=sdkLang,proto3" json:"sdkLang,omitempty"`
	SdkVer               string           `protobuf:"bytes,5,opt,name=sdkVer,proto3" json:"sdkVer,omitempty"`
	SdkOS                string           `protobuf:"bytes,6,opt,name=sdkOS,proto3" json:"sdkOS,omitempty"`
	Network              string           `protobuf:"bytes,7,opt,name=network,proto3" json:"network,omitempty"`
	ProtoVer             string           `protobuf:"bytes,8,opt,name=protoVer,proto3" json:"protoVer,omitempty"`
	HostIP               string           `protobuf:"bytes,9,opt,name=hostIP,proto3" json:"hostIP,omitempty"`
	Ts                   *types.Timestamp `protobuf:"bytes,10,opt,name=ts,proto3" json:"ts,omitempty"`
	Token                string           `protobuf:"bytes,11,opt,name=token,proto3" json:"token,omitempty"`
	TokenType            string           `protobuf:"bytes,12,opt,name=tokenType,proto3" json:"tokenType,omitempty"`
	Sig                  string           `protobuf:"bytes,13,opt,name=sig,proto3" json:"sig,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

请求头

func (*ReqHeader) Descriptor 

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

func (*ReqHeader) GetAppID 

func (m *ReqHeader) GetAppID() string

func (*ReqHeader) GetAppName 

func (m *ReqHeader) GetAppName() string

func (*ReqHeader) GetAppVer 

func (m *ReqHeader) GetAppVer() string

func (*ReqHeader) GetHostIP 

func (m *ReqHeader) GetHostIP() string

func (*ReqHeader) GetNetwork 

func (m *ReqHeader) GetNetwork() string

func (*ReqHeader) GetProtoVer 

func (m *ReqHeader) GetProtoVer() string

func (*ReqHeader) GetSdkLang 

func (m *ReqHeader) GetSdkLang() string

func (*ReqHeader) GetSdkOS 

func (m *ReqHeader) GetSdkOS() string

func (*ReqHeader) GetSdkVer 

func (m *ReqHeader) GetSdkVer() string

func (*ReqHeader) GetSig 

func (m *ReqHeader) GetSig() string

func (*ReqHeader) GetToken 

func (m *ReqHeader) GetToken() string

func (*ReqHeader) GetTokenType 

func (m *ReqHeader) GetTokenType() string

func (*ReqHeader) GetTs 

func (m *ReqHeader) GetTs() *types.Timestamp

func (*ReqHeader) Marshal 

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

func (*ReqHeader) MarshalTo 

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

func (*ReqHeader) MarshalToSizedBuffer 

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

func (*ReqHeader) ProtoMessage 

func (*ReqHeader) ProtoMessage()

func (*ReqHeader) Reset 

func (m *ReqHeader) Reset()

func (*ReqHeader) Size 

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

func (*ReqHeader) String 

func (m *ReqHeader) String() string

func (*ReqHeader) Unmarshal 

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

func (*ReqHeader) XXX_DiscardUnknown 

func (m *ReqHeader) XXX_DiscardUnknown()

func (*ReqHeader) XXX_Marshal 

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

func (*ReqHeader) XXX_Merge 

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

func (*ReqHeader) XXX_Size 

func (m *ReqHeader) XXX_Size() int

func (*ReqHeader) XXX_Unmarshal 

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

type Req_AuthReq 

type Req_AuthReq struct {
	AuthReq *AuthReq `protobuf:"bytes,11,opt,name=authReq,proto3,oneof" json:"authReq,omitempty"`
}

func (*Req_AuthReq) MarshalTo 

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

func (*Req_AuthReq) MarshalToSizedBuffer 

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

func (*Req_AuthReq) Size 

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

type Req_HeartbeatReq 

type Req_HeartbeatReq struct {
	HeartbeatReq *HeartbeatReq `protobuf:"bytes,13,opt,name=heartbeatReq,proto3,oneof" json:"heartbeatReq,omitempty"`
}

func (*Req_HeartbeatReq) MarshalTo 

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

func (*Req_HeartbeatReq) MarshalToSizedBuffer 

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

func (*Req_HeartbeatReq) Size 

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

type Req_LogReq 

type Req_LogReq struct {
	LogReq *LogReq `protobuf:"bytes,12,opt,name=logReq,proto3,oneof" json:"logReq,omitempty"`
}

func (*Req_LogReq) MarshalTo 

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

func (*Req_LogReq) MarshalToSizedBuffer 

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

func (*Req_LogReq) Size 

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

type Rsp 

type Rsp struct {
	Header *RspHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Types that are valid to be assigned to Rsp:
	//	*Rsp_AuthRsp
	//	*Rsp_LogRsp
	//	*Rsp_HeartbeatRsp
	Rsp                  isRsp_Rsp `protobuf_oneof:"rsp"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

响应

func (*Rsp) Descriptor 

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

func (*Rsp) GetAuthRsp 

func (m *Rsp) GetAuthRsp() *AuthRsp

func (*Rsp) GetHeader 

func (m *Rsp) GetHeader() *RspHeader

func (*Rsp) GetHeartbeatRsp 

func (m *Rsp) GetHeartbeatRsp() *HeartbeatRsp

func (*Rsp) GetLogRsp 

func (m *Rsp) GetLogRsp() *LogRsp

func (*Rsp) GetRsp 

func (m *Rsp) GetRsp() isRsp_Rsp

func (*Rsp) Marshal 

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

func (*Rsp) MarshalTo 

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

func (*Rsp) MarshalToSizedBuffer 

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

func (*Rsp) ProtoMessage 

func (*Rsp) ProtoMessage()

func (*Rsp) Reset 

func (m *Rsp) Reset()

func (*Rsp) Size 

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

func (*Rsp) String 

func (m *Rsp) String() string

func (*Rsp) Unmarshal 

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

func (*Rsp) XXX_DiscardUnknown 

func (m *Rsp) XXX_DiscardUnknown()

func (*Rsp) XXX_Marshal 

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

func (*Rsp) XXX_Merge 

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

func (*Rsp) XXX_OneofWrappers 

func (*Rsp) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Rsp) XXX_Size 

func (m *Rsp) XXX_Size() int

func (*Rsp) XXX_Unmarshal 

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

type RspHeader 

type RspHeader struct {
	Code                 int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	ReqID                string   `protobuf:"bytes,3,opt,name=reqID,proto3" json:"reqID,omitempty"`
	AppMetaData          []byte   `protobuf:"bytes,4,opt,name=appMetaData,proto3" json:"appMetaData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

响应头

func (*RspHeader) Descriptor 

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

func (*RspHeader) GetAppMetaData 

func (m *RspHeader) GetAppMetaData() []byte

func (*RspHeader) GetCode 

func (m *RspHeader) GetCode() int32

func (*RspHeader) GetMsg 

func (m *RspHeader) GetMsg() string

func (*RspHeader) GetReqID 

func (m *RspHeader) GetReqID() string

func (*RspHeader) Marshal 

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

func (*RspHeader) MarshalTo 

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

func (*RspHeader) MarshalToSizedBuffer 

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

func (*RspHeader) ProtoMessage 

func (*RspHeader) ProtoMessage()

func (*RspHeader) Reset 

func (m *RspHeader) Reset()

func (*RspHeader) Size 

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

func (*RspHeader) String 

func (m *RspHeader) String() string

func (*RspHeader) Unmarshal 

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

func (*RspHeader) XXX_DiscardUnknown 

func (m *RspHeader) XXX_DiscardUnknown()

func (*RspHeader) XXX_Marshal 

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

func (*RspHeader) XXX_Merge 

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

func (*RspHeader) XXX_Size 

func (m *RspHeader) XXX_Size() int

func (*RspHeader) XXX_Unmarshal 

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

type Rsp_AuthRsp 

type Rsp_AuthRsp struct {
	AuthRsp *AuthRsp `protobuf:"bytes,11,opt,name=authRsp,proto3,oneof" json:"authRsp,omitempty"`
}

func (*Rsp_AuthRsp) MarshalTo 

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

func (*Rsp_AuthRsp) MarshalToSizedBuffer 

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

func (*Rsp_AuthRsp) Size 

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

type Rsp_HeartbeatRsp 

type Rsp_HeartbeatRsp struct {
	HeartbeatRsp *HeartbeatRsp `protobuf:"bytes,13,opt,name=heartbeatRsp,proto3,oneof" json:"heartbeatRsp,omitempty"`
}

func (*Rsp_HeartbeatRsp) MarshalTo 

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

func (*Rsp_HeartbeatRsp) MarshalToSizedBuffer 

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

func (*Rsp_HeartbeatRsp) Size 

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

type Rsp_LogRsp 

type Rsp_LogRsp struct {
	LogRsp *LogRsp `protobuf:"bytes,12,opt,name=logRsp,proto3,oneof" json:"logRsp,omitempty"`
}

func (*Rsp_LogRsp) MarshalTo 

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

func (*Rsp_LogRsp) MarshalToSizedBuffer 

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

func (*Rsp_LogRsp) Size 

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

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.