Documentation ¶
Index ¶
- Variables
- type CommonRequestHeader
- func (*CommonRequestHeader) Descriptor() ([]byte, []int)deprecated
- func (x *CommonRequestHeader) GetApikey() string
- func (x *CommonRequestHeader) GetHeader() map[string]string
- func (x *CommonRequestHeader) GetTraceId() string
- func (x *CommonRequestHeader) GetWorkspace() string
- func (*CommonRequestHeader) ProtoMessage()
- func (x *CommonRequestHeader) ProtoReflect() protoreflect.Message
- func (x *CommonRequestHeader) Reset()
- func (x *CommonRequestHeader) String() string
- type CommonResponseHeader
- func (*CommonResponseHeader) Descriptor() ([]byte, []int)deprecated
- func (x *CommonResponseHeader) GetCode() int32
- func (x *CommonResponseHeader) GetMessage() string
- func (*CommonResponseHeader) ProtoMessage()
- func (x *CommonResponseHeader) ProtoReflect() protoreflect.Message
- func (x *CommonResponseHeader) Reset()
- func (x *CommonResponseHeader) String() string
- type FileInfo
- func (*FileInfo) Descriptor() ([]byte, []int)deprecated
- func (x *FileInfo) GetModTime() int64
- func (x *FileInfo) GetMode() int32
- func (x *FileInfo) GetSize() int64
- func (*FileInfo) ProtoMessage()
- func (x *FileInfo) ProtoReflect() protoreflect.Message
- func (x *FileInfo) Reset()
- func (x *FileInfo) String() string
- type FileNode
- func (*FileNode) Descriptor() ([]byte, []int)deprecated
- func (x *FileNode) GetChildren() []*FileNode
- func (x *FileNode) GetDir() bool
- func (x *FileNode) GetExist() bool
- func (x *FileNode) GetName() string
- func (x *FileNode) GetReadable() bool
- func (x *FileNode) GetStat() *FileInfo
- func (x *FileNode) GetSymbol() bool
- func (*FileNode) ProtoMessage()
- func (x *FileNode) ProtoReflect() protoreflect.Message
- func (x *FileNode) Reset()
- func (x *FileNode) String() string
- type GenericData
- type GenericDataBatch
- type GenericRpcCommand
- func (*GenericRpcCommand) Descriptor() ([]byte, []int)deprecated
- func (x *GenericRpcCommand) GetBizType() int32
- func (x *GenericRpcCommand) GetData() []byte
- func (x *GenericRpcCommand) GetReqId() int64
- func (x *GenericRpcCommand) GetRpcType() int32
- func (*GenericRpcCommand) ProtoMessage()
- func (x *GenericRpcCommand) ProtoReflect() protoreflect.Message
- func (x *GenericRpcCommand) Reset()
- func (x *GenericRpcCommand) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_pb_common_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type CommonRequestHeader ¶
type CommonRequestHeader struct { Apikey string `protobuf:"bytes,1,opt,name=apikey,proto3" json:"apikey,omitempty"` TraceId string `protobuf:"bytes,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` Header map[string]string `` /* 153-byte string literal not displayed */ // workspace Workspace string `protobuf:"bytes,4,opt,name=workspace,proto3" json:"workspace,omitempty"` // contains filtered or unexported fields }
func (*CommonRequestHeader) Descriptor
deprecated
func (*CommonRequestHeader) Descriptor() ([]byte, []int)
Deprecated: Use CommonRequestHeader.ProtoReflect.Descriptor instead.
func (*CommonRequestHeader) GetApikey ¶
func (x *CommonRequestHeader) GetApikey() string
func (*CommonRequestHeader) GetHeader ¶
func (x *CommonRequestHeader) GetHeader() map[string]string
func (*CommonRequestHeader) GetTraceId ¶
func (x *CommonRequestHeader) GetTraceId() string
func (*CommonRequestHeader) GetWorkspace ¶
func (x *CommonRequestHeader) GetWorkspace() string
func (*CommonRequestHeader) ProtoMessage ¶
func (*CommonRequestHeader) ProtoMessage()
func (*CommonRequestHeader) ProtoReflect ¶
func (x *CommonRequestHeader) ProtoReflect() protoreflect.Message
func (*CommonRequestHeader) Reset ¶
func (x *CommonRequestHeader) Reset()
func (*CommonRequestHeader) String ¶
func (x *CommonRequestHeader) String() string
type CommonResponseHeader ¶
type CommonResponseHeader struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*CommonResponseHeader) Descriptor
deprecated
func (*CommonResponseHeader) Descriptor() ([]byte, []int)
Deprecated: Use CommonResponseHeader.ProtoReflect.Descriptor instead.
func (*CommonResponseHeader) GetCode ¶
func (x *CommonResponseHeader) GetCode() int32
func (*CommonResponseHeader) GetMessage ¶
func (x *CommonResponseHeader) GetMessage() string
func (*CommonResponseHeader) ProtoMessage ¶
func (*CommonResponseHeader) ProtoMessage()
func (*CommonResponseHeader) ProtoReflect ¶
func (x *CommonResponseHeader) ProtoReflect() protoreflect.Message
func (*CommonResponseHeader) Reset ¶
func (x *CommonResponseHeader) Reset()
func (*CommonResponseHeader) String ¶
func (x *CommonResponseHeader) String() string
type FileInfo ¶
type FileInfo struct { Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` ModTime int64 `protobuf:"varint,2,opt,name=mod_time,json=modTime,proto3" json:"mod_time,omitempty"` Mode int32 `protobuf:"varint,3,opt,name=mode,proto3" json:"mode,omitempty"` // contains filtered or unexported fields }
模拟 golang 里的 fs.FileInfo
func (*FileInfo) Descriptor
deprecated
func (*FileInfo) GetModTime ¶
func (*FileInfo) ProtoMessage ¶
func (*FileInfo) ProtoMessage()
func (*FileInfo) ProtoReflect ¶
func (x *FileInfo) ProtoReflect() protoreflect.Message
type FileNode ¶
type FileNode struct { // 名字 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // 如果是目录, 则持有子文件 Children []*FileNode `protobuf:"bytes,2,rep,name=children,proto3" json:"children,omitempty"` // 目标文件是否是目录 Dir bool `protobuf:"varint,3,opt,name=dir,proto3" json:"dir,omitempty"` // 对 目标文件 做stat的结果 Stat *FileInfo `protobuf:"bytes,4,opt,name=stat,proto3" json:"stat,omitempty"` // 直接文件是否是一个symbol Symbol bool `protobuf:"varint,5,opt,name=symbol,proto3" json:"symbol,omitempty"` // 对agent来说, 目标文件是否可读: 目标文件不存在/权限/目标文件不是常规类型 // 对于dir, 该字段表示是否有权限list出该目录下的文件(即r权限) // 但如果dir缺少x权限的话会导致无法"进入目录", 会导致无法读该目录下的文件及其元信息 (只能读到子文件名, 无法读到子文件信息, 更无法读子文件) Readable bool `protobuf:"varint,6,opt,name=readable,proto3" json:"readable,omitempty"` // 目标文件是否存在, 对于symbol该值可能是false, 意味着此时symbol指向一个不存在的文件 Exist bool `protobuf:"varint,7,opt,name=exist,proto3" json:"exist,omitempty"` // contains filtered or unexported fields }
文件相关 begin 直接文件: 不跟进symbol的结果 目标文件: 也叫最终文件, 是跟进symbol的结果
func (*FileNode) Descriptor
deprecated
func (*FileNode) GetChildren ¶
func (*FileNode) GetReadable ¶
func (*FileNode) ProtoMessage ¶
func (*FileNode) ProtoMessage()
func (*FileNode) ProtoReflect ¶
func (x *FileNode) ProtoReflect() protoreflect.Message
type GenericData ¶
type GenericData struct { Type int32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
通用数据结构 begin
func (*GenericData) Descriptor
deprecated
func (*GenericData) Descriptor() ([]byte, []int)
Deprecated: Use GenericData.ProtoReflect.Descriptor instead.
func (*GenericData) GetData ¶
func (x *GenericData) GetData() []byte
func (*GenericData) GetType ¶
func (x *GenericData) GetType() int32
func (*GenericData) ProtoMessage ¶
func (*GenericData) ProtoMessage()
func (*GenericData) ProtoReflect ¶
func (x *GenericData) ProtoReflect() protoreflect.Message
func (*GenericData) Reset ¶
func (x *GenericData) Reset()
func (*GenericData) String ¶
func (x *GenericData) String() string
type GenericDataBatch ¶
type GenericDataBatch struct { Data []*GenericData `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*GenericDataBatch) Descriptor
deprecated
func (*GenericDataBatch) Descriptor() ([]byte, []int)
Deprecated: Use GenericDataBatch.ProtoReflect.Descriptor instead.
func (*GenericDataBatch) GetData ¶
func (x *GenericDataBatch) GetData() []*GenericData
func (*GenericDataBatch) ProtoMessage ¶
func (*GenericDataBatch) ProtoMessage()
func (*GenericDataBatch) ProtoReflect ¶
func (x *GenericDataBatch) ProtoReflect() protoreflect.Message
func (*GenericDataBatch) Reset ¶
func (x *GenericDataBatch) Reset()
func (*GenericDataBatch) String ¶
func (x *GenericDataBatch) String() string
type GenericRpcCommand ¶
type GenericRpcCommand struct { // 描述data的类型, 这是需要agent与registry约定好的 // 0: oneway // 1: req // 2: resp // 3: client_handshake // 4: server_handshake // 因为这个字段名称如果交租type很容易用错... 所以故意加个 rpc 前缀 RpcType int32 `protobuf:"varint,1,opt,name=rpc_type,json=rpcType,proto3" json:"rpc_type,omitempty"` // req_id for req and resp case ReqId int64 `protobuf:"varint,2,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"` // user data type BizType int32 `protobuf:"varint,3,opt,name=biz_type,json=bizType,proto3" json:"biz_type,omitempty"` // user data Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
通用的rpc消息模型
func (*GenericRpcCommand) Descriptor
deprecated
func (*GenericRpcCommand) Descriptor() ([]byte, []int)
Deprecated: Use GenericRpcCommand.ProtoReflect.Descriptor instead.
func (*GenericRpcCommand) GetBizType ¶
func (x *GenericRpcCommand) GetBizType() int32
func (*GenericRpcCommand) GetData ¶
func (x *GenericRpcCommand) GetData() []byte
func (*GenericRpcCommand) GetReqId ¶
func (x *GenericRpcCommand) GetReqId() int64
func (*GenericRpcCommand) GetRpcType ¶
func (x *GenericRpcCommand) GetRpcType() int32
func (*GenericRpcCommand) ProtoMessage ¶
func (*GenericRpcCommand) ProtoMessage()
func (*GenericRpcCommand) ProtoReflect ¶
func (x *GenericRpcCommand) ProtoReflect() protoreflect.Message
func (*GenericRpcCommand) Reset ¶
func (x *GenericRpcCommand) Reset()
func (*GenericRpcCommand) String ¶
func (x *GenericRpcCommand) String() string
Click to show internal directories.
Click to hide internal directories.