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.