Documentation
¶
Index ¶
- Variables
- type Access
- func (*Access) Descriptor() ([]byte, []int)deprecated
- func (x *Access) GetBytes() int64
- func (x *Access) GetDigest() string
- func (x *Access) GetEdits() uint32
- func (x *Access) GetError() string
- func (x *Access) GetId() string
- func (x *Access) GetOp() AccessOp
- func (x *Access) GetPath() string
- func (x *Access) GetSize() int64
- func (x *Access) GetSource() AccessSource
- func (x *Access) GetTimestamp() *timestamppb.Timestamp
- func (x *Access) GetWorkDir() string
- func (*Access) ProtoMessage()
- func (x *Access) ProtoReflect() protoreflect.Message
- func (x *Access) Reset()
- func (x *Access) String() string
- type AccessOp
- type AccessSource
- func (AccessSource) Descriptor() protoreflect.EnumDescriptor
- func (x AccessSource) Enum() *AccessSource
- func (AccessSource) EnumDescriptor() ([]byte, []int)deprecated
- func (x AccessSource) Number() protoreflect.EnumNumber
- func (x AccessSource) String() string
- func (AccessSource) Type() protoreflect.EnumType
- type Entry
- type ListRequest
- type MkdirRequest
- type ProtocolMessage
- func (*ProtocolMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ProtocolMessage) GetListRequest() *ListRequest
- func (x *ProtocolMessage) GetMessage() isProtocolMessage_Message
- func (x *ProtocolMessage) GetMkdirRequest() *MkdirRequest
- func (x *ProtocolMessage) GetReadRequest() *ReadRequest
- func (x *ProtocolMessage) GetResult() *Result
- func (x *ProtocolMessage) GetUploadRequest() *UploadRequest
- func (x *ProtocolMessage) GetWriteRequest() *WriteRequest
- func (*ProtocolMessage) ProtoMessage()
- func (x *ProtocolMessage) ProtoReflect() protoreflect.Message
- func (x *ProtocolMessage) Reset()
- func (x *ProtocolMessage) String() string
- type ProtocolMessage_ListRequest
- type ProtocolMessage_MkdirRequest
- type ProtocolMessage_ReadRequest
- type ProtocolMessage_Result
- type ProtocolMessage_UploadRequest
- type ProtocolMessage_WriteRequest
- type ReadRequest
- func (*ReadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadRequest) GetLimit() int32
- func (x *ReadRequest) GetOffset() int64
- func (x *ReadRequest) GetPath() string
- func (*ReadRequest) ProtoMessage()
- func (x *ReadRequest) ProtoReflect() protoreflect.Message
- func (x *ReadRequest) Reset()
- func (x *ReadRequest) String() string
- type Result
- func (*Result) Descriptor() ([]byte, []int)deprecated
- func (x *Result) GetData() []byte
- func (x *Result) GetEntries() []*Entry
- func (x *Result) GetEof() bool
- func (x *Result) GetFilename() string
- func (x *Result) GetMediaType() string
- func (x *Result) GetOffset() int64
- func (x *Result) GetPath() string
- func (x *Result) GetSize() int64
- func (*Result) ProtoMessage()
- func (x *Result) ProtoReflect() protoreflect.Message
- func (x *Result) Reset()
- func (x *Result) String() string
- type UploadRequest
- func (*UploadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UploadRequest) GetData() []byte
- func (x *UploadRequest) GetFilename() string
- func (x *UploadRequest) GetMediaType() string
- func (x *UploadRequest) GetSessionId() string
- func (*UploadRequest) ProtoMessage()
- func (x *UploadRequest) ProtoReflect() protoreflect.Message
- func (x *UploadRequest) Reset()
- func (x *UploadRequest) String() string
- type WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteRequest) GetData() []byte
- func (x *WriteRequest) GetPath() string
- func (*WriteRequest) ProtoMessage()
- func (x *WriteRequest) ProtoReflect() protoreflect.Message
- func (x *WriteRequest) Reset()
- func (x *WriteRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var ( AccessOp_name = map[int32]string{ 0: "ACCESS_OP_UNSPECIFIED", 1: "ACCESS_OP_READ", 2: "ACCESS_OP_WRITE", 3: "ACCESS_OP_EDIT", 4: "ACCESS_OP_CREATE", 5: "ACCESS_OP_DELETE", } AccessOp_value = map[string]int32{ "ACCESS_OP_UNSPECIFIED": 0, "ACCESS_OP_READ": 1, "ACCESS_OP_WRITE": 2, "ACCESS_OP_EDIT": 3, "ACCESS_OP_CREATE": 4, "ACCESS_OP_DELETE": 5, } )
Enum value maps for AccessOp.
var ( AccessSource_name = map[int32]string{ 0: "ACCESS_SOURCE_UNSPECIFIED", 1: "ACCESS_SOURCE_TOOL", 2: "ACCESS_SOURCE_SNAPSHOT", 3: "ACCESS_SOURCE_CONTROL", } AccessSource_value = map[string]int32{ "ACCESS_SOURCE_UNSPECIFIED": 0, "ACCESS_SOURCE_TOOL": 1, "ACCESS_SOURCE_SNAPSHOT": 2, "ACCESS_SOURCE_CONTROL": 3, } )
Enum value maps for AccessSource.
var File_aop_file_protocol_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Access ¶
type Access struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Op AccessOp `protobuf:"varint,3,opt,name=op,proto3,enum=aop.file.AccessOp" json:"op,omitempty"`
Source AccessSource `protobuf:"varint,4,opt,name=source,proto3,enum=aop.file.AccessSource" json:"source,omitempty"`
// path is absolute; work_dir is the execution's working directory, carried so
// a consumer can present the path relative to it without guessing.
Path string `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
WorkDir string `protobuf:"bytes,6,opt,name=work_dir,json=workDir,proto3" json:"work_dir,omitempty"`
Size int64 `protobuf:"varint,7,opt,name=size,proto3" json:"size,omitempty"` // file size after the access
Bytes int64 `protobuf:"varint,8,opt,name=bytes,proto3" json:"bytes,omitempty"` // bytes read or written by this access, 0 when unknown
Edits uint32 `protobuf:"varint,9,opt,name=edits,proto3" json:"edits,omitempty"` // patch count for EDIT
Digest string `protobuf:"bytes,10,opt,name=digest,proto3" json:"digest,omitempty"` // sha256 of the content after a write, when computed
Error string `protobuf:"bytes,11,opt,name=error,proto3" json:"error,omitempty"`
Timestamp *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// contains filtered or unexported fields
}
Access is one observed file access.
func (*Access) Descriptor
deprecated
func (*Access) GetSource ¶
func (x *Access) GetSource() AccessSource
func (*Access) GetTimestamp ¶
func (x *Access) GetTimestamp() *timestamppb.Timestamp
func (*Access) GetWorkDir ¶
func (*Access) ProtoMessage ¶
func (*Access) ProtoMessage()
func (*Access) ProtoReflect ¶
func (x *Access) ProtoReflect() protoreflect.Message
type AccessOp ¶
type AccessOp int32
AccessOp is what happened to the path. EDIT is a targeted patch and WRITE a full-content overwrite; both are distinguished from CREATE, which says the path did not exist beforehand.
func (AccessOp) Descriptor ¶
func (AccessOp) Descriptor() protoreflect.EnumDescriptor
func (AccessOp) EnumDescriptor
deprecated
func (AccessOp) Number ¶
func (x AccessOp) Number() protoreflect.EnumNumber
func (AccessOp) Type ¶
func (AccessOp) Type() protoreflect.EnumType
type AccessSource ¶
type AccessSource int32
AccessSource is how the access was observed, which is also how far it can be trusted. TOOL is an exact record taken inside the tool that performed it. SNAPSHOT is derived by diffing the work dir around a shell execution: the path and the operation are real, but attribution to that execution is an inference, and reads are invisible to it entirely. CONTROL is a file request this node served for a peer rather than anything the agent did.
const ( AccessSource_ACCESS_SOURCE_UNSPECIFIED AccessSource = 0 AccessSource_ACCESS_SOURCE_TOOL AccessSource = 1 AccessSource_ACCESS_SOURCE_SNAPSHOT AccessSource = 2 AccessSource_ACCESS_SOURCE_CONTROL AccessSource = 3 )
func (AccessSource) Descriptor ¶
func (AccessSource) Descriptor() protoreflect.EnumDescriptor
func (AccessSource) Enum ¶
func (x AccessSource) Enum() *AccessSource
func (AccessSource) EnumDescriptor
deprecated
func (AccessSource) EnumDescriptor() ([]byte, []int)
Deprecated: Use AccessSource.Descriptor instead.
func (AccessSource) Number ¶
func (x AccessSource) Number() protoreflect.EnumNumber
func (AccessSource) String ¶
func (x AccessSource) String() string
func (AccessSource) Type ¶
func (AccessSource) Type() protoreflect.EnumType
type Entry ¶
type Entry struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
IsDirectory bool `protobuf:"varint,2,opt,name=is_directory,json=isDirectory,proto3" json:"is_directory,omitempty"`
Size int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
// contains filtered or unexported fields
}
func (*Entry) Descriptor
deprecated
func (*Entry) GetIsDirectory ¶
func (*Entry) ProtoMessage ¶
func (*Entry) ProtoMessage()
func (*Entry) ProtoReflect ¶
func (x *Entry) ProtoReflect() protoreflect.Message
type ListRequest ¶
type ListRequest struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
// contains filtered or unexported fields
}
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetPath ¶
func (x *ListRequest) GetPath() string
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type MkdirRequest ¶
type MkdirRequest struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
// contains filtered or unexported fields
}
func (*MkdirRequest) Descriptor
deprecated
func (*MkdirRequest) Descriptor() ([]byte, []int)
Deprecated: Use MkdirRequest.ProtoReflect.Descriptor instead.
func (*MkdirRequest) GetPath ¶
func (x *MkdirRequest) GetPath() string
func (*MkdirRequest) ProtoMessage ¶
func (*MkdirRequest) ProtoMessage()
func (*MkdirRequest) ProtoReflect ¶
func (x *MkdirRequest) ProtoReflect() protoreflect.Message
func (*MkdirRequest) Reset ¶
func (x *MkdirRequest) Reset()
func (*MkdirRequest) String ¶
func (x *MkdirRequest) String() string
type ProtocolMessage ¶
type ProtocolMessage struct {
// Types that are valid to be assigned to Message:
//
// *ProtocolMessage_ReadRequest
// *ProtocolMessage_WriteRequest
// *ProtocolMessage_ListRequest
// *ProtocolMessage_MkdirRequest
// *ProtocolMessage_UploadRequest
// *ProtocolMessage_Result
Message isProtocolMessage_Message `protobuf_oneof:"message"`
// contains filtered or unexported fields
}
func (*ProtocolMessage) Descriptor
deprecated
func (*ProtocolMessage) Descriptor() ([]byte, []int)
Deprecated: Use ProtocolMessage.ProtoReflect.Descriptor instead.
func (*ProtocolMessage) GetListRequest ¶
func (x *ProtocolMessage) GetListRequest() *ListRequest
func (*ProtocolMessage) GetMessage ¶
func (x *ProtocolMessage) GetMessage() isProtocolMessage_Message
func (*ProtocolMessage) GetMkdirRequest ¶
func (x *ProtocolMessage) GetMkdirRequest() *MkdirRequest
func (*ProtocolMessage) GetReadRequest ¶
func (x *ProtocolMessage) GetReadRequest() *ReadRequest
func (*ProtocolMessage) GetResult ¶
func (x *ProtocolMessage) GetResult() *Result
func (*ProtocolMessage) GetUploadRequest ¶
func (x *ProtocolMessage) GetUploadRequest() *UploadRequest
func (*ProtocolMessage) GetWriteRequest ¶
func (x *ProtocolMessage) GetWriteRequest() *WriteRequest
func (*ProtocolMessage) ProtoMessage ¶
func (*ProtocolMessage) ProtoMessage()
func (*ProtocolMessage) ProtoReflect ¶
func (x *ProtocolMessage) ProtoReflect() protoreflect.Message
func (*ProtocolMessage) Reset ¶
func (x *ProtocolMessage) Reset()
func (*ProtocolMessage) String ¶
func (x *ProtocolMessage) String() string
type ProtocolMessage_ListRequest ¶
type ProtocolMessage_ListRequest struct {
ListRequest *ListRequest `protobuf:"bytes,12,opt,name=list_request,json=listRequest,proto3,oneof"`
}
type ProtocolMessage_MkdirRequest ¶
type ProtocolMessage_MkdirRequest struct {
MkdirRequest *MkdirRequest `protobuf:"bytes,13,opt,name=mkdir_request,json=mkdirRequest,proto3,oneof"`
}
type ProtocolMessage_ReadRequest ¶
type ProtocolMessage_ReadRequest struct {
ReadRequest *ReadRequest `protobuf:"bytes,10,opt,name=read_request,json=readRequest,proto3,oneof"`
}
type ProtocolMessage_Result ¶
type ProtocolMessage_Result struct {
Result *Result `protobuf:"bytes,20,opt,name=result,proto3,oneof"`
}
type ProtocolMessage_UploadRequest ¶
type ProtocolMessage_UploadRequest struct {
UploadRequest *UploadRequest `protobuf:"bytes,14,opt,name=upload_request,json=uploadRequest,proto3,oneof"`
}
type ProtocolMessage_WriteRequest ¶
type ProtocolMessage_WriteRequest struct {
WriteRequest *WriteRequest `protobuf:"bytes,11,opt,name=write_request,json=writeRequest,proto3,oneof"`
}
type ReadRequest ¶
type ReadRequest struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
// offset and limit enable bounded reads for large artifacts. A zero limit
// preserves the original whole-file behavior for older clients.
Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
// contains filtered or unexported fields
}
func (*ReadRequest) Descriptor
deprecated
func (*ReadRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.
func (*ReadRequest) GetLimit ¶
func (x *ReadRequest) GetLimit() int32
func (*ReadRequest) GetOffset ¶
func (x *ReadRequest) GetOffset() int64
func (*ReadRequest) GetPath ¶
func (x *ReadRequest) GetPath() string
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) ProtoReflect ¶
func (x *ReadRequest) ProtoReflect() protoreflect.Message
func (*ReadRequest) Reset ¶
func (x *ReadRequest) Reset()
func (*ReadRequest) String ¶
func (x *ReadRequest) String() string
type Result ¶
type Result struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
Filename string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
Size int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
Entries []*Entry `protobuf:"bytes,5,rep,name=entries,proto3" json:"entries,omitempty"`
MediaType string `protobuf:"bytes,6,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
// offset is the position of data within the file; size remains the total
// file size. eof marks the final chunk.
Offset int64 `protobuf:"varint,7,opt,name=offset,proto3" json:"offset,omitempty"`
Eof bool `protobuf:"varint,8,opt,name=eof,proto3" json:"eof,omitempty"`
// contains filtered or unexported fields
}
func (*Result) Descriptor
deprecated
func (*Result) GetEntries ¶
func (*Result) GetFilename ¶
func (*Result) GetMediaType ¶
func (*Result) ProtoMessage ¶
func (*Result) ProtoMessage()
func (*Result) ProtoReflect ¶
func (x *Result) ProtoReflect() protoreflect.Message
type UploadRequest ¶
type UploadRequest struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
Filename string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
MediaType string `protobuf:"bytes,3,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
// contains filtered or unexported fields
}
func (*UploadRequest) Descriptor
deprecated
func (*UploadRequest) Descriptor() ([]byte, []int)
Deprecated: Use UploadRequest.ProtoReflect.Descriptor instead.
func (*UploadRequest) GetData ¶
func (x *UploadRequest) GetData() []byte
func (*UploadRequest) GetFilename ¶
func (x *UploadRequest) GetFilename() string
func (*UploadRequest) GetMediaType ¶
func (x *UploadRequest) GetMediaType() string
func (*UploadRequest) GetSessionId ¶
func (x *UploadRequest) GetSessionId() string
func (*UploadRequest) ProtoMessage ¶
func (*UploadRequest) ProtoMessage()
func (*UploadRequest) ProtoReflect ¶
func (x *UploadRequest) ProtoReflect() protoreflect.Message
func (*UploadRequest) Reset ¶
func (x *UploadRequest) Reset()
func (*UploadRequest) String ¶
func (x *UploadRequest) String() string
type WriteRequest ¶
type WriteRequest struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
// contains filtered or unexported fields
}
func (*WriteRequest) Descriptor
deprecated
func (*WriteRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.
func (*WriteRequest) GetData ¶
func (x *WriteRequest) GetData() []byte
func (*WriteRequest) GetPath ¶
func (x *WriteRequest) GetPath() string
func (*WriteRequest) ProtoMessage ¶
func (*WriteRequest) ProtoMessage()
func (*WriteRequest) ProtoReflect ¶
func (x *WriteRequest) ProtoReflect() protoreflect.Message
func (*WriteRequest) Reset ¶
func (x *WriteRequest) Reset()
func (*WriteRequest) String ¶
func (x *WriteRequest) String() string