file

package
v0.0.0-...-fddd243 Latest Latest
Warning

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

Go to latest
Published: Aug 27, 2026 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
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"`
	// tool_id is the AOP tool-call id whose execution produced this access, empty
	// when it happened outside one (a control request, a detached session).
	ToolId string       `protobuf:"bytes,2,opt,name=tool_id,json=toolId,proto3" json:"tool_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) Descriptor() ([]byte, []int)

Deprecated: Use Access.ProtoReflect.Descriptor instead.

func (*Access) GetBytes

func (x *Access) GetBytes() int64

func (*Access) GetDigest

func (x *Access) GetDigest() string

func (*Access) GetEdits

func (x *Access) GetEdits() uint32

func (*Access) GetError

func (x *Access) GetError() string

func (*Access) GetId

func (x *Access) GetId() string

func (*Access) GetOp

func (x *Access) GetOp() AccessOp

func (*Access) GetPath

func (x *Access) GetPath() string

func (*Access) GetSize

func (x *Access) GetSize() int64

func (*Access) GetSource

func (x *Access) GetSource() AccessSource

func (*Access) GetTimestamp

func (x *Access) GetTimestamp() *timestamppb.Timestamp

func (*Access) GetToolId

func (x *Access) GetToolId() string

func (*Access) GetWorkDir

func (x *Access) GetWorkDir() string

func (*Access) ProtoMessage

func (*Access) ProtoMessage()

func (*Access) ProtoReflect

func (x *Access) ProtoReflect() protoreflect.Message

func (*Access) Reset

func (x *Access) Reset()

func (*Access) String

func (x *Access) String() string

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.

const (
	AccessOp_ACCESS_OP_UNSPECIFIED AccessOp = 0
	AccessOp_ACCESS_OP_READ        AccessOp = 1
	AccessOp_ACCESS_OP_WRITE       AccessOp = 2
	AccessOp_ACCESS_OP_EDIT        AccessOp = 3
	AccessOp_ACCESS_OP_CREATE      AccessOp = 4
	AccessOp_ACCESS_OP_DELETE      AccessOp = 5
)

func (AccessOp) Descriptor

func (AccessOp) Descriptor() protoreflect.EnumDescriptor

func (AccessOp) Enum

func (x AccessOp) Enum() *AccessOp

func (AccessOp) EnumDescriptor deprecated

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

Deprecated: Use AccessOp.Descriptor instead.

func (AccessOp) Number

func (x AccessOp) Number() protoreflect.EnumNumber

func (AccessOp) String

func (x AccessOp) String() string

func (AccessOp) Type

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) Enum

func (x AccessSource) Enum() *AccessSource

func (AccessSource) EnumDescriptor deprecated

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

Deprecated: Use AccessSource.Descriptor instead.

func (AccessSource) Number

func (AccessSource) String

func (x AccessSource) String() string

func (AccessSource) Type

type Configure

type Configure struct {
	Watch *WatchConfig `protobuf:"bytes,1,opt,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

func (*Configure) Descriptor deprecated

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

Deprecated: Use Configure.ProtoReflect.Descriptor instead.

func (*Configure) GetWatch

func (x *Configure) GetWatch() *WatchConfig

func (*Configure) ProtoMessage

func (*Configure) ProtoMessage()

func (*Configure) ProtoReflect

func (x *Configure) ProtoReflect() protoreflect.Message

func (*Configure) Reset

func (x *Configure) Reset()

func (*Configure) String

func (x *Configure) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetIsDirectory

func (x *Entry) GetIsDirectory() bool

func (*Entry) GetName

func (x *Entry) GetName() string

func (*Entry) GetSize

func (x *Entry) GetSize() int64

func (*Entry) ProtoMessage

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect

func (x *Entry) ProtoReflect() protoreflect.Message

func (*Entry) Reset

func (x *Entry) Reset()

func (*Entry) String

