proto

package
v1.64.1 Latest Latest
Warning

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

Go to latest
Published: Oct 13, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source
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"
)
View Source
const HashSize = sha256.Size

HashSize is the width in bytes of every Ref.

View Source
const InlineLimit = 4 << 10

InlineLimit is the largest file stored inline in its File object.

Variables

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

View Source
var (
	Encryption_name = map[int32]string{
		0: "PLAINTEXT",
		3: "SEALED",
	}
	Encryption_value = map[string]int32{
		"PLAINTEXT": 0,
		"SEALED":    3,
	}
)

Enum value maps for Encryption.

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

View Source
var (
	Chunker_name = map[int32]string{
		0: "FASTCDC_64K",
	}
	Chunker_value = map[string]int32{
		"FASTCDC_64K": 0,
	}
)

Enum value maps for Chunker.

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

View Source
var (
	Compression_name = map[int32]string{
		0: "NONE",
		2: "ZSTD",
	}
	Compression_value = map[string]int32{
		"NONE": 0,
		"ZSTD": 2,
	}
)

Enum value maps for Compression.

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

View Source
var File_commit_proto protoreflect.FileDescriptor
View Source
var File_encryption_proto protoreflect.FileDescriptor
View Source
var File_object_proto protoreflect.FileDescriptor
View Source
var File_policy_proto protoreflect.FileDescriptor
View Source
var File_presence_proto protoreflect.FileDescriptor
View Source
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 Bytes

func Bytes(m pb.Message) []byte

Bytes marshals a message and panics on the (unreachable) marshal errors.

func Decode

func Decode(stored []byte, compression Compression) ([]byte, error)

Decode reverses Encode for any supported codec.

func DecodeVarint

func DecodeVarint(buf []byte) (x uint64, n int)

DecodeVarint reads a protobuf varint and the number of bytes it took; n is negative on a malformed input.

func EncodeVarint

func EncodeVarint(buf []byte, x uint64) []byte

EncodeVarint appends x as a protobuf varint.

func GetOSFileInfo

func GetOSFileInfo(info *FileInfo) os.FileInfo

GetOSFileInfo presents a recorded FileInfo as an os.FileInfo whose Sys returns the FileInfo itself.

func JoinPath

func JoinPath(prefix string, name []byte) string

JoinPath appends a name to an index path.

func NameFromComponent

func NameFromComponent(component string) []byte

NameFromComponent reverses PathComponent.

func PathComponent

func PathComponent(name []byte) string

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

func StoredHash(stored []byte) []byte

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.

func WithDetails

func WithDetails(info os.FileInfo, user, group, linkTarget string) os.FileInfo

WithDetails attaches owner names and a symlink target to stat data so GetFileInfo records them.

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

Deprecated: Use Blob.ProtoReflect.Descriptor instead.

func (*Blob) GetData

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

func (*Blob) ProtoMessage

func (*Blob) ProtoMessage()

func (*Blob) ProtoReflect

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

func (*Blob) Reset

func (x *Blob) Reset()

func (*Blob) String

func (x *Blob) String() string

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

func (x Chunker) Enum() *Chunker

func (Chunker) EnumDescriptor deprecated

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

Deprecated: Use Chunker.Descriptor instead.

func (Chunker) Number

func (x Chunker) Number() protoreflect.EnumNumber

func (Chunker) String

func (x Chunker) String() string

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

Deprecated: Use Commit.ProtoReflect.Descriptor instead.

func (*Commit) GetAgentId

func (x *Commit) GetAgentId() string

func (*Commit) GetBackupSet

func (x *Commit) GetBackupSet() string

func (*Commit) GetConsistent

func (x *Commit) GetConsistent() bool

func (*Commit) GetKeyId

func (x *Commit) GetKeyId() []byte

func (*Commit) GetMetadata

func (x *Commit) GetMetadata() map[string]string

func (*Commit) GetParent

func (x *Commit) GetParent() *Ref

func (*Commit) GetPartial

func (x *Commit) GetPartial() bool

func (*Commit) GetPolicyVersion

func (x *Commit) GetPolicyVersion() uint32

func (*Commit) GetReceivedAtNs

func (x *Commit) GetReceivedAtNs() int64

func (*Commit) GetScanStartNs

func (x *Commit) GetScanStartNs() int64

func (*Commit) GetSetId

func (x *Commit) GetSetId() uint64

func (*Commit) GetTimestamp

func (x *Commit) GetTimestamp() int64

func (*Commit) GetTree

func (x *Commit) GetTree() *Ref

func (*Commit) ProtoMessage

func (*Commit) ProtoMessage()

func (*Commit) ProtoReflect

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

func (*Commit) Reset

func (x *Commit) Reset()

func (*Commit) String

func (x *Commit) String() string

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

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

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetChunker

func (x *File) GetChunker() Chunker

func (*File) GetInline

func (x *File) GetInline() []byte

func (*File) GetInlineEncryption

func (x *File) GetInlineEncryption() Encryption

func (*File) GetParts

func (x *File) GetParts() []*FilePart

func (*File) GetSplitDepth

func (x *File) GetSplitDepth() uint32

func (*File) GetSplitLengths

func (x *File) GetSplitLengths() []uint64

func (*File) GetSplits

func (x *File) GetSplits() []*Ref

func (*File) ProtoMessage

func (*File) ProtoMessage()

func (*File) ProtoReflect

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

func (*File) Reset

func (x *File) Reset()

func (*File) String

func (x *File) String() string

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

func GetFileInfo(info os.FileInfo) *FileInfo

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

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetGroup

func (x *FileInfo) GetGroup() []byte

func (*FileInfo) GetLinkTarget

func (x *FileInfo) GetLinkTarget() []byte

func (*FileInfo) GetMode

func (x *FileInfo) GetMode() uint32

func (*FileInfo) GetMtimeNs

func (x *FileInfo) GetMtimeNs() int64

func (*FileInfo) GetName

func (x *FileInfo) GetName() []byte

func (*FileInfo) GetSize

func (x *FileInfo) GetSize() int64

func (*FileInfo) GetType

func (x *FileInfo) GetType() NodeType

func (*FileInfo) GetUser

func (x *FileInfo) GetUser() []byte

func (*FileInfo) IsDir

func (fi *FileInfo) IsDir() bool

IsDir reports whether the node describes a directory.

func (*FileInfo) ModTime

func (fi *FileInfo) ModTime() time.Time

ModTime returns the recorded modification time.

func (*FileInfo) ProtoMessage

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect

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

func (*FileInfo) Reset

func (x *FileInfo) Reset()

func (*FileInfo) String

func (x *FileInfo) String() string

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

Deprecated: Use FilePart.ProtoReflect.Descriptor instead.

func (*FilePart) GetLength

func (x *FilePart) GetLength() uint64

func (*FilePart) GetOffset

func (x *FilePart) GetOffset() uint64

func (*FilePart) GetRef

func (x *FilePart) GetRef() *Ref

func (*FilePart) ProtoMessage

func (*FilePart) ProtoMessage()

func (*FilePart) ProtoReflect

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

func (*FilePart) Reset

func (x *FilePart) Reset()

func (*FilePart) String

func (x *FilePart) String() string

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

Deprecated: Use Location.ProtoReflect.Descriptor instead.

func (*Location) GetAtRestKey

func (x *Location) GetAtRestKey() []byte

func (*Location) GetExpires

func (x *Location) GetExpires() *timestamppb.Timestamp

func (*Location) GetHeader

func (x *Location) GetHeader() map[string]string

func (*Location) GetLength

func (x *Location) GetLength() int64

func (*Location) GetUrl

func (x *Location) GetUrl() string

func (*Location) ProtoMessage

func (*Location) ProtoMessage()

func (*Location) ProtoReflect

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

func (*Location) Reset

func (x *Location) Reset()

func (*Location) String

func (x *Location) String() string

type NodeType

type NodeType int32

NodeType says what kind of filesystem entry a tree node describes.

const (
	NodeType_NODE_FILE      NodeType = 0
	NodeType_NODE_DIRECTORY NodeType = 1
	NodeType_NODE_SYMLINK   NodeType = 2
)

func NodeTypeOf

func NodeTypeOf(mode os.FileMode) NodeType

NodeTypeOf maps a file mode to the node type recorded in a tree.

func (NodeType) Descriptor

func (NodeType) Descriptor() protoreflect.EnumDescriptor

func (NodeType) Enum

func (x NodeType) Enum() *NodeType

func (NodeType) EnumDescriptor deprecated

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

Deprecated: Use NodeType.Descriptor instead.

func (NodeType) Number

func (x NodeType) Number() protoreflect.EnumNumber

func (NodeType) String

func (x NodeType) String() string

func (NodeType) Type

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

func NewObjectFromBytes(bytes []byte) (*Object, error)

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

func (o *Object) Bytes() []byte

Bytes marshals the Object wrapper; it is a transport encoding, not the hashed payload (see Canonical).

func (*Object) Canonical

func (o *Object) Canonical() ([]byte, error)

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

Deprecated: Use Object.ProtoReflect.Descriptor instead.

func (*Object) GetBlob

func (x *Object) GetBlob() *Blob

func (*Object) GetCommit

func (x *Object) GetCommit() *Commit

func (*Object) GetFile

func (x *Object) GetFile() *File

func (*Object) GetKeyId

func (x *Object) GetKeyId() []byte

func (*Object) GetObject

func (x *Object) GetObject() isObject_Object

func (*Object) GetPin

func (x *Object) GetPin() *Pin

func (*Object) GetPolicy

func (x *Object) GetPolicy() *Policy

func (*Object) GetSealed

func (x *Object) GetSealed() *Sealed

func (*Object) GetTree

func (x *Object) GetTree() *Tree

func (*Object) ProtoMessage

func (*Object) ProtoMessage()

func (*Object) ProtoReflect

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

func (*Object) ReceivedAtNs

func (o *Object) ReceivedAtNs() int64

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

func (o *Object) Ref() *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) Reset

func (x *Object) Reset()

func (*Object) Stamp

func (o *Object) Stamp(setID uint64, receivedAt time.Time)

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

func (x *Object) String() string

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.

func (*Object) Validate

func (o *Object) Validate() error

Validate reports whether the object can be canonically encoded.

func (*Object) Verify

func (o *Object) Verify(ref *Ref) error

Verify fails with ErrRefMismatch, naming ref, unless the object is the one ref names. A sealed object is checked only against the ref it carries; opening it under the store key checks its contents.

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

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
const (
	Period_PERIOD_UNSPECIFIED Period = 0
	Period_PERIOD_YEAR        Period = 1
	Period_PERIOD_MONTH       Period = 2
	Period_PERIOD_DAY         Period = 3
	Period_PERIOD_HOUR        Period = 4
)

func (Period) Descriptor

func (Period) Descriptor() protoreflect.EnumDescriptor

func (Period) Enum

func (x Period) Enum() *Period

func (Period) EnumDescriptor deprecated

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

Deprecated: Use Period.Descriptor instead.

func (Period) Number

func (x Period) Number() protoreflect.EnumNumber

func (Period) String

func (x Period) String() string

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

Deprecated: Use Pin.ProtoReflect.Descriptor instead.

func (*Pin) GetMetadata

func (x *Pin) GetMetadata() map[string]string

func (*Pin) GetReceivedAtNs

func (x *Pin) GetReceivedAtNs() int64

func (*Pin) GetTarget

func (x *Pin) GetTarget() *Ref

func (*Pin) ProtoMessage

func (*Pin) ProtoMessage()

func (*Pin) ProtoReflect

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

func (*Pin) Reset

func (x *Pin) Reset()

func (*Pin) String

func (x *Pin) String() string

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

Deprecated: Use PinInfo.ProtoReflect.Descriptor instead.

func (*PinInfo) GetMetadata

func (x *PinInfo) GetMetadata() map[string]string

func (*PinInfo) GetReceivedAtNs

func (x *PinInfo) GetReceivedAtNs() int64

func (*PinInfo) GetRef

func (x *PinInfo) GetRef() *Ref

func (*PinInfo) GetTarget

func (x *PinInfo) GetTarget() *Ref

func (*PinInfo) ProtoMessage

func (*PinInfo) ProtoMessage()

func (*PinInfo) ProtoReflect

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

func (*PinInfo) Reset

func (x *PinInfo) Reset()

func (*PinInfo) String

func (x *PinInfo) String() string

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

Deprecated: Use Policy.ProtoReflect.Descriptor instead.

func (*Policy) GetCommit

func (x *Policy) GetCommit() *CommitScope

func (*Policy) GetScope

func (x *Policy) GetScope() isPolicy_Scope

func (*Policy) GetSequence

func (x *Policy) GetSequence() uint64

func (*Policy) GetSet

func (x *Policy) GetSet() *SetScope

func (*Policy) GetStore

func (x *Policy) GetStore() *StoreScope

func (*Policy) GetWrittenAtNs

func (x *Policy) GetWrittenAtNs() int64

func (*Policy) ProtoMessage

func (*Policy) ProtoMessage()

func (*Policy) ProtoReflect

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

func (*Policy) Reset

func (x *Policy) Reset()

func (*Policy) String

func (x *Policy) String() string

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

func TombstoneRef(target *Ref) *Ref

TombstoneRef is the ref under which a tombstone for target is stored.

func (*Ref) Descriptor deprecated

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

Deprecated: Use Ref.ProtoReflect.Descriptor instead.

func (*Ref) Equal

func (r *Ref) Equal(other *Ref) bool

Equal reports whether two refs name the same object.

func (*Ref) GetHash

func (x *Ref) GetHash() []byte

func (*Ref) ProtoMessage

func (*Ref) ProtoMessage()

func (*Ref) ProtoReflect

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

func (*Ref) Reset

func (x *Ref) Reset()

func (*Ref) String

func (x *Ref) String() string

func (*Ref) Valid

func (r *Ref) Valid() bool

Valid reports whether the ref has the expected width.

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

Deprecated: Use Sealed.ProtoReflect.Descriptor instead.

func (*Sealed) GetCompression

func (x *Sealed) GetCompression() Compression

func (*Sealed) GetData

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

func (*Sealed) GetEncryption

func (x *Sealed) GetEncryption() Encryption

func (*Sealed) GetKeyId

func (x *Sealed) GetKeyId() []byte

func (*Sealed) GetRef

func (x *Sealed) GetRef() *Ref

func (*Sealed) GetType

func (x *Sealed) GetType() ObjectType

func (*Sealed) ProtoMessage

func (*Sealed) ProtoMessage()

func (*Sealed) ProtoReflect

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

func (*Sealed) Reset

func (x *Sealed) Reset()

func (*Sealed) String

func (x *Sealed) String() string

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

Deprecated: Use SetScope.ProtoReflect.Descriptor instead.

func (*SetScope) GetClosedAtNs

func (x *SetScope) GetClosedAtNs() int64

func (*SetScope) GetErase

func (x *SetScope) GetErase() bool

func (*SetScope) GetName

func (x *SetScope) GetName() string

func (*SetScope) GetRetention

func (x *SetScope) GetRetention() string

func (*SetScope) GetRetentionPaused

func (x *SetScope) GetRetentionPaused() bool

func (*SetScope) GetSetId

func (x *SetScope) GetSetId() uint64

func (*SetScope) GetState

func (x *SetScope) GetState() SetState

func (*SetScope) ProtoMessage

func (*SetScope) ProtoMessage()

func (*SetScope) ProtoReflect

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

func (*SetScope) Reset

func (x *SetScope) Reset()

func (*SetScope) String

func (x *SetScope) String() string

type SetState

type SetState int32
const (
	SetState_SET_ACTIVE  SetState = 0
	SetState_SET_CLOSING SetState = 1
	SetState_SET_DELETED SetState = 2
)

func (SetState) Descriptor

func (SetState) Descriptor() protoreflect.EnumDescriptor

func (SetState) Enum

func (x SetState) Enum() *SetState

func (SetState) EnumDescriptor deprecated

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

Deprecated: Use SetState.Descriptor instead.

func (SetState) Number

func (x SetState) Number() protoreflect.EnumNumber

func (SetState) String

func (x SetState) String() string

func (SetState) Type

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

Deprecated: Use Tree.ProtoReflect.Descriptor instead.

func (*Tree) GetNodes

func (x *Tree) GetNodes() []*TreeNode

func (*Tree) GetSplits

func (x *Tree) GetSplits() []*Ref

func (*Tree) ProtoMessage

func (*Tree) ProtoMessage()

func (*Tree) ProtoReflect

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

func (*Tree) Reset

func (x *Tree) Reset()

func (*Tree) String

func (x *Tree) String() string

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

Deprecated: Use TreeNode.ProtoReflect.Descriptor instead.

func (*TreeNode) GetRef

func (x *TreeNode) GetRef() *Ref

func (*TreeNode) GetStat

func (x *TreeNode) GetStat() *FileInfo

func (*TreeNode) ProtoMessage

func (*TreeNode) ProtoMessage()

func (*TreeNode) ProtoReflect

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

func (*TreeNode) Reset

func (x *TreeNode) Reset()

func (*TreeNode) String

func (x *TreeNode) String() string

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

func (UnimplementedStoreServer) CommitInfo

func (UnimplementedStoreServer) CountCommits

func (UnimplementedStoreServer) DeleteCommit

func (UnimplementedStoreServer) DeleteSet

func (UnimplementedStoreServer) EndSession

func (UnimplementedStoreServer) EscrowedKeys

func (UnimplementedStoreServer) FileInfo

func (UnimplementedStoreServer) Get

func (UnimplementedStoreServer) LatestCommit

func (UnimplementedStoreServer) ListPins

func (UnimplementedStoreServer) ListTrash

func (UnimplementedStoreServer) Put

func (UnimplementedStoreServer) ReadDir

func (UnimplementedStoreServer) UndeleteCommit

func (UnimplementedStoreServer) UndeleteSet

func (UnimplementedStoreServer) Unpin

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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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