Documentation
¶
Index ¶
- Constants
- Variables
- func Bytes(m pb.Message) []byte
- func Decode(stored []byte, compression Compression) ([]byte, error)
- func DecodeVarint(buf []byte) (x uint64, n int)
- func EncodeVarint(buf []byte, x uint64) []byte
- func GetOSFileInfo(info *FileInfo) os.FileInfo
- func JoinPath(prefix string, name []byte) string
- func NameFromComponent(component string) []byte
- func PathComponent(name []byte) string
- func RegisterStoreServer(s grpc.ServiceRegistrar, srv StoreServer)
- func StoredHash(stored []byte) []byte
- func VerifyPayload(stored []byte, compression Compression, t ObjectType, ref *Ref) ([]byte, error)
- func VerifyStored(hdr *ObjectHeader, stored []byte) error
- func WithDetails(info os.FileInfo, user, group, linkTarget string) os.FileInfo
- type BeginCommitRequest
- func (*BeginCommitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BeginCommitRequest) GetBackupSet() string
- func (*BeginCommitRequest) ProtoMessage()
- func (x *BeginCommitRequest) ProtoReflect() protoreflect.Message
- func (x *BeginCommitRequest) Reset()
- func (x *BeginCommitRequest) String() string
- type BeginCommitResponse
- func (*BeginCommitResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BeginCommitResponse) GetAllowed() bool
- func (x *BeginCommitResponse) GetDamagedPaths() []string
- func (x *BeginCommitResponse) GetPolicy() *StorePolicy
- func (x *BeginCommitResponse) GetReason() string
- func (x *BeginCommitResponse) GetRescan() bool
- func (*BeginCommitResponse) ProtoMessage()
- func (x *BeginCommitResponse) ProtoReflect() protoreflect.Message
- func (x *BeginCommitResponse) Reset()
- func (x *BeginCommitResponse) String() string
- type BeginSessionRequest
- func (*BeginSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BeginSessionRequest) GetBackupSet() string
- func (x *BeginSessionRequest) GetInitialRetention() *RetentionPolicy
- func (x *BeginSessionRequest) GetRestore() *Ref
- func (*BeginSessionRequest) ProtoMessage()
- func (x *BeginSessionRequest) ProtoReflect() protoreflect.Message
- func (x *BeginSessionRequest) Reset()
- func (x *BeginSessionRequest) String() string
- type BeginSessionResponse
- func (*BeginSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BeginSessionResponse) GetLeaseSeconds() int64
- func (x *BeginSessionResponse) GetSessionId() string
- func (*BeginSessionResponse) ProtoMessage()
- func (x *BeginSessionResponse) ProtoReflect() protoreflect.Message
- func (x *BeginSessionResponse) Reset()
- func (x *BeginSessionResponse) String() string
- type Blob
- type Chunker
- type Commit
- func (*Commit) Descriptor() ([]byte, []int)deprecated
- func (x *Commit) GetAgentId() string
- func (x *Commit) GetBackupSet() string
- func (x *Commit) GetConsistent() bool
- func (x *Commit) GetKeyId() []byte
- func (x *Commit) GetMetadata() map[string]string
- func (x *Commit) GetParent() *Ref
- func (x *Commit) GetPartial() bool
- func (x *Commit) GetPolicyVersion() uint32
- func (x *Commit) GetReceivedAtNs() int64
- func (x *Commit) GetScanStartNs() int64
- func (x *Commit) GetSetId() uint64
- func (x *Commit) GetTimestamp() int64
- func (x *Commit) GetTree() *Ref
- func (*Commit) ProtoMessage()
- func (x *Commit) ProtoReflect() protoreflect.Message
- func (x *Commit) Reset()
- func (x *Commit) String() string
- type CommitCount
- type CommitInfoRequest
- func (*CommitInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CommitInfoRequest) GetBackupSet() string
- func (x *CommitInfoRequest) GetCount() int32
- func (x *CommitInfoRequest) GetNotAfter() *timestamppb.Timestamp
- func (*CommitInfoRequest) ProtoMessage()
- func (x *CommitInfoRequest) ProtoReflect() protoreflect.Message
- func (x *CommitInfoRequest) Reset()
- func (x *CommitInfoRequest) String() string
- type CommitInfoResponse
- func (*CommitInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CommitInfoResponse) GetCommits() []*Commit
- func (x *CommitInfoResponse) GetSizes() []*CommitSize
- func (*CommitInfoResponse) ProtoMessage()
- func (x *CommitInfoResponse) ProtoReflect() protoreflect.Message
- func (x *CommitInfoResponse) Reset()
- func (x *CommitInfoResponse) String() string
- type CommitScope
- func (*CommitScope) Descriptor() ([]byte, []int)deprecated
- func (x *CommitScope) GetCommit() *Ref
- func (x *CommitScope) GetDeletedAtNs() int64
- func (*CommitScope) ProtoMessage()
- func (x *CommitScope) ProtoReflect() protoreflect.Message
- func (x *CommitScope) Reset()
- func (x *CommitScope) String() string
- type CommitSize
- type Compression
- func (Compression) Descriptor() protoreflect.EnumDescriptor
- func (x Compression) Enum() *Compression
- func (Compression) EnumDescriptor() ([]byte, []int)deprecated
- func (x Compression) Number() protoreflect.EnumNumber
- func (x Compression) String() string
- func (Compression) Type() protoreflect.EnumType
- type CountCommitsRequest
- func (*CountCommitsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CountCommitsRequest) GetBackupSet() string
- func (x *CountCommitsRequest) GetDeleted() bool
- func (x *CountCommitsRequest) GetFromNs() int64
- func (x *CountCommitsRequest) GetPeriod() Period
- func (x *CountCommitsRequest) GetTimeZone() string
- func (x *CountCommitsRequest) GetToNs() int64
- func (*CountCommitsRequest) ProtoMessage()
- func (x *CountCommitsRequest) ProtoReflect() protoreflect.Message
- func (x *CountCommitsRequest) Reset()
- func (x *CountCommitsRequest) String() string
- type CountCommitsResponse
- func (*CountCommitsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CountCommitsResponse) GetCounts() []*CommitCount
- func (*CountCommitsResponse) ProtoMessage()
- func (x *CountCommitsResponse) ProtoReflect() protoreflect.Message
- func (x *CountCommitsResponse) Reset()
- func (x *CountCommitsResponse) String() string
- type DeleteCommitRequest
- func (*DeleteCommitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteCommitRequest) GetRef() *Ref
- func (*DeleteCommitRequest) ProtoMessage()
- func (x *DeleteCommitRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteCommitRequest) Reset()
- func (x *DeleteCommitRequest) String() string
- type DeleteCommitResponse
- type DeleteSetRequest
- func (*DeleteSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSetRequest) GetBackupSet() string
- func (x *DeleteSetRequest) GetErase() bool
- func (*DeleteSetRequest) ProtoMessage()
- func (x *DeleteSetRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSetRequest) Reset()
- func (x *DeleteSetRequest) String() string
- type DeleteSetResponse
- type Encryption
- type EndSessionRequest
- type EndSessionResponse
- type EscrowedKey
- func (*EscrowedKey) Descriptor() ([]byte, []int)deprecated
- func (x *EscrowedKey) GetEscrowed() []byte
- func (x *EscrowedKey) GetKeyId() string
- func (*EscrowedKey) ProtoMessage()
- func (x *EscrowedKey) ProtoReflect() protoreflect.Message
- func (x *EscrowedKey) Reset()
- func (x *EscrowedKey) String() string
- type EscrowedKeysRequest
- type EscrowedKeysResponse
- func (*EscrowedKeysResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EscrowedKeysResponse) GetKeys() []*EscrowedKey
- func (*EscrowedKeysResponse) ProtoMessage()
- func (x *EscrowedKeysResponse) ProtoReflect() protoreflect.Message
- func (x *EscrowedKeysResponse) Reset()
- func (x *EscrowedKeysResponse) String() string
- type File
- func (*File) Descriptor() ([]byte, []int)deprecated
- func (x *File) GetChunker() Chunker
- func (x *File) GetInline() []byte
- func (x *File) GetInlineEncryption() Encryption
- func (x *File) GetParts() []*FilePart
- func (x *File) GetSplitDepth() uint32
- func (x *File) GetSplitLengths() []uint64
- func (x *File) GetSplits() []*Ref
- func (*File) ProtoMessage()
- func (x *File) ProtoReflect() protoreflect.Message
- func (x *File) Reset()
- func (x *File) String() string
- type FileInfo
- func (*FileInfo) Descriptor() ([]byte, []int)deprecated
- func (x *FileInfo) GetGroup() []byte
- func (x *FileInfo) GetLinkTarget() []byte
- func (x *FileInfo) GetMode() uint32
- func (x *FileInfo) GetMtimeNs() int64
- func (x *FileInfo) GetName() []byte
- func (x *FileInfo) GetSize() int64
- func (x *FileInfo) GetType() NodeType
- func (x *FileInfo) GetUser() []byte
- func (fi *FileInfo) IsDir() bool
- func (fi *FileInfo) ModTime() time.Time
- func (*FileInfo) ProtoMessage()
- func (x *FileInfo) ProtoReflect() protoreflect.Message
- func (x *FileInfo) Reset()
- func (x *FileInfo) String() string
- type FileInfoRequest
- func (*FileInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FileInfoRequest) GetBackupSet() string
- func (x *FileInfoRequest) GetCount() int32
- func (x *FileInfoRequest) GetNotAfter() *timestamppb.Timestamp
- func (x *FileInfoRequest) GetPath() string
- func (*FileInfoRequest) ProtoMessage()
- func (x *FileInfoRequest) ProtoReflect() protoreflect.Message
- func (x *FileInfoRequest) Reset()
- func (x *FileInfoRequest) String() string
- type FileInfoResponse
- type FilePart
- func (*FilePart) Descriptor() ([]byte, []int)deprecated
- func (x *FilePart) GetLength() uint64
- func (x *FilePart) GetOffset() uint64
- func (x *FilePart) GetRef() *Ref
- func (*FilePart) ProtoMessage()
- func (x *FilePart) ProtoReflect() protoreflect.Message
- func (x *FilePart) Reset()
- func (x *FilePart) String() string
- type GetPresenceRequest
- func (*GetPresenceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetPresenceRequest) GetBackupSet() string
- func (*GetPresenceRequest) ProtoMessage()
- func (x *GetPresenceRequest) ProtoReflect() protoreflect.Message
- func (x *GetPresenceRequest) Reset()
- func (x *GetPresenceRequest) String() string
- type GetPresenceResponse
- func (*GetPresenceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetPresenceResponse) GetFilter() *PresenceFilter
- func (x *GetPresenceResponse) GetIndex() uint32
- func (*GetPresenceResponse) ProtoMessage()
- func (x *GetPresenceResponse) ProtoReflect() protoreflect.Message
- func (x *GetPresenceResponse) Reset()
- func (x *GetPresenceResponse) String() string
- type GetRequest
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetResponse) GetBody() isGetResponse_Body
- func (x *GetResponse) GetLocation() *Location
- func (x *GetResponse) GetObject() *Object
- func (*GetResponse) ProtoMessage()
- func (x *GetResponse) ProtoReflect() protoreflect.Message
- func (x *GetResponse) Reset()
- func (x *GetResponse) String() string
- type GetResponse_Location
- type GetResponse_Object
- type GetTreeRequest
- func (*GetTreeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTreeRequest) GetMaxDepth() uint32
- func (x *GetTreeRequest) GetRef() *Ref
- func (*GetTreeRequest) ProtoMessage()
- func (x *GetTreeRequest) ProtoReflect() protoreflect.Message
- func (x *GetTreeRequest) Reset()
- func (x *GetTreeRequest) String() string
- type GetTreeResponse
- func (*GetTreeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTreeResponse) GetObject() *Object
- func (x *GetTreeResponse) GetRef() *Ref
- func (x *GetTreeResponse) GetRuns() []*LocatedRun
- func (*GetTreeResponse) ProtoMessage()
- func (x *GetTreeResponse) ProtoReflect() protoreflect.Message
- func (x *GetTreeResponse) Reset()
- func (x *GetTreeResponse) String() string
- type LatestCommitRequest
- func (*LatestCommitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LatestCommitRequest) GetBackupSet() string
- func (*LatestCommitRequest) ProtoMessage()
- func (x *LatestCommitRequest) ProtoReflect() protoreflect.Message
- func (x *LatestCommitRequest) Reset()
- func (x *LatestCommitRequest) String() string
- type LatestCommitResponse
- func (*LatestCommitResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LatestCommitResponse) GetRef() *Ref
- func (*LatestCommitResponse) ProtoMessage()
- func (x *LatestCommitResponse) ProtoReflect() protoreflect.Message
- func (x *LatestCommitResponse) Reset()
- func (x *LatestCommitResponse) String() string
- type ListPinsRequest
- type ListPinsResponse
- type ListTrashRequest
- func (*ListTrashRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListTrashRequest) GetBackupSet() string
- func (x *ListTrashRequest) GetBeforeNs() int64
- func (x *ListTrashRequest) GetLimit() int32
- func (*ListTrashRequest) ProtoMessage()
- func (x *ListTrashRequest) ProtoReflect() protoreflect.Message
- func (x *ListTrashRequest) Reset()
- func (x *ListTrashRequest) String() string
- type ListTrashResponse
- func (*ListTrashResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListTrashResponse) GetCommits() []*TrashedCommit
- func (*ListTrashResponse) ProtoMessage()
- func (x *ListTrashResponse) ProtoReflect() protoreflect.Message
- func (x *ListTrashResponse) Reset()
- func (x *ListTrashResponse) String() string
- type LocatedRecord
- func (*LocatedRecord) Descriptor() ([]byte, []int)deprecated
- func (x *LocatedRecord) GetFile() uint32
- func (x *LocatedRecord) GetIndex() uint32
- func (x *LocatedRecord) GetLength() int64
- func (x *LocatedRecord) GetOffset() int64
- func (*LocatedRecord) ProtoMessage()
- func (x *LocatedRecord) ProtoReflect() protoreflect.Message
- func (x *LocatedRecord) Reset()
- func (x *LocatedRecord) String() string
- type LocatedRun
- func (*LocatedRun) Descriptor() ([]byte, []int)deprecated
- func (x *LocatedRun) GetLocation() *Location
- func (x *LocatedRun) GetRecords() []*LocatedRecord
- func (*LocatedRun) ProtoMessage()
- func (x *LocatedRun) ProtoReflect() protoreflect.Message
- func (x *LocatedRun) Reset()
- func (x *LocatedRun) String() string
- type Location
- func (*Location) Descriptor() ([]byte, []int)deprecated
- func (x *Location) GetAtRestKey() []byte
- func (x *Location) GetExpires() *timestamppb.Timestamp
- func (x *Location) GetHeader() map[string]string
- func (x *Location) GetLength() int64
- func (x *Location) GetUrl() string
- func (*Location) ProtoMessage()
- func (x *Location) ProtoReflect() protoreflect.Message
- func (x *Location) Reset()
- func (x *Location) String() string
- type NodeType
- type Object
- func NewObject(in interface{}) *Object
- func NewObjectFromBytes(bytes []byte) (*Object, error)
- func NewObjectFromPayload(payload []byte, t ObjectType) (*Object, error)
- func NewVerifiedObject(stored []byte, compression Compression, t ObjectType, ref *Ref) (*Object, error)
- func ObjectFromStored(hdr *ObjectHeader, stored []byte) (*Object, error)
- func (o *Object) Bytes() []byte
- func (o *Object) Canonical() ([]byte, error)
- func (*Object) Descriptor() ([]byte, []int)deprecated
- func (x *Object) GetBlob() *Blob
- func (x *Object) GetCommit() *Commit
- func (x *Object) GetFile() *File
- func (x *Object) GetKeyId() []byte
- func (x *Object) GetObject() isObject_Object
- func (x *Object) GetPin() *Pin
- func (x *Object) GetPolicy() *Policy
- func (x *Object) GetSealed() *Sealed
- func (x *Object) GetTree() *Tree
- func (*Object) ProtoMessage()
- func (x *Object) ProtoReflect() protoreflect.Message
- func (o *Object) ReceivedAtNs() int64
- func (o *Object) Ref() *Ref
- func (x *Object) Reset()
- func (o *Object) Stamp(setID uint64, receivedAt time.Time)
- func (x *Object) String() string
- func (o *Object) Type() ObjectType
- func (o *Object) Validate() error
- func (o *Object) Verify(ref *Ref) error
- type ObjectHeader
- func (*ObjectHeader) Descriptor() ([]byte, []int)deprecated
- func (x *ObjectHeader) GetAtRestKeyId() []byte
- func (x *ObjectHeader) GetCompression() Compression
- func (x *ObjectHeader) GetEncryption() Encryption
- func (x *ObjectHeader) GetErase() bool
- func (x *ObjectHeader) GetKeyId() []byte
- func (x *ObjectHeader) GetPredecessor() *Ref
- func (x *ObjectHeader) GetRef() *Ref
- func (x *ObjectHeader) GetSize() uint64
- func (x *ObjectHeader) GetStoredHash() []byte
- func (x *ObjectHeader) GetTimestamp() *timestamppb.Timestamp
- func (x *ObjectHeader) GetTombstoneFor() *Ref
- func (x *ObjectHeader) GetType() ObjectType
- func (*ObjectHeader) ProtoMessage()
- func (x *ObjectHeader) ProtoReflect() protoreflect.Message
- func (x *ObjectHeader) Reset()
- func (x *ObjectHeader) String() string
- type ObjectType
- func (ObjectType) Descriptor() protoreflect.EnumDescriptor
- func (x ObjectType) Enum() *ObjectType
- func (ObjectType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ObjectType) Metadata() bool
- func (x ObjectType) Number() protoreflect.EnumNumber
- func (x ObjectType) String() string
- func (ObjectType) Type() protoreflect.EnumType
- type Object_Blob
- type Object_Commit
- type Object_File
- type Object_Pin
- type Object_Policy
- type Object_Sealed
- type Object_Tree
- type Period
- type Pin
- type PinInfo
- func (*PinInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PinInfo) GetMetadata() map[string]string
- func (x *PinInfo) GetReceivedAtNs() int64
- func (x *PinInfo) GetRef() *Ref
- func (x *PinInfo) GetTarget() *Ref
- func (*PinInfo) ProtoMessage()
- func (x *PinInfo) ProtoReflect() protoreflect.Message
- func (x *PinInfo) Reset()
- func (x *PinInfo) String() string
- type Policy
- func (*Policy) Descriptor() ([]byte, []int)deprecated
- func (x *Policy) GetCommit() *CommitScope
- func (x *Policy) GetScope() isPolicy_Scope
- func (x *Policy) GetSequence() uint64
- func (x *Policy) GetSet() *SetScope
- func (x *Policy) GetStore() *StoreScope
- func (x *Policy) GetWrittenAtNs() int64
- func (*Policy) ProtoMessage()
- func (x *Policy) ProtoReflect() protoreflect.Message
- func (x *Policy) Reset()
- func (x *Policy) String() string
- type Policy_Commit
- type Policy_Set
- type Policy_Store
- type PresenceFilter
- func (*PresenceFilter) Descriptor() ([]byte, []int)deprecated
- func (x *PresenceFilter) GetBackupSet() string
- func (x *PresenceFilter) GetBits() uint64
- func (x *PresenceFilter) GetCommit() *Ref
- func (x *PresenceFilter) GetData() []byte
- func (x *PresenceFilter) GetEntries() uint64
- func (x *PresenceFilter) GetHashes() uint32
- func (x *PresenceFilter) GetVersion() uint32
- func (*PresenceFilter) ProtoMessage()
- func (x *PresenceFilter) ProtoReflect() protoreflect.Message
- func (x *PresenceFilter) Reset()
- func (x *PresenceFilter) String() string
- type PutRequest
- func (*PutRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PutRequest) GetAssumedRefs() []*Ref
- func (x *PutRequest) GetObject() *Object
- func (x *PutRequest) GetRef() *Ref
- func (*PutRequest) ProtoMessage()
- func (x *PutRequest) ProtoReflect() protoreflect.Message
- func (x *PutRequest) Reset()
- func (x *PutRequest) String() string
- type PutResponse
- func (*PutResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PutResponse) GetMissing() []*Ref
- func (x *PutResponse) GetObject() *Object
- func (x *PutResponse) GetRef() *Ref
- func (*PutResponse) ProtoMessage()
- func (x *PutResponse) ProtoReflect() protoreflect.Message
- func (x *PutResponse) Reset()
- func (x *PutResponse) String() string
- type ReadDirRequest
- func (*ReadDirRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadDirRequest) GetBackupSet() string
- func (x *ReadDirRequest) GetNotAfter() *timestamppb.Timestamp
- func (x *ReadDirRequest) GetPath() string
- func (*ReadDirRequest) ProtoMessage()
- func (x *ReadDirRequest) ProtoReflect() protoreflect.Message
- func (x *ReadDirRequest) Reset()
- func (x *ReadDirRequest) String() string
- type ReadDirResponse
- type ReadFileRequest
- func (*ReadFileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadFileRequest) GetRef() *Ref
- func (x *ReadFileRequest) GetSkipParts() []uint32
- func (*ReadFileRequest) ProtoMessage()
- func (x *ReadFileRequest) ProtoReflect() protoreflect.Message
- func (x *ReadFileRequest) Reset()
- func (x *ReadFileRequest) String() string
- type ReadFileResponse
- func (*ReadFileResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadFileResponse) GetIndex() uint32
- func (x *ReadFileResponse) GetObject() *Object
- func (x *ReadFileResponse) GetRuns() []*LocatedRun
- func (*ReadFileResponse) ProtoMessage()
- func (x *ReadFileResponse) ProtoReflect() protoreflect.Message
- func (x *ReadFileResponse) Reset()
- func (x *ReadFileResponse) String() string
- type ReadFilesEntry
- func (*ReadFilesEntry) Descriptor() ([]byte, []int)deprecated
- func (x *ReadFilesEntry) GetRef() *Ref
- func (x *ReadFilesEntry) GetSkipParts() []uint32
- func (*ReadFilesEntry) ProtoMessage()
- func (x *ReadFilesEntry) ProtoReflect() protoreflect.Message
- func (x *ReadFilesEntry) Reset()
- func (x *ReadFilesEntry) String() string
- type ReadFilesRequest
- func (*ReadFilesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadFilesRequest) GetFiles() []*ReadFilesEntry
- func (x *ReadFilesRequest) GetObjectsOnly() bool
- func (*ReadFilesRequest) ProtoMessage()
- func (x *ReadFilesRequest) ProtoReflect() protoreflect.Message
- func (x *ReadFilesRequest) Reset()
- func (x *ReadFilesRequest) String() string
- type ReadFilesResponse
- func (*ReadFilesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadFilesResponse) GetFile() uint32
- func (x *ReadFilesResponse) GetIndex() uint32
- func (x *ReadFilesResponse) GetObject() *Object
- func (x *ReadFilesResponse) GetPart() bool
- func (x *ReadFilesResponse) GetRuns() []*LocatedRun
- func (*ReadFilesResponse) ProtoMessage()
- func (x *ReadFilesResponse) ProtoReflect() protoreflect.Message
- func (x *ReadFilesResponse) Reset()
- func (x *ReadFilesResponse) String() string
- type Ref
- type RetentionBracket
- func (*RetentionBracket) Descriptor() ([]byte, []int)deprecated
- func (x *RetentionBracket) GetCount() int32
- func (x *RetentionBracket) GetPeriod() string
- func (*RetentionBracket) ProtoMessage()
- func (x *RetentionBracket) ProtoReflect() protoreflect.Message
- func (x *RetentionBracket) Reset()
- func (x *RetentionBracket) String() string
- type RetentionPolicy
- func (*RetentionPolicy) Descriptor() ([]byte, []int)deprecated
- func (x *RetentionPolicy) GetBrackets() []*RetentionBracket
- func (x *RetentionPolicy) GetKeepLast() int32
- func (x *RetentionPolicy) GetKeepWithin() int64
- func (*RetentionPolicy) ProtoMessage()
- func (x *RetentionPolicy) ProtoReflect() protoreflect.Message
- func (x *RetentionPolicy) Reset()
- func (x *RetentionPolicy) String() string
- type Sealed
- func (*Sealed) Descriptor() ([]byte, []int)deprecated
- func (x *Sealed) GetCompression() Compression
- func (x *Sealed) GetData() []byte
- func (x *Sealed) GetEncryption() Encryption
- func (x *Sealed) GetKeyId() []byte
- func (x *Sealed) GetRef() *Ref
- func (x *Sealed) GetType() ObjectType
- func (*Sealed) ProtoMessage()
- func (x *Sealed) ProtoReflect() protoreflect.Message
- func (x *Sealed) Reset()
- func (x *Sealed) String() string
- type SetScope
- func (*SetScope) Descriptor() ([]byte, []int)deprecated
- func (x *SetScope) GetClosedAtNs() int64
- func (x *SetScope) GetErase() bool
- func (x *SetScope) GetName() string
- func (x *SetScope) GetRetention() string
- func (x *SetScope) GetRetentionPaused() bool
- func (x *SetScope) GetSetId() uint64
- func (x *SetScope) GetState() SetState
- func (*SetScope) ProtoMessage()
- func (x *SetScope) ProtoReflect() protoreflect.Message
- func (x *SetScope) Reset()
- func (x *SetScope) String() string
- type SetState
- type StoreClient
- type StorePolicy
- func (*StorePolicy) Descriptor() ([]byte, []int)deprecated
- func (x *StorePolicy) GetMode() string
- func (x *StorePolicy) GetPresenceScope() string
- func (x *StorePolicy) GetVersion() uint32
- func (*StorePolicy) ProtoMessage()
- func (x *StorePolicy) ProtoReflect() protoreflect.Message
- func (x *StorePolicy) Reset()
- func (x *StorePolicy) String() string
- type StoreScope
- func (*StoreScope) Descriptor() ([]byte, []int)deprecated
- func (x *StoreScope) GetDefaultRetention() string
- func (x *StoreScope) GetHoldDays() uint32
- func (x *StoreScope) GetKeyAcknowledgedAtNs() int64
- func (x *StoreScope) GetTrashDays() uint32
- func (x *StoreScope) GetWritePolicy() string
- func (x *StoreScope) GetWritePolicyVersion() uint32
- func (*StoreScope) ProtoMessage()
- func (x *StoreScope) ProtoReflect() protoreflect.Message
- func (x *StoreScope) Reset()
- func (x *StoreScope) String() string
- type StoreServer
- type Store_GetPresenceClient
- type Store_GetPresenceServer
- type Store_GetTreeClient
- type Store_GetTreeServer
- type Store_ReadFileClient
- type Store_ReadFileServer
- type Store_ReadFilesClient
- type Store_ReadFilesServer
- type TrashedCommit
- func (*TrashedCommit) Descriptor() ([]byte, []int)deprecated
- func (x *TrashedCommit) GetCommit() *Commit
- func (x *TrashedCommit) GetDeletedAtNs() int64
- func (x *TrashedCommit) GetExpiresAtNs() int64
- func (x *TrashedCommit) GetRef() *Ref
- func (x *TrashedCommit) GetSize() *CommitSize
- func (*TrashedCommit) ProtoMessage()
- func (x *TrashedCommit) ProtoReflect() protoreflect.Message
- func (x *TrashedCommit) Reset()
- func (x *TrashedCommit) String() string
- type Tree
- type TreeNode
- type UndeleteCommitRequest
- func (*UndeleteCommitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UndeleteCommitRequest) GetRef() *Ref
- func (*UndeleteCommitRequest) ProtoMessage()
- func (x *UndeleteCommitRequest) ProtoReflect() protoreflect.Message
- func (x *UndeleteCommitRequest) Reset()
- func (x *UndeleteCommitRequest) String() string
- type UndeleteCommitResponse
- type UndeleteSetRequest
- func (*UndeleteSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UndeleteSetRequest) GetBackupSet() string
- func (*UndeleteSetRequest) ProtoMessage()
- func (x *UndeleteSetRequest) ProtoReflect() protoreflect.Message
- func (x *UndeleteSetRequest) Reset()
- func (x *UndeleteSetRequest) String() string
- type UndeleteSetResponse
- type UnimplementedStoreServer
- func (UnimplementedStoreServer) BeginCommit(context.Context, *BeginCommitRequest) (*BeginCommitResponse, error)
- func (UnimplementedStoreServer) BeginSession(context.Context, *BeginSessionRequest) (*BeginSessionResponse, error)
- func (UnimplementedStoreServer) CommitInfo(context.Context, *CommitInfoRequest) (*CommitInfoResponse, error)
- func (UnimplementedStoreServer) CountCommits(context.Context, *CountCommitsRequest) (*CountCommitsResponse, error)
- func (UnimplementedStoreServer) DeleteCommit(context.Context, *DeleteCommitRequest) (*DeleteCommitResponse, error)
- func (UnimplementedStoreServer) DeleteSet(context.Context, *DeleteSetRequest) (*DeleteSetResponse, error)
- func (UnimplementedStoreServer) EndSession(context.Context, *EndSessionRequest) (*EndSessionResponse, error)
- func (UnimplementedStoreServer) EscrowedKeys(context.Context, *EscrowedKeysRequest) (*EscrowedKeysResponse, error)
- func (UnimplementedStoreServer) FileInfo(context.Context, *FileInfoRequest) (*FileInfoResponse, error)
- func (UnimplementedStoreServer) Get(context.Context, *GetRequest) (*GetResponse, error)
- func (UnimplementedStoreServer) GetPresence(*GetPresenceRequest, grpc.ServerStreamingServer[GetPresenceResponse]) error
- func (UnimplementedStoreServer) GetTree(*GetTreeRequest, grpc.ServerStreamingServer[GetTreeResponse]) error
- func (UnimplementedStoreServer) LatestCommit(context.Context, *LatestCommitRequest) (*LatestCommitResponse, error)
- func (UnimplementedStoreServer) ListPins(context.Context, *ListPinsRequest) (*ListPinsResponse, error)
- func (UnimplementedStoreServer) ListTrash(context.Context, *ListTrashRequest) (*ListTrashResponse, error)
- func (UnimplementedStoreServer) Put(context.Context, *PutRequest) (*PutResponse, error)
- func (UnimplementedStoreServer) ReadDir(context.Context, *ReadDirRequest) (*ReadDirResponse, error)
- func (UnimplementedStoreServer) ReadFile(*ReadFileRequest, grpc.ServerStreamingServer[ReadFileResponse]) error
- func (UnimplementedStoreServer) ReadFiles(*ReadFilesRequest, grpc.ServerStreamingServer[ReadFilesResponse]) error
- func (UnimplementedStoreServer) UndeleteCommit(context.Context, *UndeleteCommitRequest) (*UndeleteCommitResponse, error)
- func (UnimplementedStoreServer) UndeleteSet(context.Context, *UndeleteSetRequest) (*UndeleteSetResponse, error)
- func (UnimplementedStoreServer) Unpin(context.Context, *UnpinRequest) (*UnpinResponse, error)
- type UnpinRequest
- type UnpinResponse
- type UnsafeStoreServer
Constants ¶
const ( Store_Put_FullMethodName = "/proto.Store/Put" Store_Get_FullMethodName = "/proto.Store/Get" Store_ReadFile_FullMethodName = "/proto.Store/ReadFile" Store_ReadFiles_FullMethodName = "/proto.Store/ReadFiles" Store_FileInfo_FullMethodName = "/proto.Store/FileInfo" Store_ReadDir_FullMethodName = "/proto.Store/ReadDir" Store_CommitInfo_FullMethodName = "/proto.Store/CommitInfo" Store_LatestCommit_FullMethodName = "/proto.Store/LatestCommit" Store_GetTree_FullMethodName = "/proto.Store/GetTree" Store_BeginCommit_FullMethodName = "/proto.Store/BeginCommit" Store_BeginSession_FullMethodName = "/proto.Store/BeginSession" Store_EndSession_FullMethodName = "/proto.Store/EndSession" Store_GetPresence_FullMethodName = "/proto.Store/GetPresence" Store_DeleteCommit_FullMethodName = "/proto.Store/DeleteCommit" Store_UndeleteCommit_FullMethodName = "/proto.Store/UndeleteCommit" Store_ListTrash_FullMethodName = "/proto.Store/ListTrash" Store_CountCommits_FullMethodName = "/proto.Store/CountCommits" Store_DeleteSet_FullMethodName = "/proto.Store/DeleteSet" Store_UndeleteSet_FullMethodName = "/proto.Store/UndeleteSet" Store_Unpin_FullMethodName = "/proto.Store/Unpin" Store_ListPins_FullMethodName = "/proto.Store/ListPins" Store_EscrowedKeys_FullMethodName = "/proto.Store/EscrowedKeys" )
const HashSize = sha256.Size
HashSize is the width in bytes of every Ref.
const InlineLimit = 4 << 10
InlineLimit is the largest file stored inline in its File object.
Variables ¶
var ( Period_name = map[int32]string{ 0: "PERIOD_UNSPECIFIED", 1: "PERIOD_YEAR", 2: "PERIOD_MONTH", 3: "PERIOD_DAY", 4: "PERIOD_HOUR", } Period_value = map[string]int32{ "PERIOD_UNSPECIFIED": 0, "PERIOD_YEAR": 1, "PERIOD_MONTH": 2, "PERIOD_DAY": 3, "PERIOD_HOUR": 4, } )
Enum value maps for Period.
var ( Encryption_name = map[int32]string{ 0: "PLAINTEXT", 3: "SEALED", } Encryption_value = map[string]int32{ "PLAINTEXT": 0, "SEALED": 3, } )
Enum value maps for Encryption.
var ( NodeType_name = map[int32]string{ 0: "NODE_FILE", 1: "NODE_DIRECTORY", 2: "NODE_SYMLINK", } NodeType_value = map[string]int32{ "NODE_FILE": 0, "NODE_DIRECTORY": 1, "NODE_SYMLINK": 2, } )
Enum value maps for NodeType.
var ( Chunker_name = map[int32]string{ 0: "FASTCDC_64K", } Chunker_value = map[string]int32{ "FASTCDC_64K": 0, } )
Enum value maps for Chunker.
var ( // ErrRefMismatch is returned when stored bytes do not hash to the ref // they are filed under. ErrRefMismatch = errors.New("object bytes do not match ref") // ErrInvalidObject is wrapped by every error from canonical encoding. ErrInvalidObject = errors.New("invalid object") )
var ( ObjectType_name = map[int32]string{ 0: "INVALID", 1: "COMMIT", 2: "TREE", 3: "FILE", 4: "BLOB", 5: "TOMBSTONE", 6: "PIN", 7: "POLICY", } ObjectType_value = map[string]int32{ "INVALID": 0, "COMMIT": 1, "TREE": 2, "FILE": 3, "BLOB": 4, "TOMBSTONE": 5, "PIN": 6, "POLICY": 7, } )
Enum value maps for ObjectType.
var ( Compression_name = map[int32]string{ 0: "NONE", 2: "ZSTD", } Compression_value = map[string]int32{ "NONE": 0, "ZSTD": 2, } )
Enum value maps for Compression.
var ( SetState_name = map[int32]string{ 0: "SET_ACTIVE", 1: "SET_CLOSING", 2: "SET_DELETED", } SetState_value = map[string]int32{ "SET_ACTIVE": 0, "SET_CLOSING": 1, "SET_DELETED": 2, } )
Enum value maps for SetState.
var File_api_proto protoreflect.FileDescriptor
var File_blob_proto protoreflect.FileDescriptor
var File_commit_proto protoreflect.FileDescriptor
var File_encryption_proto protoreflect.FileDescriptor
var File_file_proto protoreflect.FileDescriptor
var File_object_proto protoreflect.FileDescriptor
var File_pin_proto protoreflect.FileDescriptor
var File_policy_proto protoreflect.FileDescriptor
var File_presence_proto protoreflect.FileDescriptor
var File_ref_proto protoreflect.FileDescriptor
var File_retention_proto protoreflect.FileDescriptor
var File_tree_proto protoreflect.FileDescriptor
var Store_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.Store", HandlerType: (*StoreServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Put", Handler: _Store_Put_Handler, }, { MethodName: "Get", Handler: _Store_Get_Handler, }, { MethodName: "FileInfo", Handler: _Store_FileInfo_Handler, }, { MethodName: "ReadDir", Handler: _Store_ReadDir_Handler, }, { MethodName: "CommitInfo", Handler: _Store_CommitInfo_Handler, }, { MethodName: "LatestCommit", Handler: _Store_LatestCommit_Handler, }, { MethodName: "BeginCommit", Handler: _Store_BeginCommit_Handler, }, { MethodName: "BeginSession", Handler: _Store_BeginSession_Handler, }, { MethodName: "EndSession", Handler: _Store_EndSession_Handler, }, { MethodName: "DeleteCommit", Handler: _Store_DeleteCommit_Handler, }, { MethodName: "UndeleteCommit", Handler: _Store_UndeleteCommit_Handler, }, { MethodName: "ListTrash", Handler: _Store_ListTrash_Handler, }, { MethodName: "CountCommits", Handler: _Store_CountCommits_Handler, }, { MethodName: "DeleteSet", Handler: _Store_DeleteSet_Handler, }, { MethodName: "UndeleteSet", Handler: _Store_UndeleteSet_Handler, }, { MethodName: "Unpin", Handler: _Store_Unpin_Handler, }, { MethodName: "ListPins", Handler: _Store_ListPins_Handler, }, { MethodName: "EscrowedKeys", Handler: _Store_EscrowedKeys_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ReadFile", Handler: _Store_ReadFile_Handler, ServerStreams: true, }, { StreamName: "ReadFiles", Handler: _Store_ReadFiles_Handler, ServerStreams: true, }, { StreamName: "GetTree", Handler: _Store_GetTree_Handler, ServerStreams: true, }, { StreamName: "GetPresence", Handler: _Store_GetPresence_Handler, ServerStreams: true, }, }, Metadata: "api.proto", }
Store_ServiceDesc is the grpc.ServiceDesc for Store service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func Decode ¶
func Decode(stored []byte, compression Compression) ([]byte, error)
Decode reverses Encode for any supported codec.
func DecodeVarint ¶
DecodeVarint reads a protobuf varint and the number of bytes it took; n is negative on a malformed input.
func EncodeVarint ¶
EncodeVarint appends x as a protobuf varint.
func GetOSFileInfo ¶
GetOSFileInfo presents a recorded FileInfo as an os.FileInfo whose Sys returns the FileInfo itself.
func NameFromComponent ¶
NameFromComponent reverses PathComponent.
func PathComponent ¶
PathComponent encodes a name for a slash-separated index path. Plain UTF-8 names stay readable; anything else, including name tokens of an encrypted store, is base64url with a leading "=".
func RegisterStoreServer ¶
func RegisterStoreServer(s grpc.ServiceRegistrar, srv StoreServer)
func StoredHash ¶
StoredHash is the hash every object header carries over its stored bytes.
func VerifyPayload ¶
func VerifyPayload(stored []byte, compression Compression, t ObjectType, ref *Ref) ([]byte, error)
VerifyPayload decompresses stored bytes and fails with ErrRefMismatch unless they hash to ref under type t. It returns the decompressed payload.
func VerifyStored ¶
func VerifyStored(hdr *ObjectHeader, stored []byte) error
VerifyStored checks stored bytes against their header: the stored hash when present, and the ref for objects the server can rehash. Sealed objects can only be checked by their stored hash.
Types ¶
type BeginCommitRequest ¶
type BeginCommitRequest struct {
BackupSet string `protobuf:"bytes,1,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
// contains filtered or unexported fields
}
BeginCommitRequest asks, before a backup run moves bytes, whether the caller may commit to the set.
func (*BeginCommitRequest) Descriptor
deprecated
func (*BeginCommitRequest) Descriptor() ([]byte, []int)
Deprecated: Use BeginCommitRequest.ProtoReflect.Descriptor instead.
func (*BeginCommitRequest) GetBackupSet ¶
func (x *BeginCommitRequest) GetBackupSet() string
func (*BeginCommitRequest) ProtoMessage ¶
func (*BeginCommitRequest) ProtoMessage()
func (*BeginCommitRequest) ProtoReflect ¶
func (x *BeginCommitRequest) ProtoReflect() protoreflect.Message
func (*BeginCommitRequest) Reset ¶
func (x *BeginCommitRequest) Reset()
func (*BeginCommitRequest) String ¶
func (x *BeginCommitRequest) String() string
type BeginCommitResponse ¶
type BeginCommitResponse struct {
Allowed bool `protobuf:"varint,2,opt,name=allowed,proto3" json:"allowed,omitempty"`
// why the commit was refused, empty when allowed
Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
// the store's write policy for this run; absent when the operator never
// set one, which leaves the agent's key file in charge
Policy *StorePolicy `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"`
// the run must read every file again, whatever its change detection
// says, because the store lost content it could not name a path for
Rescan bool `protobuf:"varint,5,opt,name=rescan,proto3" json:"rescan,omitempty"`
// paths whose stored content the store lost: read them again and take
// no chunk of theirs on trust
DamagedPaths []string `protobuf:"bytes,6,rep,name=damaged_paths,json=damagedPaths,proto3" json:"damaged_paths,omitempty"`
// contains filtered or unexported fields
}
func (*BeginCommitResponse) Descriptor
deprecated
func (*BeginCommitResponse) Descriptor() ([]byte, []int)
Deprecated: Use BeginCommitResponse.ProtoReflect.Descriptor instead.
func (*BeginCommitResponse) GetAllowed ¶
func (x *BeginCommitResponse) GetAllowed() bool
func (*BeginCommitResponse) GetDamagedPaths ¶
func (x *BeginCommitResponse) GetDamagedPaths() []string
func (*BeginCommitResponse) GetPolicy ¶
func (x *BeginCommitResponse) GetPolicy() *StorePolicy
func (*BeginCommitResponse) GetReason ¶
func (x *BeginCommitResponse) GetReason() string
func (*BeginCommitResponse) GetRescan ¶
func (x *BeginCommitResponse) GetRescan() bool
func (*BeginCommitResponse) ProtoMessage ¶
func (*BeginCommitResponse) ProtoMessage()
func (*BeginCommitResponse) ProtoReflect ¶
func (x *BeginCommitResponse) ProtoReflect() protoreflect.Message
func (*BeginCommitResponse) Reset ¶
func (x *BeginCommitResponse) Reset()
func (*BeginCommitResponse) String ¶
func (x *BeginCommitResponse) String() string
type BeginSessionRequest ¶
type BeginSessionRequest struct {
BackupSet string `protobuf:"bytes,1,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
// the object a restore session reads; retirement and garbage collection
// keep it and everything it names while the session lives
Restore *Ref `protobuf:"bytes,2,opt,name=restore,proto3" json:"restore,omitempty"`
// the retention policy backup_set starts with as its own if it is
// created under this session; a set that exists keeps its own
InitialRetention *RetentionPolicy `protobuf:"bytes,3,opt,name=initial_retention,json=initialRetention,proto3" json:"initial_retention,omitempty"`
// contains filtered or unexported fields
}
func (*BeginSessionRequest) Descriptor
deprecated
func (*BeginSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use BeginSessionRequest.ProtoReflect.Descriptor instead.
func (*BeginSessionRequest) GetBackupSet ¶
func (x *BeginSessionRequest) GetBackupSet() string
func (*BeginSessionRequest) GetInitialRetention ¶ added in v1.65.0
func (x *BeginSessionRequest) GetInitialRetention() *RetentionPolicy
func (*BeginSessionRequest) GetRestore ¶
func (x *BeginSessionRequest) GetRestore() *Ref
func (*BeginSessionRequest) ProtoMessage ¶
func (*BeginSessionRequest) ProtoMessage()
func (*BeginSessionRequest) ProtoReflect ¶
func (x *BeginSessionRequest) ProtoReflect() protoreflect.Message
func (*BeginSessionRequest) Reset ¶
func (x *BeginSessionRequest) Reset()
func (*BeginSessionRequest) String ¶
func (x *BeginSessionRequest) String() string
type BeginSessionResponse ¶
type BeginSessionResponse struct {
// sent as the goback-session metadata header on every call of the session
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
// how long the session survives without a call before the server drops
// what it did not commit
LeaseSeconds int64 `protobuf:"varint,2,opt,name=lease_seconds,json=leaseSeconds,proto3" json:"lease_seconds,omitempty"`
// contains filtered or unexported fields
}
func (*BeginSessionResponse) Descriptor
deprecated
func (*BeginSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use BeginSessionResponse.ProtoReflect.Descriptor instead.
func (*BeginSessionResponse) GetLeaseSeconds ¶
func (x *BeginSessionResponse) GetLeaseSeconds() int64
func (*BeginSessionResponse) GetSessionId ¶
func (x *BeginSessionResponse) GetSessionId() string
func (*BeginSessionResponse) ProtoMessage ¶
func (*BeginSessionResponse) ProtoMessage()
func (*BeginSessionResponse) ProtoReflect ¶
func (x *BeginSessionResponse) ProtoReflect() protoreflect.Message
func (*BeginSessionResponse) Reset ¶
func (x *BeginSessionResponse) Reset()
func (*BeginSessionResponse) String ¶
func (x *BeginSessionResponse) String() string
type Blob ¶
type Blob struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
// contains filtered or unexported fields
}
func (*Blob) Descriptor
deprecated
func (*Blob) ProtoMessage ¶
func (*Blob) ProtoMessage()
func (*Blob) ProtoReflect ¶
func (x *Blob) ProtoReflect() protoreflect.Message
type Chunker ¶
type Chunker int32
Chunker names the boundary function and parameters that cut a file.
const ( // FastCDC with a 16 KiB minimum, 64 KiB target and 256 KiB maximum Chunker_FASTCDC_64K Chunker = 0 )
func (Chunker) Descriptor ¶
func (Chunker) Descriptor() protoreflect.EnumDescriptor
func (Chunker) EnumDescriptor
deprecated
func (Chunker) Number ¶
func (x Chunker) Number() protoreflect.EnumNumber
func (Chunker) Type ¶
func (Chunker) Type() protoreflect.EnumType
type Commit ¶
type Commit struct {
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
Tree *Ref `protobuf:"bytes,2,opt,name=tree,proto3" json:"tree,omitempty"`
BackupSet string `protobuf:"bytes,3,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
// the commit this one was diffed against, empty for a full run
Parent *Ref `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
AgentId string `protobuf:"bytes,5,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
// agent wall time in nanoseconds at the start of the walk
ScanStartNs int64 `protobuf:"varint,6,opt,name=scan_start_ns,json=scanStartNs,proto3" json:"scan_start_ns,omitempty"`
// a checkpoint written mid-run, superseded by the final commit
Partial bool `protobuf:"varint,7,opt,name=partial,proto3" json:"partial,omitempty"`
// the store policy version the agent wrote under, 0 for no policy
PolicyVersion uint32 `protobuf:"varint,9,opt,name=policy_version,json=policyVersion,proto3" json:"policy_version,omitempty"`
// the set's id, globally unique; the receiving index assigns it on Put
// and ignores the client's value
SetId uint64 `protobuf:"varint,10,opt,name=set_id,json=setId,proto3" json:"set_id,omitempty"`
// server clock at receipt, nanoseconds since the Unix epoch; ordering,
// retention and "latest commit" use this, timestamp is display metadata
ReceivedAtNs int64 `protobuf:"varint,11,opt,name=received_at_ns,json=receivedAtNs,proto3" json:"received_at_ns,omitempty"`
// the agent's pre hook quiesced the application and no file was torn or
// unreadable; never set on a checkpoint
Consistent bool `protobuf:"varint,12,opt,name=consistent,proto3" json:"consistent,omitempty"`
// labels the agent attached; the store keeps them and never interprets them
Metadata map[string]string `` /* 144-byte string literal not displayed */
// the id of the store key names and contents were sealed under, empty
// when the commit was written plain; absent on a commit written before
// it was recorded
KeyId []byte `protobuf:"bytes,14,opt,name=key_id,json=keyId,proto3,oneof" json:"key_id,omitempty"`
// contains filtered or unexported fields
}
func (*Commit) Descriptor
deprecated
func (*Commit) GetAgentId ¶
func (*Commit) GetBackupSet ¶
func (*Commit) GetConsistent ¶
func (*Commit) GetMetadata ¶
func (*Commit) GetPartial ¶
func (*Commit) GetPolicyVersion ¶
func (*Commit) GetReceivedAtNs ¶
func (*Commit) GetScanStartNs ¶
func (*Commit) GetTimestamp ¶
func (*Commit) ProtoMessage ¶
func (*Commit) ProtoMessage()
func (*Commit) ProtoReflect ¶
func (x *Commit) ProtoReflect() protoreflect.Message
type CommitCount ¶
type CommitCount struct {
// the period's first instant
StartNs int64 `protobuf:"varint,1,opt,name=start_ns,json=startNs,proto3" json:"start_ns,omitempty"`
Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
// contains filtered or unexported fields
}
CommitCount is how many commits a period holds.
func (*CommitCount) Descriptor
deprecated
func (*CommitCount) Descriptor() ([]byte, []int)
Deprecated: Use CommitCount.ProtoReflect.Descriptor instead.
func (*CommitCount) GetCount ¶
func (x *CommitCount) GetCount() int64
func (*CommitCount) GetStartNs ¶
func (x *CommitCount) GetStartNs() int64
func (*CommitCount) ProtoMessage ¶
func (*CommitCount) ProtoMessage()
func (*CommitCount) ProtoReflect ¶
func (x *CommitCount) ProtoReflect() protoreflect.Message
func (*CommitCount) Reset ¶
func (x *CommitCount) Reset()
func (*CommitCount) String ¶
func (x *CommitCount) String() string
type CommitInfoRequest ¶
type CommitInfoRequest struct {
BackupSet string `protobuf:"bytes,1,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
NotAfter *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=notAfter,proto3" json:"notAfter,omitempty"`
Count int32 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
// contains filtered or unexported fields
}
func (*CommitInfoRequest) Descriptor
deprecated
func (*CommitInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use CommitInfoRequest.ProtoReflect.Descriptor instead.
func (*CommitInfoRequest) GetBackupSet ¶
func (x *CommitInfoRequest) GetBackupSet() string
func (*CommitInfoRequest) GetCount ¶
func (x *CommitInfoRequest) GetCount() int32
func (*CommitInfoRequest) GetNotAfter ¶
func (x *CommitInfoRequest) GetNotAfter() *timestamppb.Timestamp
func (*CommitInfoRequest) ProtoMessage ¶
func (*CommitInfoRequest) ProtoMessage()
func (*CommitInfoRequest) ProtoReflect ¶
func (x *CommitInfoRequest) ProtoReflect() protoreflect.Message
func (*CommitInfoRequest) Reset ¶
func (x *CommitInfoRequest) Reset()
func (*CommitInfoRequest) String ¶
func (x *CommitInfoRequest) String() string
type CommitInfoResponse ¶
type CommitInfoResponse struct {
Commits []*Commit `protobuf:"bytes,1,rep,name=commits,proto3" json:"commits,omitempty"`
// what the set held at each of commits, in the same order; empty when
// the store measures nothing
Sizes []*CommitSize `protobuf:"bytes,2,rep,name=sizes,proto3" json:"sizes,omitempty"`
// contains filtered or unexported fields
}
func (*CommitInfoResponse) Descriptor
deprecated
func (*CommitInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use CommitInfoResponse.ProtoReflect.Descriptor instead.
func (*CommitInfoResponse) GetCommits ¶
func (x *CommitInfoResponse) GetCommits() []*Commit
func (*CommitInfoResponse) GetSizes ¶
func (x *CommitInfoResponse) GetSizes() []*CommitSize
func (*CommitInfoResponse) ProtoMessage ¶
func (*CommitInfoResponse) ProtoMessage()
func (*CommitInfoResponse) ProtoReflect ¶
func (x *CommitInfoResponse) ProtoReflect() protoreflect.Message
func (*CommitInfoResponse) Reset ¶
func (x *CommitInfoResponse) Reset()
func (*CommitInfoResponse) String ¶
func (x *CommitInfoResponse) String() string
type CommitScope ¶
type CommitScope struct {
Commit *Ref `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
// when it was moved to the trash; 0 when it is not there
DeletedAtNs int64 `protobuf:"varint,2,opt,name=deleted_at_ns,json=deletedAtNs,proto3" json:"deleted_at_ns,omitempty"`
// contains filtered or unexported fields
}
CommitScope is whether a commit is in the trash.
func (*CommitScope) Descriptor
deprecated
func (*CommitScope) Descriptor() ([]byte, []int)
Deprecated: Use CommitScope.ProtoReflect.Descriptor instead.
func (*CommitScope) GetCommit ¶
func (x *CommitScope) GetCommit() *Ref
func (*CommitScope) GetDeletedAtNs ¶
func (x *CommitScope) GetDeletedAtNs() int64
func (*CommitScope) ProtoMessage ¶
func (*CommitScope) ProtoMessage()
func (*CommitScope) ProtoReflect ¶
func (x *CommitScope) ProtoReflect() protoreflect.Message
func (*CommitScope) Reset ¶
func (x *CommitScope) Reset()
func (*CommitScope) String ¶
func (x *CommitScope) String() string
type CommitSize ¶
type CommitSize struct {
// the size of every file, before deduplication and compression;
// absent for a commit the store has not measured
LogicalBytes *int64 `protobuf:"varint,1,opt,name=logical_bytes,json=logicalBytes,proto3,oneof" json:"logical_bytes,omitempty"`
// how many files there were, absent likewise
Files *int64 `protobuf:"varint,2,opt,name=files,proto3,oneof" json:"files,omitempty"`
// contains filtered or unexported fields
}
CommitSize is how big a set was at one commit, as the store measured it.
func (*CommitSize) Descriptor
deprecated
func (*CommitSize) Descriptor() ([]byte, []int)
Deprecated: Use CommitSize.ProtoReflect.Descriptor instead.
func (*CommitSize) GetFiles ¶
func (x *CommitSize) GetFiles() int64
func (*CommitSize) GetLogicalBytes ¶
func (x *CommitSize) GetLogicalBytes() int64
func (*CommitSize) ProtoMessage ¶
func (*CommitSize) ProtoMessage()
func (*CommitSize) ProtoReflect ¶
func (x *CommitSize) ProtoReflect() protoreflect.Message
func (*CommitSize) Reset ¶
func (x *CommitSize) Reset()
func (*CommitSize) String ¶
func (x *CommitSize) String() string
type Compression ¶
type Compression int32
const ( Compression_NONE Compression = 0 Compression_ZSTD Compression = 2 )
func Encode ¶
func Encode(payload []byte) ([]byte, Compression)
Encode compresses a payload for storage and reports the codec used; it stores the payload as is when compression does not make it smaller.
func (Compression) Descriptor ¶
func (Compression) Descriptor() protoreflect.EnumDescriptor
func (Compression) Enum ¶
func (x Compression) Enum() *Compression
func (Compression) EnumDescriptor
deprecated
func (Compression) EnumDescriptor() ([]byte, []int)
Deprecated: Use Compression.Descriptor instead.
func (Compression) Number ¶
func (x Compression) Number() protoreflect.EnumNumber
func (Compression) String ¶
func (x Compression) String() string
func (Compression) Type ¶
func (Compression) Type() protoreflect.EnumType
type CountCommitsRequest ¶
type CountCommitsRequest struct {
BackupSet string `protobuf:"bytes,1,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
Period Period `protobuf:"varint,2,opt,name=period,proto3,enum=proto.Period" json:"period,omitempty"`
// the receipt range counted: from_ns inclusive, to_ns exclusive
FromNs int64 `protobuf:"varint,3,opt,name=from_ns,json=fromNs,proto3" json:"from_ns,omitempty"`
ToNs int64 `protobuf:"varint,4,opt,name=to_ns,json=toNs,proto3" json:"to_ns,omitempty"`
// IANA name the periods fall in; empty for UTC
TimeZone string `protobuf:"bytes,5,opt,name=time_zone,json=timeZone,proto3" json:"time_zone,omitempty"`
// count the deleted commits UndeleteCommit can still bring back
// instead of the live ones
Deleted bool `protobuf:"varint,6,opt,name=deleted,proto3" json:"deleted,omitempty"`
// contains filtered or unexported fields
}
func (*CountCommitsRequest) Descriptor
deprecated
func (*CountCommitsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CountCommitsRequest.ProtoReflect.Descriptor instead.
func (*CountCommitsRequest) GetBackupSet ¶
func (x *CountCommitsRequest) GetBackupSet() string
func (*CountCommitsRequest) GetDeleted ¶
func (x *CountCommitsRequest) GetDeleted() bool
func (*CountCommitsRequest) GetFromNs ¶
func (x *CountCommitsRequest) GetFromNs() int64
func (*CountCommitsRequest) GetPeriod ¶
func (x *CountCommitsRequest) GetPeriod() Period
func (*CountCommitsRequest) GetTimeZone ¶
func (x *CountCommitsRequest) GetTimeZone() string
func (*CountCommitsRequest) GetToNs ¶
func (x *CountCommitsRequest) GetToNs() int64
func (*CountCommitsRequest) ProtoMessage ¶
func (*CountCommitsRequest) ProtoMessage()
func (*CountCommitsRequest) ProtoReflect ¶
func (x *CountCommitsRequest) ProtoReflect() protoreflect.Message
func (*CountCommitsRequest) Reset ¶
func (x *CountCommitsRequest) Reset()
func (*CountCommitsRequest) String ¶
func (x *CountCommitsRequest) String() string
type CountCommitsResponse ¶
type CountCommitsResponse struct {
// the non-empty periods, oldest first
Counts []*CommitCount `protobuf:"bytes,1,rep,name=counts,proto3" json:"counts,omitempty"`
// contains filtered or unexported fields
}
func (*CountCommitsResponse) Descriptor
deprecated
func (*CountCommitsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CountCommitsResponse.ProtoReflect.Descriptor instead.
func (*CountCommitsResponse) GetCounts ¶
func (x *CountCommitsResponse) GetCounts() []*CommitCount
func (*CountCommitsResponse) ProtoMessage ¶
func (*CountCommitsResponse) ProtoMessage()
func (*CountCommitsResponse) ProtoReflect ¶
func (x *CountCommitsResponse) ProtoReflect() protoreflect.Message
func (*CountCommitsResponse) Reset ¶
func (x *CountCommitsResponse) Reset()
func (*CountCommitsResponse) String ¶
func (x *CountCommitsResponse) String() string
type DeleteCommitRequest ¶
type DeleteCommitRequest struct {
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteCommitRequest) Descriptor
deprecated
func (*DeleteCommitRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCommitRequest.ProtoReflect.Descriptor instead.
func (*DeleteCommitRequest) GetRef ¶
func (x *DeleteCommitRequest) GetRef() *Ref
func (*DeleteCommitRequest) ProtoMessage ¶
func (*DeleteCommitRequest) ProtoMessage()
func (*DeleteCommitRequest) ProtoReflect ¶
func (x *DeleteCommitRequest) ProtoReflect() protoreflect.Message
func (*DeleteCommitRequest) Reset ¶
func (x *DeleteCommitRequest) Reset()
func (*DeleteCommitRequest) String ¶
func (x *DeleteCommitRequest) String() string
type DeleteCommitResponse ¶
type DeleteCommitResponse struct {
// contains filtered or unexported fields
}
func (*DeleteCommitResponse) Descriptor
deprecated
func (*DeleteCommitResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCommitResponse.ProtoReflect.Descriptor instead.
func (*DeleteCommitResponse) ProtoMessage ¶
func (*DeleteCommitResponse) ProtoMessage()
func (*DeleteCommitResponse) ProtoReflect ¶
func (x *DeleteCommitResponse) ProtoReflect() protoreflect.Message
func (*DeleteCommitResponse) Reset ¶
func (x *DeleteCommitResponse) Reset()
func (*DeleteCommitResponse) String ¶
func (x *DeleteCommitResponse) String() string
type DeleteSetRequest ¶
type DeleteSetRequest struct {
BackupSet string `protobuf:"bytes,1,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
// erase uses a zero window: the commits are tombstoned by the next
// retirement run
Erase bool `protobuf:"varint,2,opt,name=erase,proto3" json:"erase,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteSetRequest) Descriptor
deprecated
func (*DeleteSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSetRequest.ProtoReflect.Descriptor instead.
func (*DeleteSetRequest) GetBackupSet ¶
func (x *DeleteSetRequest) GetBackupSet() string
func (*DeleteSetRequest) GetErase ¶
func (x *DeleteSetRequest) GetErase() bool
func (*DeleteSetRequest) ProtoMessage ¶
func (*DeleteSetRequest) ProtoMessage()
func (*DeleteSetRequest) ProtoReflect ¶
func (x *DeleteSetRequest) ProtoReflect() protoreflect.Message
func (*DeleteSetRequest) Reset ¶
func (x *DeleteSetRequest) Reset()
func (*DeleteSetRequest) String ¶
func (x *DeleteSetRequest) String() string
type DeleteSetResponse ¶
type DeleteSetResponse struct {
// contains filtered or unexported fields
}
func (*DeleteSetResponse) Descriptor
deprecated
func (*DeleteSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSetResponse.ProtoReflect.Descriptor instead.
func (*DeleteSetResponse) ProtoMessage ¶
func (*DeleteSetResponse) ProtoMessage()
func (*DeleteSetResponse) ProtoReflect ¶
func (x *DeleteSetResponse) ProtoReflect() protoreflect.Message
func (*DeleteSetResponse) Reset ¶
func (x *DeleteSetResponse) Reset()
func (*DeleteSetResponse) String ¶
func (x *DeleteSetResponse) String() string
type Encryption ¶
type Encryption int32
Encryption says how a blob's stored bytes or a file's inline content are sealed. Structure objects are never sealed as a whole.
const ( Encryption_PLAINTEXT Encryption = 0 // deterministic AEAD under the store key Encryption_SEALED Encryption = 3 )
func (Encryption) Descriptor ¶
func (Encryption) Descriptor() protoreflect.EnumDescriptor
func (Encryption) Enum ¶
func (x Encryption) Enum() *Encryption
func (Encryption) EnumDescriptor
deprecated
func (Encryption) EnumDescriptor() ([]byte, []int)
Deprecated: Use Encryption.Descriptor instead.
func (Encryption) Number ¶
func (x Encryption) Number() protoreflect.EnumNumber
func (Encryption) String ¶
func (x Encryption) String() string
func (Encryption) Type ¶
func (Encryption) Type() protoreflect.EnumType
type EndSessionRequest ¶
type EndSessionRequest struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
// contains filtered or unexported fields
}
EndSessionRequest drops whatever the session has not committed
func (*EndSessionRequest) Descriptor
deprecated
func (*EndSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use EndSessionRequest.ProtoReflect.Descriptor instead.
func (*EndSessionRequest) GetSessionId ¶
func (x *EndSessionRequest) GetSessionId() string
func (*EndSessionRequest) ProtoMessage ¶
func (*EndSessionRequest) ProtoMessage()
func (*EndSessionRequest) ProtoReflect ¶
func (x *EndSessionRequest) ProtoReflect() protoreflect.Message
func (*EndSessionRequest) Reset ¶
func (x *EndSessionRequest) Reset()
func (*EndSessionRequest) String ¶
func (x *EndSessionRequest) String() string
type EndSessionResponse ¶
type EndSessionResponse struct {
// contains filtered or unexported fields
}
func (*EndSessionResponse) Descriptor
deprecated
func (*EndSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use EndSessionResponse.ProtoReflect.Descriptor instead.
func (*EndSessionResponse) ProtoMessage ¶
func (*EndSessionResponse) ProtoMessage()
func (*EndSessionResponse) ProtoReflect ¶
func (x *EndSessionResponse) ProtoReflect() protoreflect.Message
func (*EndSessionResponse) Reset ¶
func (x *EndSessionResponse) Reset()
func (*EndSessionResponse) String ¶
func (x *EndSessionResponse) String() string
type EscrowedKey ¶
type EscrowedKey struct {
KeyId string `protobuf:"bytes,1,opt,name=key_id,json=keyId,proto3" json:"key_id,omitempty"`
Escrowed []byte `protobuf:"bytes,2,opt,name=escrowed,proto3" json:"escrowed,omitempty"`
// contains filtered or unexported fields
}
EscrowedKey is the store key escrowed under a passphrase, as goback key escrow prints it; the store keeps it without being able to open it.
func (*EscrowedKey) Descriptor
deprecated
func (*EscrowedKey) Descriptor() ([]byte, []int)
Deprecated: Use EscrowedKey.ProtoReflect.Descriptor instead.
func (*EscrowedKey) GetEscrowed ¶
func (x *EscrowedKey) GetEscrowed() []byte
func (*EscrowedKey) GetKeyId ¶
func (x *EscrowedKey) GetKeyId() string
func (*EscrowedKey) ProtoMessage ¶
func (*EscrowedKey) ProtoMessage()
func (*EscrowedKey) ProtoReflect ¶
func (x *EscrowedKey) ProtoReflect() protoreflect.Message
func (*EscrowedKey) Reset ¶
func (x *EscrowedKey) Reset()
func (*EscrowedKey) String ¶
func (x *EscrowedKey) String() string
type EscrowedKeysRequest ¶
type EscrowedKeysRequest struct {
// contains filtered or unexported fields
}
func (*EscrowedKeysRequest) Descriptor
deprecated
func (*EscrowedKeysRequest) Descriptor() ([]byte, []int)
Deprecated: Use EscrowedKeysRequest.ProtoReflect.Descriptor instead.
func (*EscrowedKeysRequest) ProtoMessage ¶
func (*EscrowedKeysRequest) ProtoMessage()
func (*EscrowedKeysRequest) ProtoReflect ¶
func (x *EscrowedKeysRequest) ProtoReflect() protoreflect.Message
func (*EscrowedKeysRequest) Reset ¶
func (x *EscrowedKeysRequest) Reset()
func (*EscrowedKeysRequest) String ¶
func (x *EscrowedKeysRequest) String() string
type EscrowedKeysResponse ¶
type EscrowedKeysResponse struct {
Keys []*EscrowedKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
// contains filtered or unexported fields
}
func (*EscrowedKeysResponse) Descriptor
deprecated
func (*EscrowedKeysResponse) Descriptor() ([]byte, []int)
Deprecated: Use EscrowedKeysResponse.ProtoReflect.Descriptor instead.
func (*EscrowedKeysResponse) GetKeys ¶
func (x *EscrowedKeysResponse) GetKeys() []*EscrowedKey
func (*EscrowedKeysResponse) ProtoMessage ¶
func (*EscrowedKeysResponse) ProtoMessage()
func (*EscrowedKeysResponse) ProtoReflect ¶
func (x *EscrowedKeysResponse) ProtoReflect() protoreflect.Message
func (*EscrowedKeysResponse) Reset ¶
func (x *EscrowedKeysResponse) Reset()
func (*EscrowedKeysResponse) String ¶
func (x *EscrowedKeysResponse) String() string
type File ¶
type File struct {
// an ordered list of file parts
Parts []*FilePart `protobuf:"bytes,1,rep,name=parts,proto3" json:"parts,omitempty"`
// an ordered list of references to other file objects, which together
// hold the file's parts
Splits []*Ref `protobuf:"bytes,2,rep,name=splits,proto3" json:"splits,omitempty"`
// the chunker that cut the parts
Chunker Chunker `protobuf:"varint,3,opt,name=chunker,proto3,enum=proto.Chunker" json:"chunker,omitempty"`
// the whole content of a small file, stored without a blob; sealed
// under the store key when the store is encrypted
Inline []byte `protobuf:"bytes,4,opt,name=inline,proto3" json:"inline,omitempty"`
// how inline is stored
InlineEncryption Encryption `` /* 132-byte string literal not displayed */
// the content bytes under each split, in order, so a read finds the
// split holding an offset without loading the others; absent in a file
// written before splits were measured
SplitLengths []uint64 `protobuf:"varint,7,rep,packed,name=split_lengths,json=splitLengths,proto3" json:"split_lengths,omitempty"`
// how many levels of splits lie below this one: 1 when the splits hold
// parts, more when they are split themselves; 0 without split_lengths
SplitDepth uint32 `protobuf:"varint,8,opt,name=split_depth,json=splitDepth,proto3" json:"split_depth,omitempty"`
// contains filtered or unexported fields
}
func (*File) Descriptor
deprecated
func (*File) GetChunker ¶
func (*File) GetInlineEncryption ¶
func (x *File) GetInlineEncryption() Encryption
func (*File) GetSplitDepth ¶
func (*File) GetSplitLengths ¶
func (*File) ProtoMessage ¶
func (*File) ProtoMessage()
func (*File) ProtoReflect ¶
func (x *File) ProtoReflect() protoreflect.Message
type FileInfo ¶
type FileInfo struct {
Name []byte `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Mode uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
User []byte `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
Group []byte `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"`
Size int64 `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
// modification time in nanoseconds since the Unix epoch
MtimeNs int64 `protobuf:"varint,8,opt,name=mtime_ns,json=mtimeNs,proto3" json:"mtime_ns,omitempty"`
Type NodeType `protobuf:"varint,9,opt,name=type,proto3,enum=proto.NodeType" json:"type,omitempty"`
// the target of a symlink, empty for every other type
LinkTarget []byte `protobuf:"bytes,10,opt,name=link_target,json=linkTarget,proto3" json:"link_target,omitempty"`
// contains filtered or unexported fields
}
this contains file metadata, which can be different accross backups, even if file content is the same Name, user, group and link_target are plaintext bytes in an unencrypted store and deterministic tokens under the store key otherwise.
func GetFileInfo ¶
GetFileInfo converts stat data into a FileInfo. Owner names and the symlink target come from a FileInfo returned by Sys(), as WithDetails and GetOSFileInfo arrange.
func (*FileInfo) Descriptor
deprecated
func (*FileInfo) GetLinkTarget ¶
func (*FileInfo) GetMtimeNs ¶
func (*FileInfo) ProtoMessage ¶
func (*FileInfo) ProtoMessage()
func (*FileInfo) ProtoReflect ¶
func (x *FileInfo) ProtoReflect() protoreflect.Message
type FileInfoRequest ¶
type FileInfoRequest struct {
BackupSet string `protobuf:"bytes,1,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
NotAfter *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=notAfter,proto3" json:"notAfter,omitempty"`
Count int32 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
// contains filtered or unexported fields
}
func (*FileInfoRequest) Descriptor
deprecated
func (*FileInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use FileInfoRequest.ProtoReflect.Descriptor instead.
func (*FileInfoRequest) GetBackupSet ¶
func (x *FileInfoRequest) GetBackupSet() string
func (*FileInfoRequest) GetCount ¶
func (x *FileInfoRequest) GetCount() int32
func (*FileInfoRequest) GetNotAfter ¶
func (x *FileInfoRequest) GetNotAfter() *timestamppb.Timestamp
func (*FileInfoRequest) GetPath ¶
func (x *FileInfoRequest) GetPath() string
func (*FileInfoRequest) ProtoMessage ¶
func (*FileInfoRequest) ProtoMessage()
func (*FileInfoRequest) ProtoReflect ¶
func (x *FileInfoRequest) ProtoReflect() protoreflect.Message
func (*FileInfoRequest) Reset ¶
func (x *FileInfoRequest) Reset()
func (*FileInfoRequest) String ¶
func (x *FileInfoRequest) String() string
type FileInfoResponse ¶
type FileInfoResponse struct {
Files []*TreeNode `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
// contains filtered or unexported fields
}
func (*FileInfoResponse) Descriptor
deprecated
func (*FileInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use FileInfoResponse.ProtoReflect.Descriptor instead.
func (*FileInfoResponse) GetFiles ¶
func (x *FileInfoResponse) GetFiles() []*TreeNode
func (*FileInfoResponse) ProtoMessage ¶
func (*FileInfoResponse) ProtoMessage()
func (*FileInfoResponse) ProtoReflect ¶
func (x *FileInfoResponse) ProtoReflect() protoreflect.Message
func (*FileInfoResponse) Reset ¶
func (x *FileInfoResponse) Reset()
func (*FileInfoResponse) String ¶
func (x *FileInfoResponse) String() string
type FilePart ¶
type FilePart struct {
Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
Length uint64 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
Ref *Ref `protobuf:"bytes,3,opt,name=ref,proto3" json:"ref,omitempty"`
// contains filtered or unexported fields
}
func (*FilePart) Descriptor
deprecated
func (*FilePart) ProtoMessage ¶
func (*FilePart) ProtoMessage()
func (*FilePart) ProtoReflect ¶
func (x *FilePart) ProtoReflect() protoreflect.Message
type GetPresenceRequest ¶
type GetPresenceRequest struct {
// the set whose filter is wanted when the scope is the set
BackupSet string `protobuf:"bytes,1,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
// contains filtered or unexported fields
}
func (*GetPresenceRequest) Descriptor
deprecated
func (*GetPresenceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPresenceRequest.ProtoReflect.Descriptor instead.
func (*GetPresenceRequest) GetBackupSet ¶
func (x *GetPresenceRequest) GetBackupSet() string
func (*GetPresenceRequest) ProtoMessage ¶
func (*GetPresenceRequest) ProtoMessage()
func (*GetPresenceRequest) ProtoReflect ¶
func (x *GetPresenceRequest) ProtoReflect() protoreflect.Message
func (*GetPresenceRequest) Reset ¶
func (x *GetPresenceRequest) Reset()
func (*GetPresenceRequest) String ¶
func (x *GetPresenceRequest) String() string
type GetPresenceResponse ¶
type GetPresenceResponse struct {
Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
Filter *PresenceFilter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
// contains filtered or unexported fields
}
GetPresenceResponse carries one filter of the caller's scope in pieces: messages with the same index concatenate their data.
func (*GetPresenceResponse) Descriptor
deprecated
func (*GetPresenceResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetPresenceResponse.ProtoReflect.Descriptor instead.
func (*GetPresenceResponse) GetFilter ¶
func (x *GetPresenceResponse) GetFilter() *PresenceFilter
func (*GetPresenceResponse) GetIndex ¶
func (x *GetPresenceResponse) GetIndex() uint32
func (*GetPresenceResponse) ProtoMessage ¶
func (*GetPresenceResponse) ProtoMessage()
func (*GetPresenceResponse) ProtoReflect ¶
func (x *GetPresenceResponse) ProtoReflect() protoreflect.Message
func (*GetPresenceResponse) Reset ¶
func (x *GetPresenceResponse) Reset()
func (*GetPresenceResponse) String ¶
func (x *GetPresenceResponse) String() string
type GetRequest ¶
type GetRequest struct {
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
// contains filtered or unexported fields
}
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetRef ¶
func (x *GetRequest) GetRef() *Ref
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) String ¶
func (x *GetRequest) String() string
type GetResponse ¶
type GetResponse struct {
// a store that can address its bytes answers where they are, and one
// that cannot serves them
//
// Types that are valid to be assigned to Body:
//
// *GetResponse_Object
// *GetResponse_Location
Body isGetResponse_Body `protobuf_oneof:"body"`
// contains filtered or unexported fields
}
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetBody ¶
func (x *GetResponse) GetBody() isGetResponse_Body
func (*GetResponse) GetLocation ¶
func (x *GetResponse) GetLocation() *Location
func (*GetResponse) GetObject ¶
func (x *GetResponse) GetObject() *Object
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) String ¶
func (x *GetResponse) String() string
type GetResponse_Location ¶
type GetResponse_Location struct {
Location *Location `protobuf:"bytes,2,opt,name=location,proto3,oneof"`
}
type GetResponse_Object ¶
type GetResponse_Object struct {
Object *Object `protobuf:"bytes,1,opt,name=object,proto3,oneof"`
}
type GetTreeRequest ¶
type GetTreeRequest struct {
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
// how many directory levels below ref to include; 0 means only ref
MaxDepth uint32 `protobuf:"varint,2,opt,name=max_depth,json=maxDepth,proto3" json:"max_depth,omitempty"`
// contains filtered or unexported fields
}
func (*GetTreeRequest) Descriptor
deprecated
func (*GetTreeRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTreeRequest.ProtoReflect.Descriptor instead.
func (*GetTreeRequest) GetMaxDepth ¶
func (x *GetTreeRequest) GetMaxDepth() uint32
func (*GetTreeRequest) GetRef ¶
func (x *GetTreeRequest) GetRef() *Ref
func (*GetTreeRequest) ProtoMessage ¶
func (*GetTreeRequest) ProtoMessage()
func (*GetTreeRequest) ProtoReflect ¶
func (x *GetTreeRequest) ProtoReflect() protoreflect.Message
func (*GetTreeRequest) Reset ¶
func (x *GetTreeRequest) Reset()
func (*GetTreeRequest) String ¶
func (x *GetTreeRequest) String() string
type GetTreeResponse ¶
type GetTreeResponse struct {
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
Object *Object `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
Runs []*LocatedRun `protobuf:"bytes,3,rep,name=runs,proto3" json:"runs,omitempty"`
// contains filtered or unexported fields
}
GetTreeResponse carries either one tree object or runs of trees whose stored records the client fetches itself; a record's index is the tree's place in the walk.
func (*GetTreeResponse) Descriptor
deprecated
func (*GetTreeResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTreeResponse.ProtoReflect.Descriptor instead.
func (*GetTreeResponse) GetObject ¶
func (x *GetTreeResponse) GetObject() *Object
func (*GetTreeResponse) GetRef ¶
func (x *GetTreeResponse) GetRef() *Ref
func (*GetTreeResponse) GetRuns ¶
func (x *GetTreeResponse) GetRuns() []*LocatedRun
func (*GetTreeResponse) ProtoMessage ¶
func (*GetTreeResponse) ProtoMessage()
func (*GetTreeResponse) ProtoReflect ¶
func (x *GetTreeResponse) ProtoReflect() protoreflect.Message
func (*GetTreeResponse) Reset ¶
func (x *GetTreeResponse) Reset()
func (*GetTreeResponse) String ¶
func (x *GetTreeResponse) String() string
type LatestCommitRequest ¶
type LatestCommitRequest struct {
BackupSet string `protobuf:"bytes,1,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
// contains filtered or unexported fields
}
func (*LatestCommitRequest) Descriptor
deprecated
func (*LatestCommitRequest) Descriptor() ([]byte, []int)
Deprecated: Use LatestCommitRequest.ProtoReflect.Descriptor instead.
func (*LatestCommitRequest) GetBackupSet ¶
func (x *LatestCommitRequest) GetBackupSet() string
func (*LatestCommitRequest) ProtoMessage ¶
func (*LatestCommitRequest) ProtoMessage()
func (*LatestCommitRequest) ProtoReflect ¶
func (x *LatestCommitRequest) ProtoReflect() protoreflect.Message
func (*LatestCommitRequest) Reset ¶
func (x *LatestCommitRequest) Reset()
func (*LatestCommitRequest) String ¶
func (x *LatestCommitRequest) String() string
type LatestCommitResponse ¶
type LatestCommitResponse struct {
// empty when the set has no commit
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
// contains filtered or unexported fields
}
func (*LatestCommitResponse) Descriptor
deprecated
func (*LatestCommitResponse) Descriptor() ([]byte, []int)
Deprecated: Use LatestCommitResponse.ProtoReflect.Descriptor instead.
func (*LatestCommitResponse) GetRef ¶
func (x *LatestCommitResponse) GetRef() *Ref
func (*LatestCommitResponse) ProtoMessage ¶
func (*LatestCommitResponse) ProtoMessage()
func (*LatestCommitResponse) ProtoReflect ¶
func (x *LatestCommitResponse) ProtoReflect() protoreflect.Message
func (*LatestCommitResponse) Reset ¶
func (x *LatestCommitResponse) Reset()
func (*LatestCommitResponse) String ¶
func (x *LatestCommitResponse) String() string
type ListPinsRequest ¶
type ListPinsRequest struct {
// contains filtered or unexported fields
}
func (*ListPinsRequest) Descriptor
deprecated
func (*ListPinsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListPinsRequest.ProtoReflect.Descriptor instead.
func (*ListPinsRequest) ProtoMessage ¶
func (*ListPinsRequest) ProtoMessage()
func (*ListPinsRequest) ProtoReflect ¶
func (x *ListPinsRequest) ProtoReflect() protoreflect.Message
func (*ListPinsRequest) Reset ¶
func (x *ListPinsRequest) Reset()
func (*ListPinsRequest) String ¶
func (x *ListPinsRequest) String() string
type ListPinsResponse ¶
type ListPinsResponse struct {
Pins []*PinInfo `protobuf:"bytes,1,rep,name=pins,proto3" json:"pins,omitempty"`
// contains filtered or unexported fields
}
func (*ListPinsResponse) Descriptor
deprecated
func (*ListPinsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListPinsResponse.ProtoReflect.Descriptor instead.
func (*ListPinsResponse) GetPins ¶
func (x *ListPinsResponse) GetPins() []*PinInfo
func (*ListPinsResponse) ProtoMessage ¶
func (*ListPinsResponse) ProtoMessage()
func (*ListPinsResponse) ProtoReflect ¶
func (x *ListPinsResponse) ProtoReflect() protoreflect.Message
func (*ListPinsResponse) Reset ¶
func (x *ListPinsResponse) Reset()
func (*ListPinsResponse) String ¶
func (x *ListPinsResponse) String() string
type ListTrashRequest ¶
type ListTrashRequest struct {
BackupSet string `protobuf:"bytes,1,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
// only commits deleted before this instant; 0 for the newest
BeforeNs int64 `protobuf:"varint,2,opt,name=before_ns,json=beforeNs,proto3" json:"before_ns,omitempty"`
// at most this many, and then the rest deleted at the last one's
// instant; 0 for all
Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
// contains filtered or unexported fields
}
func (*ListTrashRequest) Descriptor
deprecated
func (*ListTrashRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListTrashRequest.ProtoReflect.Descriptor instead.
func (*ListTrashRequest) GetBackupSet ¶
func (x *ListTrashRequest) GetBackupSet() string
func (*ListTrashRequest) GetBeforeNs ¶
func (x *ListTrashRequest) GetBeforeNs() int64
func (*ListTrashRequest) GetLimit ¶
func (x *ListTrashRequest) GetLimit() int32
func (*ListTrashRequest) ProtoMessage ¶
func (*ListTrashRequest) ProtoMessage()
func (*ListTrashRequest) ProtoReflect ¶
func (x *ListTrashRequest) ProtoReflect() protoreflect.Message
func (*ListTrashRequest) Reset ¶
func (x *ListTrashRequest) Reset()
func (*ListTrashRequest) String ¶
func (x *ListTrashRequest) String() string
type ListTrashResponse ¶
type ListTrashResponse struct {
// newest deleted first
Commits []*TrashedCommit `protobuf:"bytes,1,rep,name=commits,proto3" json:"commits,omitempty"`
// contains filtered or unexported fields
}
func (*ListTrashResponse) Descriptor
deprecated
func (*ListTrashResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListTrashResponse.ProtoReflect.Descriptor instead.
func (*ListTrashResponse) GetCommits ¶
func (x *ListTrashResponse) GetCommits() []*TrashedCommit
func (*ListTrashResponse) ProtoMessage ¶
func (*ListTrashResponse) ProtoMessage()
func (*ListTrashResponse) ProtoReflect ¶
func (x *ListTrashResponse) ProtoReflect() protoreflect.Message
func (*ListTrashResponse) Reset ¶
func (x *ListTrashResponse) Reset()
func (*ListTrashResponse) String ¶
func (x *ListTrashResponse) String() string
type LocatedRecord ¶
type LocatedRecord struct {
Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
Length int64 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
File uint32 `protobuf:"varint,4,opt,name=file,proto3" json:"file,omitempty"`
// contains filtered or unexported fields
}
LocatedRecord is where one object's stored record sits in the body of a run; index names the object to whoever asked for the run, and in a ReadFiles answer file names the file whose part index it is.
func (*LocatedRecord) Descriptor
deprecated
func (*LocatedRecord) Descriptor() ([]byte, []int)
Deprecated: Use LocatedRecord.ProtoReflect.Descriptor instead.
func (*LocatedRecord) GetFile ¶
func (x *LocatedRecord) GetFile() uint32
func (*LocatedRecord) GetIndex ¶
func (x *LocatedRecord) GetIndex() uint32
func (*LocatedRecord) GetLength ¶
func (x *LocatedRecord) GetLength() int64
func (*LocatedRecord) GetOffset ¶
func (x *LocatedRecord) GetOffset() int64
func (*LocatedRecord) ProtoMessage ¶
func (*LocatedRecord) ProtoMessage()
func (*LocatedRecord) ProtoReflect ¶
func (x *LocatedRecord) ProtoReflect() protoreflect.Message
func (*LocatedRecord) Reset ¶
func (x *LocatedRecord) Reset()
func (*LocatedRecord) String ¶
func (x *LocatedRecord) String() string
type LocatedRun ¶
type LocatedRun struct {
Location *Location `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
Records []*LocatedRecord `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
// contains filtered or unexported fields
}
LocatedRun is a location whose body holds the stored records of several objects, each at its offset into the body.
func (*LocatedRun) Descriptor
deprecated
func (*LocatedRun) Descriptor() ([]byte, []int)
Deprecated: Use LocatedRun.ProtoReflect.Descriptor instead.
func (*LocatedRun) GetLocation ¶
func (x *LocatedRun) GetLocation() *Location
func (*LocatedRun) GetRecords ¶
func (x *LocatedRun) GetRecords() []*LocatedRecord
func (*LocatedRun) ProtoMessage ¶
func (*LocatedRun) ProtoMessage()
func (*LocatedRun) ProtoReflect ¶
func (x *LocatedRun) ProtoReflect() protoreflect.Message
func (*LocatedRun) Reset ¶
func (x *LocatedRun) Reset()
func (*LocatedRun) String ¶
func (x *LocatedRun) String() string
type Location ¶
type Location struct {
Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
// header must be sent with the request, verbatim
Header map[string]string `` /* 139-byte string literal not displayed */
Length int64 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
Expires *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires,proto3" json:"expires,omitempty"`
// at_rest_key opens the record when it is sealed at rest: a Tink
// keyset for its archive alone
AtRestKey []byte `protobuf:"bytes,5,opt,name=at_rest_key,json=atRestKey,proto3" json:"at_rest_key,omitempty"`
// contains filtered or unexported fields
}
Location is a plain GET whose body is one object's stored record. It is minted to be used at once and expires quickly.
func (*Location) Descriptor
deprecated
func (*Location) GetAtRestKey ¶
func (*Location) GetExpires ¶
func (x *Location) GetExpires() *timestamppb.Timestamp
func (*Location) ProtoMessage ¶
func (*Location) ProtoMessage()
func (*Location) ProtoReflect ¶
func (x *Location) ProtoReflect() protoreflect.Message
type NodeType ¶
type NodeType int32
NodeType says what kind of filesystem entry a tree node describes.
func NodeTypeOf ¶
NodeTypeOf maps a file mode to the node type recorded in a tree.
func (NodeType) Descriptor ¶
func (NodeType) Descriptor() protoreflect.EnumDescriptor
func (NodeType) EnumDescriptor
deprecated
func (NodeType) Number ¶
func (x NodeType) Number() protoreflect.EnumNumber
func (NodeType) Type ¶
func (NodeType) Type() protoreflect.EnumType
type Object ¶
type Object struct {
// Types that are valid to be assigned to Object:
//
// *Object_Commit
// *Object_Tree
// *Object_File
// *Object_Blob
// *Object_Sealed
// *Object_Pin
// *Object_Policy
Object isObject_Object `protobuf_oneof:"object"`
// the store key under which a tree's names or a file's part keys are
// encrypted; transport only, never part of the hashed payload
KeyId []byte `protobuf:"bytes,10,opt,name=key_id,json=keyId,proto3" json:"key_id,omitempty"`
// contains filtered or unexported fields
}
func NewObject ¶
func NewObject(in interface{}) *Object
NewObject wraps a Commit, Tree, Blob, File, Sealed, Pin or Policy; it panics on anything else.
func NewObjectFromBytes ¶
NewObjectFromBytes decodes an Object wrapper written by Object.Bytes.
func NewObjectFromPayload ¶
func NewObjectFromPayload(payload []byte, t ObjectType) (*Object, error)
NewObjectFromPayload decodes a stored payload of the given type.
func NewVerifiedObject ¶
func NewVerifiedObject(stored []byte, compression Compression, t ObjectType, ref *Ref) (*Object, error)
NewVerifiedObject decodes stored bytes after checking them against ref.
func ObjectFromStored ¶
func ObjectFromStored(hdr *ObjectHeader, stored []byte) (*Object, error)
ObjectFromStored decodes stored bytes after VerifyStored. A sealed object comes back as is, for the holder of the key to open.
func (*Object) Bytes ¶
Bytes marshals the Object wrapper; it is a transport encoding, not the hashed payload (see Canonical).
func (*Object) Canonical ¶
Canonical returns the payload that is hashed and stored for the object: the raw chunk for a blob, and the canonical protowire encoding of the inner message for everything else.
func (*Object) Descriptor
deprecated
func (*Object) ProtoMessage ¶
func (*Object) ProtoMessage()
func (*Object) ProtoReflect ¶
func (x *Object) ProtoReflect() protoreflect.Message
func (*Object) ReceivedAtNs ¶
ReceivedAtNs is the server receipt time of a commit or pin, 0 for every other object and for one the server has not stamped yet.
func (*Object) Ref ¶
Ref computes the object's ref, or returns the carried ref of a sealed object. It panics on an object that cannot be canonically encoded; use Canonical to get the error instead.
func (*Object) Stamp ¶
Stamp records the server receipt time on a commit or pin, and the set id on a commit. It does nothing for other objects.
func (*Object) Type ¶
func (o *Object) Type() ObjectType
Type is the object's type; a sealed object reports the type it carries, an empty wrapper INVALID.
type ObjectHeader ¶
type ObjectHeader struct {
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
Predecessor *Ref `protobuf:"bytes,2,opt,name=predecessor,proto3" json:"predecessor,omitempty"`
Size uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
Compression Compression `protobuf:"varint,4,opt,name=compression,proto3,enum=proto.Compression" json:"compression,omitempty"`
Timestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
Type ObjectType `protobuf:"varint,6,opt,name=type,proto3,enum=proto.ObjectType" json:"type,omitempty"`
TombstoneFor *Ref `protobuf:"bytes,7,opt,name=tombstone_for,json=tombstoneFor,proto3" json:"tombstone_for,omitempty"`
Encryption Encryption `protobuf:"varint,8,opt,name=encryption,proto3,enum=proto.Encryption" json:"encryption,omitempty"`
// identifies the store key under which the object's sealed parts were
// encrypted; empty for plaintext and convergent objects
KeyId []byte `protobuf:"bytes,9,opt,name=key_id,json=keyId,proto3" json:"key_id,omitempty"`
// SHA-256 of the stored bytes, so a copy can be checked without a key
StoredHash []byte `protobuf:"bytes,10,opt,name=stored_hash,json=storedHash,proto3" json:"stored_hash,omitempty"`
// set on a tombstone written for an erasure: garbage collection rewrites
// the archives holding the target's objects as soon as its rules allow
Erase bool `protobuf:"varint,11,opt,name=erase,proto3" json:"erase,omitempty"`
// identifies the server key under which the stored bytes were sealed at
// rest; empty when they are stored as the agent sent them
AtRestKeyId []byte `protobuf:"bytes,12,opt,name=at_rest_key_id,json=atRestKeyId,proto3" json:"at_rest_key_id,omitempty"`
// contains filtered or unexported fields
}
func HeaderFor ¶
func HeaderFor(o *Object) (*ObjectHeader, []byte, error)
HeaderFor builds the archive header of an object and returns the bytes to store: sealed data as is, anything else compressed.
func NewObjectHeaderFromBytes ¶
func NewObjectHeaderFromBytes(bytes []byte) (*ObjectHeader, error)
NewObjectHeaderFromBytes decodes a marshaled ObjectHeader.
func (*ObjectHeader) Descriptor
deprecated
func (*ObjectHeader) Descriptor() ([]byte, []int)
Deprecated: Use ObjectHeader.ProtoReflect.Descriptor instead.
func (*ObjectHeader) GetAtRestKeyId ¶
func (x *ObjectHeader) GetAtRestKeyId() []byte
func (*ObjectHeader) GetCompression ¶
func (x *ObjectHeader) GetCompression() Compression
func (*ObjectHeader) GetEncryption ¶
func (x *ObjectHeader) GetEncryption() Encryption
func (*ObjectHeader) GetErase ¶
func (x *ObjectHeader) GetErase() bool
func (*ObjectHeader) GetKeyId ¶
func (x *ObjectHeader) GetKeyId() []byte
func (*ObjectHeader) GetPredecessor ¶
func (x *ObjectHeader) GetPredecessor() *Ref
func (*ObjectHeader) GetRef ¶
func (x *ObjectHeader) GetRef() *Ref
func (*ObjectHeader) GetSize ¶
func (x *ObjectHeader) GetSize() uint64
func (*ObjectHeader) GetStoredHash ¶
func (x *ObjectHeader) GetStoredHash() []byte
func (*ObjectHeader) GetTimestamp ¶
func (x *ObjectHeader) GetTimestamp() *timestamppb.Timestamp
func (*ObjectHeader) GetTombstoneFor ¶
func (x *ObjectHeader) GetTombstoneFor() *Ref
func (*ObjectHeader) GetType ¶
func (x *ObjectHeader) GetType() ObjectType
func (*ObjectHeader) ProtoMessage ¶
func (*ObjectHeader) ProtoMessage()
func (*ObjectHeader) ProtoReflect ¶
func (x *ObjectHeader) ProtoReflect() protoreflect.Message
func (*ObjectHeader) Reset ¶
func (x *ObjectHeader) Reset()
func (*ObjectHeader) String ¶
func (x *ObjectHeader) String() string
type ObjectType ¶
type ObjectType int32
const ( ObjectType_INVALID ObjectType = 0 ObjectType_COMMIT ObjectType = 1 ObjectType_TREE ObjectType = 2 ObjectType_FILE ObjectType = 3 ObjectType_BLOB ObjectType = 4 ObjectType_TOMBSTONE ObjectType = 5 ObjectType_PIN ObjectType = 6 ObjectType_POLICY ObjectType = 7 )
func (ObjectType) Descriptor ¶
func (ObjectType) Descriptor() protoreflect.EnumDescriptor
func (ObjectType) Enum ¶
func (x ObjectType) Enum() *ObjectType
func (ObjectType) EnumDescriptor
deprecated
func (ObjectType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ObjectType.Descriptor instead.
func (ObjectType) Metadata ¶
func (x ObjectType) Metadata() bool
Metadata reports whether objects of the type describe a backup rather than carry its content: commits, trees and files, which metadata caches keep.
func (ObjectType) Number ¶
func (x ObjectType) Number() protoreflect.EnumNumber
func (ObjectType) String ¶
func (x ObjectType) String() string
func (ObjectType) Type ¶
func (ObjectType) Type() protoreflect.EnumType
type Object_Blob ¶
type Object_Blob struct {
Blob *Blob `protobuf:"bytes,4,opt,name=blob,proto3,oneof"`
}
type Object_Commit ¶
type Object_Commit struct {
Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3,oneof"`
}
type Object_File ¶
type Object_File struct {
File *File `protobuf:"bytes,3,opt,name=file,proto3,oneof"`
}
type Object_Pin ¶
type Object_Pin struct {
Pin *Pin `protobuf:"bytes,6,opt,name=pin,proto3,oneof"`
}
type Object_Policy ¶
type Object_Policy struct {
Policy *Policy `protobuf:"bytes,7,opt,name=policy,proto3,oneof"`
}
type Object_Sealed ¶
type Object_Sealed struct {
Sealed *Sealed `protobuf:"bytes,5,opt,name=sealed,proto3,oneof"`
}
type Object_Tree ¶
type Object_Tree struct {
Tree *Tree `protobuf:"bytes,2,opt,name=tree,proto3,oneof"`
}
type Period ¶
type Period int32
func (Period) Descriptor ¶
func (Period) Descriptor() protoreflect.EnumDescriptor
func (Period) EnumDescriptor
deprecated
func (Period) Number ¶
func (x Period) Number() protoreflect.EnumNumber
func (Period) Type ¶
func (Period) Type() protoreflect.EnumType
type Pin ¶
type Pin struct {
Target *Ref `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
// server clock at receipt, nanoseconds since the Unix epoch; makes every
// pin unique
ReceivedAtNs int64 `protobuf:"varint,3,opt,name=received_at_ns,json=receivedAtNs,proto3" json:"received_at_ns,omitempty"`
// labels the agent attached; the store keeps them and never interprets them
Metadata map[string]string `` /* 143-byte string literal not displayed */
// contains filtered or unexported fields
}
Pin keeps its target alive regardless of retention: a commit is never retired while pinned, a tree or file is kept without its commit. Unpinning is a tombstone whose target is the pin.
func (*Pin) Descriptor
deprecated
func (*Pin) GetMetadata ¶
func (*Pin) GetReceivedAtNs ¶
func (*Pin) ProtoMessage ¶
func (*Pin) ProtoMessage()
func (*Pin) ProtoReflect ¶
func (x *Pin) ProtoReflect() protoreflect.Message
type PinInfo ¶
type PinInfo struct {
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
Target *Ref `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
ReceivedAtNs int64 `protobuf:"varint,3,opt,name=received_at_ns,json=receivedAtNs,proto3" json:"received_at_ns,omitempty"`
// the labels the pin carries; the store keeps them and never
// interprets them
Metadata map[string]string `` /* 143-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*PinInfo) Descriptor
deprecated
func (*PinInfo) GetMetadata ¶
func (*PinInfo) GetReceivedAtNs ¶
func (*PinInfo) ProtoMessage ¶
func (*PinInfo) ProtoMessage()
func (*PinInfo) ProtoReflect ¶
func (x *PinInfo) ProtoReflect() protoreflect.Message
type Policy ¶
type Policy struct {
// increases with every change the store makes
Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
WrittenAtNs int64 `protobuf:"varint,2,opt,name=written_at_ns,json=writtenAtNs,proto3" json:"written_at_ns,omitempty"`
// Types that are valid to be assigned to Scope:
//
// *Policy_Store
// *Policy_Set
// *Policy_Commit
Scope isPolicy_Scope `protobuf_oneof:"scope"`
// contains filtered or unexported fields
}
Policy is the full state of one scope after a change the store's index made to it. A reindex replays a store's policies in order of sequence, then of written_at. Only the store writes these.
func (*Policy) Descriptor
deprecated
func (*Policy) GetCommit ¶
func (x *Policy) GetCommit() *CommitScope
func (*Policy) GetSequence ¶
func (*Policy) GetStore ¶
func (x *Policy) GetStore() *StoreScope
func (*Policy) GetWrittenAtNs ¶
func (*Policy) ProtoMessage ¶
func (*Policy) ProtoMessage()
func (*Policy) ProtoReflect ¶
func (x *Policy) ProtoReflect() protoreflect.Message
type Policy_Commit ¶
type Policy_Commit struct {
Commit *CommitScope `protobuf:"bytes,5,opt,name=commit,proto3,oneof"`
}
type Policy_Set ¶
type Policy_Set struct {
Set *SetScope `protobuf:"bytes,4,opt,name=set,proto3,oneof"`
}
type Policy_Store ¶
type Policy_Store struct {
Store *StoreScope `protobuf:"bytes,3,opt,name=store,proto3,oneof"`
}
type PresenceFilter ¶
type PresenceFilter struct {
// format version, currently 1
Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
// refs added to the filter
Entries uint64 `protobuf:"varint,2,opt,name=entries,proto3" json:"entries,omitempty"`
// size of the bit array in bits
Bits uint64 `protobuf:"varint,3,opt,name=bits,proto3" json:"bits,omitempty"`
// bit positions probed per ref
Hashes uint32 `protobuf:"varint,4,opt,name=hashes,proto3" json:"hashes,omitempty"`
// the bit array, bits / 8 bytes; streamed in pieces over GetPresence
Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
Commit *Ref `protobuf:"bytes,6,opt,name=commit,proto3" json:"commit,omitempty"`
BackupSet string `protobuf:"bytes,7,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
// contains filtered or unexported fields
}
PresenceFilter is a Bloom filter over the blob refs one commit reaches, built when the commit is indexed and handed to agents of its scope.
func (*PresenceFilter) Descriptor
deprecated
func (*PresenceFilter) Descriptor() ([]byte, []int)
Deprecated: Use PresenceFilter.ProtoReflect.Descriptor instead.
func (*PresenceFilter) GetBackupSet ¶
func (x *PresenceFilter) GetBackupSet() string
func (*PresenceFilter) GetBits ¶
func (x *PresenceFilter) GetBits() uint64
func (*PresenceFilter) GetCommit ¶
func (x *PresenceFilter) GetCommit() *Ref
func (*PresenceFilter) GetData ¶
func (x *PresenceFilter) GetData() []byte
func (*PresenceFilter) GetEntries ¶
func (x *PresenceFilter) GetEntries() uint64
func (*PresenceFilter) GetHashes ¶
func (x *PresenceFilter) GetHashes() uint32
func (*PresenceFilter) GetVersion ¶
func (x *PresenceFilter) GetVersion() uint32
func (*PresenceFilter) ProtoMessage ¶
func (*PresenceFilter) ProtoMessage()
func (*PresenceFilter) ProtoReflect ¶
func (x *PresenceFilter) ProtoReflect() protoreflect.Message
func (*PresenceFilter) Reset ¶
func (x *PresenceFilter) Reset()
func (*PresenceFilter) String ¶
func (x *PresenceFilter) String() string
type PutRequest ¶
type PutRequest struct {
Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
// the ref the client computed for object; the server rejects a mismatch
Ref *Ref `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
// for a file object: part refs the client did not upload because it
// assumes the store holds them; the server confirms them before storing
AssumedRefs []*Ref `protobuf:"bytes,3,rep,name=assumed_refs,json=assumedRefs,proto3" json:"assumed_refs,omitempty"`
// contains filtered or unexported fields
}
Put(*proto.Object) error
func (*PutRequest) Descriptor
deprecated
func (*PutRequest) Descriptor() ([]byte, []int)
Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.
func (*PutRequest) GetAssumedRefs ¶
func (x *PutRequest) GetAssumedRefs() []*Ref
func (*PutRequest) GetObject ¶
func (x *PutRequest) GetObject() *Object
func (*PutRequest) GetRef ¶
func (x *PutRequest) GetRef() *Ref
func (*PutRequest) ProtoMessage ¶
func (*PutRequest) ProtoMessage()
func (*PutRequest) ProtoReflect ¶
func (x *PutRequest) ProtoReflect() protoreflect.Message
func (*PutRequest) Reset ¶
func (x *PutRequest) Reset()
func (*PutRequest) String ¶
func (x *PutRequest) String() string
type PutResponse ¶
type PutResponse struct {
// the ref the object was stored under
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
// the object as stored, returned for commits and pins, whose set id and
// receipt time the server assigns
Object *Object `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
// assumed refs the store does not hold; when set the object was not
// stored and the client must upload them and put the object again
Missing []*Ref `protobuf:"bytes,3,rep,name=missing,proto3" json:"missing,omitempty"`
// contains filtered or unexported fields
}
func (*PutResponse) Descriptor
deprecated
func (*PutResponse) Descriptor() ([]byte, []int)
Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.
func (*PutResponse) GetMissing ¶
func (x *PutResponse) GetMissing() []*Ref
func (*PutResponse) GetObject ¶
func (x *PutResponse) GetObject() *Object
func (*PutResponse) GetRef ¶
func (x *PutResponse) GetRef() *Ref
func (*PutResponse) ProtoMessage ¶
func (*PutResponse) ProtoMessage()
func (*PutResponse) ProtoReflect ¶
func (x *PutResponse) ProtoReflect() protoreflect.Message
func (*PutResponse) Reset ¶
func (x *PutResponse) Reset()
func (*PutResponse) String ¶
func (x *PutResponse) String() string
type ReadDirRequest ¶
type ReadDirRequest struct {
BackupSet string `protobuf:"bytes,1,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
NotAfter *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=notAfter,proto3" json:"notAfter,omitempty"`
// contains filtered or unexported fields
}
func (*ReadDirRequest) Descriptor
deprecated
func (*ReadDirRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadDirRequest.ProtoReflect.Descriptor instead.
func (*ReadDirRequest) GetBackupSet ¶
func (x *ReadDirRequest) GetBackupSet() string
func (*ReadDirRequest) GetNotAfter ¶
func (x *ReadDirRequest) GetNotAfter() *timestamppb.Timestamp
func (*ReadDirRequest) GetPath ¶
func (x *ReadDirRequest) GetPath() string
func (*ReadDirRequest) ProtoMessage ¶
func (*ReadDirRequest) ProtoMessage()
func (*ReadDirRequest) ProtoReflect ¶
func (x *ReadDirRequest) ProtoReflect() protoreflect.Message
func (*ReadDirRequest) Reset ¶
func (x *ReadDirRequest) Reset()
func (*ReadDirRequest) String ¶
func (x *ReadDirRequest) String() string
type ReadDirResponse ¶
type ReadDirResponse struct {
Entries []*TreeNode `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
// contains filtered or unexported fields
}
func (*ReadDirResponse) Descriptor
deprecated
func (*ReadDirResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadDirResponse.ProtoReflect.Descriptor instead.
func (*ReadDirResponse) GetEntries ¶
func (x *ReadDirResponse) GetEntries() []*TreeNode
func (*ReadDirResponse) ProtoMessage ¶
func (*ReadDirResponse) ProtoMessage()
func (*ReadDirResponse) ProtoReflect ¶
func (x *ReadDirResponse) ProtoReflect() protoreflect.Message
func (*ReadDirResponse) Reset ¶
func (x *ReadDirResponse) Reset()
func (*ReadDirResponse) String ¶
func (x *ReadDirResponse) String() string
type ReadFileRequest ¶
type ReadFileRequest struct {
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
SkipParts []uint32 `protobuf:"varint,2,rep,packed,name=skip_parts,json=skipParts,proto3" json:"skip_parts,omitempty"`
// contains filtered or unexported fields
}
ReadFileRequest names a file object the store references; the server streams its parts, except the indexes in skip_parts.
func (*ReadFileRequest) Descriptor
deprecated
func (*ReadFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadFileRequest.ProtoReflect.Descriptor instead.
func (*ReadFileRequest) GetRef ¶
func (x *ReadFileRequest) GetRef() *Ref
func (*ReadFileRequest) GetSkipParts ¶
func (x *ReadFileRequest) GetSkipParts() []uint32
func (*ReadFileRequest) ProtoMessage ¶
func (*ReadFileRequest) ProtoMessage()
func (*ReadFileRequest) ProtoReflect ¶
func (x *ReadFileRequest) ProtoReflect() protoreflect.Message
func (*ReadFileRequest) Reset ¶
func (x *ReadFileRequest) Reset()
func (*ReadFileRequest) String ¶
func (x *ReadFileRequest) String() string
type ReadFileResponse ¶
type ReadFileResponse struct {
Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
Object *Object `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
Runs []*LocatedRun `protobuf:"bytes,3,rep,name=runs,proto3" json:"runs,omitempty"`
// contains filtered or unexported fields
}
ReadFileResponse carries either one part's stored object, sealed as it was uploaded, at index, or runs of parts whose stored records the client fetches itself. Indexes count the parts of the whole file, splits flattened.
func (*ReadFileResponse) Descriptor
deprecated
func (*ReadFileResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadFileResponse.ProtoReflect.Descriptor instead.
func (*ReadFileResponse) GetIndex ¶
func (x *ReadFileResponse) GetIndex() uint32
func (*ReadFileResponse) GetObject ¶
func (x *ReadFileResponse) GetObject() *Object
func (*ReadFileResponse) GetRuns ¶
func (x *ReadFileResponse) GetRuns() []*LocatedRun
func (*ReadFileResponse) ProtoMessage ¶
func (*ReadFileResponse) ProtoMessage()
func (*ReadFileResponse) ProtoReflect ¶
func (x *ReadFileResponse) ProtoReflect() protoreflect.Message
func (*ReadFileResponse) Reset ¶
func (x *ReadFileResponse) Reset()
func (*ReadFileResponse) String ¶
func (x *ReadFileResponse) String() string
type ReadFilesEntry ¶
type ReadFilesEntry struct {
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
SkipParts []uint32 `protobuf:"varint,2,rep,packed,name=skip_parts,json=skipParts,proto3" json:"skip_parts,omitempty"`
// contains filtered or unexported fields
}
func (*ReadFilesEntry) Descriptor
deprecated
func (*ReadFilesEntry) Descriptor() ([]byte, []int)
Deprecated: Use ReadFilesEntry.ProtoReflect.Descriptor instead.
func (*ReadFilesEntry) GetRef ¶
func (x *ReadFilesEntry) GetRef() *Ref
func (*ReadFilesEntry) GetSkipParts ¶
func (x *ReadFilesEntry) GetSkipParts() []uint32
func (*ReadFilesEntry) ProtoMessage ¶
func (*ReadFilesEntry) ProtoMessage()
func (*ReadFilesEntry) ProtoReflect ¶
func (x *ReadFilesEntry) ProtoReflect() protoreflect.Message
func (*ReadFilesEntry) Reset ¶
func (x *ReadFilesEntry) Reset()
func (*ReadFilesEntry) String ¶
func (x *ReadFilesEntry) String() string
type ReadFilesRequest ¶
type ReadFilesRequest struct {
Files []*ReadFilesEntry `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
ObjectsOnly bool `protobuf:"varint,2,opt,name=objects_only,json=objectsOnly,proto3" json:"objects_only,omitempty"`
// contains filtered or unexported fields
}
ReadFilesRequest names up to 1024 file objects the store references. The server streams every file object in order and then, unless objects_only, the parts of each except the indexes in its skip_parts, a part several of the files hold once.
func (*ReadFilesRequest) Descriptor
deprecated
func (*ReadFilesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadFilesRequest.ProtoReflect.Descriptor instead.
func (*ReadFilesRequest) GetFiles ¶
func (x *ReadFilesRequest) GetFiles() []*ReadFilesEntry
func (*ReadFilesRequest) GetObjectsOnly ¶
func (x *ReadFilesRequest) GetObjectsOnly() bool
func (*ReadFilesRequest) ProtoMessage ¶
func (*ReadFilesRequest) ProtoMessage()
func (*ReadFilesRequest) ProtoReflect ¶
func (x *ReadFilesRequest) ProtoReflect() protoreflect.Message
func (*ReadFilesRequest) Reset ¶
func (x *ReadFilesRequest) Reset()
func (*ReadFilesRequest) String ¶
func (x *ReadFilesRequest) String() string
type ReadFilesResponse ¶
type ReadFilesResponse struct {
File uint32 `protobuf:"varint,1,opt,name=file,proto3" json:"file,omitempty"`
Object *Object `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
Part bool `protobuf:"varint,3,opt,name=part,proto3" json:"part,omitempty"`
Index uint32 `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"`
Runs []*LocatedRun `protobuf:"bytes,5,rep,name=runs,proto3" json:"runs,omitempty"`
// contains filtered or unexported fields
}
ReadFilesResponse carries the object of the file at place file in the request, or with part set the stored object of that file's part at index, or runs of parts whose records name the file and the part.
func (*ReadFilesResponse) Descriptor
deprecated
func (*ReadFilesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadFilesResponse.ProtoReflect.Descriptor instead.
func (*ReadFilesResponse) GetFile ¶
func (x *ReadFilesResponse) GetFile() uint32
func (*ReadFilesResponse) GetIndex ¶
func (x *ReadFilesResponse) GetIndex() uint32
func (*ReadFilesResponse) GetObject ¶
func (x *ReadFilesResponse) GetObject() *Object
func (*ReadFilesResponse) GetPart ¶
func (x *ReadFilesResponse) GetPart() bool
func (*ReadFilesResponse) GetRuns ¶
func (x *ReadFilesResponse) GetRuns() []*LocatedRun
func (*ReadFilesResponse) ProtoMessage ¶
func (*ReadFilesResponse) ProtoMessage()
func (*ReadFilesResponse) ProtoReflect ¶
func (x *ReadFilesResponse) ProtoReflect() protoreflect.Message
func (*ReadFilesResponse) Reset ¶
func (x *ReadFilesResponse) Reset()
func (*ReadFilesResponse) String ¶
func (x *ReadFilesResponse) String() string
type Ref ¶
type Ref struct {
Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
// contains filtered or unexported fields
}
func HashPayload ¶
func HashPayload(t ObjectType, payload []byte) *Ref
HashPayload computes the ref of a payload of the given type as SHA-256(tag || " " || decimal(len(payload)) || 0x00 || payload).
func TombstoneRef ¶
TombstoneRef is the ref under which a tombstone for target is stored.
func (*Ref) Descriptor
deprecated
func (*Ref) ProtoMessage ¶
func (*Ref) ProtoMessage()
func (*Ref) ProtoReflect ¶
func (x *Ref) ProtoReflect() protoreflect.Message
type RetentionBracket ¶ added in v1.65.0
type RetentionBracket struct {
// hourly, daily, weekly or monthly
Period string `protobuf:"bytes,1,opt,name=period,proto3" json:"period,omitempty"`
// zero is the tail, which keeps every older period and so must be last
Count int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
// contains filtered or unexported fields
}
RetentionBracket keeps the last commit of each of count UTC calendar periods. Brackets run consecutively back from now, each starting with the period the one before it ended in.
func (*RetentionBracket) Descriptor
deprecated
added in
v1.65.0
func (*RetentionBracket) Descriptor() ([]byte, []int)
Deprecated: Use RetentionBracket.ProtoReflect.Descriptor instead.
func (*RetentionBracket) GetCount ¶ added in v1.65.0
func (x *RetentionBracket) GetCount() int32
func (*RetentionBracket) GetPeriod ¶ added in v1.65.0
func (x *RetentionBracket) GetPeriod() string
func (*RetentionBracket) ProtoMessage ¶ added in v1.65.0
func (*RetentionBracket) ProtoMessage()
func (*RetentionBracket) ProtoReflect ¶ added in v1.65.0
func (x *RetentionBracket) ProtoReflect() protoreflect.Message
func (*RetentionBracket) Reset ¶ added in v1.65.0
func (x *RetentionBracket) Reset()
func (*RetentionBracket) String ¶ added in v1.65.0
func (x *RetentionBracket) String() string
type RetentionPolicy ¶ added in v1.65.0
type RetentionPolicy struct {
KeepLast int32 `protobuf:"varint,1,opt,name=keep_last,json=keepLast,proto3" json:"keep_last,omitempty"`
// seconds
KeepWithin int64 `protobuf:"varint,2,opt,name=keep_within,json=keepWithin,proto3" json:"keep_within,omitempty"`
Brackets []*RetentionBracket `protobuf:"bytes,3,rep,name=brackets,proto3" json:"brackets,omitempty"`
// contains filtered or unexported fields
}
RetentionPolicy keeps a commit while a bracket holds it, it is one of the last keep_last, or it is younger than keep_within.
func (*RetentionPolicy) Descriptor
deprecated
added in
v1.65.0
func (*RetentionPolicy) Descriptor() ([]byte, []int)
Deprecated: Use RetentionPolicy.ProtoReflect.Descriptor instead.
func (*RetentionPolicy) GetBrackets ¶ added in v1.65.0
func (x *RetentionPolicy) GetBrackets() []*RetentionBracket
func (*RetentionPolicy) GetKeepLast ¶ added in v1.65.0
func (x *RetentionPolicy) GetKeepLast() int32
func (*RetentionPolicy) GetKeepWithin ¶ added in v1.65.0
func (x *RetentionPolicy) GetKeepWithin() int64
func (*RetentionPolicy) ProtoMessage ¶ added in v1.65.0
func (*RetentionPolicy) ProtoMessage()
func (*RetentionPolicy) ProtoReflect ¶ added in v1.65.0
func (x *RetentionPolicy) ProtoReflect() protoreflect.Message
func (*RetentionPolicy) Reset ¶ added in v1.65.0
func (x *RetentionPolicy) Reset()
func (*RetentionPolicy) String ¶ added in v1.65.0
func (x *RetentionPolicy) String() string
type Sealed ¶
type Sealed struct {
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
Type ObjectType `protobuf:"varint,2,opt,name=type,proto3,enum=proto.ObjectType" json:"type,omitempty"`
Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
// the codec applied before encryption
Compression Compression `protobuf:"varint,4,opt,name=compression,proto3,enum=proto.Compression" json:"compression,omitempty"`
Encryption Encryption `protobuf:"varint,5,opt,name=encryption,proto3,enum=proto.Encryption" json:"encryption,omitempty"`
KeyId []byte `protobuf:"bytes,6,opt,name=key_id,json=keyId,proto3" json:"key_id,omitempty"`
// contains filtered or unexported fields
}
Sealed carries a blob that the client encrypted: its ref is derived from the blob key, not from the stored bytes, so the server stores it as is.
func (*Sealed) Descriptor
deprecated
func (*Sealed) GetCompression ¶
func (x *Sealed) GetCompression() Compression
func (*Sealed) GetEncryption ¶
func (x *Sealed) GetEncryption() Encryption
func (*Sealed) GetType ¶
func (x *Sealed) GetType() ObjectType
func (*Sealed) ProtoMessage ¶
func (*Sealed) ProtoMessage()
func (*Sealed) ProtoReflect ¶
func (x *Sealed) ProtoReflect() protoreflect.Message
type SetScope ¶
type SetScope struct {
SetId uint64 `protobuf:"varint,1,opt,name=set_id,json=setId,proto3" json:"set_id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// the set's own retention policy as JSON, empty to inherit the default
Retention string `protobuf:"bytes,3,opt,name=retention,proto3" json:"retention,omitempty"`
RetentionPaused bool `protobuf:"varint,4,opt,name=retention_paused,json=retentionPaused,proto3" json:"retention_paused,omitempty"`
State SetState `protobuf:"varint,5,opt,name=state,proto3,enum=proto.SetState" json:"state,omitempty"`
Erase bool `protobuf:"varint,6,opt,name=erase,proto3" json:"erase,omitempty"`
// when the set was deleted, which moved its live commits to the trash;
// 0 unless it is closing
ClosedAtNs int64 `protobuf:"varint,7,opt,name=closed_at_ns,json=closedAtNs,proto3" json:"closed_at_ns,omitempty"`
// contains filtered or unexported fields
}
SetScope is one set's retention and lifecycle.
func (*SetScope) Descriptor
deprecated
func (*SetScope) GetClosedAtNs ¶
func (*SetScope) GetRetention ¶
func (*SetScope) GetRetentionPaused ¶
func (*SetScope) ProtoMessage ¶
func (*SetScope) ProtoMessage()
func (*SetScope) ProtoReflect ¶
func (x *SetScope) ProtoReflect() protoreflect.Message
type SetState ¶
type SetState int32
func (SetState) Descriptor ¶
func (SetState) Descriptor() protoreflect.EnumDescriptor
func (SetState) EnumDescriptor
deprecated
func (SetState) Number ¶
func (x SetState) Number() protoreflect.EnumNumber
func (SetState) Type ¶
func (SetState) Type() protoreflect.EnumType
type StoreClient ¶
type StoreClient interface {
Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
// Get serves a commit, tree or file object the store references; blobs
// are read through ReadFile
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
ReadFile(ctx context.Context, in *ReadFileRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ReadFileResponse], error)
// ReadFiles reads many small files in one call
ReadFiles(ctx context.Context, in *ReadFilesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ReadFilesResponse], error)
FileInfo(ctx context.Context, in *FileInfoRequest, opts ...grpc.CallOption) (*FileInfoResponse, error)
// ReadDir lists what a set held directly under a path, as of a time
ReadDir(ctx context.Context, in *ReadDirRequest, opts ...grpc.CallOption) (*ReadDirResponse, error)
CommitInfo(ctx context.Context, in *CommitInfoRequest, opts ...grpc.CallOption) (*CommitInfoResponse, error)
LatestCommit(ctx context.Context, in *LatestCommitRequest, opts ...grpc.CallOption) (*LatestCommitResponse, error)
// GetTree streams a subtree's tree objects breadth-first from the server
GetTree(ctx context.Context, in *GetTreeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetTreeResponse], error)
// BeginSession opens a backup session; its writes are visible to other
// callers only once it stores a commit
// BeginCommit checks the set's state and ownership before a run
BeginCommit(ctx context.Context, in *BeginCommitRequest, opts ...grpc.CallOption) (*BeginCommitResponse, error)
BeginSession(ctx context.Context, in *BeginSessionRequest, opts ...grpc.CallOption) (*BeginSessionResponse, error)
EndSession(ctx context.Context, in *EndSessionRequest, opts ...grpc.CallOption) (*EndSessionResponse, error)
// GetPresence streams the presence filters of the caller's scope
GetPresence(ctx context.Context, in *GetPresenceRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetPresenceResponse], error)
DeleteCommit(ctx context.Context, in *DeleteCommitRequest, opts ...grpc.CallOption) (*DeleteCommitResponse, error)
UndeleteCommit(ctx context.Context, in *UndeleteCommitRequest, opts ...grpc.CallOption) (*UndeleteCommitResponse, error)
// ListTrash pages through a set's deleted commits, newest deleted first
ListTrash(ctx context.Context, in *ListTrashRequest, opts ...grpc.CallOption) (*ListTrashResponse, error)
// CountCommits counts a set's commits per year, month, day or hour
CountCommits(ctx context.Context, in *CountCommitsRequest, opts ...grpc.CallOption) (*CountCommitsResponse, error)
DeleteSet(ctx context.Context, in *DeleteSetRequest, opts ...grpc.CallOption) (*DeleteSetResponse, error)
UndeleteSet(ctx context.Context, in *UndeleteSetRequest, opts ...grpc.CallOption) (*UndeleteSetResponse, error)
Unpin(ctx context.Context, in *UnpinRequest, opts ...grpc.CallOption) (*UnpinResponse, error)
ListPins(ctx context.Context, in *ListPinsRequest, opts ...grpc.CallOption) (*ListPinsResponse, error)
// EscrowedKeys returns every escrowed copy of the store key the store
// keeps, for an agent that holds only the passphrase
EscrowedKeys(ctx context.Context, in *EscrowedKeysRequest, opts ...grpc.CallOption) (*EscrowedKeysResponse, error)
}
StoreClient is the client API for Store service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewStoreClient ¶
func NewStoreClient(cc grpc.ClientConnInterface) StoreClient
type StorePolicy ¶
type StorePolicy struct {
Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
Mode string `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"`
PresenceScope string `protobuf:"bytes,6,opt,name=presence_scope,json=presenceScope,proto3" json:"presence_scope,omitempty"`
// contains filtered or unexported fields
}
StorePolicy is a store's write policy: the encryption mode of new writes and the presence scope.
func (*StorePolicy) Descriptor
deprecated
func (*StorePolicy) Descriptor() ([]byte, []int)
Deprecated: Use StorePolicy.ProtoReflect.Descriptor instead.
func (*StorePolicy) GetMode ¶
func (x *StorePolicy) GetMode() string
func (*StorePolicy) GetPresenceScope ¶
func (x *StorePolicy) GetPresenceScope() string
func (*StorePolicy) GetVersion ¶
func (x *StorePolicy) GetVersion() uint32
func (*StorePolicy) ProtoMessage ¶
func (*StorePolicy) ProtoMessage()
func (*StorePolicy) ProtoReflect ¶
func (x *StorePolicy) ProtoReflect() protoreflect.Message
func (*StorePolicy) Reset ¶
func (x *StorePolicy) Reset()
func (*StorePolicy) String ¶
func (x *StorePolicy) String() string
type StoreScope ¶
type StoreScope struct {
// the write policy as JSON, empty for the default
WritePolicy string `protobuf:"bytes,1,opt,name=write_policy,json=writePolicy,proto3" json:"write_policy,omitempty"`
WritePolicyVersion uint32 `protobuf:"varint,2,opt,name=write_policy_version,json=writePolicyVersion,proto3" json:"write_policy_version,omitempty"`
// when the operator confirmed saving the store key; 0 for never
KeyAcknowledgedAtNs int64 `protobuf:"varint,3,opt,name=key_acknowledged_at_ns,json=keyAcknowledgedAtNs,proto3" json:"key_acknowledged_at_ns,omitempty"`
// the default retention policy as JSON, empty for the built-in one
DefaultRetention string `protobuf:"bytes,4,opt,name=default_retention,json=defaultRetention,proto3" json:"default_retention,omitempty"`
// ignored: policies stored with it keep their hash
HoldDays uint32 `protobuf:"varint,5,opt,name=hold_days,json=holdDays,proto3" json:"hold_days,omitempty"`
TrashDays uint32 `protobuf:"varint,6,opt,name=trash_days,json=trashDays,proto3" json:"trash_days,omitempty"`
// contains filtered or unexported fields
}
StoreScope is the store's settings.
func (*StoreScope) Descriptor
deprecated
func (*StoreScope) Descriptor() ([]byte, []int)
Deprecated: Use StoreScope.ProtoReflect.Descriptor instead.
func (*StoreScope) GetDefaultRetention ¶
func (x *StoreScope) GetDefaultRetention() string
func (*StoreScope) GetHoldDays ¶
func (x *StoreScope) GetHoldDays() uint32
func (*StoreScope) GetKeyAcknowledgedAtNs ¶
func (x *StoreScope) GetKeyAcknowledgedAtNs() int64
func (*StoreScope) GetTrashDays ¶
func (x *StoreScope) GetTrashDays() uint32
func (*StoreScope) GetWritePolicy ¶
func (x *StoreScope) GetWritePolicy() string
func (*StoreScope) GetWritePolicyVersion ¶
func (x *StoreScope) GetWritePolicyVersion() uint32
func (*StoreScope) ProtoMessage ¶
func (*StoreScope) ProtoMessage()
func (*StoreScope) ProtoReflect ¶
func (x *StoreScope) ProtoReflect() protoreflect.Message
func (*StoreScope) Reset ¶
func (x *StoreScope) Reset()
func (*StoreScope) String ¶
func (x *StoreScope) String() string
type StoreServer ¶
type StoreServer interface {
Put(context.Context, *PutRequest) (*PutResponse, error)
// Get serves a commit, tree or file object the store references; blobs
// are read through ReadFile
Get(context.Context, *GetRequest) (*GetResponse, error)
ReadFile(*ReadFileRequest, grpc.ServerStreamingServer[ReadFileResponse]) error
// ReadFiles reads many small files in one call
ReadFiles(*ReadFilesRequest, grpc.ServerStreamingServer[ReadFilesResponse]) error
FileInfo(context.Context, *FileInfoRequest) (*FileInfoResponse, error)
// ReadDir lists what a set held directly under a path, as of a time
ReadDir(context.Context, *ReadDirRequest) (*ReadDirResponse, error)
CommitInfo(context.Context, *CommitInfoRequest) (*CommitInfoResponse, error)
LatestCommit(context.Context, *LatestCommitRequest) (*LatestCommitResponse, error)
// GetTree streams a subtree's tree objects breadth-first from the server
GetTree(*GetTreeRequest, grpc.ServerStreamingServer[GetTreeResponse]) error
// BeginSession opens a backup session; its writes are visible to other
// callers only once it stores a commit
// BeginCommit checks the set's state and ownership before a run
BeginCommit(context.Context, *BeginCommitRequest) (*BeginCommitResponse, error)
BeginSession(context.Context, *BeginSessionRequest) (*BeginSessionResponse, error)
EndSession(context.Context, *EndSessionRequest) (*EndSessionResponse, error)
// GetPresence streams the presence filters of the caller's scope
GetPresence(*GetPresenceRequest, grpc.ServerStreamingServer[GetPresenceResponse]) error
DeleteCommit(context.Context, *DeleteCommitRequest) (*DeleteCommitResponse, error)
UndeleteCommit(context.Context, *UndeleteCommitRequest) (*UndeleteCommitResponse, error)
// ListTrash pages through a set's deleted commits, newest deleted first
ListTrash(context.Context, *ListTrashRequest) (*ListTrashResponse, error)
// CountCommits counts a set's commits per year, month, day or hour
CountCommits(context.Context, *CountCommitsRequest) (*CountCommitsResponse, error)
DeleteSet(context.Context, *DeleteSetRequest) (*DeleteSetResponse, error)
UndeleteSet(context.Context, *UndeleteSetRequest) (*UndeleteSetResponse, error)
Unpin(context.Context, *UnpinRequest) (*UnpinResponse, error)
ListPins(context.Context, *ListPinsRequest) (*ListPinsResponse, error)
// EscrowedKeys returns every escrowed copy of the store key the store
// keeps, for an agent that holds only the passphrase
EscrowedKeys(context.Context, *EscrowedKeysRequest) (*EscrowedKeysResponse, error)
// contains filtered or unexported methods
}
StoreServer is the server API for Store service. All implementations must embed UnimplementedStoreServer for forward compatibility.
type Store_GetPresenceClient ¶
type Store_GetPresenceClient = grpc.ServerStreamingClient[GetPresenceResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Store_GetPresenceServer ¶
type Store_GetPresenceServer = grpc.ServerStreamingServer[GetPresenceResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Store_GetTreeClient ¶
type Store_GetTreeClient = grpc.ServerStreamingClient[GetTreeResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Store_GetTreeServer ¶
type Store_GetTreeServer = grpc.ServerStreamingServer[GetTreeResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Store_ReadFileClient ¶
type Store_ReadFileClient = grpc.ServerStreamingClient[ReadFileResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Store_ReadFileServer ¶
type Store_ReadFileServer = grpc.ServerStreamingServer[ReadFileResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Store_ReadFilesClient ¶
type Store_ReadFilesClient = grpc.ServerStreamingClient[ReadFilesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Store_ReadFilesServer ¶
type Store_ReadFilesServer = grpc.ServerStreamingServer[ReadFilesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TrashedCommit ¶
type TrashedCommit struct {
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
Commit *Commit `protobuf:"bytes,2,opt,name=commit,proto3" json:"commit,omitempty"`
Size *CommitSize `protobuf:"bytes,3,opt,name=size,proto3" json:"size,omitempty"`
DeletedAtNs int64 `protobuf:"varint,4,opt,name=deleted_at_ns,json=deletedAtNs,proto3" json:"deleted_at_ns,omitempty"`
// when retirement tombstones it
ExpiresAtNs int64 `protobuf:"varint,5,opt,name=expires_at_ns,json=expiresAtNs,proto3" json:"expires_at_ns,omitempty"`
// contains filtered or unexported fields
}
TrashedCommit is a deleted commit that UndeleteCommit can still bring back.
func (*TrashedCommit) Descriptor
deprecated
func (*TrashedCommit) Descriptor() ([]byte, []int)
Deprecated: Use TrashedCommit.ProtoReflect.Descriptor instead.
func (*TrashedCommit) GetCommit ¶
func (x *TrashedCommit) GetCommit() *Commit
func (*TrashedCommit) GetDeletedAtNs ¶
func (x *TrashedCommit) GetDeletedAtNs() int64
func (*TrashedCommit) GetExpiresAtNs ¶
func (x *TrashedCommit) GetExpiresAtNs() int64
func (*TrashedCommit) GetRef ¶
func (x *TrashedCommit) GetRef() *Ref
func (*TrashedCommit) GetSize ¶
func (x *TrashedCommit) GetSize() *CommitSize
func (*TrashedCommit) ProtoMessage ¶
func (*TrashedCommit) ProtoMessage()
func (*TrashedCommit) ProtoReflect ¶
func (x *TrashedCommit) ProtoReflect() protoreflect.Message
func (*TrashedCommit) Reset ¶
func (x *TrashedCommit) Reset()
func (*TrashedCommit) String ¶
func (x *TrashedCommit) String() string
type Tree ¶
type Tree struct {
Nodes []*TreeNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
// an ordered list of tree objects whose nodes, concatenated, form this
// tree; set instead of nodes for directories above the fan-out limit
Splits []*Ref `protobuf:"bytes,2,rep,name=splits,proto3" json:"splits,omitempty"`
// contains filtered or unexported fields
}
func (*Tree) Descriptor
deprecated
func (*Tree) ProtoMessage ¶
func (*Tree) ProtoMessage()
func (*Tree) ProtoReflect ¶
func (x *Tree) ProtoReflect() protoreflect.Message
type TreeNode ¶
type TreeNode struct {
// contains info about whether this is a file or a directory (tree)
Stat *FileInfo `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
Ref *Ref `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
// contains filtered or unexported fields
}
func (*TreeNode) Descriptor
deprecated
func (*TreeNode) ProtoMessage ¶
func (*TreeNode) ProtoMessage()
func (*TreeNode) ProtoReflect ¶
func (x *TreeNode) ProtoReflect() protoreflect.Message
type UndeleteCommitRequest ¶
type UndeleteCommitRequest struct {
Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
// contains filtered or unexported fields
}
func (*UndeleteCommitRequest) Descriptor
deprecated
func (*UndeleteCommitRequest) Descriptor() ([]byte, []int)
Deprecated: Use UndeleteCommitRequest.ProtoReflect.Descriptor instead.
func (*UndeleteCommitRequest) GetRef ¶
func (x *UndeleteCommitRequest) GetRef() *Ref
func (*UndeleteCommitRequest) ProtoMessage ¶
func (*UndeleteCommitRequest) ProtoMessage()
func (*UndeleteCommitRequest) ProtoReflect ¶
func (x *UndeleteCommitRequest) ProtoReflect() protoreflect.Message
func (*UndeleteCommitRequest) Reset ¶
func (x *UndeleteCommitRequest) Reset()
func (*UndeleteCommitRequest) String ¶
func (x *UndeleteCommitRequest) String() string
type UndeleteCommitResponse ¶
type UndeleteCommitResponse struct {
// contains filtered or unexported fields
}
func (*UndeleteCommitResponse) Descriptor
deprecated
func (*UndeleteCommitResponse) Descriptor() ([]byte, []int)
Deprecated: Use UndeleteCommitResponse.ProtoReflect.Descriptor instead.
func (*UndeleteCommitResponse) ProtoMessage ¶
func (*UndeleteCommitResponse) ProtoMessage()
func (*UndeleteCommitResponse) ProtoReflect ¶
func (x *UndeleteCommitResponse) ProtoReflect() protoreflect.Message
func (*UndeleteCommitResponse) Reset ¶
func (x *UndeleteCommitResponse) Reset()
func (*UndeleteCommitResponse) String ¶
func (x *UndeleteCommitResponse) String() string
type UndeleteSetRequest ¶
type UndeleteSetRequest struct {
BackupSet string `protobuf:"bytes,1,opt,name=backup_set,json=backupSet,proto3" json:"backup_set,omitempty"`
// contains filtered or unexported fields
}
func (*UndeleteSetRequest) Descriptor
deprecated
func (*UndeleteSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use UndeleteSetRequest.ProtoReflect.Descriptor instead.
func (*UndeleteSetRequest) GetBackupSet ¶
func (x *UndeleteSetRequest) GetBackupSet() string
func (*UndeleteSetRequest) ProtoMessage ¶
func (*UndeleteSetRequest) ProtoMessage()
func (*UndeleteSetRequest) ProtoReflect ¶
func (x *UndeleteSetRequest) ProtoReflect() protoreflect.Message
func (*UndeleteSetRequest) Reset ¶
func (x *UndeleteSetRequest) Reset()
func (*UndeleteSetRequest) String ¶
func (x *UndeleteSetRequest) String() string
type UndeleteSetResponse ¶
type UndeleteSetResponse struct {
// contains filtered or unexported fields
}
func (*UndeleteSetResponse) Descriptor
deprecated
func (*UndeleteSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use UndeleteSetResponse.ProtoReflect.Descriptor instead.
func (*UndeleteSetResponse) ProtoMessage ¶
func (*UndeleteSetResponse) ProtoMessage()
func (*UndeleteSetResponse) ProtoReflect ¶
func (x *UndeleteSetResponse) ProtoReflect() protoreflect.Message
func (*UndeleteSetResponse) Reset ¶
func (x *UndeleteSetResponse) Reset()
func (*UndeleteSetResponse) String ¶
func (x *UndeleteSetResponse) String() string
type UnimplementedStoreServer ¶
type UnimplementedStoreServer struct{}
UnimplementedStoreServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedStoreServer) BeginCommit ¶
func (UnimplementedStoreServer) BeginCommit(context.Context, *BeginCommitRequest) (*BeginCommitResponse, error)
func (UnimplementedStoreServer) BeginSession ¶
func (UnimplementedStoreServer) BeginSession(context.Context, *BeginSessionRequest) (*BeginSessionResponse, error)
func (UnimplementedStoreServer) CommitInfo ¶
func (UnimplementedStoreServer) CommitInfo(context.Context, *CommitInfoRequest) (*CommitInfoResponse, error)
func (UnimplementedStoreServer) CountCommits ¶
func (UnimplementedStoreServer) CountCommits(context.Context, *CountCommitsRequest) (*CountCommitsResponse, error)
func (UnimplementedStoreServer) DeleteCommit ¶
func (UnimplementedStoreServer) DeleteCommit(context.Context, *DeleteCommitRequest) (*DeleteCommitResponse, error)
func (UnimplementedStoreServer) DeleteSet ¶
func (UnimplementedStoreServer) DeleteSet(context.Context, *DeleteSetRequest) (*DeleteSetResponse, error)
func (UnimplementedStoreServer) EndSession ¶
func (UnimplementedStoreServer) EndSession(context.Context, *EndSessionRequest) (*EndSessionResponse, error)
func (UnimplementedStoreServer) EscrowedKeys ¶
func (UnimplementedStoreServer) EscrowedKeys(context.Context, *EscrowedKeysRequest) (*EscrowedKeysResponse, error)
func (UnimplementedStoreServer) FileInfo ¶
func (UnimplementedStoreServer) FileInfo(context.Context, *FileInfoRequest) (*FileInfoResponse, error)
func (UnimplementedStoreServer) Get ¶
func (UnimplementedStoreServer) Get(context.Context, *GetRequest) (*GetResponse, error)
func (UnimplementedStoreServer) GetPresence ¶
func (UnimplementedStoreServer) GetPresence(*GetPresenceRequest, grpc.ServerStreamingServer[GetPresenceResponse]) error
func (UnimplementedStoreServer) GetTree ¶
func (UnimplementedStoreServer) GetTree(*GetTreeRequest, grpc.ServerStreamingServer[GetTreeResponse]) error
func (UnimplementedStoreServer) LatestCommit ¶
func (UnimplementedStoreServer) LatestCommit(context.Context, *LatestCommitRequest) (*LatestCommitResponse, error)
func (UnimplementedStoreServer) ListPins ¶
func (UnimplementedStoreServer) ListPins(context.Context, *ListPinsRequest) (*ListPinsResponse, error)
func (UnimplementedStoreServer) ListTrash ¶
func (UnimplementedStoreServer) ListTrash(context.Context, *ListTrashRequest) (*ListTrashResponse, error)
func (UnimplementedStoreServer) Put ¶
func (UnimplementedStoreServer) Put(context.Context, *PutRequest) (*PutResponse, error)
func (UnimplementedStoreServer) ReadDir ¶
func (UnimplementedStoreServer) ReadDir(context.Context, *ReadDirRequest) (*ReadDirResponse, error)
func (UnimplementedStoreServer) ReadFile ¶
func (UnimplementedStoreServer) ReadFile(*ReadFileRequest, grpc.ServerStreamingServer[ReadFileResponse]) error
func (UnimplementedStoreServer) ReadFiles ¶
func (UnimplementedStoreServer) ReadFiles(*ReadFilesRequest, grpc.ServerStreamingServer[ReadFilesResponse]) error
func (UnimplementedStoreServer) UndeleteCommit ¶
func (UnimplementedStoreServer) UndeleteCommit(context.Context, *UndeleteCommitRequest) (*UndeleteCommitResponse, error)
func (UnimplementedStoreServer) UndeleteSet ¶
func (UnimplementedStoreServer) UndeleteSet(context.Context, *UndeleteSetRequest) (*UndeleteSetResponse, error)
func (UnimplementedStoreServer) Unpin ¶
func (UnimplementedStoreServer) Unpin(context.Context, *UnpinRequest) (*UnpinResponse, error)
type UnpinRequest ¶
type UnpinRequest struct {
Pin *Ref `protobuf:"bytes,1,opt,name=pin,proto3" json:"pin,omitempty"`
// contains filtered or unexported fields
}
func (*UnpinRequest) Descriptor
deprecated
func (*UnpinRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnpinRequest.ProtoReflect.Descriptor instead.
func (*UnpinRequest) GetPin ¶
func (x *UnpinRequest) GetPin() *Ref
func (*UnpinRequest) ProtoMessage ¶
func (*UnpinRequest) ProtoMessage()
func (*UnpinRequest) ProtoReflect ¶
func (x *UnpinRequest) ProtoReflect() protoreflect.Message
func (*UnpinRequest) Reset ¶
func (x *UnpinRequest) Reset()
func (*UnpinRequest) String ¶
func (x *UnpinRequest) String() string
type UnpinResponse ¶
type UnpinResponse struct {
// contains filtered or unexported fields
}
func (*UnpinResponse) Descriptor
deprecated
func (*UnpinResponse) Descriptor() ([]byte, []int)
Deprecated: Use UnpinResponse.ProtoReflect.Descriptor instead.
func (*UnpinResponse) ProtoMessage ¶
func (*UnpinResponse) ProtoMessage()
func (*UnpinResponse) ProtoReflect ¶
func (x *UnpinResponse) ProtoReflect() protoreflect.Message
func (*UnpinResponse) Reset ¶
func (x *UnpinResponse) Reset()
func (*UnpinResponse) String ¶
func (x *UnpinResponse) String() string
type UnsafeStoreServer ¶
type UnsafeStoreServer interface {
// contains filtered or unexported methods
}
UnsafeStoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StoreServer will result in compilation errors.