func (x *Entry) String() string

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
	//	*ProtocolMessage_Configure
	//	*ProtocolMessage_State
	//	*ProtocolMessage_Access
	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) GetAccess

func (x *ProtocolMessage) GetAccess() *Access

func (*ProtocolMessage) GetConfigure

func (x *ProtocolMessage) GetConfigure() *Configure

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) GetState

func (x *ProtocolMessage) GetState() *WatchState

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_Access

type ProtocolMessage_Access struct {
	Access *Access `protobuf:"bytes,23,opt,name=access,proto3,oneof"`
}

type ProtocolMessage_Configure

type ProtocolMessage_Configure struct {
	Configure *Configure `protobuf:"bytes,21,opt,name=configure,proto3,oneof"`
}

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_State

type ProtocolMessage_State struct {
	State *WatchState `protobuf:"bytes,22,opt,name=state,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) Descriptor() ([]byte, []int)

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetData

func (x *Result) GetData() []byte

func (*Result) GetEntries

func (x *Result) GetEntries() []*Entry

func (*Result) GetEof

func (x *Result) GetEof() bool

func (*Result) GetFilename

func (x *Result) GetFilename() string

func (*Result) GetMediaType

func (x *Result) GetMediaType() string

func (*Result) GetOffset

func (x *Result) GetOffset() int64

func (*Result) GetPath

func (x *Result) GetPath() string

func (*Result) GetSize

func (x *Result) GetSize() int64

func (*Result) ProtoMessage

func (*Result) ProtoMessage()

func (*Result) ProtoReflect

func (x *Result) ProtoReflect() protoreflect.Message

func (*Result) Reset

func (x *Result) Reset()

func (*Result) String

func (x *Result) String() string

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 WatchConfig

type WatchConfig struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// ignore holds path substrings excluded from snapshot diffing; empty leaves
	// the node's own defaults (VCS metadata, dependency trees) in place.
	Ignore []string `protobuf:"bytes,2,rep,name=ignore,proto3" json:"ignore,omitempty"`
	// max_entries bounds one snapshot. A work dir over it is not diffed at all,
	// and the node says so through an Access carrying error rather than
	// reporting a silently partial diff.
	MaxEntries uint32 `protobuf:"varint,3,opt,name=max_entries,json=maxEntries,proto3" json:"max_entries,omitempty"`
	// contains filtered or unexported fields
}

WatchConfig steers observation. Disabling it stops the node reporting, which is the only way a peer can opt out of the stream it would otherwise receive.

func (*WatchConfig) Descriptor deprecated

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

Deprecated: Use WatchConfig.ProtoReflect.Descriptor instead.

func (*WatchConfig) GetEnabled

func (x *WatchConfig) GetEnabled() bool

func (*WatchConfig) GetIgnore

func (x *WatchConfig) GetIgnore() []string

func (*WatchConfig) GetMaxEntries

func (x *WatchConfig) GetMaxEntries() uint32

func (*WatchConfig) ProtoMessage

func (*WatchConfig) ProtoMessage()

func (*WatchConfig) ProtoReflect

func (x *WatchConfig) ProtoReflect() protoreflect.Message

func (*WatchConfig) Reset

func (x *WatchConfig) Reset()

func (*WatchConfig) String

func (x *WatchConfig) String() string

type WatchState

type WatchState struct {
	Watching bool   `protobuf:"varint,1,opt,name=watching,proto3" json:"watching,omitempty"`
	Error    string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchState) Descriptor deprecated

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

Deprecated: Use WatchState.ProtoReflect.Descriptor instead.

func (*WatchState) GetError

func (x *WatchState) GetError() string

func (*WatchState) GetWatching

func (x *WatchState) GetWatching() bool

func (*WatchState) ProtoMessage

func (*WatchState) ProtoMessage()

func (*WatchState) ProtoReflect

func (x *WatchState) ProtoReflect() protoreflect.Message

func (*WatchState) Reset

func (x *WatchState) Reset()

func (*WatchState) String

func (x *WatchState) 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL