loonfs

package module
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: Aug 29, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

README

LoonFS Go SDK

One module for LoonFS server and proxy applications. SDK v0.1.x targets LoonFS API v0.3.x.

Install

go get github.com/loonfs/loonfs-sdk-go@latest

Choose the package that matches where your code runs.

Server

package main

import (
	"context"
	"fmt"
	"os"

	"github.com/loonfs/loonfs-sdk-go/server"
	"github.com/loonfs/loonfs-sdk-go/option"
)

func main() {
	loon := server.NewClient(
		option.WithBaseURL(os.Getenv("LOONFS_URL")),
		option.WithToken(os.Getenv("LOONFS_AUTH_TOKEN")),
	)

	capabilities, err := loon.System.GetCapabilities(context.Background())
	if err != nil {
		panic(err)
	}
	fmt.Println(capabilities.ProtocolVersion)
}

Upload and download helpers are available from the transfers package. See reference.md for the generated API reference.

Proxy

Use the proxy package in your backend to forward client requests while keeping the LoonFS credential on the server.

Retries

The Go SDK makes one HTTP attempt by default. You can opt into retries with option.WithMaxAttempts, but only do so for operations your application can safely repeat.

Generated code

This SDK is generated from the LoonFS OpenAPI specification. Please report SDK issues in the main LoonFS repository.

License

Apache-2.0.

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrorCodes internal.ErrorCodes = internal.ErrorCodes{
	503: func(apiError *core.APIError) error {
		return &ServiceUnavailableError{
			APIError: apiError,
		}
	},
	401: func(apiError *core.APIError) error {
		return &UnauthorizedError{
			APIError: apiError,
		}
	},
	400: func(apiError *core.APIError) error {
		return &BadRequestError{
			APIError: apiError,
		}
	},
	404: func(apiError *core.APIError) error {
		return &NotFoundError{
			APIError: apiError,
		}
	},
	410: func(apiError *core.APIError) error {
		return &GoneError{
			APIError: apiError,
		}
	},
	500: func(apiError *core.APIError) error {
		return &InternalServerError{
			APIError: apiError,
		}
	},
	501: func(apiError *core.APIError) error {
		return &NotImplementedError{
			APIError: apiError,
		}
	},
	409: func(apiError *core.APIError) error {
		return &ConflictError{
			APIError: apiError,
		}
	},
	413: func(apiError *core.APIError) error {
		return &ContentTooLargeError{
			APIError: apiError,
		}
	},
}

Functions

func Bool

func Bool(b bool) *bool

Bool returns a pointer to the given bool value.

func Byte

func Byte(b byte) *byte

Byte returns a pointer to the given byte value.

func Bytes

func Bytes(b []byte) *[]byte

Bytes returns a pointer to the given []byte value.

func Complex64

func Complex64(c complex64) *complex64

Complex64 returns a pointer to the given complex64 value.

func Complex128

func Complex128(c complex128) *complex128

Complex128 returns a pointer to the given complex128 value.

func Float32

func Float32(f float32) *float32

Float32 returns a pointer to the given float32 value.

func Float64

func Float64(f float64) *float64

Float64 returns a pointer to the given float64 value.

func Int

func Int(i int) *int

Int returns a pointer to the given int value.

func Int8

func Int8(i int8) *int8

Int8 returns a pointer to the given int8 value.

func Int16

func Int16(i int16) *int16

Int16 returns a pointer to the given int16 value.

func Int32

func Int32(i int32) *int32

Int32 returns a pointer to the given int32 value.

func Int64

func Int64(i int64) *int64

Int64 returns a pointer to the given int64 value.

func MustParseDate

func MustParseDate(date string) time.Time

MustParseDate attempts to parse the given string as a date time.Time, and panics upon failure.

func MustParseDateTime

func MustParseDateTime(datetime string) time.Time

MustParseDateTime attempts to parse the given string as a datetime time.Time, and panics upon failure.

func Rune

func Rune(r rune) *rune

Rune returns a pointer to the given rune value.

func String

func String(s string) *string

String returns a pointer to the given string value.

func Time

func Time(t time.Time) *time.Time

Time returns a pointer to the given time.Time value.

func UUID

func UUID(u uuid.UUID) *uuid.UUID

UUID returns a pointer to the given uuid.UUID value.

func Uint

func Uint(u uint) *uint

Uint returns a pointer to the given uint value.

func Uint8

func Uint8(u uint8) *uint8

Uint8 returns a pointer to the given uint8 value.

func Uint16

func Uint16(u uint16) *uint16

Uint16 returns a pointer to the given uint16 value.

func Uint32

func Uint32(u uint32) *uint32

Uint32 returns a pointer to the given uint32 value.

func Uint64

func Uint64(u uint64) *uint64

Uint64 returns a pointer to the given uint64 value.

func Uintptr

func Uintptr(u uintptr) *uintptr

Uintptr returns a pointer to the given uintptr value.

Types

type APIError

type APIError struct {
	// Stable machine-readable reason from the [`ErrorCode`](crate::ErrorCode)
	// registry.
	//
	// Carried as a string so clients keep working when a newer server
	// introduces a code they do not know; use
	// [`ErrorCode::parse`](crate::ErrorCode::parse) for typed access.
	Code string `json:"code" url:"code"`
	// Structured context for the code, present when the failure carries
	// machine-usable identity (API spec, "Standard error contract"). Boxed
	// so the rare detailed error does not widen every error-carrying result.
	Details *ErrorDetails `json:"details,omitempty" url:"details,omitempty"`
	// For `not_supported` errors, the capability-document feature key the
	// client should reconcile against.
	Feature *string `json:"feature,omitempty" url:"feature,omitempty"`
	// Human-readable error message.
	Message string `json:"message" url:"message"`
	// Identifies the invalid input. Body fields use JSON Pointer paths;
	// query and path parameters use their names; CLI errors use the flag or
	// argument as written.
	Param *string `json:"param,omitempty" url:"param,omitempty"`
	// Correlation id the server assigned to the failed request; the same
	// value is sent as the `x-request-id` response header.
	RequestID *string `json:"request_id,omitempty" url:"request_id,omitempty"`
	// contains filtered or unexported fields
}

func (*APIError) GetCode

func (a *APIError) GetCode() string

func (*APIError) GetDetails

func (a *APIError) GetDetails() *ErrorDetails

func (*APIError) GetExtraProperties

func (a *APIError) GetExtraProperties() map[string]interface{}

func (*APIError) GetFeature

func (a *APIError) GetFeature() *string

func (*APIError) GetMessage

func (a *APIError) GetMessage() string

func (*APIError) GetParam

func (a *APIError) GetParam() *string

func (*APIError) GetRequestID

func (a *APIError) GetRequestID() *string

func (*APIError) MarshalJSON

func (a *APIError) MarshalJSON() ([]byte, error)

func (*APIError) SetCode

func (a *APIError) SetCode(code string)

SetCode sets the Code field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*APIError) SetDetails

func (a *APIError) SetDetails(details *ErrorDetails)

SetDetails sets the Details field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*APIError) SetFeature

func (a *APIError) SetFeature(feature *string)

SetFeature sets the Feature field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*APIError) SetMessage

func (a *APIError) SetMessage(message string)

SetMessage sets the Message field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*APIError) SetParam

func (a *APIError) SetParam(param *string)

SetParam sets the Param field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*APIError) SetRequestID

func (a *APIError) SetRequestID(requestID *string)

SetRequestID sets the RequestID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*APIError) String

func (a *APIError) String() string

func (*APIError) UnmarshalJSON

func (a *APIError) UnmarshalJSON(data []byte) error

type AbortUploadRequest

type AbortUploadRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Upload session id
	UploadID string `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*AbortUploadRequest) SetNamespaceID

func (a *AbortUploadRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*AbortUploadRequest) SetUploadID

func (a *AbortUploadRequest) SetUploadID(uploadID string)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type AbsolutePath

type AbsolutePath = string

Validated complete absolute namespace path, serialized as a plain string.

type ActorID

type ActorID = string

Opaque hosting-platform actor id: non-empty, at most 256 UTF-8 bytes, without leading or trailing whitespace or control characters.

type ActorKind

type ActorKind string

The type of actor responsible for a commit.

const (
	ActorKindUser    ActorKind = "user"
	ActorKindService ActorKind = "service"
	ActorKindSystem  ActorKind = "system"
)

func NewActorKindFromString

func NewActorKindFromString(s string) (ActorKind, error)

func (ActorKind) Ptr

func (a ActorKind) Ptr() *ActorKind

type ActorRef

type ActorRef struct {
	// A stable identifier supplied by the application.
	ID ActorID `json:"id" url:"id"`
	// The type of actor.
	Kind ActorKind `json:"kind" url:"kind"`
	// contains filtered or unexported fields
}

func (*ActorRef) GetExtraProperties

func (a *ActorRef) GetExtraProperties() map[string]interface{}

func (*ActorRef) GetID

func (a *ActorRef) GetID() ActorID

func (*ActorRef) GetKind

func (a *ActorRef) GetKind() ActorKind

func (*ActorRef) MarshalJSON

func (a *ActorRef) MarshalJSON() ([]byte, error)

func (*ActorRef) SetID

func (a *ActorRef) SetID(id ActorID)

SetID sets the ID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ActorRef) SetKind

func (a *ActorRef) SetKind(kind ActorKind)

SetKind sets the Kind field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ActorRef) String

func (a *ActorRef) String() string

func (*ActorRef) UnmarshalJSON

func (a *ActorRef) UnmarshalJSON(data []byte) error

type AdvanceRetentionRequest

type AdvanceRetentionRequest = map[string]any

Selects retention-floor advancement. This request has no options yet.

type AdvanceRetentionResponse

type AdvanceRetentionResponse struct {
	// New minimum sequence for incremental replay.
	RetentionFloorSeq ChangeSeq `json:"retention_floor_seq" url:"retention_floor_seq"`
	// contains filtered or unexported fields
}

func (*AdvanceRetentionResponse) GetExtraProperties

func (a *AdvanceRetentionResponse) GetExtraProperties() map[string]interface{}

func (*AdvanceRetentionResponse) GetRetentionFloorSeq

func (a *AdvanceRetentionResponse) GetRetentionFloorSeq() ChangeSeq

func (*AdvanceRetentionResponse) MarshalJSON

func (a *AdvanceRetentionResponse) MarshalJSON() ([]byte, error)

func (*AdvanceRetentionResponse) SetRetentionFloorSeq

func (a *AdvanceRetentionResponse) SetRetentionFloorSeq(retentionFloorSeq ChangeSeq)

SetRetentionFloorSeq sets the RetentionFloorSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*AdvanceRetentionResponse) String

func (a *AdvanceRetentionResponse) String() string

func (*AdvanceRetentionResponse) UnmarshalJSON

func (a *AdvanceRetentionResponse) UnmarshalJSON(data []byte) error

type AttributeKey

type AttributeKey = string

Validated name of one inode attribute.

A key is 1 to 128 UTF-8 bytes and carries no Unicode control character, which is also what rejects NUL. Keys are compared exactly: nothing case-folds or normalizes them, so two spellings that differ in any byte name two different attributes.

The `loonfs.` prefix is reserved for system-owned attributes. This type accepts a reserved key, because a durable row has to be able to carry a system attribute. The write operation is where a caller's attempt to write a reserved key is rejected.

type AttributeRevisionNo

type AttributeRevisionNo = int64

Revision number for an inode's attributes. It starts at 0 and increases whenever the attribute map changes.

type AttributeValue

type AttributeValue = string

One validated attribute value.

A value is at most [`MAX_ATTRIBUTE_VALUE_BYTES`] UTF-8 bytes. It is otherwise free text: control characters and the empty string are legal. Empty is a stored value, not a tombstone; only an explicit remove operation deletes an attribute.

type Attributes

type Attributes = map[string]AttributeValue

A validated attribute map for one inode.

Construction and decoding both enforce the same limits: a map holds at most [`MAX_ATTRIBUTE_ENTRIES`] entries, each value is at most [`MAX_ATTRIBUTE_VALUE_BYTES`] UTF-8 bytes, and the whole map is at most [`MAX_ATTRIBUTES_TOTAL_BYTES`] logical UTF-8 bytes. The total counts key bytes and value bytes and nothing else, so it does not depend on the encoding the map is written in. Durable state that breaks a limit fails to decode rather than decoding to something smaller.

An empty map is valid. It is the cleared state, and clearing an inode's attributes is a real update with its own revision.

type BadRequestError

type BadRequestError struct {
	*core.APIError
	Body *APIError
}

Invalid namespace id, limit, or cursor

func (*BadRequestError) MarshalJSON

func (b *BadRequestError) MarshalJSON() ([]byte, error)

func (*BadRequestError) UnmarshalJSON

func (b *BadRequestError) UnmarshalJSON(data []byte) error

func (*BadRequestError) Unwrap

func (b *BadRequestError) Unwrap() error

type BeginDownloadByInodeRequest

type BeginDownloadByInodeRequest = map[string]any

Empty request for an inode-addressed download.

type BeginDownloadByInodeResponse

type BeginDownloadByInodeResponse struct {
	// Short-lived provider access without the raw object key.
	Access *ObjectTransferAccess `json:"access" url:"access"`
	// Content identity, size, and checksum.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// Namespace that was read.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Revision being read.
	RevisionNo RevisionNo `json:"revision_no" url:"revision_no"`
	// contains filtered or unexported fields
}

func (*BeginDownloadByInodeResponse) GetAccess

func (*BeginDownloadByInodeResponse) GetContentRef

func (b *BeginDownloadByInodeResponse) GetContentRef() *ContentRef

func (*BeginDownloadByInodeResponse) GetExtraProperties

func (b *BeginDownloadByInodeResponse) GetExtraProperties() map[string]interface{}

func (*BeginDownloadByInodeResponse) GetInodeID

func (b *BeginDownloadByInodeResponse) GetInodeID() string

func (*BeginDownloadByInodeResponse) GetNamespaceID

func (b *BeginDownloadByInodeResponse) GetNamespaceID() NamespaceID

func (*BeginDownloadByInodeResponse) GetRevisionNo

func (b *BeginDownloadByInodeResponse) GetRevisionNo() RevisionNo

func (*BeginDownloadByInodeResponse) MarshalJSON

func (b *BeginDownloadByInodeResponse) MarshalJSON() ([]byte, error)

func (*BeginDownloadByInodeResponse) SetAccess

func (b *BeginDownloadByInodeResponse) SetAccess(access *ObjectTransferAccess)

SetAccess sets the Access field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadByInodeResponse) SetContentRef

func (b *BeginDownloadByInodeResponse) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadByInodeResponse) SetInodeID

func (b *BeginDownloadByInodeResponse) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadByInodeResponse) SetNamespaceID

func (b *BeginDownloadByInodeResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadByInodeResponse) SetRevisionNo

func (b *BeginDownloadByInodeResponse) SetRevisionNo(revisionNo RevisionNo)

SetRevisionNo sets the RevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadByInodeResponse) String

func (*BeginDownloadByInodeResponse) UnmarshalJSON

func (b *BeginDownloadByInodeResponse) UnmarshalJSON(data []byte) error

type BeginDownloadRequest

type BeginDownloadRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Use the file revision captured by this snapshot
	SnapshotID *CheckpointID `json:"-" url:"snapshot_id,omitempty"`
	// Absolute path of the file to read.
	Path AbsolutePath `json:"path" url:"-"`
	// Revision to read, or `None` for the path's current revision.
	RevisionNo *RevisionNo `json:"revision_no,omitempty" url:"-"`
	// contains filtered or unexported fields
}

func (*BeginDownloadRequest) MarshalJSON

func (b *BeginDownloadRequest) MarshalJSON() ([]byte, error)

func (*BeginDownloadRequest) SetNamespaceID

func (b *BeginDownloadRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadRequest) SetPath

func (b *BeginDownloadRequest) SetPath(path AbsolutePath)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadRequest) SetRevisionNo

func (b *BeginDownloadRequest) SetRevisionNo(revisionNo *RevisionNo)

SetRevisionNo sets the RevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadRequest) SetSnapshotID

func (b *BeginDownloadRequest) SetSnapshotID(snapshotID *CheckpointID)

SetSnapshotID sets the SnapshotID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadRequest) UnmarshalJSON

func (b *BeginDownloadRequest) UnmarshalJSON(data []byte) error

type BeginDownloadResponse

type BeginDownloadResponse struct {
	// Short-lived read capability the client uses without learning the raw object key.
	Access *ObjectTransferAccess `json:"access" url:"access"`
	// Identity, byte length, and checksum evidence for the object the
	// capability reads. A reader checks the bytes it receives against
	// `size_bytes` and recomputes `checksum.algorithm` over the complete
	// payload.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// Namespace that was read.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Absolute path as rendered from stored display names.
	Path AbsolutePath `json:"path" url:"path"`
	// Revision the capability reads, resolved from the request.
	RevisionNo RevisionNo `json:"revision_no" url:"revision_no"`
	// contains filtered or unexported fields
}

func (*BeginDownloadResponse) GetAccess

func (*BeginDownloadResponse) GetContentRef

func (b *BeginDownloadResponse) GetContentRef() *ContentRef

func (*BeginDownloadResponse) GetExtraProperties

func (b *BeginDownloadResponse) GetExtraProperties() map[string]interface{}

func (*BeginDownloadResponse) GetNamespaceID

func (b *BeginDownloadResponse) GetNamespaceID() NamespaceID

func (*BeginDownloadResponse) GetPath

func (b *BeginDownloadResponse) GetPath() AbsolutePath

func (*BeginDownloadResponse) GetRevisionNo

func (b *BeginDownloadResponse) GetRevisionNo() RevisionNo

func (*BeginDownloadResponse) MarshalJSON

func (b *BeginDownloadResponse) MarshalJSON() ([]byte, error)

func (*BeginDownloadResponse) SetAccess

func (b *BeginDownloadResponse) SetAccess(access *ObjectTransferAccess)

SetAccess sets the Access field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadResponse) SetContentRef

func (b *BeginDownloadResponse) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadResponse) SetNamespaceID

func (b *BeginDownloadResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadResponse) SetPath

func (b *BeginDownloadResponse) SetPath(path AbsolutePath)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadResponse) SetRevisionNo

func (b *BeginDownloadResponse) SetRevisionNo(revisionNo RevisionNo)

SetRevisionNo sets the RevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginDownloadResponse) String

func (b *BeginDownloadResponse) String() string

func (*BeginDownloadResponse) UnmarshalJSON

func (b *BeginDownloadResponse) UnmarshalJSON(data []byte) error

type BeginUploadDirectMultipart

type BeginUploadDirectMultipart struct {
	// Byte length of every part except the last. The server uses its
	// default when this is omitted.
	PartSizeBytes *int64 `json:"part_size_bytes,omitempty" url:"part_size_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*BeginUploadDirectMultipart) GetExtraProperties

func (b *BeginUploadDirectMultipart) GetExtraProperties() map[string]interface{}

func (*BeginUploadDirectMultipart) GetPartSizeBytes

func (b *BeginUploadDirectMultipart) GetPartSizeBytes() *int64

func (*BeginUploadDirectMultipart) MarshalJSON

func (b *BeginUploadDirectMultipart) MarshalJSON() ([]byte, error)

func (*BeginUploadDirectMultipart) SetPartSizeBytes

func (b *BeginUploadDirectMultipart) SetPartSizeBytes(partSizeBytes *int64)

SetPartSizeBytes sets the PartSizeBytes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadDirectMultipart) String

func (b *BeginUploadDirectMultipart) String() string

func (*BeginUploadDirectMultipart) UnmarshalJSON

func (b *BeginUploadDirectMultipart) UnmarshalJSON(data []byte) error

type BeginUploadDirectPut

type BeginUploadDirectPut struct {
	// Advisory byte length for an early provider-limit check.
	SizeBytes *int64 `json:"size_bytes,omitempty" url:"size_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*BeginUploadDirectPut) GetExtraProperties

func (b *BeginUploadDirectPut) GetExtraProperties() map[string]interface{}

func (*BeginUploadDirectPut) GetSizeBytes

func (b *BeginUploadDirectPut) GetSizeBytes() *int64

func (*BeginUploadDirectPut) MarshalJSON

func (b *BeginUploadDirectPut) MarshalJSON() ([]byte, error)

func (*BeginUploadDirectPut) SetSizeBytes

func (b *BeginUploadDirectPut) SetSizeBytes(sizeBytes *int64)

SetSizeBytes sets the SizeBytes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadDirectPut) String

func (b *BeginUploadDirectPut) String() string

func (*BeginUploadDirectPut) UnmarshalJSON

func (b *BeginUploadDirectPut) UnmarshalJSON(data []byte) error

type BeginUploadRequest

type BeginUploadRequest struct {
	Mode            string
	ServiceProxied  *BeginUploadServiceProxied
	DirectPut       *BeginUploadDirectPut
	DirectMultipart *BeginUploadDirectMultipart
	// contains filtered or unexported fields
}

Request to start an upload session, tagged by transport mode.

Each variant contains only fields valid for that transport, so invalid combinations are rejected during decoding. The `mode` field is required.

func (*BeginUploadRequest) Accept

func (*BeginUploadRequest) GetDirectMultipart

func (b *BeginUploadRequest) GetDirectMultipart() *BeginUploadDirectMultipart

func (*BeginUploadRequest) GetDirectPut

func (b *BeginUploadRequest) GetDirectPut() *BeginUploadDirectPut

func (*BeginUploadRequest) GetMode

func (b *BeginUploadRequest) GetMode() string

func (*BeginUploadRequest) GetServiceProxied

func (b *BeginUploadRequest) GetServiceProxied() *BeginUploadServiceProxied

func (BeginUploadRequest) MarshalJSON

func (b BeginUploadRequest) MarshalJSON() ([]byte, error)

func (*BeginUploadRequest) UnmarshalJSON

func (b *BeginUploadRequest) UnmarshalJSON(data []byte) error

type BeginUploadRequestVisitor

type BeginUploadRequestVisitor interface {
	VisitServiceProxied(*BeginUploadServiceProxied) error
	VisitDirectPut(*BeginUploadDirectPut) error
	VisitDirectMultipart(*BeginUploadDirectMultipart) error
}

type BeginUploadResponse

type BeginUploadResponse struct {
	Mode            string
	ServiceProxied  *BeginUploadResponseServiceProxied
	DirectPut       *BeginUploadResponseDirectPut
	DirectMultipart *BeginUploadResponseDirectMultipart
	// contains filtered or unexported fields
}

Response to starting an upload session, tagged by transport mode.

Each variant contains only the fields needed by that transport. Unknown response fields are accepted for forward compatibility.

func (*BeginUploadResponse) Accept

func (*BeginUploadResponse) GetDirectMultipart

func (*BeginUploadResponse) GetDirectPut

func (*BeginUploadResponse) GetMode

func (b *BeginUploadResponse) GetMode() string

func (*BeginUploadResponse) GetServiceProxied

func (BeginUploadResponse) MarshalJSON

func (b BeginUploadResponse) MarshalJSON() ([]byte, error)

func (*BeginUploadResponse) UnmarshalJSON

func (b *BeginUploadResponse) UnmarshalJSON(data []byte) error

type BeginUploadResponseDirectMultipart

type BeginUploadResponseDirectMultipart struct {
	// Checksum algorithm for every part and for the complete payload.
	ChecksumAlgorithm ChecksumAlgorithm `json:"checksum_algorithm" url:"checksum_algorithm"`
	// Namespace authorized to consume the eventual staged content.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Byte length of every part except the last. At most 10,000 parts
	// may be uploaded, so this bounds the object at 10,000 times the
	// part size.
	PartSizeBytes int64 `json:"part_size_bytes" url:"part_size_bytes"`
	// Durable session identity used by subsequent part-signing and
	// completion calls.
	UploadID UploadID `json:"upload_id" url:"upload_id"`
	// contains filtered or unexported fields
}

func (*BeginUploadResponseDirectMultipart) GetChecksumAlgorithm

func (b *BeginUploadResponseDirectMultipart) GetChecksumAlgorithm() ChecksumAlgorithm

func (*BeginUploadResponseDirectMultipart) GetExtraProperties

func (b *BeginUploadResponseDirectMultipart) GetExtraProperties() map[string]interface{}

func (*BeginUploadResponseDirectMultipart) GetNamespaceID

func (b *BeginUploadResponseDirectMultipart) GetNamespaceID() NamespaceID

func (*BeginUploadResponseDirectMultipart) GetPartSizeBytes

func (b *BeginUploadResponseDirectMultipart) GetPartSizeBytes() int64

func (*BeginUploadResponseDirectMultipart) GetUploadID

func (*BeginUploadResponseDirectMultipart) MarshalJSON

func (b *BeginUploadResponseDirectMultipart) MarshalJSON() ([]byte, error)

func (*BeginUploadResponseDirectMultipart) SetChecksumAlgorithm

func (b *BeginUploadResponseDirectMultipart) SetChecksumAlgorithm(checksumAlgorithm ChecksumAlgorithm)

SetChecksumAlgorithm sets the ChecksumAlgorithm field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadResponseDirectMultipart) SetNamespaceID

func (b *BeginUploadResponseDirectMultipart) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadResponseDirectMultipart) SetPartSizeBytes

func (b *BeginUploadResponseDirectMultipart) SetPartSizeBytes(partSizeBytes int64)

SetPartSizeBytes sets the PartSizeBytes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadResponseDirectMultipart) SetUploadID

func (b *BeginUploadResponseDirectMultipart) SetUploadID(uploadID UploadID)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadResponseDirectMultipart) String

func (*BeginUploadResponseDirectMultipart) UnmarshalJSON

func (b *BeginUploadResponseDirectMultipart) UnmarshalJSON(data []byte) error

type BeginUploadResponseDirectPut

type BeginUploadResponseDirectPut struct {
	// Short-lived permission to write the object.
	Access *ObjectTransferAccess `json:"access" url:"access"`
	// Checksum algorithm the client must use for its completion claim.
	ChecksumAlgorithm ChecksumAlgorithm `json:"checksum_algorithm" url:"checksum_algorithm"`
	// Namespace authorized to consume the eventual staged content.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Durable session identity used by subsequent completion calls.
	UploadID UploadID `json:"upload_id" url:"upload_id"`
	// contains filtered or unexported fields
}

func (*BeginUploadResponseDirectPut) GetAccess

func (*BeginUploadResponseDirectPut) GetChecksumAlgorithm

func (b *BeginUploadResponseDirectPut) GetChecksumAlgorithm() ChecksumAlgorithm

func (*BeginUploadResponseDirectPut) GetExtraProperties

func (b *BeginUploadResponseDirectPut) GetExtraProperties() map[string]interface{}

func (*BeginUploadResponseDirectPut) GetNamespaceID

func (b *BeginUploadResponseDirectPut) GetNamespaceID() NamespaceID

func (*BeginUploadResponseDirectPut) GetUploadID

func (b *BeginUploadResponseDirectPut) GetUploadID() UploadID

func (*BeginUploadResponseDirectPut) MarshalJSON

func (b *BeginUploadResponseDirectPut) MarshalJSON() ([]byte, error)

func (*BeginUploadResponseDirectPut) SetAccess

func (b *BeginUploadResponseDirectPut) SetAccess(access *ObjectTransferAccess)

SetAccess sets the Access field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadResponseDirectPut) SetChecksumAlgorithm

func (b *BeginUploadResponseDirectPut) SetChecksumAlgorithm(checksumAlgorithm ChecksumAlgorithm)

SetChecksumAlgorithm sets the ChecksumAlgorithm field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadResponseDirectPut) SetNamespaceID

func (b *BeginUploadResponseDirectPut) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadResponseDirectPut) SetUploadID

func (b *BeginUploadResponseDirectPut) SetUploadID(uploadID UploadID)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadResponseDirectPut) String

func (*BeginUploadResponseDirectPut) UnmarshalJSON

func (b *BeginUploadResponseDirectPut) UnmarshalJSON(data []byte) error

type BeginUploadResponseServiceProxied

type BeginUploadResponseServiceProxied struct {
	// Namespace authorized to consume the eventual staged content.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Durable session identity used by subsequent append and completion
	// calls.
	UploadID UploadID `json:"upload_id" url:"upload_id"`
	// contains filtered or unexported fields
}

func (*BeginUploadResponseServiceProxied) GetExtraProperties

func (b *BeginUploadResponseServiceProxied) GetExtraProperties() map[string]interface{}

func (*BeginUploadResponseServiceProxied) GetNamespaceID

func (b *BeginUploadResponseServiceProxied) GetNamespaceID() NamespaceID

func (*BeginUploadResponseServiceProxied) GetUploadID

func (*BeginUploadResponseServiceProxied) MarshalJSON

func (b *BeginUploadResponseServiceProxied) MarshalJSON() ([]byte, error)

func (*BeginUploadResponseServiceProxied) SetNamespaceID

func (b *BeginUploadResponseServiceProxied) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadResponseServiceProxied) SetUploadID

func (b *BeginUploadResponseServiceProxied) SetUploadID(uploadID UploadID)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*BeginUploadResponseServiceProxied) String

func (*BeginUploadResponseServiceProxied) UnmarshalJSON

func (b *BeginUploadResponseServiceProxied) UnmarshalJSON(data []byte) error

type BeginUploadResponseVisitor

type BeginUploadResponseVisitor interface {
	VisitServiceProxied(*BeginUploadResponseServiceProxied) error
	VisitDirectPut(*BeginUploadResponseDirectPut) error
	VisitDirectMultipart(*BeginUploadResponseDirectMultipart) error
}

type BeginUploadServiceProxied

type BeginUploadServiceProxied struct {
	// contains filtered or unexported fields
}

Send the bytes to the service, which writes the content object.

func (*BeginUploadServiceProxied) GetExtraProperties

func (b *BeginUploadServiceProxied) GetExtraProperties() map[string]interface{}

func (*BeginUploadServiceProxied) MarshalJSON

func (b *BeginUploadServiceProxied) MarshalJSON() ([]byte, error)

func (*BeginUploadServiceProxied) String

func (b *BeginUploadServiceProxied) String() string

func (*BeginUploadServiceProxied) UnmarshalJSON

func (b *BeginUploadServiceProxied) UnmarshalJSON(data []byte) error

type CapabilityDocument

type CapabilityDocument struct {
	// Named features and whether this deployment supports them. An absent
	// key means unsupported.
	Features map[string]bool `json:"features,omitempty" url:"features,omitempty"`
	// Advisory numeric limits clients may use to pre-validate requests.
	Limits map[string]int64 `json:"limits,omitempty" url:"limits,omitempty"`
	// Advertised profiles, each `plane/version`. All-or-nothing: every
	// required op of an advertised profile is implemented.
	Profiles []string `json:"profiles" url:"profiles"`
	// The protocol generation, currently `v0`.
	ProtocolVersion string `json:"protocol_version" url:"protocol_version"`
	// contains filtered or unexported fields
}

func (*CapabilityDocument) GetExtraProperties

func (c *CapabilityDocument) GetExtraProperties() map[string]interface{}

func (*CapabilityDocument) GetFeatures

func (c *CapabilityDocument) GetFeatures() map[string]bool

func (*CapabilityDocument) GetLimits

func (c *CapabilityDocument) GetLimits() map[string]int64

func (*CapabilityDocument) GetProfiles

func (c *CapabilityDocument) GetProfiles() []string

func (*CapabilityDocument) GetProtocolVersion

func (c *CapabilityDocument) GetProtocolVersion() string

func (*CapabilityDocument) MarshalJSON

func (c *CapabilityDocument) MarshalJSON() ([]byte, error)

func (*CapabilityDocument) SetFeatures

func (c *CapabilityDocument) SetFeatures(features map[string]bool)

SetFeatures sets the Features field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CapabilityDocument) SetLimits

func (c *CapabilityDocument) SetLimits(limits map[string]int64)

SetLimits sets the Limits field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CapabilityDocument) SetProfiles

func (c *CapabilityDocument) SetProfiles(profiles []string)

SetProfiles sets the Profiles field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CapabilityDocument) SetProtocolVersion

func (c *CapabilityDocument) SetProtocolVersion(protocolVersion string)

SetProtocolVersion sets the ProtocolVersion field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CapabilityDocument) String

func (c *CapabilityDocument) String() string

func (*CapabilityDocument) UnmarshalJSON

func (c *CapabilityDocument) UnmarshalJSON(data []byte) error

type ChangeSeq

type ChangeSeq = int64

Sequence number assigned to a namespace commit. It determines the order in which commits become visible.

type Checkpoint

type Checkpoint struct {
	// Durable checkpoint id used to address the checkpoint for release.
	CheckpointID CheckpointID `json:"checkpoint_id" url:"checkpoint_id"`
	// Sequence covered by the checkpoint's pinned basis.
	CheckpointSeq ChangeSeq `json:"checkpoint_seq" url:"checkpoint_seq"`
	// Time the checkpoint record was created, in Unix milliseconds.
	CreatedAtMs int64 `json:"created_at_ms" url:"created_at_ms"`
	// When garbage collection may release the record without being asked,
	// in Unix milliseconds. Absent means the pin holds until it is
	// released. An instant already in the past is a record whose expiry
	// has passed and which no collection pass has reached yet: it is still
	// a root, so it is still listed.
	ExpiresAtMs *int64 `json:"expires_at_ms,omitempty" url:"expires_at_ms,omitempty"`
	// Manifest pinned by the checkpoint.
	ManifestNo ManifestNo `json:"manifest_no" url:"manifest_no"`
	// Namespace that owns the checkpoint.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Who owns the checkpoint, including the label carried by a user pin.
	Owner *CheckpointOwnerSummary `json:"owner" url:"owner"`
	// contains filtered or unexported fields
}

func (*Checkpoint) GetCheckpointID

func (c *Checkpoint) GetCheckpointID() CheckpointID

func (*Checkpoint) GetCheckpointSeq

func (c *Checkpoint) GetCheckpointSeq() ChangeSeq

func (*Checkpoint) GetCreatedAtMs

func (c *Checkpoint) GetCreatedAtMs() int64

func (*Checkpoint) GetExpiresAtMs

func (c *Checkpoint) GetExpiresAtMs() *int64

func (*Checkpoint) GetExtraProperties

func (c *Checkpoint) GetExtraProperties() map[string]interface{}

func (*Checkpoint) GetManifestNo

func (c *Checkpoint) GetManifestNo() ManifestNo

func (*Checkpoint) GetNamespaceID

func (c *Checkpoint) GetNamespaceID() NamespaceID

func (*Checkpoint) GetOwner

func (c *Checkpoint) GetOwner() *CheckpointOwnerSummary

func (*Checkpoint) MarshalJSON

func (c *Checkpoint) MarshalJSON() ([]byte, error)

func (*Checkpoint) SetCheckpointID

func (c *Checkpoint) SetCheckpointID(checkpointID CheckpointID)

SetCheckpointID sets the CheckpointID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Checkpoint) SetCheckpointSeq

func (c *Checkpoint) SetCheckpointSeq(checkpointSeq ChangeSeq)

SetCheckpointSeq sets the CheckpointSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Checkpoint) SetCreatedAtMs

func (c *Checkpoint) SetCreatedAtMs(createdAtMs int64)

SetCreatedAtMs sets the CreatedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Checkpoint) SetExpiresAtMs

func (c *Checkpoint) SetExpiresAtMs(expiresAtMs *int64)

SetExpiresAtMs sets the ExpiresAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Checkpoint) SetManifestNo

func (c *Checkpoint) SetManifestNo(manifestNo ManifestNo)

SetManifestNo sets the ManifestNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Checkpoint) SetNamespaceID

func (c *Checkpoint) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Checkpoint) SetOwner

func (c *Checkpoint) SetOwner(owner *CheckpointOwnerSummary)

SetOwner sets the Owner field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Checkpoint) String

func (c *Checkpoint) String() string

func (*Checkpoint) UnmarshalJSON

func (c *Checkpoint) UnmarshalJSON(data []byte) error

type CheckpointID

type CheckpointID = string

Durable checkpoint identifier.

A checkpoint is a durable bookmark to a namespace manifest version.

type CheckpointOwnerFork

type CheckpointOwnerFork struct {
	// Namespace whose continued existence keeps this pin standing.
	TargetNamespaceID NamespaceID `json:"target_namespace_id" url:"target_namespace_id"`
	// contains filtered or unexported fields
}

func (*CheckpointOwnerFork) GetExtraProperties

func (c *CheckpointOwnerFork) GetExtraProperties() map[string]interface{}

func (*CheckpointOwnerFork) GetTargetNamespaceID

func (c *CheckpointOwnerFork) GetTargetNamespaceID() NamespaceID

func (*CheckpointOwnerFork) MarshalJSON

func (c *CheckpointOwnerFork) MarshalJSON() ([]byte, error)

func (*CheckpointOwnerFork) SetTargetNamespaceID

func (c *CheckpointOwnerFork) SetTargetNamespaceID(targetNamespaceID NamespaceID)

SetTargetNamespaceID sets the TargetNamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CheckpointOwnerFork) String

func (c *CheckpointOwnerFork) String() string

func (*CheckpointOwnerFork) UnmarshalJSON

func (c *CheckpointOwnerFork) UnmarshalJSON(data []byte) error

type CheckpointOwnerSnapshot

type CheckpointOwnerSnapshot struct {
	// When the snapshot lease expires, in Unix milliseconds.
	ExpiresAtMs int64 `json:"expires_at_ms" url:"expires_at_ms"`
	// A label that does not need to be unique.
	Name string `json:"name" url:"name"`
	// contains filtered or unexported fields
}

func (*CheckpointOwnerSnapshot) GetExpiresAtMs

func (c *CheckpointOwnerSnapshot) GetExpiresAtMs() int64

func (*CheckpointOwnerSnapshot) GetExtraProperties

func (c *CheckpointOwnerSnapshot) GetExtraProperties() map[string]interface{}

func (*CheckpointOwnerSnapshot) GetName

func (c *CheckpointOwnerSnapshot) GetName() string

func (*CheckpointOwnerSnapshot) MarshalJSON

func (c *CheckpointOwnerSnapshot) MarshalJSON() ([]byte, error)

func (*CheckpointOwnerSnapshot) SetExpiresAtMs

func (c *CheckpointOwnerSnapshot) SetExpiresAtMs(expiresAtMs int64)

SetExpiresAtMs sets the ExpiresAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CheckpointOwnerSnapshot) SetName

func (c *CheckpointOwnerSnapshot) SetName(name string)

SetName sets the Name field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CheckpointOwnerSnapshot) String

func (c *CheckpointOwnerSnapshot) String() string

func (*CheckpointOwnerSnapshot) UnmarshalJSON

func (c *CheckpointOwnerSnapshot) UnmarshalJSON(data []byte) error

type CheckpointOwnerSummary

type CheckpointOwnerSummary struct {
	Kind     string
	User     *CheckpointOwnerUser
	Fork     *CheckpointOwnerFork
	Snapshot *CheckpointOwnerSnapshot
	// contains filtered or unexported fields
}

The owner of a checkpoint record.

func (*CheckpointOwnerSummary) Accept

func (*CheckpointOwnerSummary) GetFork

func (*CheckpointOwnerSummary) GetKind

func (c *CheckpointOwnerSummary) GetKind() string

func (*CheckpointOwnerSummary) GetSnapshot

func (*CheckpointOwnerSummary) GetUser

func (CheckpointOwnerSummary) MarshalJSON

func (c CheckpointOwnerSummary) MarshalJSON() ([]byte, error)

func (*CheckpointOwnerSummary) UnmarshalJSON

func (c *CheckpointOwnerSummary) UnmarshalJSON(data []byte) error

type CheckpointOwnerSummaryVisitor

type CheckpointOwnerSummaryVisitor interface {
	VisitUser(*CheckpointOwnerUser) error
	VisitFork(*CheckpointOwnerFork) error
	VisitSnapshot(*CheckpointOwnerSnapshot) error
}

type CheckpointOwnerUser

type CheckpointOwnerUser struct {
	// The label the creator recorded. Not a key: several records may
	// carry one label over different bases.
	Name string `json:"name" url:"name"`
	// contains filtered or unexported fields
}

func (*CheckpointOwnerUser) GetExtraProperties

func (c *CheckpointOwnerUser) GetExtraProperties() map[string]interface{}

func (*CheckpointOwnerUser) GetName

func (c *CheckpointOwnerUser) GetName() string

func (*CheckpointOwnerUser) MarshalJSON

func (c *CheckpointOwnerUser) MarshalJSON() ([]byte, error)

func (*CheckpointOwnerUser) SetName

func (c *CheckpointOwnerUser) SetName(name string)

SetName sets the Name field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CheckpointOwnerUser) String

func (c *CheckpointOwnerUser) String() string

func (*CheckpointOwnerUser) UnmarshalJSON

func (c *CheckpointOwnerUser) UnmarshalJSON(data []byte) error

type Checksum

type Checksum struct {
	// Algorithm that produced `value`.
	Algorithm ChecksumAlgorithm `json:"algorithm" url:"algorithm"`
	// Lowercase hex of the raw checksum bytes.
	//
	// The algorithm is its own field, so the value carries no prefix.
	// Provider APIs that report base64 are converted at the adapter.
	Value string `json:"value" url:"value"`
	// contains filtered or unexported fields
}

func (*Checksum) GetAlgorithm

func (c *Checksum) GetAlgorithm() ChecksumAlgorithm

func (*Checksum) GetExtraProperties

func (c *Checksum) GetExtraProperties() map[string]interface{}

func (*Checksum) GetValue

func (c *Checksum) GetValue() string

func (*Checksum) MarshalJSON

func (c *Checksum) MarshalJSON() ([]byte, error)

func (*Checksum) SetAlgorithm

func (c *Checksum) SetAlgorithm(algorithm ChecksumAlgorithm)

SetAlgorithm sets the Algorithm field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Checksum) SetValue

func (c *Checksum) SetValue(value string)

SetValue sets the Value field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Checksum) String

func (c *Checksum) String() string

func (*Checksum) UnmarshalJSON

func (c *Checksum) UnmarshalJSON(data []byte) error

type ChecksumAlgorithm

type ChecksumAlgorithm string

Supported checksum algorithms.

The enclosing value defines which bytes a checksum covers. Unknown algorithms fail to decode because every in-memory `ChecksumAlgorithm` must be recomputable by this build. Adding a variant also requires adding its implementation.

const (
	ChecksumAlgorithmSha256    ChecksumAlgorithm = "sha256"
	ChecksumAlgorithmCrc64Nvme ChecksumAlgorithm = "crc64nvme"
	ChecksumAlgorithmCrc32C    ChecksumAlgorithm = "crc32c"
)

func NewChecksumAlgorithmFromString

func NewChecksumAlgorithmFromString(s string) (ChecksumAlgorithm, error)

func (ChecksumAlgorithm) Ptr

type CommitID

type CommitID = string

Client-supplied idempotency key for one logical commit.

Reuse the same `CommitId` when retrying the same request. The accepted grammar is 1 to 128 lowercase ASCII letters, digits, dots, underscores, or hyphens, starting with a letter or digit. [`CommitId::generate`] returns `c_<32 lowercase hex>`, but callers may supply any value in that grammar.

type CommitRequest

type CommitRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Actor responsible for the commit, as supplied by the application.
	Actor *ActorRef `json:"actor" url:"-"`
	// Caller-supplied idempotency key for the whole request.
	CommitID CommitID `json:"commit_id" url:"-"`
	// Proofs for any new external content refs introduced by this request.
	// One proof covers every operation that names its content ref.
	ContentTokens []*ContentToken `json:"content_tokens,omitempty" url:"-"`
	// Caller annotation recorded on the commit and reported by the change
	// feed. Part of the commit's identity: reusing `commit_id` with a
	// different message is a `commit_id_reuse_conflict`, exactly as it is
	// for an explicit commit.
	Message *string `json:"message,omitempty" url:"-"`
	// Ordered operations to apply. Must be non-empty; they commit all
	// together or not at all.
	Operations []*FilesystemOperation `json:"operations" url:"-"`
	// contains filtered or unexported fields
}

func (*CommitRequest) MarshalJSON

func (c *CommitRequest) MarshalJSON() ([]byte, error)

func (*CommitRequest) SetActor

func (c *CommitRequest) SetActor(actor *ActorRef)

SetActor sets the Actor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitRequest) SetCommitID

func (c *CommitRequest) SetCommitID(commitID CommitID)

SetCommitID sets the CommitID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitRequest) SetContentTokens

func (c *CommitRequest) SetContentTokens(contentTokens []*ContentToken)

SetContentTokens sets the ContentTokens field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitRequest) SetMessage

func (c *CommitRequest) SetMessage(message *string)

SetMessage sets the Message field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitRequest) SetNamespaceID

func (c *CommitRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitRequest) SetOperations

func (c *CommitRequest) SetOperations(operations []*FilesystemOperation)

SetOperations sets the Operations field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitRequest) UnmarshalJSON

func (c *CommitRequest) UnmarshalJSON(data []byte) error

type CommitResponse

type CommitResponse struct {
	// Idempotency key the commit landed under: caller-supplied, or
	// generated on the caller's behalf when the request carried none.
	CommitID CommitID `json:"commit_id" url:"commit_id"`
	// Wall-clock stamp of the commit, in Unix milliseconds.
	// Observational: `committed_seq` is the order.
	CommittedAtMs int64 `json:"committed_at_ms" url:"committed_at_ms"`
	// Actor responsible for the commit, as supplied by the application.
	CommittedBy *ActorRef `json:"committed_by" url:"committed_by"`
	// Sequence number where the commit became visible.
	CommittedSeq ChangeSeq `json:"committed_seq" url:"committed_seq"`
	// Semantic filesystem events in commit order. This is omitted only when
	// replaying a commit whose WAL history is no longer retained.
	Events []*FilesystemChange `json:"events,omitempty" url:"events,omitempty"`
	// Caller annotation, omitted when absent and carrying no filesystem
	// semantics.
	Message *string `json:"message,omitempty" url:"message,omitempty"`
	// Namespace that changed.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// contains filtered or unexported fields
}

func (*CommitResponse) GetCommitID

func (c *CommitResponse) GetCommitID() CommitID

func (*CommitResponse) GetCommittedAtMs

func (c *CommitResponse) GetCommittedAtMs() int64

func (*CommitResponse) GetCommittedBy

func (c *CommitResponse) GetCommittedBy() *ActorRef

func (*CommitResponse) GetCommittedSeq

func (c *CommitResponse) GetCommittedSeq() ChangeSeq

func (*CommitResponse) GetEvents

func (c *CommitResponse) GetEvents() []*FilesystemChange

func (*CommitResponse) GetExtraProperties

func (c *CommitResponse) GetExtraProperties() map[string]interface{}

func (*CommitResponse) GetMessage

func (c *CommitResponse) GetMessage() *string

func (*CommitResponse) GetNamespaceID

func (c *CommitResponse) GetNamespaceID() NamespaceID

func (*CommitResponse) MarshalJSON

func (c *CommitResponse) MarshalJSON() ([]byte, error)

func (*CommitResponse) SetCommitID

func (c *CommitResponse) SetCommitID(commitID CommitID)

SetCommitID sets the CommitID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitResponse) SetCommittedAtMs

func (c *CommitResponse) SetCommittedAtMs(committedAtMs int64)

SetCommittedAtMs sets the CommittedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitResponse) SetCommittedBy

func (c *CommitResponse) SetCommittedBy(committedBy *ActorRef)

SetCommittedBy sets the CommittedBy field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitResponse) SetCommittedSeq

func (c *CommitResponse) SetCommittedSeq(committedSeq ChangeSeq)

SetCommittedSeq sets the CommittedSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitResponse) SetEvents

func (c *CommitResponse) SetEvents(events []*FilesystemChange)

SetEvents sets the Events field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitResponse) SetMessage

func (c *CommitResponse) SetMessage(message *string)

SetMessage sets the Message field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitResponse) SetNamespaceID

func (c *CommitResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommitResponse) String

func (c *CommitResponse) String() string

func (*CommitResponse) UnmarshalJSON

func (c *CommitResponse) UnmarshalJSON(data []byte) error

type CommittedChange

type CommittedChange struct {
	// Client idempotency key for this logical commit.
	CommitID CommitID `json:"commit_id" url:"commit_id"`
	// Wall-clock stamp of the commit, in Unix milliseconds.
	// Observational: `committed_seq` is the order.
	CommittedAtMs int64 `json:"committed_at_ms" url:"committed_at_ms"`
	// Actor responsible for the commit, as supplied by the application.
	CommittedBy *ActorRef `json:"committed_by" url:"committed_by"`
	// Namespace sequence for this logical commit.
	CommittedSeq ChangeSeq `json:"committed_seq" url:"committed_seq"`
	// Semantic filesystem events for this commit, in the order the commit
	// applied them. One request operation may produce more than one event
	// (see [`FilesystemChange`]).
	Events []*FilesystemChange `json:"events" url:"events"`
	// Caller annotation, omitted when absent and carrying no filesystem semantics.
	Message *string `json:"message,omitempty" url:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*CommittedChange) GetCommitID

func (c *CommittedChange) GetCommitID() CommitID

func (*CommittedChange) GetCommittedAtMs

func (c *CommittedChange) GetCommittedAtMs() int64

func (*CommittedChange) GetCommittedBy

func (c *CommittedChange) GetCommittedBy() *ActorRef

func (*CommittedChange) GetCommittedSeq

func (c *CommittedChange) GetCommittedSeq() ChangeSeq

func (*CommittedChange) GetEvents

func (c *CommittedChange) GetEvents() []*FilesystemChange

func (*CommittedChange) GetExtraProperties

func (c *CommittedChange) GetExtraProperties() map[string]interface{}

func (*CommittedChange) GetMessage

func (c *CommittedChange) GetMessage() *string

func (*CommittedChange) MarshalJSON

func (c *CommittedChange) MarshalJSON() ([]byte, error)

func (*CommittedChange) SetCommitID

func (c *CommittedChange) SetCommitID(commitID CommitID)

SetCommitID sets the CommitID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommittedChange) SetCommittedAtMs

func (c *CommittedChange) SetCommittedAtMs(committedAtMs int64)

SetCommittedAtMs sets the CommittedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommittedChange) SetCommittedBy

func (c *CommittedChange) SetCommittedBy(committedBy *ActorRef)

SetCommittedBy sets the CommittedBy field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommittedChange) SetCommittedSeq

func (c *CommittedChange) SetCommittedSeq(committedSeq ChangeSeq)

SetCommittedSeq sets the CommittedSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommittedChange) SetEvents

func (c *CommittedChange) SetEvents(events []*FilesystemChange)

SetEvents sets the Events field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommittedChange) SetMessage

func (c *CommittedChange) SetMessage(message *string)

SetMessage sets the Message field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CommittedChange) String

func (c *CommittedChange) String() string

func (*CommittedChange) UnmarshalJSON

func (c *CommittedChange) UnmarshalJSON(data []byte) error

type CompleteUploadBody

type CompleteUploadBody struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Upload session id
	UploadID string                 `json:"-" url:"-"`
	Body     *CompleteUploadRequest `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*CompleteUploadBody) MarshalJSON

func (c *CompleteUploadBody) MarshalJSON() ([]byte, error)

func (*CompleteUploadBody) SetNamespaceID

func (c *CompleteUploadBody) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CompleteUploadBody) SetUploadID

func (c *CompleteUploadBody) SetUploadID(uploadID string)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CompleteUploadBody) UnmarshalJSON

func (c *CompleteUploadBody) UnmarshalJSON(data []byte) error

type CompleteUploadDirectMultipart

type CompleteUploadDirectMultipart struct {
	// Expected length and checksum of the assembled object.
	Content *UploadContentClaim `json:"content" url:"content"`
	// Uploaded parts in ascending part order.
	Parts []*CompletedUploadPart `json:"parts" url:"parts"`
	// contains filtered or unexported fields
}

func (*CompleteUploadDirectMultipart) GetContent

func (*CompleteUploadDirectMultipart) GetExtraProperties

func (c *CompleteUploadDirectMultipart) GetExtraProperties() map[string]interface{}

func (*CompleteUploadDirectMultipart) GetParts

func (*CompleteUploadDirectMultipart) MarshalJSON

func (c *CompleteUploadDirectMultipart) MarshalJSON() ([]byte, error)

func (*CompleteUploadDirectMultipart) SetContent

func (c *CompleteUploadDirectMultipart) SetContent(content *UploadContentClaim)

SetContent sets the Content field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CompleteUploadDirectMultipart) SetParts

func (c *CompleteUploadDirectMultipart) SetParts(parts []*CompletedUploadPart)

SetParts sets the Parts field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CompleteUploadDirectMultipart) String

func (*CompleteUploadDirectMultipart) UnmarshalJSON

func (c *CompleteUploadDirectMultipart) UnmarshalJSON(data []byte) error

type CompleteUploadDirectPut

type CompleteUploadDirectPut struct {
	// Expected length and checksum of the stored object.
	Content *UploadContentClaim `json:"content" url:"content"`
	// contains filtered or unexported fields
}

func (*CompleteUploadDirectPut) GetContent

func (*CompleteUploadDirectPut) GetExtraProperties

func (c *CompleteUploadDirectPut) GetExtraProperties() map[string]interface{}

func (*CompleteUploadDirectPut) MarshalJSON

func (c *CompleteUploadDirectPut) MarshalJSON() ([]byte, error)

func (*CompleteUploadDirectPut) SetContent

func (c *CompleteUploadDirectPut) SetContent(content *UploadContentClaim)

SetContent sets the Content field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CompleteUploadDirectPut) String

func (c *CompleteUploadDirectPut) String() string

func (*CompleteUploadDirectPut) UnmarshalJSON

func (c *CompleteUploadDirectPut) UnmarshalJSON(data []byte) error

type CompleteUploadRequest

type CompleteUploadRequest struct {
	Mode            string
	ServiceProxied  *CompleteUploadServiceProxied
	DirectPut       *CompleteUploadDirectPut
	DirectMultipart *CompleteUploadDirectMultipart
	// contains filtered or unexported fields
}

Request to complete an upload session.

`mode` must match the mode used to start the session. Direct uploads include the expected content details. Multipart also includes its parts.

func (*CompleteUploadRequest) Accept

func (*CompleteUploadRequest) GetDirectMultipart

func (c *CompleteUploadRequest) GetDirectMultipart() *CompleteUploadDirectMultipart

func (*CompleteUploadRequest) GetDirectPut

func (*CompleteUploadRequest) GetMode

func (c *CompleteUploadRequest) GetMode() string

func (*CompleteUploadRequest) GetServiceProxied

func (c *CompleteUploadRequest) GetServiceProxied() *CompleteUploadServiceProxied

func (CompleteUploadRequest) MarshalJSON

func (c CompleteUploadRequest) MarshalJSON() ([]byte, error)

func (*CompleteUploadRequest) UnmarshalJSON

func (c *CompleteUploadRequest) UnmarshalJSON(data []byte) error

type CompleteUploadRequestVisitor

type CompleteUploadRequestVisitor interface {
	VisitServiceProxied(*CompleteUploadServiceProxied) error
	VisitDirectPut(*CompleteUploadDirectPut) error
	VisitDirectMultipart(*CompleteUploadDirectMultipart) error
}

type CompleteUploadServiceProxied

type CompleteUploadServiceProxied struct {
	// contains filtered or unexported fields
}

Complete a service-proxied upload.

func (*CompleteUploadServiceProxied) GetExtraProperties

func (c *CompleteUploadServiceProxied) GetExtraProperties() map[string]interface{}

func (*CompleteUploadServiceProxied) MarshalJSON

func (c *CompleteUploadServiceProxied) MarshalJSON() ([]byte, error)

func (*CompleteUploadServiceProxied) String

func (*CompleteUploadServiceProxied) UnmarshalJSON

func (c *CompleteUploadServiceProxied) UnmarshalJSON(data []byte) error

type CompletedUploadPart

type CompletedUploadPart struct {
	// Checksum the part was signed and accepted with.
	Checksum *Checksum `json:"checksum" url:"checksum"`
	// Entity tag the provider returned for the accepted part.
	Etag string `json:"etag" url:"etag"`
	// One-based part number.
	PartNumber int `json:"part_number" url:"part_number"`
	// contains filtered or unexported fields
}

func (*CompletedUploadPart) GetChecksum

func (c *CompletedUploadPart) GetChecksum() *Checksum

func (*CompletedUploadPart) GetEtag

func (c *CompletedUploadPart) GetEtag() string

func (*CompletedUploadPart) GetExtraProperties

func (c *CompletedUploadPart) GetExtraProperties() map[string]interface{}

func (*CompletedUploadPart) GetPartNumber

func (c *CompletedUploadPart) GetPartNumber() int

func (*CompletedUploadPart) MarshalJSON

func (c *CompletedUploadPart) MarshalJSON() ([]byte, error)

func (*CompletedUploadPart) SetChecksum

func (c *CompletedUploadPart) SetChecksum(checksum *Checksum)

SetChecksum sets the Checksum field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CompletedUploadPart) SetEtag

func (c *CompletedUploadPart) SetEtag(etag string)

SetEtag sets the Etag field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CompletedUploadPart) SetPartNumber

func (c *CompletedUploadPart) SetPartNumber(partNumber int)

SetPartNumber sets the PartNumber field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CompletedUploadPart) String

func (c *CompletedUploadPart) String() string

func (*CompletedUploadPart) UnmarshalJSON

func (c *CompletedUploadPart) UnmarshalJSON(data []byte) error

type ConflictError

type ConflictError struct {
	*core.APIError
	Body *APIError
}

Lost a grep root-pointer publication race; retry

func (*ConflictError) MarshalJSON

func (c *ConflictError) MarshalJSON() ([]byte, error)

func (*ConflictError) UnmarshalJSON

func (c *ConflictError) UnmarshalJSON(data []byte) error

func (*ConflictError) Unwrap

func (c *ConflictError) Unwrap() error

type ContentID

type ContentID = string

Durable identity of one immutable content object.

The body is 128 fully random bits, with no time component: content object keys shard on the id's leading characters, and a clock-derived prefix would put every upload in one window into one shard. The id names *which object*, never what it contains — integrity evidence rides [`crate::ContentRef`] beside it.

type ContentRef

type ContentRef struct {
	// Mandatory checksum over the complete object.
	Checksum *Checksum `json:"checksum" url:"checksum"`
	// Immutable identity of the referenced object.
	ContentID ContentID `json:"content_id" url:"content_id"`
	// Content strategy used by the referenced object.
	Kind string `json:"kind" url:"kind"`
	// Complete byte length of the referenced content.
	SizeBytes int64 `json:"size_bytes" url:"size_bytes"`
	// contains filtered or unexported fields
}

func (*ContentRef) GetChecksum

func (c *ContentRef) GetChecksum() *Checksum

func (*ContentRef) GetContentID

func (c *ContentRef) GetContentID() ContentID

func (*ContentRef) GetExtraProperties

func (c *ContentRef) GetExtraProperties() map[string]interface{}

func (*ContentRef) GetKind

func (c *ContentRef) GetKind() string

func (*ContentRef) GetSizeBytes

func (c *ContentRef) GetSizeBytes() int64

func (*ContentRef) MarshalJSON

func (c *ContentRef) MarshalJSON() ([]byte, error)

func (*ContentRef) SetChecksum

func (c *ContentRef) SetChecksum(checksum *Checksum)

SetChecksum sets the Checksum field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ContentRef) SetContentID

func (c *ContentRef) SetContentID(contentID ContentID)

SetContentID sets the ContentID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ContentRef) SetKind

func (c *ContentRef) SetKind(kind string)

SetKind sets the Kind field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ContentRef) SetSizeBytes

func (c *ContentRef) SetSizeBytes(sizeBytes int64)

SetSizeBytes sets the SizeBytes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ContentRef) String

func (c *ContentRef) String() string

func (*ContentRef) UnmarshalJSON

func (c *ContentRef) UnmarshalJSON(data []byte) error

type ContentToken

type ContentToken struct {
	// Content authorized by this token.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// Opaque, server-signed token. Clients must not parse it.
	Token string `json:"token" url:"token"`
	// contains filtered or unexported fields
}

func (*ContentToken) GetContentRef

func (c *ContentToken) GetContentRef() *ContentRef

func (*ContentToken) GetExtraProperties

func (c *ContentToken) GetExtraProperties() map[string]interface{}

func (*ContentToken) GetToken

func (c *ContentToken) GetToken() string

func (*ContentToken) MarshalJSON

func (c *ContentToken) MarshalJSON() ([]byte, error)

func (*ContentToken) SetContentRef

func (c *ContentToken) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ContentToken) SetToken

func (c *ContentToken) SetToken(token string)

SetToken sets the Token field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ContentToken) String

func (c *ContentToken) String() string

func (*ContentToken) UnmarshalJSON

func (c *ContentToken) UnmarshalJSON(data []byte) error

type ContentTooLargeError

type ContentTooLargeError struct {
	*core.APIError
	Body *APIError
}

Content exceeds the advertised `download.max_content_bytes` limit

func (*ContentTooLargeError) MarshalJSON

func (c *ContentTooLargeError) MarshalJSON() ([]byte, error)

func (*ContentTooLargeError) UnmarshalJSON

func (c *ContentTooLargeError) UnmarshalJSON(data []byte) error

func (*ContentTooLargeError) Unwrap

func (c *ContentTooLargeError) Unwrap() error

type CreateCheckpointRequest

type CreateCheckpointRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Label recorded on the checkpoint record. A label, not a key: several
	// records may carry the same name over different bases.
	Name string `json:"name" url:"-"`
	// Optional lifetime; the server computes the record's expiry from its
	// own clock. Absent means the pin holds until explicitly released.
	TTLMs *int64 `json:"ttl_ms,omitempty" url:"-"`
	// contains filtered or unexported fields
}

func (*CreateCheckpointRequest) MarshalJSON

func (c *CreateCheckpointRequest) MarshalJSON() ([]byte, error)

func (*CreateCheckpointRequest) SetName

func (c *CreateCheckpointRequest) SetName(name string)

SetName sets the Name field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CreateCheckpointRequest) SetNamespaceID

func (c *CreateCheckpointRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CreateCheckpointRequest) SetTTLMs

func (c *CreateCheckpointRequest) SetTTLMs(ttlMs *int64)

SetTTLMs sets the TTLMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CreateCheckpointRequest) UnmarshalJSON

func (c *CreateCheckpointRequest) UnmarshalJSON(data []byte) error

type CreateDownloadByInodeRequest

type CreateDownloadByInodeRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// File inode ID
	InodeID string `json:"-" url:"-"`
	// Revision number
	RevisionNo RevisionNo                  `json:"-" url:"-"`
	Body       BeginDownloadByInodeRequest `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*CreateDownloadByInodeRequest) MarshalJSON

func (c *CreateDownloadByInodeRequest) MarshalJSON() ([]byte, error)

func (*CreateDownloadByInodeRequest) SetInodeID

func (c *CreateDownloadByInodeRequest) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CreateDownloadByInodeRequest) SetNamespaceID

func (c *CreateDownloadByInodeRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CreateDownloadByInodeRequest) SetRevisionNo

func (c *CreateDownloadByInodeRequest) SetRevisionNo(revisionNo RevisionNo)

SetRevisionNo sets the RevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CreateDownloadByInodeRequest) UnmarshalJSON

func (c *CreateDownloadByInodeRequest) UnmarshalJSON(data []byte) error

type CreateNamespaceRequest

type CreateNamespaceRequest struct {
	// Durable namespace id to create.
	NamespaceID NamespaceID `json:"namespace_id" url:"-"`
	// contains filtered or unexported fields
}

func (*CreateNamespaceRequest) MarshalJSON

func (c *CreateNamespaceRequest) MarshalJSON() ([]byte, error)

func (*CreateNamespaceRequest) SetNamespaceID

func (c *CreateNamespaceRequest) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CreateNamespaceRequest) UnmarshalJSON

func (c *CreateNamespaceRequest) UnmarshalJSON(data []byte) error

type CreateSnapshotRequest

type CreateSnapshotRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// A label that does not need to be unique.
	Name string `json:"name" url:"-"`
	// Snapshot lifetime from the current server time, in milliseconds.
	TTLMs int64 `json:"ttl_ms" url:"-"`
	// contains filtered or unexported fields
}

func (*CreateSnapshotRequest) MarshalJSON

func (c *CreateSnapshotRequest) MarshalJSON() ([]byte, error)

func (*CreateSnapshotRequest) SetName

func (c *CreateSnapshotRequest) SetName(name string)

SetName sets the Name field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CreateSnapshotRequest) SetNamespaceID

func (c *CreateSnapshotRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CreateSnapshotRequest) SetTTLMs

func (c *CreateSnapshotRequest) SetTTLMs(ttlMs int64)

SetTTLMs sets the TTLMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CreateSnapshotRequest) UnmarshalJSON

func (c *CreateSnapshotRequest) UnmarshalJSON(data []byte) error

type CreateUploadRequest

type CreateUploadRequest struct {
	// Namespace id
	NamespaceID string              `json:"-" url:"-"`
	Body        *BeginUploadRequest `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*CreateUploadRequest) MarshalJSON

func (c *CreateUploadRequest) MarshalJSON() ([]byte, error)

func (*CreateUploadRequest) SetNamespaceID

func (c *CreateUploadRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*CreateUploadRequest) UnmarshalJSON

func (c *CreateUploadRequest) UnmarshalJSON(data []byte) error

type DeleteDirectoryBehavior

type DeleteDirectoryBehavior string

Directory delete behavior for path-oriented deletes.

const (
	DeleteDirectoryBehaviorNonRecursive DeleteDirectoryBehavior = "non_recursive"
	DeleteDirectoryBehaviorRecursive    DeleteDirectoryBehavior = "recursive"
)

func NewDeleteDirectoryBehaviorFromString

func NewDeleteDirectoryBehaviorFromString(s string) (DeleteDirectoryBehavior, error)

func (DeleteDirectoryBehavior) Ptr

type DeleteNamespaceRequest

type DeleteNamespaceRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Delete only if the namespace head is still at this sequence
	ExpectedHeadSeq *ChangeSeq `json:"-" url:"expected_head_seq,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteNamespaceRequest) SetExpectedHeadSeq

func (d *DeleteNamespaceRequest) SetExpectedHeadSeq(expectedHeadSeq *ChangeSeq)

SetExpectedHeadSeq sets the ExpectedHeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DeleteNamespaceRequest) SetNamespaceID

func (d *DeleteNamespaceRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type DeleteNamespaceResponse

type DeleteNamespaceResponse struct {
	// The head's last committed sequence; the delete linearized
	// immediately after it, so this is where history ended.
	HeadSeq ChangeSeq `json:"head_seq" url:"head_seq"`
	// Namespace whose history ended.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// contains filtered or unexported fields
}

func (*DeleteNamespaceResponse) GetExtraProperties

func (d *DeleteNamespaceResponse) GetExtraProperties() map[string]interface{}

func (*DeleteNamespaceResponse) GetHeadSeq

func (d *DeleteNamespaceResponse) GetHeadSeq() ChangeSeq

func (*DeleteNamespaceResponse) GetNamespaceID

func (d *DeleteNamespaceResponse) GetNamespaceID() NamespaceID

func (*DeleteNamespaceResponse) MarshalJSON

func (d *DeleteNamespaceResponse) MarshalJSON() ([]byte, error)

func (*DeleteNamespaceResponse) SetHeadSeq

func (d *DeleteNamespaceResponse) SetHeadSeq(headSeq ChangeSeq)

SetHeadSeq sets the HeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DeleteNamespaceResponse) SetNamespaceID

func (d *DeleteNamespaceResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DeleteNamespaceResponse) String

func (d *DeleteNamespaceResponse) String() string

func (*DeleteNamespaceResponse) UnmarshalJSON

func (d *DeleteNamespaceResponse) UnmarshalJSON(data []byte) error

type DeletedObjectCounts

type DeletedObjectCounts struct {
	// Released checkpoint records deleted after their grace window.
	CheckpointRecords int64 `json:"checkpoint_records" url:"checkpoint_records"`
	// Content objects deleted after their completed upload session passed
	// the reclamation grace period and no reachable data referenced them.
	// Cleanup of abandoned sessions is not counted here.
	ContentObjects int64 `json:"content_objects" url:"content_objects"`
	// Unreferenced manifests deleted.
	Manifests int64 `json:"manifests" url:"manifests"`
	// Unreferenced metadata segments deleted.
	MetadataSegments int64 `json:"metadata_segments" url:"metadata_segments"`
	// Upload-session control objects deleted after the reap window.
	UploadSessions int64 `json:"upload_sessions" url:"upload_sessions"`
	// Unreferenced WAL segments deleted.
	WalSegments int64 `json:"wal_segments" url:"wal_segments"`
	// contains filtered or unexported fields
}

func (*DeletedObjectCounts) GetCheckpointRecords

func (d *DeletedObjectCounts) GetCheckpointRecords() int64

func (*DeletedObjectCounts) GetContentObjects

func (d *DeletedObjectCounts) GetContentObjects() int64

func (*DeletedObjectCounts) GetExtraProperties

func (d *DeletedObjectCounts) GetExtraProperties() map[string]interface{}

func (*DeletedObjectCounts) GetManifests

func (d *DeletedObjectCounts) GetManifests() int64

func (*DeletedObjectCounts) GetMetadataSegments

func (d *DeletedObjectCounts) GetMetadataSegments() int64

func (*DeletedObjectCounts) GetUploadSessions

func (d *DeletedObjectCounts) GetUploadSessions() int64

func (*DeletedObjectCounts) GetWalSegments

func (d *DeletedObjectCounts) GetWalSegments() int64

func (*DeletedObjectCounts) MarshalJSON

func (d *DeletedObjectCounts) MarshalJSON() ([]byte, error)

func (*DeletedObjectCounts) SetCheckpointRecords

func (d *DeletedObjectCounts) SetCheckpointRecords(checkpointRecords int64)

SetCheckpointRecords sets the CheckpointRecords field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DeletedObjectCounts) SetContentObjects

func (d *DeletedObjectCounts) SetContentObjects(contentObjects int64)

SetContentObjects sets the ContentObjects field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DeletedObjectCounts) SetManifests

func (d *DeletedObjectCounts) SetManifests(manifests int64)

SetManifests sets the Manifests field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DeletedObjectCounts) SetMetadataSegments

func (d *DeletedObjectCounts) SetMetadataSegments(metadataSegments int64)

SetMetadataSegments sets the MetadataSegments field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DeletedObjectCounts) SetUploadSessions

func (d *DeletedObjectCounts) SetUploadSessions(uploadSessions int64)

SetUploadSessions sets the UploadSessions field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DeletedObjectCounts) SetWalSegments

func (d *DeletedObjectCounts) SetWalSegments(walSegments int64)

SetWalSegments sets the WalSegments field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DeletedObjectCounts) String

func (d *DeletedObjectCounts) String() string

func (*DeletedObjectCounts) UnmarshalJSON

func (d *DeletedObjectCounts) UnmarshalJSON(data []byte) error

type DestinationBehavior

type DestinationBehavior string

Destination-conflict behavior for path-oriented puts, moves, and copies.

const (
	DestinationBehaviorNoReplace DestinationBehavior = "no_replace"
	DestinationBehaviorReplace   DestinationBehavior = "replace"
)

func NewDestinationBehaviorFromString

func NewDestinationBehaviorFromString(s string) (DestinationBehavior, error)

func (DestinationBehavior) Ptr

type DirectoryBinding

type DirectoryBinding struct {
	// Name shown to users.
	DisplayName DisplayName `json:"display_name" url:"display_name"`
	// Name used to look up the entry.
	NameKey NameKey `json:"name_key" url:"name_key"`
	// Stable inode ID within a namespace
	ParentInodeID string `json:"parent_inode_id" url:"parent_inode_id"`
	// contains filtered or unexported fields
}

func (*DirectoryBinding) GetDisplayName

func (d *DirectoryBinding) GetDisplayName() DisplayName

func (*DirectoryBinding) GetExtraProperties

func (d *DirectoryBinding) GetExtraProperties() map[string]interface{}

func (*DirectoryBinding) GetNameKey

func (d *DirectoryBinding) GetNameKey() NameKey

func (*DirectoryBinding) GetParentInodeID

func (d *DirectoryBinding) GetParentInodeID() string

func (*DirectoryBinding) MarshalJSON

func (d *DirectoryBinding) MarshalJSON() ([]byte, error)

func (*DirectoryBinding) SetDisplayName

func (d *DirectoryBinding) SetDisplayName(displayName DisplayName)

SetDisplayName sets the DisplayName field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DirectoryBinding) SetNameKey

func (d *DirectoryBinding) SetNameKey(nameKey NameKey)

SetNameKey sets the NameKey field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DirectoryBinding) SetParentInodeID

func (d *DirectoryBinding) SetParentInodeID(parentInodeID string)

SetParentInodeID sets the ParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*DirectoryBinding) String

func (d *DirectoryBinding) String() string

func (*DirectoryBinding) UnmarshalJSON

func (d *DirectoryBinding) UnmarshalJSON(data []byte) error

type DisableGrepIndexRequest

type DisableGrepIndexRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*DisableGrepIndexRequest) SetNamespaceID

func (d *DisableGrepIndexRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type DisplayName

type DisplayName = string

User-facing spelling of one path component.

type EnableGrepIndexRequest

type EnableGrepIndexRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*EnableGrepIndexRequest) SetNamespaceID

func (e *EnableGrepIndexRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type ErrorDetails

type ErrorDetails struct {
	// Unix milliseconds at which the current epoch's acquirer took it, when
	// the head recorded one. Writer ids are process labels, so two runs on
	// one machine can share one; the stamp is what tells them apart.
	ActiveAcquiredAtMs *int64 `json:"active_acquired_at_ms,omitempty" url:"active_acquired_at_ms,omitempty"`
	// Writer id recorded by the current epoch's acquirer, when the head
	// recorded one.
	ActiveWriter *string `json:"active_writer,omitempty" url:"active_writer,omitempty"`
	// Epoch that currently owns the namespace.
	ActiveWriterEpoch *WriterEpoch `json:"active_writer_epoch,omitempty" url:"active_writer_epoch,omitempty"`
	// Attribute revision that is actually current for the inode.
	ActualAttributesRevisionNo *AttributeRevisionNo `json:"actual_attributes_revision_no,omitempty" url:"actual_attributes_revision_no,omitempty"`
	// Deletion generation actually active for the inode.
	ActualDeletionSeq *ChangeSeq `json:"actual_deletion_seq,omitempty" url:"actual_deletion_seq,omitempty"`
	// Head sequence the namespace was actually at, which is what a caller
	// that still means to delete it retries against.
	ActualHeadSeq *ChangeSeq `json:"actual_head_seq,omitempty" url:"actual_head_seq,omitempty"`
	// Revision that is actually current; absent when the inode has none.
	ActualRevisionNo *RevisionNo `json:"actual_revision_no,omitempty" url:"actual_revision_no,omitempty"`
	// Change-feed cursor the request asked to resume after.
	AfterSeq *ChangeSeq `json:"after_seq,omitempty" url:"after_seq,omitempty"`
	// Idempotency key of the commit the error concerns.
	CommitID *CommitID `json:"commit_id,omitempty" url:"commit_id,omitempty"`
	// Semantic identity of the mutation that already landed under that
	// commit id, from the same receipt as `committed_seq` and present
	// exactly when it is. A retry recomputes this value from the request it
	// just made — see
	// [`put_retry_fingerprint`](crate::put_retry_fingerprint) — and equality
	// is what proves the two are the same request.
	CommittedFingerprint *string `json:"committed_fingerprint,omitempty" url:"committed_fingerprint,omitempty"`
	// Sequence at which that commit id already landed. Present when the
	// failure was decided against a durable commit receipt, which is what
	// holds the sequence; absent when nothing has committed under the id
	// yet and two live requests are simply claiming it at once.
	CommittedSeq *ChangeSeq `json:"committed_seq,omitempty" url:"committed_seq,omitempty"`
	// Attribute revision the request expected to be current.
	ExpectedAttributesRevisionNo *AttributeRevisionNo `json:"expected_attributes_revision_no,omitempty" url:"expected_attributes_revision_no,omitempty"`
	// Deletion generation the undelete expected to be active.
	ExpectedDeletionSeq *ChangeSeq `json:"expected_deletion_seq,omitempty" url:"expected_deletion_seq,omitempty"`
	// Head sequence a namespace delete required the namespace to still be
	// at.
	ExpectedHeadSeq *ChangeSeq `json:"expected_head_seq,omitempty" url:"expected_head_seq,omitempty"`
	// Revision the request expected to be current.
	ExpectedRevisionNo *RevisionNo `json:"expected_revision_no,omitempty" url:"expected_revision_no,omitempty"`
	// Epoch the failing writer session held when it was displaced.
	FencedWriterEpoch *WriterEpoch `json:"fenced_writer_epoch,omitempty" url:"fenced_writer_epoch,omitempty"`
	// Stable inode ID within a namespace
	InodeID *string `json:"inode_id,omitempty" url:"inode_id,omitempty"`
	// Position, in the request's operation list, of the operation that
	// failed. A commit applies all of its operations or none of them, so
	// this names the one that stopped the whole request.
	OperationIndex *int `json:"operation_index,omitempty" url:"operation_index,omitempty"`
	// Oldest sequence still promised for incremental replay.
	RetentionFloorSeq *ChangeSeq `json:"retention_floor_seq,omitempty" url:"retention_floor_seq,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorDetails) GetActiveAcquiredAtMs

func (e *ErrorDetails) GetActiveAcquiredAtMs() *int64

func (*ErrorDetails) GetActiveWriter

func (e *ErrorDetails) GetActiveWriter() *string

func (*ErrorDetails) GetActiveWriterEpoch

func (e *ErrorDetails) GetActiveWriterEpoch() *WriterEpoch

func (*ErrorDetails) GetActualAttributesRevisionNo

func (e *ErrorDetails) GetActualAttributesRevisionNo() *AttributeRevisionNo

func (*ErrorDetails) GetActualDeletionSeq

func (e *ErrorDetails) GetActualDeletionSeq() *ChangeSeq

func (*ErrorDetails) GetActualHeadSeq

func (e *ErrorDetails) GetActualHeadSeq() *ChangeSeq

func (*ErrorDetails) GetActualRevisionNo

func (e *ErrorDetails) GetActualRevisionNo() *RevisionNo

func (*ErrorDetails) GetAfterSeq

func (e *ErrorDetails) GetAfterSeq() *ChangeSeq

func (*ErrorDetails) GetCommitID

func (e *ErrorDetails) GetCommitID() *CommitID

func (*ErrorDetails) GetCommittedFingerprint

func (e *ErrorDetails) GetCommittedFingerprint() *string

func (*ErrorDetails) GetCommittedSeq

func (e *ErrorDetails) GetCommittedSeq() *ChangeSeq

func (*ErrorDetails) GetExpectedAttributesRevisionNo

func (e *ErrorDetails) GetExpectedAttributesRevisionNo() *AttributeRevisionNo

func (*ErrorDetails) GetExpectedDeletionSeq

func (e *ErrorDetails) GetExpectedDeletionSeq() *ChangeSeq

func (*ErrorDetails) GetExpectedHeadSeq

func (e *ErrorDetails) GetExpectedHeadSeq() *ChangeSeq

func (*ErrorDetails) GetExpectedRevisionNo

func (e *ErrorDetails) GetExpectedRevisionNo() *RevisionNo

func (*ErrorDetails) GetExtraProperties

func (e *ErrorDetails) GetExtraProperties() map[string]interface{}

func (*ErrorDetails) GetFencedWriterEpoch

func (e *ErrorDetails) GetFencedWriterEpoch() *WriterEpoch

func (*ErrorDetails) GetInodeID

func (e *ErrorDetails) GetInodeID() *string

func (*ErrorDetails) GetOperationIndex

func (e *ErrorDetails) GetOperationIndex() *int

func (*ErrorDetails) GetRetentionFloorSeq

func (e *ErrorDetails) GetRetentionFloorSeq() *ChangeSeq

func (*ErrorDetails) MarshalJSON

func (e *ErrorDetails) MarshalJSON() ([]byte, error)

func (*ErrorDetails) SetActiveAcquiredAtMs

func (e *ErrorDetails) SetActiveAcquiredAtMs(activeAcquiredAtMs *int64)

SetActiveAcquiredAtMs sets the ActiveAcquiredAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetActiveWriter

func (e *ErrorDetails) SetActiveWriter(activeWriter *string)

SetActiveWriter sets the ActiveWriter field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetActiveWriterEpoch

func (e *ErrorDetails) SetActiveWriterEpoch(activeWriterEpoch *WriterEpoch)

SetActiveWriterEpoch sets the ActiveWriterEpoch field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetActualAttributesRevisionNo

func (e *ErrorDetails) SetActualAttributesRevisionNo(actualAttributesRevisionNo *AttributeRevisionNo)

SetActualAttributesRevisionNo sets the ActualAttributesRevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetActualDeletionSeq

func (e *ErrorDetails) SetActualDeletionSeq(actualDeletionSeq *ChangeSeq)

SetActualDeletionSeq sets the ActualDeletionSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetActualHeadSeq

func (e *ErrorDetails) SetActualHeadSeq(actualHeadSeq *ChangeSeq)

SetActualHeadSeq sets the ActualHeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetActualRevisionNo

func (e *ErrorDetails) SetActualRevisionNo(actualRevisionNo *RevisionNo)

SetActualRevisionNo sets the ActualRevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetAfterSeq

func (e *ErrorDetails) SetAfterSeq(afterSeq *ChangeSeq)

SetAfterSeq sets the AfterSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetCommitID

func (e *ErrorDetails) SetCommitID(commitID *CommitID)

SetCommitID sets the CommitID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetCommittedFingerprint

func (e *ErrorDetails) SetCommittedFingerprint(committedFingerprint *string)

SetCommittedFingerprint sets the CommittedFingerprint field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetCommittedSeq

func (e *ErrorDetails) SetCommittedSeq(committedSeq *ChangeSeq)

SetCommittedSeq sets the CommittedSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetExpectedAttributesRevisionNo

func (e *ErrorDetails) SetExpectedAttributesRevisionNo(expectedAttributesRevisionNo *AttributeRevisionNo)

SetExpectedAttributesRevisionNo sets the ExpectedAttributesRevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetExpectedDeletionSeq

func (e *ErrorDetails) SetExpectedDeletionSeq(expectedDeletionSeq *ChangeSeq)

SetExpectedDeletionSeq sets the ExpectedDeletionSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetExpectedHeadSeq

func (e *ErrorDetails) SetExpectedHeadSeq(expectedHeadSeq *ChangeSeq)

SetExpectedHeadSeq sets the ExpectedHeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetExpectedRevisionNo

func (e *ErrorDetails) SetExpectedRevisionNo(expectedRevisionNo *RevisionNo)

SetExpectedRevisionNo sets the ExpectedRevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetFencedWriterEpoch

func (e *ErrorDetails) SetFencedWriterEpoch(fencedWriterEpoch *WriterEpoch)

SetFencedWriterEpoch sets the FencedWriterEpoch field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetInodeID

func (e *ErrorDetails) SetInodeID(inodeID *string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetOperationIndex

func (e *ErrorDetails) SetOperationIndex(operationIndex *int)

SetOperationIndex sets the OperationIndex field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) SetRetentionFloorSeq

func (e *ErrorDetails) SetRetentionFloorSeq(retentionFloorSeq *ChangeSeq)

SetRetentionFloorSeq sets the RetentionFloorSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ErrorDetails) String

func (e *ErrorDetails) String() string

func (*ErrorDetails) UnmarshalJSON

func (e *ErrorDetails) UnmarshalJSON(data []byte) error

type ExtendSnapshotRequest

type ExtendSnapshotRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Snapshot id
	SnapshotID string `json:"-" url:"-"`
	// Requested lifetime from the server's current time, in milliseconds.
	TTLMs int64 `json:"ttl_ms" url:"-"`
	// contains filtered or unexported fields
}

func (*ExtendSnapshotRequest) MarshalJSON

func (e *ExtendSnapshotRequest) MarshalJSON() ([]byte, error)

func (*ExtendSnapshotRequest) SetNamespaceID

func (e *ExtendSnapshotRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ExtendSnapshotRequest) SetSnapshotID

func (e *ExtendSnapshotRequest) SetSnapshotID(snapshotID string)

SetSnapshotID sets the SnapshotID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ExtendSnapshotRequest) SetTTLMs

func (e *ExtendSnapshotRequest) SetTTLMs(ttlMs int64)

SetTTLMs sets the TTLMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ExtendSnapshotRequest) UnmarshalJSON

func (e *ExtendSnapshotRequest) UnmarshalJSON(data []byte) error

type FileParam

type FileParam struct {
	io.Reader
	// contains filtered or unexported fields
}

FileParam is a file type suitable for multipart/form-data uploads.

func NewFileParam

func NewFileParam(
	reader io.Reader,
	filename string,
	contentType string,
	opts ...FileParamOption,
) *FileParam

NewFileParam returns a *FileParam type suitable for multipart/form-data uploads. All file upload endpoints accept a simple io.Reader, which is usually created by opening a file via os.Open.

However, some endpoints require additional metadata about the file such as a specific Content-Type or custom filename. FileParam makes it easier to create the correct type signature for these endpoints.

func (*FileParam) ContentType

func (f *FileParam) ContentType() string

func (*FileParam) Name

func (f *FileParam) Name() string

type FileParamOption

type FileParamOption interface {
	// contains filtered or unexported methods
}

FileParamOption adapts the behavior of the FileParam. No options are implemented yet, but this interface allows for future extensibility.

type FileRevision

type FileRevision struct {
	// Commit ID for this revision.
	CommitID CommitID `json:"commit_id" url:"commit_id"`
	// Wall-clock stamp of the commit that created this revision, in Unix
	// milliseconds. Observational: `committed_seq` is the order.
	CommittedAtMs int64 `json:"committed_at_ms" url:"committed_at_ms"`
	// Actor responsible for this revision, as supplied by the application.
	CommittedBy *ActorRef `json:"committed_by" url:"committed_by"`
	// Namespace sequence that created this revision.
	CommittedSeq ChangeSeq `json:"committed_seq" url:"committed_seq"`
	// Content stored for this revision.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// Revision number within the file inode.
	RevisionNo RevisionNo `json:"revision_no" url:"revision_no"`
	// contains filtered or unexported fields
}

func (*FileRevision) GetCommitID

func (f *FileRevision) GetCommitID() CommitID

func (*FileRevision) GetCommittedAtMs

func (f *FileRevision) GetCommittedAtMs() int64

func (*FileRevision) GetCommittedBy

func (f *FileRevision) GetCommittedBy() *ActorRef

func (*FileRevision) GetCommittedSeq

func (f *FileRevision) GetCommittedSeq() ChangeSeq

func (*FileRevision) GetContentRef

func (f *FileRevision) GetContentRef() *ContentRef

func (*FileRevision) GetExtraProperties

func (f *FileRevision) GetExtraProperties() map[string]interface{}

func (*FileRevision) GetInodeID

func (f *FileRevision) GetInodeID() string

func (*FileRevision) GetRevisionNo

func (f *FileRevision) GetRevisionNo() RevisionNo

func (*FileRevision) MarshalJSON

func (f *FileRevision) MarshalJSON() ([]byte, error)

func (*FileRevision) SetCommitID

func (f *FileRevision) SetCommitID(commitID CommitID)

SetCommitID sets the CommitID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FileRevision) SetCommittedAtMs

func (f *FileRevision) SetCommittedAtMs(committedAtMs int64)

SetCommittedAtMs sets the CommittedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FileRevision) SetCommittedBy

func (f *FileRevision) SetCommittedBy(committedBy *ActorRef)

SetCommittedBy sets the CommittedBy field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FileRevision) SetCommittedSeq

func (f *FileRevision) SetCommittedSeq(committedSeq ChangeSeq)

SetCommittedSeq sets the CommittedSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FileRevision) SetContentRef

func (f *FileRevision) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FileRevision) SetInodeID

func (f *FileRevision) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FileRevision) SetRevisionNo

func (f *FileRevision) SetRevisionNo(revisionNo RevisionNo)

SetRevisionNo sets the RevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FileRevision) String

func (f *FileRevision) String() string

func (*FileRevision) UnmarshalJSON

func (f *FileRevision) UnmarshalJSON(data []byte) error

type FilesystemChange

type FilesystemChange struct {
	Kind              string
	DirectoryCreated  *FilesystemChangeDirectoryCreated
	FileCreated       *FilesystemChangeFileCreated
	ContentChanged    *FilesystemChangeContentChanged
	Moved             *FilesystemChangeMoved
	Deleted           *FilesystemChangeDeleted
	Undeleted         *FilesystemChangeUndeleted
	AttributesChanged *FilesystemChangeAttributesChanged
	// contains filtered or unexported fields
}

One semantic filesystem change inside a commit.

A commit's events are the operations it applied, in the order it applied them. One request operation can apply several: creating missing parent directories, or replacing a file by moving over it, each produce an event per directory created or file replaced. So a request with three operations may report more than three events, and the events stay in request order. Events name inodes and their parent-directory bindings rather than full paths; a consumer that needs paths can stat the inode or maintain its own binding projection from this feed.

func (*FilesystemChange) Accept

func (f *FilesystemChange) Accept(visitor FilesystemChangeVisitor) error

func (*FilesystemChange) GetAttributesChanged

func (f *FilesystemChange) GetAttributesChanged() *FilesystemChangeAttributesChanged

func (*FilesystemChange) GetContentChanged

func (f *FilesystemChange) GetContentChanged() *FilesystemChangeContentChanged

func (*FilesystemChange) GetDeleted

func (f *FilesystemChange) GetDeleted() *FilesystemChangeDeleted

func (*FilesystemChange) GetDirectoryCreated

func (f *FilesystemChange) GetDirectoryCreated() *FilesystemChangeDirectoryCreated

func (*FilesystemChange) GetFileCreated

func (f *FilesystemChange) GetFileCreated() *FilesystemChangeFileCreated

func (*FilesystemChange) GetKind

func (f *FilesystemChange) GetKind() string

func (*FilesystemChange) GetMoved

func (f *FilesystemChange) GetMoved() *FilesystemChangeMoved

func (*FilesystemChange) GetUndeleted

func (f *FilesystemChange) GetUndeleted() *FilesystemChangeUndeleted

func (FilesystemChange) MarshalJSON

func (f FilesystemChange) MarshalJSON() ([]byte, error)

func (*FilesystemChange) UnmarshalJSON

func (f *FilesystemChange) UnmarshalJSON(data []byte) error

type FilesystemChangeAttributesChanged

type FilesystemChangeAttributesChanged struct {
	// The inode's complete attribute map after the update, so a consumer
	// projects it without reading anything back. An empty map is the
	// cleared state.
	Attributes Attributes `json:"attributes" url:"attributes"`
	// New attribute revision for that inode.
	AttributesRevisionNo AttributeRevisionNo `json:"attributes_revision_no" url:"attributes_revision_no"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// contains filtered or unexported fields
}

func (*FilesystemChangeAttributesChanged) GetAttributes

func (f *FilesystemChangeAttributesChanged) GetAttributes() Attributes

func (*FilesystemChangeAttributesChanged) GetAttributesRevisionNo

func (f *FilesystemChangeAttributesChanged) GetAttributesRevisionNo() AttributeRevisionNo

func (*FilesystemChangeAttributesChanged) GetExtraProperties

func (f *FilesystemChangeAttributesChanged) GetExtraProperties() map[string]interface{}

func (*FilesystemChangeAttributesChanged) GetInodeID

func (f *FilesystemChangeAttributesChanged) GetInodeID() string

func (*FilesystemChangeAttributesChanged) MarshalJSON

func (f *FilesystemChangeAttributesChanged) MarshalJSON() ([]byte, error)

func (*FilesystemChangeAttributesChanged) SetAttributes

func (f *FilesystemChangeAttributesChanged) SetAttributes(attributes Attributes)

SetAttributes sets the Attributes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeAttributesChanged) SetAttributesRevisionNo

func (f *FilesystemChangeAttributesChanged) SetAttributesRevisionNo(attributesRevisionNo AttributeRevisionNo)

SetAttributesRevisionNo sets the AttributesRevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeAttributesChanged) SetInodeID

func (f *FilesystemChangeAttributesChanged) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeAttributesChanged) String

func (*FilesystemChangeAttributesChanged) UnmarshalJSON

func (f *FilesystemChangeAttributesChanged) UnmarshalJSON(data []byte) error

type FilesystemChangeContentChanged

type FilesystemChangeContentChanged struct {
	// Immutable content published by the revision.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// New monotonic position in that file's revision history.
	RevisionNo RevisionNo `json:"revision_no" url:"revision_no"`
	// contains filtered or unexported fields
}

func (*FilesystemChangeContentChanged) GetContentRef

func (f *FilesystemChangeContentChanged) GetContentRef() *ContentRef

func (*FilesystemChangeContentChanged) GetExtraProperties

func (f *FilesystemChangeContentChanged) GetExtraProperties() map[string]interface{}

func (*FilesystemChangeContentChanged) GetInodeID

func (f *FilesystemChangeContentChanged) GetInodeID() string

func (*FilesystemChangeContentChanged) GetRevisionNo

func (f *FilesystemChangeContentChanged) GetRevisionNo() RevisionNo

func (*FilesystemChangeContentChanged) MarshalJSON

func (f *FilesystemChangeContentChanged) MarshalJSON() ([]byte, error)

func (*FilesystemChangeContentChanged) SetContentRef

func (f *FilesystemChangeContentChanged) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeContentChanged) SetInodeID

func (f *FilesystemChangeContentChanged) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeContentChanged) SetRevisionNo

func (f *FilesystemChangeContentChanged) SetRevisionNo(revisionNo RevisionNo)

SetRevisionNo sets the RevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeContentChanged) String

func (*FilesystemChangeContentChanged) UnmarshalJSON

func (f *FilesystemChangeContentChanged) UnmarshalJSON(data []byte) error

type FilesystemChangeDeleted

type FilesystemChangeDeleted struct {
	// Directory binding removed by the deletion, when the delete
	// recorded one.
	DeletedBinding *DirectoryBinding `json:"deleted_binding,omitempty" url:"deleted_binding,omitempty"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// contains filtered or unexported fields
}

func (*FilesystemChangeDeleted) GetDeletedBinding

func (f *FilesystemChangeDeleted) GetDeletedBinding() *DirectoryBinding

func (*FilesystemChangeDeleted) GetExtraProperties

func (f *FilesystemChangeDeleted) GetExtraProperties() map[string]interface{}

func (*FilesystemChangeDeleted) GetInodeID

func (f *FilesystemChangeDeleted) GetInodeID() string

func (*FilesystemChangeDeleted) MarshalJSON

func (f *FilesystemChangeDeleted) MarshalJSON() ([]byte, error)

func (*FilesystemChangeDeleted) SetDeletedBinding

func (f *FilesystemChangeDeleted) SetDeletedBinding(deletedBinding *DirectoryBinding)

SetDeletedBinding sets the DeletedBinding field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeDeleted) SetInodeID

func (f *FilesystemChangeDeleted) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeDeleted) String

func (f *FilesystemChangeDeleted) String() string

func (*FilesystemChangeDeleted) UnmarshalJSON

func (f *FilesystemChangeDeleted) UnmarshalJSON(data []byte) error

type FilesystemChangeDirectoryCreated

type FilesystemChangeDirectoryCreated struct {
	// Opaque identifier for the binding created by this event.
	BindingGeneration string `json:"binding_generation" url:"binding_generation"`
	// User-facing spelling of the new entry.
	DisplayName DisplayName `json:"display_name" url:"display_name"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// Stable inode ID within a namespace
	ParentInodeID string `json:"parent_inode_id" url:"parent_inode_id"`
	// contains filtered or unexported fields
}

func (*FilesystemChangeDirectoryCreated) GetBindingGeneration

func (f *FilesystemChangeDirectoryCreated) GetBindingGeneration() string

func (*FilesystemChangeDirectoryCreated) GetDisplayName

func (f *FilesystemChangeDirectoryCreated) GetDisplayName() DisplayName

func (*FilesystemChangeDirectoryCreated) GetExtraProperties

func (f *FilesystemChangeDirectoryCreated) GetExtraProperties() map[string]interface{}

func (*FilesystemChangeDirectoryCreated) GetInodeID

func (f *FilesystemChangeDirectoryCreated) GetInodeID() string

func (*FilesystemChangeDirectoryCreated) GetParentInodeID

func (f *FilesystemChangeDirectoryCreated) GetParentInodeID() string

func (*FilesystemChangeDirectoryCreated) MarshalJSON

func (f *FilesystemChangeDirectoryCreated) MarshalJSON() ([]byte, error)

func (*FilesystemChangeDirectoryCreated) SetBindingGeneration

func (f *FilesystemChangeDirectoryCreated) SetBindingGeneration(bindingGeneration string)

SetBindingGeneration sets the BindingGeneration field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeDirectoryCreated) SetDisplayName

func (f *FilesystemChangeDirectoryCreated) SetDisplayName(displayName DisplayName)

SetDisplayName sets the DisplayName field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeDirectoryCreated) SetInodeID

func (f *FilesystemChangeDirectoryCreated) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeDirectoryCreated) SetParentInodeID

func (f *FilesystemChangeDirectoryCreated) SetParentInodeID(parentInodeID string)

SetParentInodeID sets the ParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeDirectoryCreated) String

func (*FilesystemChangeDirectoryCreated) UnmarshalJSON

func (f *FilesystemChangeDirectoryCreated) UnmarshalJSON(data []byte) error

type FilesystemChangeFileCreated

type FilesystemChangeFileCreated struct {
	// Opaque identifier for the binding created by this event.
	BindingGeneration string `json:"binding_generation" url:"binding_generation"`
	// Content of the first revision.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// User-facing spelling of the new entry.
	DisplayName DisplayName `json:"display_name" url:"display_name"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// Stable inode ID within a namespace
	ParentInodeID string `json:"parent_inode_id" url:"parent_inode_id"`
	// First revision number.
	RevisionNo RevisionNo `json:"revision_no" url:"revision_no"`
	// contains filtered or unexported fields
}

func (*FilesystemChangeFileCreated) GetBindingGeneration

func (f *FilesystemChangeFileCreated) GetBindingGeneration() string

func (*FilesystemChangeFileCreated) GetContentRef

func (f *FilesystemChangeFileCreated) GetContentRef() *ContentRef

func (*FilesystemChangeFileCreated) GetDisplayName

func (f *FilesystemChangeFileCreated) GetDisplayName() DisplayName

func (*FilesystemChangeFileCreated) GetExtraProperties

func (f *FilesystemChangeFileCreated) GetExtraProperties() map[string]interface{}

func (*FilesystemChangeFileCreated) GetInodeID

func (f *FilesystemChangeFileCreated) GetInodeID() string

func (*FilesystemChangeFileCreated) GetParentInodeID

func (f *FilesystemChangeFileCreated) GetParentInodeID() string

func (*FilesystemChangeFileCreated) GetRevisionNo

func (f *FilesystemChangeFileCreated) GetRevisionNo() RevisionNo

func (*FilesystemChangeFileCreated) MarshalJSON

func (f *FilesystemChangeFileCreated) MarshalJSON() ([]byte, error)

func (*FilesystemChangeFileCreated) SetBindingGeneration

func (f *FilesystemChangeFileCreated) SetBindingGeneration(bindingGeneration string)

SetBindingGeneration sets the BindingGeneration field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeFileCreated) SetContentRef

func (f *FilesystemChangeFileCreated) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeFileCreated) SetDisplayName

func (f *FilesystemChangeFileCreated) SetDisplayName(displayName DisplayName)

SetDisplayName sets the DisplayName field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeFileCreated) SetInodeID

func (f *FilesystemChangeFileCreated) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeFileCreated) SetParentInodeID

func (f *FilesystemChangeFileCreated) SetParentInodeID(parentInodeID string)

SetParentInodeID sets the ParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeFileCreated) SetRevisionNo

func (f *FilesystemChangeFileCreated) SetRevisionNo(revisionNo RevisionNo)

SetRevisionNo sets the RevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeFileCreated) String

func (f *FilesystemChangeFileCreated) String() string

func (*FilesystemChangeFileCreated) UnmarshalJSON

func (f *FilesystemChangeFileCreated) UnmarshalJSON(data []byte) error

type FilesystemChangeMoved

type FilesystemChangeMoved struct {
	// Opaque identifier for the binding created by this event.
	BindingGeneration string `json:"binding_generation" url:"binding_generation"`
	// Spelling of the old binding.
	FromDisplayName DisplayName `json:"from_display_name" url:"from_display_name"`
	// Stable inode ID within a namespace
	FromParentInodeID string `json:"from_parent_inode_id" url:"from_parent_inode_id"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// Spelling of the new binding.
	ToDisplayName DisplayName `json:"to_display_name" url:"to_display_name"`
	// Stable inode ID within a namespace
	ToParentInodeID string `json:"to_parent_inode_id" url:"to_parent_inode_id"`
	// contains filtered or unexported fields
}

func (*FilesystemChangeMoved) GetBindingGeneration

func (f *FilesystemChangeMoved) GetBindingGeneration() string

func (*FilesystemChangeMoved) GetExtraProperties

func (f *FilesystemChangeMoved) GetExtraProperties() map[string]interface{}

func (*FilesystemChangeMoved) GetFromDisplayName

func (f *FilesystemChangeMoved) GetFromDisplayName() DisplayName

func (*FilesystemChangeMoved) GetFromParentInodeID

func (f *FilesystemChangeMoved) GetFromParentInodeID() string

func (*FilesystemChangeMoved) GetInodeID

func (f *FilesystemChangeMoved) GetInodeID() string

func (*FilesystemChangeMoved) GetToDisplayName

func (f *FilesystemChangeMoved) GetToDisplayName() DisplayName

func (*FilesystemChangeMoved) GetToParentInodeID

func (f *FilesystemChangeMoved) GetToParentInodeID() string

func (*FilesystemChangeMoved) MarshalJSON

func (f *FilesystemChangeMoved) MarshalJSON() ([]byte, error)

func (*FilesystemChangeMoved) SetBindingGeneration

func (f *FilesystemChangeMoved) SetBindingGeneration(bindingGeneration string)

SetBindingGeneration sets the BindingGeneration field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeMoved) SetFromDisplayName

func (f *FilesystemChangeMoved) SetFromDisplayName(fromDisplayName DisplayName)

SetFromDisplayName sets the FromDisplayName field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeMoved) SetFromParentInodeID

func (f *FilesystemChangeMoved) SetFromParentInodeID(fromParentInodeID string)

SetFromParentInodeID sets the FromParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeMoved) SetInodeID

func (f *FilesystemChangeMoved) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeMoved) SetToDisplayName

func (f *FilesystemChangeMoved) SetToDisplayName(toDisplayName DisplayName)

SetToDisplayName sets the ToDisplayName field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeMoved) SetToParentInodeID

func (f *FilesystemChangeMoved) SetToParentInodeID(toParentInodeID string)

SetToParentInodeID sets the ToParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeMoved) String

func (f *FilesystemChangeMoved) String() string

func (*FilesystemChangeMoved) UnmarshalJSON

func (f *FilesystemChangeMoved) UnmarshalJSON(data []byte) error

type FilesystemChangeUndeleted

type FilesystemChangeUndeleted struct {
	// Opaque identifier for the binding created by this event.
	BindingGeneration string `json:"binding_generation" url:"binding_generation"`
	// Spelling of the recovered binding.
	DisplayName DisplayName `json:"display_name" url:"display_name"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// Stable inode ID within a namespace
	ParentInodeID string `json:"parent_inode_id" url:"parent_inode_id"`
	// contains filtered or unexported fields
}

func (*FilesystemChangeUndeleted) GetBindingGeneration

func (f *FilesystemChangeUndeleted) GetBindingGeneration() string

func (*FilesystemChangeUndeleted) GetDisplayName

func (f *FilesystemChangeUndeleted) GetDisplayName() DisplayName

func (*FilesystemChangeUndeleted) GetExtraProperties

func (f *FilesystemChangeUndeleted) GetExtraProperties() map[string]interface{}

func (*FilesystemChangeUndeleted) GetInodeID

func (f *FilesystemChangeUndeleted) GetInodeID() string

func (*FilesystemChangeUndeleted) GetParentInodeID

func (f *FilesystemChangeUndeleted) GetParentInodeID() string

func (*FilesystemChangeUndeleted) MarshalJSON

func (f *FilesystemChangeUndeleted) MarshalJSON() ([]byte, error)

func (*FilesystemChangeUndeleted) SetBindingGeneration

func (f *FilesystemChangeUndeleted) SetBindingGeneration(bindingGeneration string)

SetBindingGeneration sets the BindingGeneration field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeUndeleted) SetDisplayName

func (f *FilesystemChangeUndeleted) SetDisplayName(displayName DisplayName)

SetDisplayName sets the DisplayName field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeUndeleted) SetInodeID

func (f *FilesystemChangeUndeleted) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeUndeleted) SetParentInodeID

func (f *FilesystemChangeUndeleted) SetParentInodeID(parentInodeID string)

SetParentInodeID sets the ParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemChangeUndeleted) String

func (f *FilesystemChangeUndeleted) String() string

func (*FilesystemChangeUndeleted) UnmarshalJSON

func (f *FilesystemChangeUndeleted) UnmarshalJSON(data []byte) error

type FilesystemChangeVisitor

type FilesystemChangeVisitor interface {
	VisitDirectoryCreated(*FilesystemChangeDirectoryCreated) error
	VisitFileCreated(*FilesystemChangeFileCreated) error
	VisitContentChanged(*FilesystemChangeContentChanged) error
	VisitMoved(*FilesystemChangeMoved) error
	VisitDeleted(*FilesystemChangeDeleted) error
	VisitUndeleted(*FilesystemChangeUndeleted) error
	VisitAttributesChanged(*FilesystemChangeAttributesChanged) error
}

type FilesystemOperation

type FilesystemOperation struct {
	Kind                   string
	CreateDirectory        *FilesystemOperationCreateDirectory
	CreateDirectoryByInode *FilesystemOperationCreateDirectoryByInode
	PutFile                *FilesystemOperationPutFile
	PutFileByInode         *FilesystemOperationPutFileByInode
	PutFileRevisionByInode *FilesystemOperationPutFileRevisionByInode
	DeletePath             *FilesystemOperationDeletePath
	DeleteByInode          *FilesystemOperationDeleteByInode
	MovePath               *FilesystemOperationMovePath
	MoveByInode            *FilesystemOperationMoveByInode
	CopyPath               *FilesystemOperationCopyPath
	Undelete               *FilesystemOperationUndelete
	RestoreRevision        *FilesystemOperationRestoreRevision
	UpdateAttributes       *FilesystemOperationUpdateAttributes
	// contains filtered or unexported fields
}

One filesystem operation.

Unknown fields are rejected so a misspelled concurrency guard cannot be ignored. Fieldless variants must use empty braces so serde rejects unexpected fields.

func (*FilesystemOperation) Accept

func (*FilesystemOperation) GetCopyPath

func (*FilesystemOperation) GetCreateDirectory

func (*FilesystemOperation) GetCreateDirectoryByInode

func (f *FilesystemOperation) GetCreateDirectoryByInode() *FilesystemOperationCreateDirectoryByInode

func (*FilesystemOperation) GetDeleteByInode

func (*FilesystemOperation) GetDeletePath

func (*FilesystemOperation) GetKind

func (f *FilesystemOperation) GetKind() string

func (*FilesystemOperation) GetMoveByInode

func (*FilesystemOperation) GetMovePath

func (*FilesystemOperation) GetPutFile

func (*FilesystemOperation) GetPutFileByInode

func (*FilesystemOperation) GetPutFileRevisionByInode

func (f *FilesystemOperation) GetPutFileRevisionByInode() *FilesystemOperationPutFileRevisionByInode

func (*FilesystemOperation) GetRestoreRevision

func (*FilesystemOperation) GetUndelete

func (*FilesystemOperation) GetUpdateAttributes

func (f *FilesystemOperation) GetUpdateAttributes() *FilesystemOperationUpdateAttributes

func (FilesystemOperation) MarshalJSON

func (f FilesystemOperation) MarshalJSON() ([]byte, error)

func (*FilesystemOperation) UnmarshalJSON

func (f *FilesystemOperation) UnmarshalJSON(data []byte) error

type FilesystemOperationCopyPath

type FilesystemOperationCopyPath struct {
	// Whether an existing destination file may receive a copied revision.
	Behavior *DestinationBehavior `json:"behavior,omitempty" url:"behavior,omitempty"`
	// Absolute source path that must resolve to a visible file.
	FromPath AbsolutePath `json:"from_path" url:"from_path"`
	// Absolute destination whose parent must be visible and writable.
	ToPath AbsolutePath `json:"to_path" url:"to_path"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationCopyPath) GetBehavior

func (*FilesystemOperationCopyPath) GetExtraProperties

func (f *FilesystemOperationCopyPath) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationCopyPath) GetFromPath

func (f *FilesystemOperationCopyPath) GetFromPath() AbsolutePath

func (*FilesystemOperationCopyPath) GetToPath

func (*FilesystemOperationCopyPath) MarshalJSON

func (f *FilesystemOperationCopyPath) MarshalJSON() ([]byte, error)

func (*FilesystemOperationCopyPath) SetBehavior

func (f *FilesystemOperationCopyPath) SetBehavior(behavior *DestinationBehavior)

SetBehavior sets the Behavior field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationCopyPath) SetFromPath

func (f *FilesystemOperationCopyPath) SetFromPath(fromPath AbsolutePath)

SetFromPath sets the FromPath field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationCopyPath) SetToPath

func (f *FilesystemOperationCopyPath) SetToPath(toPath AbsolutePath)

SetToPath sets the ToPath field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationCopyPath) String

func (f *FilesystemOperationCopyPath) String() string

func (*FilesystemOperationCopyPath) UnmarshalJSON

func (f *FilesystemOperationCopyPath) UnmarshalJSON(data []byte) error

type FilesystemOperationCreateDirectory

type FilesystemOperationCreateDirectory struct {
	// Also create missing ancestor directories (the same auto-create
	// `put_file` performs). The final component must still be new.
	Parents *bool `json:"parents,omitempty" url:"parents,omitempty"`
	// Absolute destination path, rejected when invalid or already bound.
	Path AbsolutePath `json:"path" url:"path"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationCreateDirectory) GetExtraProperties

func (f *FilesystemOperationCreateDirectory) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationCreateDirectory) GetParents

func (f *FilesystemOperationCreateDirectory) GetParents() *bool

func (*FilesystemOperationCreateDirectory) GetPath

func (*FilesystemOperationCreateDirectory) MarshalJSON

func (f *FilesystemOperationCreateDirectory) MarshalJSON() ([]byte, error)

func (*FilesystemOperationCreateDirectory) SetParents

func (f *FilesystemOperationCreateDirectory) SetParents(parents *bool)

SetParents sets the Parents field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationCreateDirectory) SetPath

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationCreateDirectory) String

func (*FilesystemOperationCreateDirectory) UnmarshalJSON

func (f *FilesystemOperationCreateDirectory) UnmarshalJSON(data []byte) error

type FilesystemOperationCreateDirectoryByInode

type FilesystemOperationCreateDirectoryByInode struct {
	// New directory name.
	DisplayName DisplayName `json:"display_name" url:"display_name"`
	// Stable inode ID within a namespace
	ParentInodeID string `json:"parent_inode_id" url:"parent_inode_id"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationCreateDirectoryByInode) GetDisplayName

func (*FilesystemOperationCreateDirectoryByInode) GetExtraProperties

func (f *FilesystemOperationCreateDirectoryByInode) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationCreateDirectoryByInode) GetParentInodeID

func (f *FilesystemOperationCreateDirectoryByInode) GetParentInodeID() string

func (*FilesystemOperationCreateDirectoryByInode) MarshalJSON

func (*FilesystemOperationCreateDirectoryByInode) SetDisplayName

func (f *FilesystemOperationCreateDirectoryByInode) SetDisplayName(displayName DisplayName)

SetDisplayName sets the DisplayName field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationCreateDirectoryByInode) SetParentInodeID

func (f *FilesystemOperationCreateDirectoryByInode) SetParentInodeID(parentInodeID string)

SetParentInodeID sets the ParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationCreateDirectoryByInode) String

func (*FilesystemOperationCreateDirectoryByInode) UnmarshalJSON

func (f *FilesystemOperationCreateDirectoryByInode) UnmarshalJSON(data []byte) error

type FilesystemOperationDeleteByInode

type FilesystemOperationDeleteByInode struct {
	// Whether a non-empty directory may be tombstoned recursively.
	Behavior *DeleteDirectoryBehavior `json:"behavior,omitempty" url:"behavior,omitempty"`
	// Binding generation required for the delete.
	ExpectedBindingGeneration string `json:"expected_binding_generation" url:"expected_binding_generation"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationDeleteByInode) GetBehavior

func (*FilesystemOperationDeleteByInode) GetExpectedBindingGeneration

func (f *FilesystemOperationDeleteByInode) GetExpectedBindingGeneration() string

func (*FilesystemOperationDeleteByInode) GetExtraProperties

func (f *FilesystemOperationDeleteByInode) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationDeleteByInode) GetInodeID

func (f *FilesystemOperationDeleteByInode) GetInodeID() string

func (*FilesystemOperationDeleteByInode) MarshalJSON

func (f *FilesystemOperationDeleteByInode) MarshalJSON() ([]byte, error)

func (*FilesystemOperationDeleteByInode) SetBehavior

SetBehavior sets the Behavior field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationDeleteByInode) SetExpectedBindingGeneration

func (f *FilesystemOperationDeleteByInode) SetExpectedBindingGeneration(expectedBindingGeneration string)

SetExpectedBindingGeneration sets the ExpectedBindingGeneration field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationDeleteByInode) SetInodeID

func (f *FilesystemOperationDeleteByInode) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationDeleteByInode) String

func (*FilesystemOperationDeleteByInode) UnmarshalJSON

func (f *FilesystemOperationDeleteByInode) UnmarshalJSON(data []byte) error

type FilesystemOperationDeletePath

type FilesystemOperationDeletePath struct {
	// Whether a non-empty directory may be tombstoned recursively.
	Behavior *DeleteDirectoryBehavior `json:"behavior,omitempty" url:"behavior,omitempty"`
	// Stable inode ID within a namespace
	ExpectedInodeID *string `json:"expected_inode_id,omitempty" url:"expected_inode_id,omitempty"`
	// Absolute path that must resolve to a visible inode.
	Path AbsolutePath `json:"path" url:"path"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationDeletePath) GetBehavior

func (*FilesystemOperationDeletePath) GetExpectedInodeID

func (f *FilesystemOperationDeletePath) GetExpectedInodeID() *string

func (*FilesystemOperationDeletePath) GetExtraProperties

func (f *FilesystemOperationDeletePath) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationDeletePath) GetPath

func (*FilesystemOperationDeletePath) MarshalJSON

func (f *FilesystemOperationDeletePath) MarshalJSON() ([]byte, error)

func (*FilesystemOperationDeletePath) SetBehavior

func (f *FilesystemOperationDeletePath) SetBehavior(behavior *DeleteDirectoryBehavior)

SetBehavior sets the Behavior field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationDeletePath) SetExpectedInodeID

func (f *FilesystemOperationDeletePath) SetExpectedInodeID(expectedInodeID *string)

SetExpectedInodeID sets the ExpectedInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationDeletePath) SetPath

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationDeletePath) String

func (*FilesystemOperationDeletePath) UnmarshalJSON

func (f *FilesystemOperationDeletePath) UnmarshalJSON(data []byte) error

type FilesystemOperationMoveByInode

type FilesystemOperationMoveByInode struct {
	// Whether an existing destination file may be replaced.
	Behavior *DestinationBehavior `json:"behavior,omitempty" url:"behavior,omitempty"`
	// Binding generation required for the move.
	ExpectedBindingGeneration string `json:"expected_binding_generation" url:"expected_binding_generation"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// New name.
	ToDisplayName DisplayName `json:"to_display_name" url:"to_display_name"`
	// Stable inode ID within a namespace
	ToParentInodeID string `json:"to_parent_inode_id" url:"to_parent_inode_id"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationMoveByInode) GetBehavior

func (*FilesystemOperationMoveByInode) GetExpectedBindingGeneration

func (f *FilesystemOperationMoveByInode) GetExpectedBindingGeneration() string

func (*FilesystemOperationMoveByInode) GetExtraProperties

func (f *FilesystemOperationMoveByInode) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationMoveByInode) GetInodeID

func (f *FilesystemOperationMoveByInode) GetInodeID() string

func (*FilesystemOperationMoveByInode) GetToDisplayName

func (f *FilesystemOperationMoveByInode) GetToDisplayName() DisplayName

func (*FilesystemOperationMoveByInode) GetToParentInodeID

func (f *FilesystemOperationMoveByInode) GetToParentInodeID() string

func (*FilesystemOperationMoveByInode) MarshalJSON

func (f *FilesystemOperationMoveByInode) MarshalJSON() ([]byte, error)

func (*FilesystemOperationMoveByInode) SetBehavior

func (f *FilesystemOperationMoveByInode) SetBehavior(behavior *DestinationBehavior)

SetBehavior sets the Behavior field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationMoveByInode) SetExpectedBindingGeneration

func (f *FilesystemOperationMoveByInode) SetExpectedBindingGeneration(expectedBindingGeneration string)

SetExpectedBindingGeneration sets the ExpectedBindingGeneration field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationMoveByInode) SetInodeID

func (f *FilesystemOperationMoveByInode) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationMoveByInode) SetToDisplayName

func (f *FilesystemOperationMoveByInode) SetToDisplayName(toDisplayName DisplayName)

SetToDisplayName sets the ToDisplayName field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationMoveByInode) SetToParentInodeID

func (f *FilesystemOperationMoveByInode) SetToParentInodeID(toParentInodeID string)

SetToParentInodeID sets the ToParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationMoveByInode) String

func (*FilesystemOperationMoveByInode) UnmarshalJSON

func (f *FilesystemOperationMoveByInode) UnmarshalJSON(data []byte) error

type FilesystemOperationMovePath

type FilesystemOperationMovePath struct {
	// Whether an existing destination file may be replaced.
	Behavior *DestinationBehavior `json:"behavior,omitempty" url:"behavior,omitempty"`
	// Absolute source path that must resolve to a visible inode.
	FromPath AbsolutePath `json:"from_path" url:"from_path"`
	// Absolute destination whose parent must be visible and writable.
	ToPath AbsolutePath `json:"to_path" url:"to_path"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationMovePath) GetBehavior

func (*FilesystemOperationMovePath) GetExtraProperties

func (f *FilesystemOperationMovePath) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationMovePath) GetFromPath

func (f *FilesystemOperationMovePath) GetFromPath() AbsolutePath

func (*FilesystemOperationMovePath) GetToPath

func (*FilesystemOperationMovePath) MarshalJSON

func (f *FilesystemOperationMovePath) MarshalJSON() ([]byte, error)

func (*FilesystemOperationMovePath) SetBehavior

func (f *FilesystemOperationMovePath) SetBehavior(behavior *DestinationBehavior)

SetBehavior sets the Behavior field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationMovePath) SetFromPath

func (f *FilesystemOperationMovePath) SetFromPath(fromPath AbsolutePath)

SetFromPath sets the FromPath field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationMovePath) SetToPath

func (f *FilesystemOperationMovePath) SetToPath(toPath AbsolutePath)

SetToPath sets the ToPath field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationMovePath) String

func (f *FilesystemOperationMovePath) String() string

func (*FilesystemOperationMovePath) UnmarshalJSON

func (f *FilesystemOperationMovePath) UnmarshalJSON(data []byte) error

type FilesystemOperationPutFile

type FilesystemOperationPutFile struct {
	// Whether an existing file may receive a new revision instead of causing a conflict.
	Behavior *DestinationBehavior `json:"behavior,omitempty" url:"behavior,omitempty"`
	// Immutable bytes that must be covered by a valid preparation proof.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// When set (with `replace` behavior), the put applies only while
	// the file's current revision is still this one; a raced write
	// fails the request instead of silently stacking on it, and a
	// missing file answers `path_not_found`.
	ExpectedRevisionNo *RevisionNo `json:"expected_revision_no,omitempty" url:"expected_revision_no,omitempty"`
	// Absolute destination path; missing ancestors are created automatically.
	Path AbsolutePath `json:"path" url:"path"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationPutFile) GetBehavior

func (*FilesystemOperationPutFile) GetContentRef

func (f *FilesystemOperationPutFile) GetContentRef() *ContentRef

func (*FilesystemOperationPutFile) GetExpectedRevisionNo

func (f *FilesystemOperationPutFile) GetExpectedRevisionNo() *RevisionNo

func (*FilesystemOperationPutFile) GetExtraProperties

func (f *FilesystemOperationPutFile) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationPutFile) GetPath

func (*FilesystemOperationPutFile) MarshalJSON

func (f *FilesystemOperationPutFile) MarshalJSON() ([]byte, error)

func (*FilesystemOperationPutFile) SetBehavior

func (f *FilesystemOperationPutFile) SetBehavior(behavior *DestinationBehavior)

SetBehavior sets the Behavior field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationPutFile) SetContentRef

func (f *FilesystemOperationPutFile) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationPutFile) SetExpectedRevisionNo

func (f *FilesystemOperationPutFile) SetExpectedRevisionNo(expectedRevisionNo *RevisionNo)

SetExpectedRevisionNo sets the ExpectedRevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationPutFile) SetPath

func (f *FilesystemOperationPutFile) SetPath(path AbsolutePath)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationPutFile) String

func (f *FilesystemOperationPutFile) String() string

func (*FilesystemOperationPutFile) UnmarshalJSON

func (f *FilesystemOperationPutFile) UnmarshalJSON(data []byte) error

type FilesystemOperationPutFileByInode

type FilesystemOperationPutFileByInode struct {
	// Immutable bytes that must be covered by a valid preparation proof.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// New file name.
	DisplayName DisplayName `json:"display_name" url:"display_name"`
	// Stable inode ID within a namespace
	ParentInodeID string `json:"parent_inode_id" url:"parent_inode_id"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationPutFileByInode) GetContentRef

func (f *FilesystemOperationPutFileByInode) GetContentRef() *ContentRef

func (*FilesystemOperationPutFileByInode) GetDisplayName

func (f *FilesystemOperationPutFileByInode) GetDisplayName() DisplayName

func (*FilesystemOperationPutFileByInode) GetExtraProperties

func (f *FilesystemOperationPutFileByInode) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationPutFileByInode) GetParentInodeID

func (f *FilesystemOperationPutFileByInode) GetParentInodeID() string

func (*FilesystemOperationPutFileByInode) MarshalJSON

func (f *FilesystemOperationPutFileByInode) MarshalJSON() ([]byte, error)

func (*FilesystemOperationPutFileByInode) SetContentRef

func (f *FilesystemOperationPutFileByInode) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationPutFileByInode) SetDisplayName

func (f *FilesystemOperationPutFileByInode) SetDisplayName(displayName DisplayName)

SetDisplayName sets the DisplayName field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationPutFileByInode) SetParentInodeID

func (f *FilesystemOperationPutFileByInode) SetParentInodeID(parentInodeID string)

SetParentInodeID sets the ParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationPutFileByInode) String

func (*FilesystemOperationPutFileByInode) UnmarshalJSON

func (f *FilesystemOperationPutFileByInode) UnmarshalJSON(data []byte) error

type FilesystemOperationPutFileRevisionByInode

type FilesystemOperationPutFileRevisionByInode struct {
	// Immutable bytes that must be covered by a valid preparation proof.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// Current revision required for the write.
	ExpectedRevisionNo RevisionNo `json:"expected_revision_no" url:"expected_revision_no"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationPutFileRevisionByInode) GetContentRef

func (*FilesystemOperationPutFileRevisionByInode) GetExpectedRevisionNo

func (f *FilesystemOperationPutFileRevisionByInode) GetExpectedRevisionNo() RevisionNo

func (*FilesystemOperationPutFileRevisionByInode) GetExtraProperties

func (f *FilesystemOperationPutFileRevisionByInode) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationPutFileRevisionByInode) GetInodeID

func (*FilesystemOperationPutFileRevisionByInode) MarshalJSON

func (*FilesystemOperationPutFileRevisionByInode) SetContentRef

func (f *FilesystemOperationPutFileRevisionByInode) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationPutFileRevisionByInode) SetExpectedRevisionNo

func (f *FilesystemOperationPutFileRevisionByInode) SetExpectedRevisionNo(expectedRevisionNo RevisionNo)

SetExpectedRevisionNo sets the ExpectedRevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationPutFileRevisionByInode) SetInodeID

func (f *FilesystemOperationPutFileRevisionByInode) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationPutFileRevisionByInode) String

func (*FilesystemOperationPutFileRevisionByInode) UnmarshalJSON

func (f *FilesystemOperationPutFileRevisionByInode) UnmarshalJSON(data []byte) error

type FilesystemOperationRestoreRevision

type FilesystemOperationRestoreRevision struct {
	// Absolute path that must resolve to a visible file.
	Path AbsolutePath `json:"path" url:"path"`
	// Existing historical revision whose content will be copied into a new current revision.
	SourceRevisionNo RevisionNo `json:"source_revision_no" url:"source_revision_no"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationRestoreRevision) GetExtraProperties

func (f *FilesystemOperationRestoreRevision) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationRestoreRevision) GetPath

func (*FilesystemOperationRestoreRevision) GetSourceRevisionNo

func (f *FilesystemOperationRestoreRevision) GetSourceRevisionNo() RevisionNo

func (*FilesystemOperationRestoreRevision) MarshalJSON

func (f *FilesystemOperationRestoreRevision) MarshalJSON() ([]byte, error)

func (*FilesystemOperationRestoreRevision) SetPath

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationRestoreRevision) SetSourceRevisionNo

func (f *FilesystemOperationRestoreRevision) SetSourceRevisionNo(sourceRevisionNo RevisionNo)

SetSourceRevisionNo sets the SourceRevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationRestoreRevision) String

func (*FilesystemOperationRestoreRevision) UnmarshalJSON

func (f *FilesystemOperationRestoreRevision) UnmarshalJSON(data []byte) error

type FilesystemOperationUndelete

type FilesystemOperationUndelete struct {
	// Observed deletion sequence, which prevents cancelling a newer tombstone generation.
	DeletionSeq ChangeSeq `json:"deletion_seq" url:"deletion_seq"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// Optional destination for the restored inode.
	//
	// When absent, the inode is rebound to the parent and name recorded by the
	// deletion. Parent identity, rather than an old path string, keeps this
	// correct after ancestor renames. An explicit path is required when the
	// deletion recorded no binding.
	Path *AbsolutePath `json:"path,omitempty" url:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationUndelete) GetDeletionSeq

func (f *FilesystemOperationUndelete) GetDeletionSeq() ChangeSeq

func (*FilesystemOperationUndelete) GetExtraProperties

func (f *FilesystemOperationUndelete) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationUndelete) GetInodeID

func (f *FilesystemOperationUndelete) GetInodeID() string

func (*FilesystemOperationUndelete) GetPath

func (*FilesystemOperationUndelete) MarshalJSON

func (f *FilesystemOperationUndelete) MarshalJSON() ([]byte, error)

func (*FilesystemOperationUndelete) SetDeletionSeq

func (f *FilesystemOperationUndelete) SetDeletionSeq(deletionSeq ChangeSeq)

SetDeletionSeq sets the DeletionSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationUndelete) SetInodeID

func (f *FilesystemOperationUndelete) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationUndelete) SetPath

func (f *FilesystemOperationUndelete) SetPath(path *AbsolutePath)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationUndelete) String

func (f *FilesystemOperationUndelete) String() string

func (*FilesystemOperationUndelete) UnmarshalJSON

func (f *FilesystemOperationUndelete) UnmarshalJSON(data []byte) error

type FilesystemOperationUpdateAttributes

type FilesystemOperationUpdateAttributes struct {
	// When set, the update applies only while the inode's attribute
	// revision is still this one. Absent means the update is applied
	// over whatever revision is current; either way the write carries
	// its own revision guard, so a concurrent update never merges
	// silently.
	ExpectedAttributesRevisionNo *AttributeRevisionNo `json:"expected_attributes_revision_no,omitempty" url:"expected_attributes_revision_no,omitempty"`
	// Stable inode ID within a namespace
	ExpectedInodeID *string `json:"expected_inode_id,omitempty" url:"expected_inode_id,omitempty"`
	// Absolute path that must resolve to a visible file or directory.
	Path AbsolutePath `json:"path" url:"path"`
	// Attribute keys to remove.
	//
	// A list preserves duplicate entries so validation can report them instead
	// of silently deduplicating the request.
	Remove []AttributeKey `json:"remove,omitempty" url:"remove,omitempty"`
	// Attributes to write. Each key replaces whatever the inode
	// currently holds under it; keys the inode holds and this map does
	// not name are left alone.
	Set map[string]AttributeValue `json:"set,omitempty" url:"set,omitempty"`
	// contains filtered or unexported fields
}

func (*FilesystemOperationUpdateAttributes) GetExpectedAttributesRevisionNo

func (f *FilesystemOperationUpdateAttributes) GetExpectedAttributesRevisionNo() *AttributeRevisionNo

func (*FilesystemOperationUpdateAttributes) GetExpectedInodeID

func (f *FilesystemOperationUpdateAttributes) GetExpectedInodeID() *string

func (*FilesystemOperationUpdateAttributes) GetExtraProperties

func (f *FilesystemOperationUpdateAttributes) GetExtraProperties() map[string]interface{}

func (*FilesystemOperationUpdateAttributes) GetPath

func (*FilesystemOperationUpdateAttributes) GetRemove

func (*FilesystemOperationUpdateAttributes) GetSet

func (*FilesystemOperationUpdateAttributes) MarshalJSON

func (f *FilesystemOperationUpdateAttributes) MarshalJSON() ([]byte, error)

func (*FilesystemOperationUpdateAttributes) SetExpectedAttributesRevisionNo

func (f *FilesystemOperationUpdateAttributes) SetExpectedAttributesRevisionNo(expectedAttributesRevisionNo *AttributeRevisionNo)

SetExpectedAttributesRevisionNo sets the ExpectedAttributesRevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationUpdateAttributes) SetExpectedInodeID

func (f *FilesystemOperationUpdateAttributes) SetExpectedInodeID(expectedInodeID *string)

SetExpectedInodeID sets the ExpectedInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationUpdateAttributes) SetPath

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationUpdateAttributes) SetRemove

func (f *FilesystemOperationUpdateAttributes) SetRemove(remove []AttributeKey)

SetRemove sets the Remove field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationUpdateAttributes) SetSet

SetSet sets the Set field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*FilesystemOperationUpdateAttributes) String

func (*FilesystemOperationUpdateAttributes) UnmarshalJSON

func (f *FilesystemOperationUpdateAttributes) UnmarshalJSON(data []byte) error

type FilesystemOperationVisitor

type FilesystemOperationVisitor interface {
	VisitCreateDirectory(*FilesystemOperationCreateDirectory) error
	VisitCreateDirectoryByInode(*FilesystemOperationCreateDirectoryByInode) error
	VisitPutFile(*FilesystemOperationPutFile) error
	VisitPutFileByInode(*FilesystemOperationPutFileByInode) error
	VisitPutFileRevisionByInode(*FilesystemOperationPutFileRevisionByInode) error
	VisitDeletePath(*FilesystemOperationDeletePath) error
	VisitDeleteByInode(*FilesystemOperationDeleteByInode) error
	VisitMovePath(*FilesystemOperationMovePath) error
	VisitMoveByInode(*FilesystemOperationMoveByInode) error
	VisitCopyPath(*FilesystemOperationCopyPath) error
	VisitUndelete(*FilesystemOperationUndelete) error
	VisitRestoreRevision(*FilesystemOperationRestoreRevision) error
	VisitUpdateAttributes(*FilesystemOperationUpdateAttributes) error
}

type ForkNamespaceRequest

type ForkNamespaceRequest struct {
	// Source namespace id
	NamespaceID string `json:"-" url:"-"`
	// Durable namespace id for the fork target.
	NewNamespaceID NamespaceID `json:"new_namespace_id" url:"-"`
	// contains filtered or unexported fields
}

func (*ForkNamespaceRequest) MarshalJSON

func (f *ForkNamespaceRequest) MarshalJSON() ([]byte, error)

func (*ForkNamespaceRequest) SetNamespaceID

func (f *ForkNamespaceRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ForkNamespaceRequest) SetNewNamespaceID

func (f *ForkNamespaceRequest) SetNewNamespaceID(newNamespaceID NamespaceID)

SetNewNamespaceID sets the NewNamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ForkNamespaceRequest) UnmarshalJSON

func (f *ForkNamespaceRequest) UnmarshalJSON(data []byte) error

type GcRequest

type GcRequest struct {
	// Opaque resume token returned as `next_cursor` by an earlier pass
	// against the same namespace.
	Cursor *string `json:"cursor,omitempty" url:"cursor,omitempty"`
	// Objects younger than this are never deleted, reachable or not. The
	// window has a derived safety floor (publication budgets plus provider
	// deadlines); a smaller value is rejected as `invalid_request`.
	GraceWindowMs *int64 `json:"grace_window_ms,omitempty" url:"grace_window_ms,omitempty"`
	// Maximum objects this invocation may read or decide. Omit to retain
	// the run-to-completion behavior.
	//
	// A completed upload session past its reclamation grace makes the pass
	// read every live manifest and retained WAL segment to find out
	// whether anything still references its content, and that read is
	// charged here like any other. A budget too small to finish it does
	// not stall the pass: the session is retained, the response sets
	// `content_reclamation_deferred`, and the sweep carries on through
	// everything else. What a chronically small budget costs is content
	// left unreclaimed, not progress. Give a pass at least as many objects
	// as the namespace has live manifests and retained segments for that
	// content to come back.
	MaxObjects *int64 `json:"max_objects,omitempty" url:"max_objects,omitempty"`
	// contains filtered or unexported fields
}

func (*GcRequest) GetCursor

func (g *GcRequest) GetCursor() *string

func (*GcRequest) GetExtraProperties

func (g *GcRequest) GetExtraProperties() map[string]interface{}

func (*GcRequest) GetGraceWindowMs

func (g *GcRequest) GetGraceWindowMs() *int64

func (*GcRequest) GetMaxObjects

func (g *GcRequest) GetMaxObjects() *int64

func (*GcRequest) MarshalJSON

func (g *GcRequest) MarshalJSON() ([]byte, error)

func (*GcRequest) SetCursor

func (g *GcRequest) SetCursor(cursor *string)

SetCursor sets the Cursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcRequest) SetGraceWindowMs

func (g *GcRequest) SetGraceWindowMs(graceWindowMs *int64)

SetGraceWindowMs sets the GraceWindowMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcRequest) SetMaxObjects

func (g *GcRequest) SetMaxObjects(maxObjects *int64)

SetMaxObjects sets the MaxObjects field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcRequest) String

func (g *GcRequest) String() string

func (*GcRequest) UnmarshalJSON

func (g *GcRequest) UnmarshalJSON(data []byte) error

type GcResponse

type GcResponse struct {
	// True when the pass reached `max_objects` before it finished. Use
	// `next_cursor` to continue or run again with a larger limit.
	BudgetExhausted bool `json:"budget_exhausted" url:"budget_exhausted"`
	// True when `max_objects` was too small to build the complete reference
	// set required for completed-content reclamation.
	ContentReclamationDeferred bool `json:"content_reclamation_deferred" url:"content_reclamation_deferred"`
	// Objects the pass deleted, split by object family.
	Deleted *DeletedObjectCounts `json:"deleted" url:"deleted"`
	// Namespace the pass ran against.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Opaque resume token when more candidates remain. It is valid only for
	// the same namespace.
	NextCursor *string `json:"next_cursor,omitempty" url:"next_cursor,omitempty"`
	// Earliest known time when a retained upload session may become
	// reclaimable. This covers open-session leases and grace periods for
	// aborted or completed sessions. It only reflects candidates inspected
	// by this pass, so absence does not mean no future work remains.
	NextReclamationAtMs *int64 `json:"next_reclamation_at_ms,omitempty" url:"next_reclamation_at_ms,omitempty"`
	// Checkpoint records the pass released, split by the reason each one
	// was released.
	ReleasedCheckpoints *ReleasedCheckpointCounts `json:"released_checkpoints" url:"released_checkpoints"`
	// `retained_candidates` grouped by reason.
	Retained *RetainedCandidates `json:"retained" url:"retained"`
	// Candidates retained at delete time (grace window, missing
	// timestamps, or reachable from the fresh root set).
	RetainedCandidates int64 `json:"retained_candidates" url:"retained_candidates"`
	// True when ambiguous roots suppressed manifest/segment deletion.
	RetentionDegraded bool `json:"retention_degraded" url:"retention_degraded"`
	// contains filtered or unexported fields
}

func (*GcResponse) GetBudgetExhausted

func (g *GcResponse) GetBudgetExhausted() bool

func (*GcResponse) GetContentReclamationDeferred

func (g *GcResponse) GetContentReclamationDeferred() bool

func (*GcResponse) GetDeleted

func (g *GcResponse) GetDeleted() *DeletedObjectCounts

func (*GcResponse) GetExtraProperties

func (g *GcResponse) GetExtraProperties() map[string]interface{}

func (*GcResponse) GetNamespaceID

func (g *GcResponse) GetNamespaceID() NamespaceID

func (*GcResponse) GetNextCursor

func (g *GcResponse) GetNextCursor() *string

func (*GcResponse) GetNextReclamationAtMs

func (g *GcResponse) GetNextReclamationAtMs() *int64

func (*GcResponse) GetReleasedCheckpoints

func (g *GcResponse) GetReleasedCheckpoints() *ReleasedCheckpointCounts

func (*GcResponse) GetRetained

func (g *GcResponse) GetRetained() *RetainedCandidates

func (*GcResponse) GetRetainedCandidates

func (g *GcResponse) GetRetainedCandidates() int64

func (*GcResponse) GetRetentionDegraded

func (g *GcResponse) GetRetentionDegraded() bool

func (*GcResponse) MarshalJSON

func (g *GcResponse) MarshalJSON() ([]byte, error)

func (*GcResponse) SetBudgetExhausted

func (g *GcResponse) SetBudgetExhausted(budgetExhausted bool)

SetBudgetExhausted sets the BudgetExhausted field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcResponse) SetContentReclamationDeferred

func (g *GcResponse) SetContentReclamationDeferred(contentReclamationDeferred bool)

SetContentReclamationDeferred sets the ContentReclamationDeferred field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcResponse) SetDeleted

func (g *GcResponse) SetDeleted(deleted *DeletedObjectCounts)

SetDeleted sets the Deleted field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcResponse) SetNamespaceID

func (g *GcResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcResponse) SetNextCursor

func (g *GcResponse) SetNextCursor(nextCursor *string)

SetNextCursor sets the NextCursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcResponse) SetNextReclamationAtMs

func (g *GcResponse) SetNextReclamationAtMs(nextReclamationAtMs *int64)

SetNextReclamationAtMs sets the NextReclamationAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcResponse) SetReleasedCheckpoints

func (g *GcResponse) SetReleasedCheckpoints(releasedCheckpoints *ReleasedCheckpointCounts)

SetReleasedCheckpoints sets the ReleasedCheckpoints field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcResponse) SetRetained

func (g *GcResponse) SetRetained(retained *RetainedCandidates)

SetRetained sets the Retained field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcResponse) SetRetainedCandidates

func (g *GcResponse) SetRetainedCandidates(retainedCandidates int64)

SetRetainedCandidates sets the RetainedCandidates field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcResponse) SetRetentionDegraded

func (g *GcResponse) SetRetentionDegraded(retentionDegraded bool)

SetRetentionDegraded sets the RetentionDegraded field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GcResponse) String

func (g *GcResponse) String() string

func (*GcResponse) UnmarshalJSON

func (g *GcResponse) UnmarshalJSON(data []byte) error

type GetFileBytesRequest

type GetFileBytesRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Absolute file path
	Path string `json:"-" url:"path"`
	// Optional prior revision number; cannot be combined with snapshot_id
	RevisionNo *RevisionNo `json:"-" url:"revision_no,omitempty"`
	// Use the file revision captured by this snapshot
	SnapshotID *CheckpointID `json:"-" url:"snapshot_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileBytesRequest) SetNamespaceID

func (g *GetFileBytesRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GetFileBytesRequest) SetPath

func (g *GetFileBytesRequest) SetPath(path string)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GetFileBytesRequest) SetRevisionNo

func (g *GetFileBytesRequest) SetRevisionNo(revisionNo *RevisionNo)

SetRevisionNo sets the RevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GetFileBytesRequest) SetSnapshotID

func (g *GetFileBytesRequest) SetSnapshotID(snapshotID *CheckpointID)

SetSnapshotID sets the SnapshotID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type GetFileRevisionBytesByInodeRequest

type GetFileRevisionBytesByInodeRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// File inode ID
	InodeID string `json:"-" url:"-"`
	// Revision number
	RevisionNo RevisionNo `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*GetFileRevisionBytesByInodeRequest) SetInodeID

func (g *GetFileRevisionBytesByInodeRequest) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GetFileRevisionBytesByInodeRequest) SetNamespaceID

func (g *GetFileRevisionBytesByInodeRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GetFileRevisionBytesByInodeRequest) SetRevisionNo

func (g *GetFileRevisionBytesByInodeRequest) SetRevisionNo(revisionNo RevisionNo)

SetRevisionNo sets the RevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type GetGrepIndexRequest

type GetGrepIndexRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*GetGrepIndexRequest) SetNamespaceID

func (g *GetGrepIndexRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type GetInodeRequest

type GetInodeRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Inode ID
	InodeID string `json:"-" url:"-"`
	// Project the inode's attribute map and revision (`true` or `false`). Defaults to `true`: a stat answers for one path and a map is capped at 64 KiB.
	IncludeAttributes *bool `json:"-" url:"include_attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInodeRequest) SetIncludeAttributes

func (g *GetInodeRequest) SetIncludeAttributes(includeAttributes *bool)

SetIncludeAttributes sets the IncludeAttributes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GetInodeRequest) SetInodeID

func (g *GetInodeRequest) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GetInodeRequest) SetNamespaceID

func (g *GetInodeRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type GetNamespaceDiagnosticsRequest

type GetNamespaceDiagnosticsRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*GetNamespaceDiagnosticsRequest) SetNamespaceID

func (g *GetNamespaceDiagnosticsRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type GetNamespaceRequest

type GetNamespaceRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*GetNamespaceRequest) SetNamespaceID

func (g *GetNamespaceRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type GetPathEntryRequest

type GetPathEntryRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Absolute filesystem path
	Path string `json:"-" url:"path"`
	// Project the inode's attribute map and revision (`true` or `false`). Defaults to `true`: a stat answers for one path and a map is capped at 64 KiB.
	IncludeAttributes *bool `json:"-" url:"include_attributes,omitempty"`
	// Use the path state captured by this snapshot
	SnapshotID *CheckpointID `json:"-" url:"snapshot_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPathEntryRequest) SetIncludeAttributes

func (g *GetPathEntryRequest) SetIncludeAttributes(includeAttributes *bool)

SetIncludeAttributes sets the IncludeAttributes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GetPathEntryRequest) SetNamespaceID

func (g *GetPathEntryRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GetPathEntryRequest) SetPath

func (g *GetPathEntryRequest) SetPath(path string)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GetPathEntryRequest) SetSnapshotID

func (g *GetPathEntryRequest) SetSnapshotID(snapshotID *CheckpointID)

SetSnapshotID sets the SnapshotID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type GetUploadRequest

type GetUploadRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Upload session id
	UploadID string `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*GetUploadRequest) SetNamespaceID

func (g *GetUploadRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GetUploadRequest) SetUploadID

func (g *GetUploadRequest) SetUploadID(uploadID string)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type GoneError

type GoneError struct {
	*core.APIError
	Body *APIError
}

Namespace deleted

func (*GoneError) MarshalJSON

func (g *GoneError) MarshalJSON() ([]byte, error)

func (*GoneError) UnmarshalJSON

func (g *GoneError) UnmarshalJSON(data []byte) error

func (*GoneError) Unwrap

func (g *GoneError) Unwrap() error

type GrepGcRequest

type GrepGcRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Opaque resume token returned as `next_cursor` by an earlier pass
	// against the same namespace.
	Cursor *string `json:"cursor,omitempty" url:"-"`
	// Reads this pass may spend before returning with a `next_cursor`.
	// Omit to take the same per-pass default the runtime's own collection
	// takes.
	MaxObjects *int64 `json:"max_objects,omitempty" url:"-"`
	// contains filtered or unexported fields
}

func (*GrepGcRequest) MarshalJSON

func (g *GrepGcRequest) MarshalJSON() ([]byte, error)

func (*GrepGcRequest) SetCursor

func (g *GrepGcRequest) SetCursor(cursor *string)

SetCursor sets the Cursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepGcRequest) SetMaxObjects

func (g *GrepGcRequest) SetMaxObjects(maxObjects *int64)

SetMaxObjects sets the MaxObjects field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepGcRequest) SetNamespaceID

func (g *GrepGcRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepGcRequest) UnmarshalJSON

func (g *GrepGcRequest) UnmarshalJSON(data []byte) error

type GrepGcResponse

type GrepGcResponse struct {
	// Other unreferenced grep objects deleted after the grace window.
	DeletedOtherObjects int64 `json:"deleted_other_objects" url:"deleted_other_objects"`
	// Unreferenced grep segments deleted after the grace window.
	DeletedSegments int64 `json:"deleted_segments" url:"deleted_segments"`
	// Whether unreadable namespace or grep state forced conservative retention.
	NamespaceDegraded bool `json:"namespace_degraded" url:"namespace_degraded"`
	// Namespace whose grep-owned keyspace was inspected.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Whether an absent or tombstoned namespace had extension state reaped.
	NamespaceReaped bool `json:"namespace_reaped" url:"namespace_reaped"`
	// Present when the budget stopped the pass with keys left to examine.
	NextCursor *string `json:"next_cursor,omitempty" url:"next_cursor,omitempty"`
	// Young or concurrently revived candidates retained by the pass.
	RetainedCandidates int64 `json:"retained_candidates" url:"retained_candidates"`
	// contains filtered or unexported fields
}

func (*GrepGcResponse) GetDeletedOtherObjects

func (g *GrepGcResponse) GetDeletedOtherObjects() int64

func (*GrepGcResponse) GetDeletedSegments

func (g *GrepGcResponse) GetDeletedSegments() int64

func (*GrepGcResponse) GetExtraProperties

func (g *GrepGcResponse) GetExtraProperties() map[string]interface{}

func (*GrepGcResponse) GetNamespaceDegraded

func (g *GrepGcResponse) GetNamespaceDegraded() bool

func (*GrepGcResponse) GetNamespaceID

func (g *GrepGcResponse) GetNamespaceID() NamespaceID

func (*GrepGcResponse) GetNamespaceReaped

func (g *GrepGcResponse) GetNamespaceReaped() bool

func (*GrepGcResponse) GetNextCursor

func (g *GrepGcResponse) GetNextCursor() *string

func (*GrepGcResponse) GetRetainedCandidates

func (g *GrepGcResponse) GetRetainedCandidates() int64

func (*GrepGcResponse) MarshalJSON

func (g *GrepGcResponse) MarshalJSON() ([]byte, error)

func (*GrepGcResponse) SetDeletedOtherObjects

func (g *GrepGcResponse) SetDeletedOtherObjects(deletedOtherObjects int64)

SetDeletedOtherObjects sets the DeletedOtherObjects field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepGcResponse) SetDeletedSegments

func (g *GrepGcResponse) SetDeletedSegments(deletedSegments int64)

SetDeletedSegments sets the DeletedSegments field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepGcResponse) SetNamespaceDegraded

func (g *GrepGcResponse) SetNamespaceDegraded(namespaceDegraded bool)

SetNamespaceDegraded sets the NamespaceDegraded field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepGcResponse) SetNamespaceID

func (g *GrepGcResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepGcResponse) SetNamespaceReaped

func (g *GrepGcResponse) SetNamespaceReaped(namespaceReaped bool)

SetNamespaceReaped sets the NamespaceReaped field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepGcResponse) SetNextCursor

func (g *GrepGcResponse) SetNextCursor(nextCursor *string)

SetNextCursor sets the NextCursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepGcResponse) SetRetainedCandidates

func (g *GrepGcResponse) SetRetainedCandidates(retainedCandidates int64)

SetRetainedCandidates sets the RetainedCandidates field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepGcResponse) String

func (g *GrepGcResponse) String() string

func (*GrepGcResponse) UnmarshalJSON

func (g *GrepGcResponse) UnmarshalJSON(data []byte) error

type GrepIndex

type GrepIndex struct {
	Status      string
	Disabled    *GrepIndexLifecycleDisabled
	Backfilling *GrepIndexLifecycleBackfilling
	Active      *GrepIndexLifecycleActive
	// contains filtered or unexported fields
}

The namespace's grep-index lifecycle and its cheap bookkeeping (admin plane).

func (*GrepIndex) Accept

func (g *GrepIndex) Accept(visitor GrepIndexVisitor) error

func (*GrepIndex) GetActive

func (g *GrepIndex) GetActive() *GrepIndexLifecycleActive

func (*GrepIndex) GetBackfilling

func (g *GrepIndex) GetBackfilling() *GrepIndexLifecycleBackfilling

func (*GrepIndex) GetDisabled

func (g *GrepIndex) GetDisabled() *GrepIndexLifecycleDisabled

func (*GrepIndex) GetStatus

func (g *GrepIndex) GetStatus() string

func (GrepIndex) MarshalJSON

func (g GrepIndex) MarshalJSON() ([]byte, error)

func (*GrepIndex) UnmarshalJSON

func (g *GrepIndex) UnmarshalJSON(data []byte) error

type GrepIndexLifecycleActive

type GrepIndexLifecycleActive struct {
	// Sequence of the commit at the index cursor.
	BuiltThroughSeq ChangeSeq `json:"built_through_seq" url:"built_through_seq"`
	// Offset of the next change event within `built_through_seq`, or
	// zero when the whole commit is represented.
	NextEventIndex *int `json:"next_event_index,omitempty" url:"next_event_index,omitempty"`
	// Namespace the status describes.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Run number the index allocates next.
	NextRunNo RunNo `json:"next_run_no" url:"next_run_no"`
	// True while a partitioned segment reorganization is in progress.
	ReorganizePending bool `json:"reorganize_pending" url:"reorganize_pending"`
	// contains filtered or unexported fields
}

func (*GrepIndexLifecycleActive) GetBuiltThroughSeq

func (g *GrepIndexLifecycleActive) GetBuiltThroughSeq() ChangeSeq

func (*GrepIndexLifecycleActive) GetExtraProperties

func (g *GrepIndexLifecycleActive) GetExtraProperties() map[string]interface{}

func (*GrepIndexLifecycleActive) GetNamespaceID

func (g *GrepIndexLifecycleActive) GetNamespaceID() NamespaceID

func (*GrepIndexLifecycleActive) GetNextEventIndex

func (g *GrepIndexLifecycleActive) GetNextEventIndex() *int

func (*GrepIndexLifecycleActive) GetNextRunNo

func (g *GrepIndexLifecycleActive) GetNextRunNo() RunNo

func (*GrepIndexLifecycleActive) GetReorganizePending

func (g *GrepIndexLifecycleActive) GetReorganizePending() bool

func (*GrepIndexLifecycleActive) MarshalJSON

func (g *GrepIndexLifecycleActive) MarshalJSON() ([]byte, error)

func (*GrepIndexLifecycleActive) SetBuiltThroughSeq

func (g *GrepIndexLifecycleActive) SetBuiltThroughSeq(builtThroughSeq ChangeSeq)

SetBuiltThroughSeq sets the BuiltThroughSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleActive) SetNamespaceID

func (g *GrepIndexLifecycleActive) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleActive) SetNextEventIndex

func (g *GrepIndexLifecycleActive) SetNextEventIndex(nextEventIndex *int)

SetNextEventIndex sets the NextEventIndex field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleActive) SetNextRunNo

func (g *GrepIndexLifecycleActive) SetNextRunNo(nextRunNo RunNo)

SetNextRunNo sets the NextRunNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleActive) SetReorganizePending

func (g *GrepIndexLifecycleActive) SetReorganizePending(reorganizePending bool)

SetReorganizePending sets the ReorganizePending field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleActive) String

func (g *GrepIndexLifecycleActive) String() string

func (*GrepIndexLifecycleActive) UnmarshalJSON

func (g *GrepIndexLifecycleActive) UnmarshalJSON(data []byte) error

type GrepIndexLifecycleBackfilling

type GrepIndexLifecycleBackfilling struct {
	// Checkpoint pinning the state being walked.
	CheckpointID CheckpointID `json:"checkpoint_id" url:"checkpoint_id"`
	// Stable inode ID within a namespace
	CursorInodeID *string `json:"cursor_inode_id,omitempty" url:"cursor_inode_id,omitempty"`
	// Namespace sequence the pinned checkpoint captured. Reaching it
	// is what completes the backfill.
	TargetSeq ChangeSeq `json:"target_seq" url:"target_seq"`
	// Namespace the status describes.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Run number the index allocates next.
	NextRunNo RunNo `json:"next_run_no" url:"next_run_no"`
	// True while a partitioned segment reorganization is in progress.
	ReorganizePending bool `json:"reorganize_pending" url:"reorganize_pending"`
	// contains filtered or unexported fields
}

func (*GrepIndexLifecycleBackfilling) GetCheckpointID

func (g *GrepIndexLifecycleBackfilling) GetCheckpointID() CheckpointID

func (*GrepIndexLifecycleBackfilling) GetCursorInodeID

func (g *GrepIndexLifecycleBackfilling) GetCursorInodeID() *string

func (*GrepIndexLifecycleBackfilling) GetExtraProperties

func (g *GrepIndexLifecycleBackfilling) GetExtraProperties() map[string]interface{}

func (*GrepIndexLifecycleBackfilling) GetNamespaceID

func (g *GrepIndexLifecycleBackfilling) GetNamespaceID() NamespaceID

func (*GrepIndexLifecycleBackfilling) GetNextRunNo

func (g *GrepIndexLifecycleBackfilling) GetNextRunNo() RunNo

func (*GrepIndexLifecycleBackfilling) GetReorganizePending

func (g *GrepIndexLifecycleBackfilling) GetReorganizePending() bool

func (*GrepIndexLifecycleBackfilling) GetTargetSeq

func (g *GrepIndexLifecycleBackfilling) GetTargetSeq() ChangeSeq

func (*GrepIndexLifecycleBackfilling) MarshalJSON

func (g *GrepIndexLifecycleBackfilling) MarshalJSON() ([]byte, error)

func (*GrepIndexLifecycleBackfilling) SetCheckpointID

func (g *GrepIndexLifecycleBackfilling) SetCheckpointID(checkpointID CheckpointID)

SetCheckpointID sets the CheckpointID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleBackfilling) SetCursorInodeID

func (g *GrepIndexLifecycleBackfilling) SetCursorInodeID(cursorInodeID *string)

SetCursorInodeID sets the CursorInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleBackfilling) SetNamespaceID

func (g *GrepIndexLifecycleBackfilling) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleBackfilling) SetNextRunNo

func (g *GrepIndexLifecycleBackfilling) SetNextRunNo(nextRunNo RunNo)

SetNextRunNo sets the NextRunNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleBackfilling) SetReorganizePending

func (g *GrepIndexLifecycleBackfilling) SetReorganizePending(reorganizePending bool)

SetReorganizePending sets the ReorganizePending field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleBackfilling) SetTargetSeq

func (g *GrepIndexLifecycleBackfilling) SetTargetSeq(targetSeq ChangeSeq)

SetTargetSeq sets the TargetSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleBackfilling) String

func (*GrepIndexLifecycleBackfilling) UnmarshalJSON

func (g *GrepIndexLifecycleBackfilling) UnmarshalJSON(data []byte) error

type GrepIndexLifecycleDisabled

type GrepIndexLifecycleDisabled struct {
	// Namespace the status describes.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Run number the index allocates next.
	NextRunNo RunNo `json:"next_run_no" url:"next_run_no"`
	// True while a partitioned segment reorganization is in progress.
	ReorganizePending bool `json:"reorganize_pending" url:"reorganize_pending"`
	// contains filtered or unexported fields
}

func (*GrepIndexLifecycleDisabled) GetExtraProperties

func (g *GrepIndexLifecycleDisabled) GetExtraProperties() map[string]interface{}

func (*GrepIndexLifecycleDisabled) GetNamespaceID

func (g *GrepIndexLifecycleDisabled) GetNamespaceID() NamespaceID

func (*GrepIndexLifecycleDisabled) GetNextRunNo

func (g *GrepIndexLifecycleDisabled) GetNextRunNo() RunNo

func (*GrepIndexLifecycleDisabled) GetReorganizePending

func (g *GrepIndexLifecycleDisabled) GetReorganizePending() bool

func (*GrepIndexLifecycleDisabled) MarshalJSON

func (g *GrepIndexLifecycleDisabled) MarshalJSON() ([]byte, error)

func (*GrepIndexLifecycleDisabled) SetNamespaceID

func (g *GrepIndexLifecycleDisabled) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleDisabled) SetNextRunNo

func (g *GrepIndexLifecycleDisabled) SetNextRunNo(nextRunNo RunNo)

SetNextRunNo sets the NextRunNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleDisabled) SetReorganizePending

func (g *GrepIndexLifecycleDisabled) SetReorganizePending(reorganizePending bool)

SetReorganizePending sets the ReorganizePending field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepIndexLifecycleDisabled) String

func (g *GrepIndexLifecycleDisabled) String() string

func (*GrepIndexLifecycleDisabled) UnmarshalJSON

func (g *GrepIndexLifecycleDisabled) UnmarshalJSON(data []byte) error

type GrepIndexVisitor

type GrepIndexVisitor interface {
	VisitDisabled(*GrepIndexLifecycleDisabled) error
	VisitBackfilling(*GrepIndexLifecycleBackfilling) error
	VisitActive(*GrepIndexLifecycleActive) error
}

type GrepMatch

type GrepMatch struct {
	// Byte offset of the match within the file.
	ByteOffset int64 `json:"byte_offset" url:"byte_offset"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// The matching line, truncated to the server's line cap.
	Line string `json:"line" url:"line"`
	// One-based line number of the match.
	LineNumber int64 `json:"line_number" url:"line_number"`
	// True when `line` was truncated.
	LineTruncated bool `json:"line_truncated" url:"line_truncated"`
	// The file's absolute path, derived at the snapshot.
	Path AbsolutePath `json:"path" url:"path"`
	// The matched revision (the newest visible one at the snapshot).
	RevisionNo RevisionNo `json:"revision_no" url:"revision_no"`
	// contains filtered or unexported fields
}

func (*GrepMatch) GetByteOffset

func (g *GrepMatch) GetByteOffset() int64

func (*GrepMatch) GetExtraProperties

func (g *GrepMatch) GetExtraProperties() map[string]interface{}

func (*GrepMatch) GetInodeID

func (g *GrepMatch) GetInodeID() string

func (*GrepMatch) GetLine

func (g *GrepMatch) GetLine() string

func (*GrepMatch) GetLineNumber

func (g *GrepMatch) GetLineNumber() int64

func (*GrepMatch) GetLineTruncated

func (g *GrepMatch) GetLineTruncated() bool

func (*GrepMatch) GetPath

func (g *GrepMatch) GetPath() AbsolutePath

func (*GrepMatch) GetRevisionNo

func (g *GrepMatch) GetRevisionNo() RevisionNo

func (*GrepMatch) MarshalJSON

func (g *GrepMatch) MarshalJSON() ([]byte, error)

func (*GrepMatch) SetByteOffset

func (g *GrepMatch) SetByteOffset(byteOffset int64)

SetByteOffset sets the ByteOffset field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepMatch) SetInodeID

func (g *GrepMatch) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepMatch) SetLine

func (g *GrepMatch) SetLine(line string)

SetLine sets the Line field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepMatch) SetLineNumber

func (g *GrepMatch) SetLineNumber(lineNumber int64)

SetLineNumber sets the LineNumber field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepMatch) SetLineTruncated

func (g *GrepMatch) SetLineTruncated(lineTruncated bool)

SetLineTruncated sets the LineTruncated field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepMatch) SetPath

func (g *GrepMatch) SetPath(path AbsolutePath)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepMatch) SetRevisionNo

func (g *GrepMatch) SetRevisionNo(revisionNo RevisionNo)

SetRevisionNo sets the RevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepMatch) String

func (g *GrepMatch) String() string

func (*GrepMatch) UnmarshalJSON

func (g *GrepMatch) UnmarshalJSON(data []byte) error

type GrepRequest

type GrepRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Pattern in the Rust `regex` crate's dialect. Its UTF-8 encoding must be at most 1024 bytes.
	Pattern string `json:"-" url:"pattern"`
	// Match case-insensitively (`true` or `false`). Defaults to `false`.
	CaseInsensitive *bool `json:"-" url:"case_insensitive,omitempty"`
	// Complete absolute path used to restrict matches.
	PathPrefix *string `json:"-" url:"path_prefix,omitempty"`
	// Permit a capped exhaustive scan when the pattern has no required grams (`true` or `false`). Defaults to `false`.
	AllowScan *bool `json:"-" url:"allow_scan,omitempty"`
	// Return indexed-only results when the unindexed tail exceeds the scan budget (`true` or `false`). Defaults to `false`.
	AllowStale *bool `json:"-" url:"allow_stale,omitempty"`
	// Maximum matches per page
	Limit *int `json:"-" url:"limit,omitempty"`
	// Opaque grep page cursor
	Cursor *string `json:"-" url:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*GrepRequest) SetAllowScan

func (g *GrepRequest) SetAllowScan(allowScan *bool)

SetAllowScan sets the AllowScan field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepRequest) SetAllowStale

func (g *GrepRequest) SetAllowStale(allowStale *bool)

SetAllowStale sets the AllowStale field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepRequest) SetCaseInsensitive

func (g *GrepRequest) SetCaseInsensitive(caseInsensitive *bool)

SetCaseInsensitive sets the CaseInsensitive field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepRequest) SetCursor

func (g *GrepRequest) SetCursor(cursor *string)

SetCursor sets the Cursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepRequest) SetLimit

func (g *GrepRequest) SetLimit(limit *int)

SetLimit sets the Limit field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepRequest) SetNamespaceID

func (g *GrepRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepRequest) SetPathPrefix

func (g *GrepRequest) SetPathPrefix(pathPrefix *string)

SetPathPrefix sets the PathPrefix field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepRequest) SetPattern

func (g *GrepRequest) SetPattern(pattern string)

SetPattern sets the Pattern field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type GrepResponse

type GrepResponse struct {
	// Commits at or below this sequence were answered from the index.
	BuiltThroughSeq ChangeSeq `json:"built_through_seq" url:"built_through_seq"`
	// Sequence this page was evaluated at. Pages are evaluated against
	// the namespace head at page time; the cursor is an ordering resume,
	// not a snapshot pin.
	HeadSeq ChangeSeq `json:"head_seq" url:"head_seq"`
	// Matches in ascending `(inode_id, byte_offset)` order. A page may
	// return fewer matches than its limit and still carry a cursor: the
	// per-page verified-candidate budget bounds how much content one
	// request reads, whatever the plan's false-positive rate.
	Matches []*GrepMatch `json:"matches" url:"matches"`
	// Namespace searched.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Present when another page follows.
	NextCursor *string `json:"next_cursor,omitempty" url:"next_cursor,omitempty"`
	// True when revisions after `built_through_seq` were scanned
	// exhaustively; false only when `allow_stale` skipped them.
	TailScanned bool `json:"tail_scanned" url:"tail_scanned"`
	// contains filtered or unexported fields
}

func (*GrepResponse) GetBuiltThroughSeq

func (g *GrepResponse) GetBuiltThroughSeq() ChangeSeq

func (*GrepResponse) GetExtraProperties

func (g *GrepResponse) GetExtraProperties() map[string]interface{}

func (*GrepResponse) GetHeadSeq

func (g *GrepResponse) GetHeadSeq() ChangeSeq

func (*GrepResponse) GetMatches

func (g *GrepResponse) GetMatches() []*GrepMatch

func (*GrepResponse) GetNamespaceID

func (g *GrepResponse) GetNamespaceID() NamespaceID

func (*GrepResponse) GetNextCursor

func (g *GrepResponse) GetNextCursor() *string

func (*GrepResponse) GetTailScanned

func (g *GrepResponse) GetTailScanned() bool

func (*GrepResponse) MarshalJSON

func (g *GrepResponse) MarshalJSON() ([]byte, error)

func (*GrepResponse) SetBuiltThroughSeq

func (g *GrepResponse) SetBuiltThroughSeq(builtThroughSeq ChangeSeq)

SetBuiltThroughSeq sets the BuiltThroughSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepResponse) SetHeadSeq

func (g *GrepResponse) SetHeadSeq(headSeq ChangeSeq)

SetHeadSeq sets the HeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepResponse) SetMatches

func (g *GrepResponse) SetMatches(matches []*GrepMatch)

SetMatches sets the Matches field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepResponse) SetNamespaceID

func (g *GrepResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepResponse) SetNextCursor

func (g *GrepResponse) SetNextCursor(nextCursor *string)

SetNextCursor sets the NextCursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepResponse) SetTailScanned

func (g *GrepResponse) SetTailScanned(tailScanned bool)

SetTailScanned sets the TailScanned field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*GrepResponse) String

func (g *GrepResponse) String() string

func (*GrepResponse) UnmarshalJSON

func (g *GrepResponse) UnmarshalJSON(data []byte) error

type InodeKind

type InodeKind string

Filesystem item kind.

const (
	InodeKindFile InodeKind = "file"
	InodeKindDir  InodeKind = "dir"
)

func NewInodeKindFromString

func NewInodeKindFromString(s string) (InodeKind, error)

func (InodeKind) Ptr

func (i InodeKind) Ptr() *InodeKind

type InternalServerError

type InternalServerError struct {
	*core.APIError
	Body *APIError
}

The grep index is corrupt or its backing store is unavailable

func (*InternalServerError) MarshalJSON

func (i *InternalServerError) MarshalJSON() ([]byte, error)

func (*InternalServerError) UnmarshalJSON

func (i *InternalServerError) UnmarshalJSON(data []byte) error

func (*InternalServerError) Unwrap

func (i *InternalServerError) Unwrap() error

type ListChangesRequest

type ListChangesRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Return committed changes after this sequence
	AfterSeq ChangeSeq `json:"-" url:"after_seq"`
	// Maximum page size
	Limit *int `json:"-" url:"limit,omitempty"`
	// End the feed at this snapshot's captured sequence
	SnapshotID *CheckpointID `json:"-" url:"snapshot_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListChangesRequest) SetAfterSeq

func (l *ListChangesRequest) SetAfterSeq(afterSeq ChangeSeq)

SetAfterSeq sets the AfterSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListChangesRequest) SetLimit

func (l *ListChangesRequest) SetLimit(limit *int)

SetLimit sets the Limit field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListChangesRequest) SetNamespaceID

func (l *ListChangesRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListChangesRequest) SetSnapshotID

func (l *ListChangesRequest) SetSnapshotID(snapshotID *CheckpointID)

SetSnapshotID sets the SnapshotID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type ListChangesResponse

type ListChangesResponse struct {
	// Exclusive cursor supplied by the caller, or the endpoint's initial position.
	AfterSeq ChangeSeq `json:"after_seq" url:"after_seq"`
	// Logical commits after `after_seq`, ordered by ascending namespace sequence.
	Changes []*CommittedChange `json:"changes" url:"changes"`
	// Namespace whose ordered commit stream was read.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Cursor to request when another page remains, or `None` at `through_seq`.
	NextAfterSeq *ChangeSeq `json:"next_after_seq,omitempty" url:"next_after_seq,omitempty"`
	// Snapshot head through which this page was evaluated.
	ThroughSeq ChangeSeq `json:"through_seq" url:"through_seq"`
	// contains filtered or unexported fields
}

func (*ListChangesResponse) GetAfterSeq

func (l *ListChangesResponse) GetAfterSeq() ChangeSeq

func (*ListChangesResponse) GetChanges

func (l *ListChangesResponse) GetChanges() []*CommittedChange

func (*ListChangesResponse) GetExtraProperties

func (l *ListChangesResponse) GetExtraProperties() map[string]interface{}

func (*ListChangesResponse) GetNamespaceID

func (l *ListChangesResponse) GetNamespaceID() NamespaceID

func (*ListChangesResponse) GetNextAfterSeq

func (l *ListChangesResponse) GetNextAfterSeq() *ChangeSeq

func (*ListChangesResponse) GetThroughSeq

func (l *ListChangesResponse) GetThroughSeq() ChangeSeq

func (*ListChangesResponse) MarshalJSON

func (l *ListChangesResponse) MarshalJSON() ([]byte, error)

func (*ListChangesResponse) SetAfterSeq

func (l *ListChangesResponse) SetAfterSeq(afterSeq ChangeSeq)

SetAfterSeq sets the AfterSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListChangesResponse) SetChanges

func (l *ListChangesResponse) SetChanges(changes []*CommittedChange)

SetChanges sets the Changes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListChangesResponse) SetNamespaceID

func (l *ListChangesResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListChangesResponse) SetNextAfterSeq

func (l *ListChangesResponse) SetNextAfterSeq(nextAfterSeq *ChangeSeq)

SetNextAfterSeq sets the NextAfterSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListChangesResponse) SetThroughSeq

func (l *ListChangesResponse) SetThroughSeq(throughSeq ChangeSeq)

SetThroughSeq sets the ThroughSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListChangesResponse) String

func (l *ListChangesResponse) String() string

func (*ListChangesResponse) UnmarshalJSON

func (l *ListChangesResponse) UnmarshalJSON(data []byte) error

type ListCheckpointsRequest

type ListCheckpointsRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Maximum page size
	Limit *int `json:"-" url:"limit,omitempty"`
	// Opaque checkpoint-list page cursor
	Cursor *string `json:"-" url:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCheckpointsRequest) SetCursor

func (l *ListCheckpointsRequest) SetCursor(cursor *string)

SetCursor sets the Cursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListCheckpointsRequest) SetLimit

func (l *ListCheckpointsRequest) SetLimit(limit *int)

SetLimit sets the Limit field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListCheckpointsRequest) SetNamespaceID

func (l *ListCheckpointsRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type ListCheckpointsResponse

type ListCheckpointsResponse struct {
	// Active records in ascending checkpoint-id order. Released records are
	// omitted even if garbage collection has not deleted them yet.
	Checkpoints []*Checkpoint `json:"checkpoints" url:"checkpoints"`
	// Namespace the records belong to.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Opaque cursor for the next page.
	NextCursor *string `json:"next_cursor,omitempty" url:"next_cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCheckpointsResponse) GetCheckpoints

func (l *ListCheckpointsResponse) GetCheckpoints() []*Checkpoint

func (*ListCheckpointsResponse) GetExtraProperties

func (l *ListCheckpointsResponse) GetExtraProperties() map[string]interface{}

func (*ListCheckpointsResponse) GetNamespaceID

func (l *ListCheckpointsResponse) GetNamespaceID() NamespaceID

func (*ListCheckpointsResponse) GetNextCursor

func (l *ListCheckpointsResponse) GetNextCursor() *string

func (*ListCheckpointsResponse) MarshalJSON

func (l *ListCheckpointsResponse) MarshalJSON() ([]byte, error)

func (*ListCheckpointsResponse) SetCheckpoints

func (l *ListCheckpointsResponse) SetCheckpoints(checkpoints []*Checkpoint)

SetCheckpoints sets the Checkpoints field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListCheckpointsResponse) SetNamespaceID

func (l *ListCheckpointsResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListCheckpointsResponse) SetNextCursor

func (l *ListCheckpointsResponse) SetNextCursor(nextCursor *string)

SetNextCursor sets the NextCursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListCheckpointsResponse) String

func (l *ListCheckpointsResponse) String() string

func (*ListCheckpointsResponse) UnmarshalJSON

func (l *ListCheckpointsResponse) UnmarshalJSON(data []byte) error

type ListFileRevisionsByInodeRequest

type ListFileRevisionsByInodeRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// File inode ID
	InodeID string `json:"-" url:"-"`
	// Maximum page size
	Limit *int `json:"-" url:"limit,omitempty"`
	// Opaque file-revisions page cursor
	Cursor *string `json:"-" url:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFileRevisionsByInodeRequest) SetCursor

func (l *ListFileRevisionsByInodeRequest) SetCursor(cursor *string)

SetCursor sets the Cursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListFileRevisionsByInodeRequest) SetInodeID

func (l *ListFileRevisionsByInodeRequest) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListFileRevisionsByInodeRequest) SetLimit

func (l *ListFileRevisionsByInodeRequest) SetLimit(limit *int)

SetLimit sets the Limit field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListFileRevisionsByInodeRequest) SetNamespaceID

func (l *ListFileRevisionsByInodeRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type ListFileRevisionsRequest

type ListFileRevisionsRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Absolute file path
	Path string `json:"-" url:"path"`
	// Maximum page size
	Limit *int `json:"-" url:"limit,omitempty"`
	// Opaque file-revisions page cursor
	Cursor *string `json:"-" url:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFileRevisionsRequest) SetCursor

func (l *ListFileRevisionsRequest) SetCursor(cursor *string)

SetCursor sets the Cursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListFileRevisionsRequest) SetLimit

func (l *ListFileRevisionsRequest) SetLimit(limit *int)

SetLimit sets the Limit field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListFileRevisionsRequest) SetNamespaceID

func (l *ListFileRevisionsRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListFileRevisionsRequest) SetPath

func (l *ListFileRevisionsRequest) SetPath(path string)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type ListFileRevisionsResponse

type ListFileRevisionsResponse struct {
	// Namespace head sequence used for the read.
	HeadSeq ChangeSeq `json:"head_seq" url:"head_seq"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// Namespace that was read.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Opaque cursor for the next page, if more revisions are available.
	NextCursor *string `json:"next_cursor,omitempty" url:"next_cursor,omitempty"`
	// Retained revisions in order.
	Revisions []*FileRevision `json:"revisions" url:"revisions"`
	// contains filtered or unexported fields
}

func (*ListFileRevisionsResponse) GetExtraProperties

func (l *ListFileRevisionsResponse) GetExtraProperties() map[string]interface{}

func (*ListFileRevisionsResponse) GetHeadSeq

func (l *ListFileRevisionsResponse) GetHeadSeq() ChangeSeq

func (*ListFileRevisionsResponse) GetInodeID

func (l *ListFileRevisionsResponse) GetInodeID() string

func (*ListFileRevisionsResponse) GetNamespaceID

func (l *ListFileRevisionsResponse) GetNamespaceID() NamespaceID

func (*ListFileRevisionsResponse) GetNextCursor

func (l *ListFileRevisionsResponse) GetNextCursor() *string

func (*ListFileRevisionsResponse) GetRevisions

func (l *ListFileRevisionsResponse) GetRevisions() []*FileRevision

func (*ListFileRevisionsResponse) MarshalJSON

func (l *ListFileRevisionsResponse) MarshalJSON() ([]byte, error)

func (*ListFileRevisionsResponse) SetHeadSeq

func (l *ListFileRevisionsResponse) SetHeadSeq(headSeq ChangeSeq)

SetHeadSeq sets the HeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListFileRevisionsResponse) SetInodeID

func (l *ListFileRevisionsResponse) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListFileRevisionsResponse) SetNamespaceID

func (l *ListFileRevisionsResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListFileRevisionsResponse) SetNextCursor

func (l *ListFileRevisionsResponse) SetNextCursor(nextCursor *string)

SetNextCursor sets the NextCursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListFileRevisionsResponse) SetRevisions

func (l *ListFileRevisionsResponse) SetRevisions(revisions []*FileRevision)

SetRevisions sets the Revisions field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListFileRevisionsResponse) String

func (l *ListFileRevisionsResponse) String() string

func (*ListFileRevisionsResponse) UnmarshalJSON

func (l *ListFileRevisionsResponse) UnmarshalJSON(data []byte) error

type ListInodeChildrenRequest

type ListInodeChildrenRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Directory inode ID
	InodeID string `json:"-" url:"-"`
	// Maximum page size
	Limit *int `json:"-" url:"limit,omitempty"`
	// Opaque directory page cursor
	Cursor *string `json:"-" url:"cursor,omitempty"`
	// Project each entry's attribute map and revision (`true` or `false`). Defaults to `false`: a page holds many entries and each map may be 64 KiB, so a listing does not carry them unless asked.
	IncludeAttributes *bool `json:"-" url:"include_attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListInodeChildrenRequest) SetCursor

func (l *ListInodeChildrenRequest) SetCursor(cursor *string)

SetCursor sets the Cursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListInodeChildrenRequest) SetIncludeAttributes

func (l *ListInodeChildrenRequest) SetIncludeAttributes(includeAttributes *bool)

SetIncludeAttributes sets the IncludeAttributes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListInodeChildrenRequest) SetInodeID

func (l *ListInodeChildrenRequest) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListInodeChildrenRequest) SetLimit

func (l *ListInodeChildrenRequest) SetLimit(limit *int)

SetLimit sets the Limit field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListInodeChildrenRequest) SetNamespaceID

func (l *ListInodeChildrenRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type ListInodeChildrenResponse

type ListInodeChildrenResponse struct {
	// Directory entries for this page.
	//
	// Entries are returned in canonical name-key order. Higher-level display
	// surfaces may sort entries separately for presentation.
	Entries []*PathEntry `json:"entries" url:"entries"`
	// Namespace head sequence this listing was read from.
	HeadSeq ChangeSeq `json:"head_seq" url:"head_seq"`
	// Namespace that was read.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Cursor for the next page, if more entries remain.
	NextCursor *string `json:"next_cursor,omitempty" url:"next_cursor,omitempty"`
	// Stable inode ID within a namespace
	ParentInodeID string `json:"parent_inode_id" url:"parent_inode_id"`
	// contains filtered or unexported fields
}

func (*ListInodeChildrenResponse) GetEntries

func (l *ListInodeChildrenResponse) GetEntries() []*PathEntry

func (*ListInodeChildrenResponse) GetExtraProperties

func (l *ListInodeChildrenResponse) GetExtraProperties() map[string]interface{}

func (*ListInodeChildrenResponse) GetHeadSeq

func (l *ListInodeChildrenResponse) GetHeadSeq() ChangeSeq

func (*ListInodeChildrenResponse) GetNamespaceID

func (l *ListInodeChildrenResponse) GetNamespaceID() NamespaceID

func (*ListInodeChildrenResponse) GetNextCursor

func (l *ListInodeChildrenResponse) GetNextCursor() *string

func (*ListInodeChildrenResponse) GetParentInodeID

func (l *ListInodeChildrenResponse) GetParentInodeID() string

func (*ListInodeChildrenResponse) MarshalJSON

func (l *ListInodeChildrenResponse) MarshalJSON() ([]byte, error)

func (*ListInodeChildrenResponse) SetEntries

func (l *ListInodeChildrenResponse) SetEntries(entries []*PathEntry)

SetEntries sets the Entries field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListInodeChildrenResponse) SetHeadSeq

func (l *ListInodeChildrenResponse) SetHeadSeq(headSeq ChangeSeq)

SetHeadSeq sets the HeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListInodeChildrenResponse) SetNamespaceID

func (l *ListInodeChildrenResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListInodeChildrenResponse) SetNextCursor

func (l *ListInodeChildrenResponse) SetNextCursor(nextCursor *string)

SetNextCursor sets the NextCursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListInodeChildrenResponse) SetParentInodeID

func (l *ListInodeChildrenResponse) SetParentInodeID(parentInodeID string)

SetParentInodeID sets the ParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListInodeChildrenResponse) String

func (l *ListInodeChildrenResponse) String() string

func (*ListInodeChildrenResponse) UnmarshalJSON

func (l *ListInodeChildrenResponse) UnmarshalJSON(data []byte) error

type ListPathEntriesRequest

type ListPathEntriesRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Absolute filesystem path
	Path string `json:"-" url:"path"`
	// Maximum page size
	Limit *int `json:"-" url:"limit,omitempty"`
	// Opaque directory-list page cursor
	Cursor *string `json:"-" url:"cursor,omitempty"`
	// Project each entry's attribute map and revision (`true` or `false`). Defaults to `false`: a page holds many entries and each map may be 64 KiB, so a listing does not carry them unless asked.
	IncludeAttributes *bool `json:"-" url:"include_attributes,omitempty"`
	// Use the directory state captured by this snapshot
	SnapshotID *CheckpointID `json:"-" url:"snapshot_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPathEntriesRequest) SetCursor

func (l *ListPathEntriesRequest) SetCursor(cursor *string)

SetCursor sets the Cursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListPathEntriesRequest) SetIncludeAttributes

func (l *ListPathEntriesRequest) SetIncludeAttributes(includeAttributes *bool)

SetIncludeAttributes sets the IncludeAttributes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListPathEntriesRequest) SetLimit

func (l *ListPathEntriesRequest) SetLimit(limit *int)

SetLimit sets the Limit field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListPathEntriesRequest) SetNamespaceID

func (l *ListPathEntriesRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListPathEntriesRequest) SetPath

func (l *ListPathEntriesRequest) SetPath(path string)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListPathEntriesRequest) SetSnapshotID

func (l *ListPathEntriesRequest) SetSnapshotID(snapshotID *CheckpointID)

SetSnapshotID sets the SnapshotID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type ListPathEntriesResponse

type ListPathEntriesResponse struct {
	// Directory entries for this page.
	//
	// Entries are returned in canonical name-key order. Higher-level display
	// surfaces may sort entries separately for presentation.
	Entries []*PathEntry `json:"entries" url:"entries"`
	// Namespace head sequence this listing was read from.
	HeadSeq ChangeSeq `json:"head_seq" url:"head_seq"`
	// Namespace that was read.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Cursor for the next page, if more entries remain.
	NextCursor *string `json:"next_cursor,omitempty" url:"next_cursor,omitempty"`
	// Absolute path of the listed directory.
	Path AbsolutePath `json:"path" url:"path"`
	// contains filtered or unexported fields
}

func (*ListPathEntriesResponse) GetEntries

func (l *ListPathEntriesResponse) GetEntries() []*PathEntry

func (*ListPathEntriesResponse) GetExtraProperties

func (l *ListPathEntriesResponse) GetExtraProperties() map[string]interface{}

func (*ListPathEntriesResponse) GetHeadSeq

func (l *ListPathEntriesResponse) GetHeadSeq() ChangeSeq

func (*ListPathEntriesResponse) GetNamespaceID

func (l *ListPathEntriesResponse) GetNamespaceID() NamespaceID

func (*ListPathEntriesResponse) GetNextCursor

func (l *ListPathEntriesResponse) GetNextCursor() *string

func (*ListPathEntriesResponse) GetPath

func (*ListPathEntriesResponse) MarshalJSON

func (l *ListPathEntriesResponse) MarshalJSON() ([]byte, error)

func (*ListPathEntriesResponse) SetEntries

func (l *ListPathEntriesResponse) SetEntries(entries []*PathEntry)

SetEntries sets the Entries field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListPathEntriesResponse) SetHeadSeq

func (l *ListPathEntriesResponse) SetHeadSeq(headSeq ChangeSeq)

SetHeadSeq sets the HeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListPathEntriesResponse) SetNamespaceID

func (l *ListPathEntriesResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListPathEntriesResponse) SetNextCursor

func (l *ListPathEntriesResponse) SetNextCursor(nextCursor *string)

SetNextCursor sets the NextCursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListPathEntriesResponse) SetPath

func (l *ListPathEntriesResponse) SetPath(path AbsolutePath)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListPathEntriesResponse) String

func (l *ListPathEntriesResponse) String() string

func (*ListPathEntriesResponse) UnmarshalJSON

func (l *ListPathEntriesResponse) UnmarshalJSON(data []byte) error

type ListSnapshotsRequest

type ListSnapshotsRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Maximum page size
	Limit *int `json:"-" url:"limit,omitempty"`
	// Opaque snapshot-list page cursor
	Cursor *string `json:"-" url:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSnapshotsRequest) SetCursor

func (l *ListSnapshotsRequest) SetCursor(cursor *string)

SetCursor sets the Cursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListSnapshotsRequest) SetLimit

func (l *ListSnapshotsRequest) SetLimit(limit *int)

SetLimit sets the Limit field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListSnapshotsRequest) SetNamespaceID

func (l *ListSnapshotsRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type ListSnapshotsResponse

type ListSnapshotsResponse struct {
	// Namespace the snapshots belong to.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Opaque cursor for the next page.
	NextCursor *string `json:"next_cursor,omitempty" url:"next_cursor,omitempty"`
	// Live snapshot records in ascending snapshot-id order.
	Snapshots []*SnapshotSummary `json:"snapshots" url:"snapshots"`
	// contains filtered or unexported fields
}

func (*ListSnapshotsResponse) GetExtraProperties

func (l *ListSnapshotsResponse) GetExtraProperties() map[string]interface{}

func (*ListSnapshotsResponse) GetNamespaceID

func (l *ListSnapshotsResponse) GetNamespaceID() NamespaceID

func (*ListSnapshotsResponse) GetNextCursor

func (l *ListSnapshotsResponse) GetNextCursor() *string

func (*ListSnapshotsResponse) GetSnapshots

func (l *ListSnapshotsResponse) GetSnapshots() []*SnapshotSummary

func (*ListSnapshotsResponse) MarshalJSON

func (l *ListSnapshotsResponse) MarshalJSON() ([]byte, error)

func (*ListSnapshotsResponse) SetNamespaceID

func (l *ListSnapshotsResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListSnapshotsResponse) SetNextCursor

func (l *ListSnapshotsResponse) SetNextCursor(nextCursor *string)

SetNextCursor sets the NextCursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListSnapshotsResponse) SetSnapshots

func (l *ListSnapshotsResponse) SetSnapshots(snapshots []*SnapshotSummary)

SetSnapshots sets the Snapshots field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListSnapshotsResponse) String

func (l *ListSnapshotsResponse) String() string

func (*ListSnapshotsResponse) UnmarshalJSON

func (l *ListSnapshotsResponse) UnmarshalJSON(data []byte) error

type ListTrashRequest

type ListTrashRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Maximum page size
	Limit *int `json:"-" url:"limit,omitempty"`
	// Opaque trash page cursor
	Cursor *string `json:"-" url:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTrashRequest) SetCursor

func (l *ListTrashRequest) SetCursor(cursor *string)

SetCursor sets the Cursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListTrashRequest) SetLimit

func (l *ListTrashRequest) SetLimit(limit *int)

SetLimit sets the Limit field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListTrashRequest) SetNamespaceID

func (l *ListTrashRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type ListTrashResponse

type ListTrashResponse struct {
	// Recoverable deletions, oldest deletion first.
	Entries []*TrashEntry `json:"entries" url:"entries"`
	// Head sequence this page was evaluated at.
	HeadSeq ChangeSeq `json:"head_seq" url:"head_seq"`
	// Namespace that was read.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Present when another page follows.
	NextCursor *string `json:"next_cursor,omitempty" url:"next_cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTrashResponse) GetEntries

func (l *ListTrashResponse) GetEntries() []*TrashEntry

func (*ListTrashResponse) GetExtraProperties

func (l *ListTrashResponse) GetExtraProperties() map[string]interface{}

func (*ListTrashResponse) GetHeadSeq

func (l *ListTrashResponse) GetHeadSeq() ChangeSeq

func (*ListTrashResponse) GetNamespaceID

func (l *ListTrashResponse) GetNamespaceID() NamespaceID

func (*ListTrashResponse) GetNextCursor

func (l *ListTrashResponse) GetNextCursor() *string

func (*ListTrashResponse) MarshalJSON

func (l *ListTrashResponse) MarshalJSON() ([]byte, error)

func (*ListTrashResponse) SetEntries

func (l *ListTrashResponse) SetEntries(entries []*TrashEntry)

SetEntries sets the Entries field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListTrashResponse) SetHeadSeq

func (l *ListTrashResponse) SetHeadSeq(headSeq ChangeSeq)

SetHeadSeq sets the HeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListTrashResponse) SetNamespaceID

func (l *ListTrashResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListTrashResponse) SetNextCursor

func (l *ListTrashResponse) SetNextCursor(nextCursor *string)

SetNextCursor sets the NextCursor field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ListTrashResponse) String

func (l *ListTrashResponse) String() string

func (*ListTrashResponse) UnmarshalJSON

func (l *ListTrashResponse) UnmarshalJSON(data []byte) error

type MaintenanceStepRequest

type MaintenanceStepRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Run one bounded mark-and-sweep garbage-collection pass. Omit this
	// field to skip garbage collection.
	Gc *GcRequest `json:"gc,omitempty" url:"-"`
	// Flush the visible WAL tail into metadata segments, then run one bounded
	// reorganization step.
	MetadataMaintenance *MetadataMaintenanceRequest `json:"metadata_maintenance,omitempty" url:"-"`
	// Advance the retention floor to the flushed manifest head. Include this
	// field to select the action.
	Retention *AdvanceRetentionRequest `json:"retention,omitempty" url:"-"`
	// contains filtered or unexported fields
}

func (*MaintenanceStepRequest) MarshalJSON

func (m *MaintenanceStepRequest) MarshalJSON() ([]byte, error)

func (*MaintenanceStepRequest) SetGc

func (m *MaintenanceStepRequest) SetGc(gc *GcRequest)

SetGc sets the Gc field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MaintenanceStepRequest) SetMetadataMaintenance

func (m *MaintenanceStepRequest) SetMetadataMaintenance(metadataMaintenance *MetadataMaintenanceRequest)

SetMetadataMaintenance sets the MetadataMaintenance field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MaintenanceStepRequest) SetNamespaceID

func (m *MaintenanceStepRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MaintenanceStepRequest) SetRetention

func (m *MaintenanceStepRequest) SetRetention(retention *AdvanceRetentionRequest)

SetRetention sets the Retention field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MaintenanceStepRequest) UnmarshalJSON

func (m *MaintenanceStepRequest) UnmarshalJSON(data []byte) error

type MaintenanceStepResponse

type MaintenanceStepResponse struct {
	// What the collection pass reclaimed.
	Gc *GcResponse `json:"gc,omitempty" url:"gc,omitempty"`
	// What the metadata-upkeep action did.
	MetadataMaintenance *MetadataMaintenanceResponse `json:"metadata_maintenance,omitempty" url:"metadata_maintenance,omitempty"`
	// Namespace the step ran against.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Where the retention floor ended up.
	Retention *AdvanceRetentionResponse `json:"retention,omitempty" url:"retention,omitempty"`
	// Namespace diagnostics observed before the step acted.
	StatusBefore *NamespaceDiagnostics `json:"status_before" url:"status_before"`
	// contains filtered or unexported fields
}

func (*MaintenanceStepResponse) GetExtraProperties

func (m *MaintenanceStepResponse) GetExtraProperties() map[string]interface{}

func (*MaintenanceStepResponse) GetGc

func (m *MaintenanceStepResponse) GetGc() *GcResponse

func (*MaintenanceStepResponse) GetMetadataMaintenance

func (m *MaintenanceStepResponse) GetMetadataMaintenance() *MetadataMaintenanceResponse

func (*MaintenanceStepResponse) GetNamespaceID

func (m *MaintenanceStepResponse) GetNamespaceID() NamespaceID

func (*MaintenanceStepResponse) GetRetention

func (*MaintenanceStepResponse) GetStatusBefore

func (m *MaintenanceStepResponse) GetStatusBefore() *NamespaceDiagnostics

func (*MaintenanceStepResponse) MarshalJSON

func (m *MaintenanceStepResponse) MarshalJSON() ([]byte, error)

func (*MaintenanceStepResponse) SetGc

func (m *MaintenanceStepResponse) SetGc(gc *GcResponse)

SetGc sets the Gc field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MaintenanceStepResponse) SetMetadataMaintenance

func (m *MaintenanceStepResponse) SetMetadataMaintenance(metadataMaintenance *MetadataMaintenanceResponse)

SetMetadataMaintenance sets the MetadataMaintenance field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MaintenanceStepResponse) SetNamespaceID

func (m *MaintenanceStepResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MaintenanceStepResponse) SetRetention

func (m *MaintenanceStepResponse) SetRetention(retention *AdvanceRetentionResponse)

SetRetention sets the Retention field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MaintenanceStepResponse) SetStatusBefore

func (m *MaintenanceStepResponse) SetStatusBefore(statusBefore *NamespaceDiagnostics)

SetStatusBefore sets the StatusBefore field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MaintenanceStepResponse) String

func (m *MaintenanceStepResponse) String() string

func (*MaintenanceStepResponse) UnmarshalJSON

func (m *MaintenanceStepResponse) UnmarshalJSON(data []byte) error

type ManifestNo

type ManifestNo = int64

Monotonic manifest counter for one namespace. It can increase when metadata changes, even if no namespace commit is written.

type MetadataMaintenanceRequest

type MetadataMaintenanceRequest struct {
	// Flush the visible WAL tail once it reaches this many segments.
	// Absent uses the server's default threshold; zero, and any value above
	// the write-rejection threshold, are rejected as `invalid_request`.
	MaxWalTailSegments *int64 `json:"max_wal_tail_segments,omitempty" url:"max_wal_tail_segments,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataMaintenanceRequest) GetExtraProperties

func (m *MetadataMaintenanceRequest) GetExtraProperties() map[string]interface{}

func (*MetadataMaintenanceRequest) GetMaxWalTailSegments

func (m *MetadataMaintenanceRequest) GetMaxWalTailSegments() *int64

func (*MetadataMaintenanceRequest) MarshalJSON

func (m *MetadataMaintenanceRequest) MarshalJSON() ([]byte, error)

func (*MetadataMaintenanceRequest) SetMaxWalTailSegments

func (m *MetadataMaintenanceRequest) SetMaxWalTailSegments(maxWalTailSegments *int64)

SetMaxWalTailSegments sets the MaxWalTailSegments field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MetadataMaintenanceRequest) String

func (m *MetadataMaintenanceRequest) String() string

func (*MetadataMaintenanceRequest) UnmarshalJSON

func (m *MetadataMaintenanceRequest) UnmarshalJSON(data []byte) error

type MetadataMaintenanceResponse

type MetadataMaintenanceResponse struct {
	// What the reorganization unit did.
	Reorganize *ReorganizeStepOutcome `json:"reorganize" url:"reorganize"`
	// What the WAL flush did.
	WalFlush *WalFlushStepOutcome `json:"wal_flush" url:"wal_flush"`
	// contains filtered or unexported fields
}

func (*MetadataMaintenanceResponse) GetExtraProperties

func (m *MetadataMaintenanceResponse) GetExtraProperties() map[string]interface{}

func (*MetadataMaintenanceResponse) GetReorganize

func (*MetadataMaintenanceResponse) GetWalFlush

func (*MetadataMaintenanceResponse) MarshalJSON

func (m *MetadataMaintenanceResponse) MarshalJSON() ([]byte, error)

func (*MetadataMaintenanceResponse) SetReorganize

func (m *MetadataMaintenanceResponse) SetReorganize(reorganize *ReorganizeStepOutcome)

SetReorganize sets the Reorganize field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MetadataMaintenanceResponse) SetWalFlush

func (m *MetadataMaintenanceResponse) SetWalFlush(walFlush *WalFlushStepOutcome)

SetWalFlush sets the WalFlush field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*MetadataMaintenanceResponse) String

func (m *MetadataMaintenanceResponse) String() string

func (*MetadataMaintenanceResponse) UnmarshalJSON

func (m *MetadataMaintenanceResponse) UnmarshalJSON(data []byte) error

type NameKey

type NameKey = string

Name-policy-derived directory entry key.

Use this for exact name preconditions. Keep user-facing spelling in `DisplayName`.

type Namespace

type Namespace struct {
	// Current visible namespace sequence.
	HeadSeq ChangeSeq `json:"head_seq" url:"head_seq"`
	// Namespace ID.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Oldest sequence still promised for incremental replay.
	RetentionFloorSeq ChangeSeq `json:"retention_floor_seq" url:"retention_floor_seq"`
	// contains filtered or unexported fields
}

func (*Namespace) GetExtraProperties

func (n *Namespace) GetExtraProperties() map[string]interface{}

func (*Namespace) GetHeadSeq

func (n *Namespace) GetHeadSeq() ChangeSeq

func (*Namespace) GetNamespaceID

func (n *Namespace) GetNamespaceID() NamespaceID

func (*Namespace) GetRetentionFloorSeq

func (n *Namespace) GetRetentionFloorSeq() ChangeSeq

func (*Namespace) MarshalJSON

func (n *Namespace) MarshalJSON() ([]byte, error)

func (*Namespace) SetHeadSeq

func (n *Namespace) SetHeadSeq(headSeq ChangeSeq)

SetHeadSeq sets the HeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Namespace) SetNamespaceID

func (n *Namespace) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Namespace) SetRetentionFloorSeq

func (n *Namespace) SetRetentionFloorSeq(retentionFloorSeq ChangeSeq)

SetRetentionFloorSeq sets the RetentionFloorSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*Namespace) String

func (n *Namespace) String() string

func (*Namespace) UnmarshalJSON

func (n *Namespace) UnmarshalJSON(data []byte) error

type NamespaceDiagnostics

type NamespaceDiagnostics struct {
	// Current manifest pointer recorded by the head.
	CurrentManifestNo *ManifestNo `json:"current_manifest_no,omitempty" url:"current_manifest_no,omitempty"`
	// Current visible namespace sequence.
	HeadSeq ChangeSeq `json:"head_seq" url:"head_seq"`
	// Number of active user checkpoints, including expired records awaiting collection.
	LiveCheckpoints int64 `json:"live_checkpoints" url:"live_checkpoints"`
	// Number of snapshots that had not expired when diagnostics began.
	LiveSnapshots int64 `json:"live_snapshots" url:"live_snapshots"`
	// Namespace ID.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Oldest sequence still promised for incremental replay.
	RetentionFloorSeq ChangeSeq `json:"retention_floor_seq" url:"retention_floor_seq"`
	// Number of visible WAL segments after the current manifest.
	WalTailSegments int64 `json:"wal_tail_segments" url:"wal_tail_segments"`
	// contains filtered or unexported fields
}

func (*NamespaceDiagnostics) GetCurrentManifestNo

func (n *NamespaceDiagnostics) GetCurrentManifestNo() *ManifestNo

func (*NamespaceDiagnostics) GetExtraProperties

func (n *NamespaceDiagnostics) GetExtraProperties() map[string]interface{}

func (*NamespaceDiagnostics) GetHeadSeq

func (n *NamespaceDiagnostics) GetHeadSeq() ChangeSeq

func (*NamespaceDiagnostics) GetLiveCheckpoints

func (n *NamespaceDiagnostics) GetLiveCheckpoints() int64

func (*NamespaceDiagnostics) GetLiveSnapshots

func (n *NamespaceDiagnostics) GetLiveSnapshots() int64

func (*NamespaceDiagnostics) GetNamespaceID

func (n *NamespaceDiagnostics) GetNamespaceID() NamespaceID

func (*NamespaceDiagnostics) GetRetentionFloorSeq

func (n *NamespaceDiagnostics) GetRetentionFloorSeq() ChangeSeq

func (*NamespaceDiagnostics) GetWalTailSegments

func (n *NamespaceDiagnostics) GetWalTailSegments() int64

func (*NamespaceDiagnostics) MarshalJSON

func (n *NamespaceDiagnostics) MarshalJSON() ([]byte, error)

func (*NamespaceDiagnostics) SetCurrentManifestNo

func (n *NamespaceDiagnostics) SetCurrentManifestNo(currentManifestNo *ManifestNo)

SetCurrentManifestNo sets the CurrentManifestNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*NamespaceDiagnostics) SetHeadSeq

func (n *NamespaceDiagnostics) SetHeadSeq(headSeq ChangeSeq)

SetHeadSeq sets the HeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*NamespaceDiagnostics) SetLiveCheckpoints

func (n *NamespaceDiagnostics) SetLiveCheckpoints(liveCheckpoints int64)

SetLiveCheckpoints sets the LiveCheckpoints field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*NamespaceDiagnostics) SetLiveSnapshots

func (n *NamespaceDiagnostics) SetLiveSnapshots(liveSnapshots int64)

SetLiveSnapshots sets the LiveSnapshots field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*NamespaceDiagnostics) SetNamespaceID

func (n *NamespaceDiagnostics) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*NamespaceDiagnostics) SetRetentionFloorSeq

func (n *NamespaceDiagnostics) SetRetentionFloorSeq(retentionFloorSeq ChangeSeq)

SetRetentionFloorSeq sets the RetentionFloorSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*NamespaceDiagnostics) SetWalTailSegments

func (n *NamespaceDiagnostics) SetWalTailSegments(walTailSegments int64)

SetWalTailSegments sets the WalTailSegments field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*NamespaceDiagnostics) String

func (n *NamespaceDiagnostics) String() string

func (*NamespaceDiagnostics) UnmarshalJSON

func (n *NamespaceDiagnostics) UnmarshalJSON(data []byte) error

type NamespaceID

type NamespaceID = string

Durable id for one namespace.

A namespace is one filesystem history. This id is not a display name and should not be reused after destruction. Its serialized form is 1 to 128 lowercase ASCII letters, digits, dots, underscores, or hyphens, starting with a letter or digit; the `loonfs-` prefix is reserved for system use.

type NotFoundError

type NotFoundError struct {
	*core.APIError
	Body *APIError
}

Namespace not found

func (*NotFoundError) MarshalJSON

func (n *NotFoundError) MarshalJSON() ([]byte, error)

func (*NotFoundError) UnmarshalJSON

func (n *NotFoundError) UnmarshalJSON(data []byte) error

func (*NotFoundError) Unwrap

func (n *NotFoundError) Unwrap() error

type NotImplementedError

type NotImplementedError struct {
	*core.APIError
	Body *APIError
}

This deployment does not maintain the grep index

func (*NotImplementedError) MarshalJSON

func (n *NotImplementedError) MarshalJSON() ([]byte, error)

func (*NotImplementedError) UnmarshalJSON

func (n *NotImplementedError) UnmarshalJSON(data []byte) error

func (*NotImplementedError) Unwrap

func (n *NotImplementedError) Unwrap() error

type ObjectTransferAccess

type ObjectTransferAccess struct {
	Kind         string
	PresignedURL *ObjectTransferAccessPresignedURL
	// contains filtered or unexported fields
}

Client-facing direct transfer capability.

func (*ObjectTransferAccess) Accept

func (*ObjectTransferAccess) GetKind

func (o *ObjectTransferAccess) GetKind() string

func (*ObjectTransferAccess) GetPresignedURL

func (ObjectTransferAccess) MarshalJSON

func (o ObjectTransferAccess) MarshalJSON() ([]byte, error)

func (*ObjectTransferAccess) UnmarshalJSON

func (o *ObjectTransferAccess) UnmarshalJSON(data []byte) error

type ObjectTransferAccessPresignedURL

type ObjectTransferAccessPresignedURL struct {
	// Expiration timestamp in Unix milliseconds.
	ExpiresAtMs int64 `json:"expires_at_ms" url:"expires_at_ms"`
	// Headers that are covered by the signature and must be sent.
	Headers map[string]string `json:"headers,omitempty" url:"headers,omitempty"`
	// HTTP method the client must use.
	Method string `json:"method" url:"method"`
	// Full presigned URL.
	URL string `json:"url" url:"url"`
	// contains filtered or unexported fields
}

func (*ObjectTransferAccessPresignedURL) GetExpiresAtMs

func (o *ObjectTransferAccessPresignedURL) GetExpiresAtMs() int64

func (*ObjectTransferAccessPresignedURL) GetExtraProperties

func (o *ObjectTransferAccessPresignedURL) GetExtraProperties() map[string]interface{}

func (*ObjectTransferAccessPresignedURL) GetHeaders

func (o *ObjectTransferAccessPresignedURL) GetHeaders() map[string]string

func (*ObjectTransferAccessPresignedURL) GetMethod

func (*ObjectTransferAccessPresignedURL) GetURL

func (*ObjectTransferAccessPresignedURL) MarshalJSON

func (o *ObjectTransferAccessPresignedURL) MarshalJSON() ([]byte, error)

func (*ObjectTransferAccessPresignedURL) SetExpiresAtMs

func (o *ObjectTransferAccessPresignedURL) SetExpiresAtMs(expiresAtMs int64)

SetExpiresAtMs sets the ExpiresAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ObjectTransferAccessPresignedURL) SetHeaders

func (o *ObjectTransferAccessPresignedURL) SetHeaders(headers map[string]string)

SetHeaders sets the Headers field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ObjectTransferAccessPresignedURL) SetMethod

func (o *ObjectTransferAccessPresignedURL) SetMethod(method string)

SetMethod sets the Method field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ObjectTransferAccessPresignedURL) SetURL

SetURL sets the URL field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ObjectTransferAccessPresignedURL) String

func (*ObjectTransferAccessPresignedURL) UnmarshalJSON

func (o *ObjectTransferAccessPresignedURL) UnmarshalJSON(data []byte) error

type ObjectTransferAccessVisitor

type ObjectTransferAccessVisitor interface {
	VisitPresignedURL(*ObjectTransferAccessPresignedURL) error
}

type PathEntry

type PathEntry struct {
	InodeKind string
	Dir       *PathEntryDirectory
	File      *PathEntryFile
	// contains filtered or unexported fields
}

Metadata for one path returned by stat and directory-listing operations.

File entries include the current revision and content details. Directory entries do not. Attribute fields are included only when requested and are serialized at the top level of the entry. Callers can pass `attributes_revision_no` as `expected_attributes_revision_no` when updating attributes.

func (*PathEntry) Accept

func (p *PathEntry) Accept(visitor PathEntryVisitor) error

func (*PathEntry) GetDir

func (p *PathEntry) GetDir() *PathEntryDirectory

func (*PathEntry) GetFile

func (p *PathEntry) GetFile() *PathEntryFile

func (*PathEntry) GetInodeKind

func (p *PathEntry) GetInodeKind() string

func (PathEntry) MarshalJSON

func (p PathEntry) MarshalJSON() ([]byte, error)

func (*PathEntry) UnmarshalJSON

func (p *PathEntry) UnmarshalJSON(data []byte) error

type PathEntryDirectory

type PathEntryDirectory struct {
	// The complete attribute map at `attributes_revision_no`.
	//
	// An inode that has never had attributes written is at revision 0 with
	// an empty map.
	Attributes *Attributes `json:"attributes,omitempty" url:"attributes,omitempty"`
	// The attribute revision this projection represents.
	AttributesRevisionNo *AttributeRevisionNo `json:"attributes_revision_no,omitempty" url:"attributes_revision_no,omitempty"`
	// Time of the latest attribute update, in Unix milliseconds. This is
	// `None` for the initial empty state at revision 0.
	AttributesUpdatedAtMs *int64 `json:"attributes_updated_at_ms,omitempty" url:"attributes_updated_at_ms,omitempty"`
	// Actor responsible for the latest attribute update. This is `None` for
	// the initial empty state at revision 0.
	AttributesUpdatedBy *ActorRef `json:"attributes_updated_by,omitempty" url:"attributes_updated_by,omitempty"`
	// Opaque identifier for this entry's current parent/name binding. Absent for the namespace root.
	BindingGeneration *string `json:"binding_generation,omitempty" url:"binding_generation,omitempty"`
	// Time the inode was created, in Unix milliseconds. Sequence numbers
	// determine order.
	CreatedAtMs int64 `json:"created_at_ms" url:"created_at_ms"`
	// Actor that created this inode, as supplied by the application.
	CreatedBy *ActorRef `json:"created_by" url:"created_by"`
	// Stored display name for this path component, absent for the nameless root.
	DisplayName *DisplayName `json:"display_name,omitempty" url:"display_name,omitempty"`
	// Namespace head sequence this answer was read from.
	HeadSeq ChangeSeq `json:"head_seq" url:"head_seq"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// Namespace that was read.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Stable inode ID within a namespace
	ParentInodeID *string `json:"parent_inode_id,omitempty" url:"parent_inode_id,omitempty"`
	// Absolute path as rendered from stored display names.
	Path AbsolutePath `json:"path" url:"path"`
	// contains filtered or unexported fields
}

func (*PathEntryDirectory) GetAttributes

func (p *PathEntryDirectory) GetAttributes() *Attributes

func (*PathEntryDirectory) GetAttributesRevisionNo

func (p *PathEntryDirectory) GetAttributesRevisionNo() *AttributeRevisionNo

func (*PathEntryDirectory) GetAttributesUpdatedAtMs

func (p *PathEntryDirectory) GetAttributesUpdatedAtMs() *int64

func (*PathEntryDirectory) GetAttributesUpdatedBy

func (p *PathEntryDirectory) GetAttributesUpdatedBy() *ActorRef

func (*PathEntryDirectory) GetBindingGeneration

func (p *PathEntryDirectory) GetBindingGeneration() *string

func (*PathEntryDirectory) GetCreatedAtMs

func (p *PathEntryDirectory) GetCreatedAtMs() int64

func (*PathEntryDirectory) GetCreatedBy

func (p *PathEntryDirectory) GetCreatedBy() *ActorRef

func (*PathEntryDirectory) GetDisplayName

func (p *PathEntryDirectory) GetDisplayName() *DisplayName

func (*PathEntryDirectory) GetExtraProperties

func (p *PathEntryDirectory) GetExtraProperties() map[string]interface{}

func (*PathEntryDirectory) GetHeadSeq

func (p *PathEntryDirectory) GetHeadSeq() ChangeSeq

func (*PathEntryDirectory) GetInodeID

func (p *PathEntryDirectory) GetInodeID() string

func (*PathEntryDirectory) GetNamespaceID

func (p *PathEntryDirectory) GetNamespaceID() NamespaceID

func (*PathEntryDirectory) GetParentInodeID

func (p *PathEntryDirectory) GetParentInodeID() *string

func (*PathEntryDirectory) GetPath

func (p *PathEntryDirectory) GetPath() AbsolutePath

func (*PathEntryDirectory) MarshalJSON

func (p *PathEntryDirectory) MarshalJSON() ([]byte, error)

func (*PathEntryDirectory) SetAttributes

func (p *PathEntryDirectory) SetAttributes(attributes *Attributes)

SetAttributes sets the Attributes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetAttributesRevisionNo

func (p *PathEntryDirectory) SetAttributesRevisionNo(attributesRevisionNo *AttributeRevisionNo)

SetAttributesRevisionNo sets the AttributesRevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetAttributesUpdatedAtMs

func (p *PathEntryDirectory) SetAttributesUpdatedAtMs(attributesUpdatedAtMs *int64)

SetAttributesUpdatedAtMs sets the AttributesUpdatedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetAttributesUpdatedBy

func (p *PathEntryDirectory) SetAttributesUpdatedBy(attributesUpdatedBy *ActorRef)

SetAttributesUpdatedBy sets the AttributesUpdatedBy field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetBindingGeneration

func (p *PathEntryDirectory) SetBindingGeneration(bindingGeneration *string)

SetBindingGeneration sets the BindingGeneration field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetCreatedAtMs

func (p *PathEntryDirectory) SetCreatedAtMs(createdAtMs int64)

SetCreatedAtMs sets the CreatedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetCreatedBy

func (p *PathEntryDirectory) SetCreatedBy(createdBy *ActorRef)

SetCreatedBy sets the CreatedBy field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetDisplayName

func (p *PathEntryDirectory) SetDisplayName(displayName *DisplayName)

SetDisplayName sets the DisplayName field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetHeadSeq

func (p *PathEntryDirectory) SetHeadSeq(headSeq ChangeSeq)

SetHeadSeq sets the HeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetInodeID

func (p *PathEntryDirectory) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetNamespaceID

func (p *PathEntryDirectory) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetParentInodeID

func (p *PathEntryDirectory) SetParentInodeID(parentInodeID *string)

SetParentInodeID sets the ParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) SetPath

func (p *PathEntryDirectory) SetPath(path AbsolutePath)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryDirectory) String

func (p *PathEntryDirectory) String() string

func (*PathEntryDirectory) UnmarshalJSON

func (p *PathEntryDirectory) UnmarshalJSON(data []byte) error

type PathEntryFile

type PathEntryFile struct {
	// Current content reference.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// Time of the current revision, in Unix milliseconds. Revision
	// sequences determine order.
	RevisionCommittedAtMs int64 `json:"revision_committed_at_ms" url:"revision_committed_at_ms"`
	// Actor responsible for the current revision.
	RevisionCommittedBy *ActorRef `json:"revision_committed_by" url:"revision_committed_by"`
	// Current file revision number.
	RevisionNo RevisionNo `json:"revision_no" url:"revision_no"`
	// Current file size in bytes.
	//
	// This remains explicit even though `content_ref` also carries the
	// length because callers sort directory listings by this field.
	SizeBytes int64 `json:"size_bytes" url:"size_bytes"`
	// The complete attribute map at `attributes_revision_no`.
	//
	// An inode that has never had attributes written is at revision 0 with
	// an empty map.
	Attributes *Attributes `json:"attributes,omitempty" url:"attributes,omitempty"`
	// The attribute revision this projection represents.
	AttributesRevisionNo *AttributeRevisionNo `json:"attributes_revision_no,omitempty" url:"attributes_revision_no,omitempty"`
	// Time of the latest attribute update, in Unix milliseconds. This is
	// `None` for the initial empty state at revision 0.
	AttributesUpdatedAtMs *int64 `json:"attributes_updated_at_ms,omitempty" url:"attributes_updated_at_ms,omitempty"`
	// Actor responsible for the latest attribute update. This is `None` for
	// the initial empty state at revision 0.
	AttributesUpdatedBy *ActorRef `json:"attributes_updated_by,omitempty" url:"attributes_updated_by,omitempty"`
	// Opaque identifier for this entry's current parent/name binding. Absent for the namespace root.
	BindingGeneration *string `json:"binding_generation,omitempty" url:"binding_generation,omitempty"`
	// Time the inode was created, in Unix milliseconds. Sequence numbers
	// determine order.
	CreatedAtMs int64 `json:"created_at_ms" url:"created_at_ms"`
	// Actor that created this inode, as supplied by the application.
	CreatedBy *ActorRef `json:"created_by" url:"created_by"`
	// Stored display name for this path component, absent for the nameless root.
	DisplayName *DisplayName `json:"display_name,omitempty" url:"display_name,omitempty"`
	// Namespace head sequence this answer was read from.
	HeadSeq ChangeSeq `json:"head_seq" url:"head_seq"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// Namespace that was read.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Stable inode ID within a namespace
	ParentInodeID *string `json:"parent_inode_id,omitempty" url:"parent_inode_id,omitempty"`
	// Absolute path as rendered from stored display names.
	Path AbsolutePath `json:"path" url:"path"`
	// contains filtered or unexported fields
}

func (*PathEntryFile) GetAttributes

func (p *PathEntryFile) GetAttributes() *Attributes

func (*PathEntryFile) GetAttributesRevisionNo

func (p *PathEntryFile) GetAttributesRevisionNo() *AttributeRevisionNo

func (*PathEntryFile) GetAttributesUpdatedAtMs

func (p *PathEntryFile) GetAttributesUpdatedAtMs() *int64

func (*PathEntryFile) GetAttributesUpdatedBy

func (p *PathEntryFile) GetAttributesUpdatedBy() *ActorRef

func (*PathEntryFile) GetBindingGeneration

func (p *PathEntryFile) GetBindingGeneration() *string

func (*PathEntryFile) GetContentRef

func (p *PathEntryFile) GetContentRef() *ContentRef

func (*PathEntryFile) GetCreatedAtMs

func (p *PathEntryFile) GetCreatedAtMs() int64

func (*PathEntryFile) GetCreatedBy

func (p *PathEntryFile) GetCreatedBy() *ActorRef

func (*PathEntryFile) GetDisplayName

func (p *PathEntryFile) GetDisplayName() *DisplayName

func (*PathEntryFile) GetExtraProperties

func (p *PathEntryFile) GetExtraProperties() map[string]interface{}

func (*PathEntryFile) GetHeadSeq

func (p *PathEntryFile) GetHeadSeq() ChangeSeq

func (*PathEntryFile) GetInodeID

func (p *PathEntryFile) GetInodeID() string

func (*PathEntryFile) GetNamespaceID

func (p *PathEntryFile) GetNamespaceID() NamespaceID

func (*PathEntryFile) GetParentInodeID

func (p *PathEntryFile) GetParentInodeID() *string

func (*PathEntryFile) GetPath

func (p *PathEntryFile) GetPath() AbsolutePath

func (*PathEntryFile) GetRevisionCommittedAtMs

func (p *PathEntryFile) GetRevisionCommittedAtMs() int64

func (*PathEntryFile) GetRevisionCommittedBy

func (p *PathEntryFile) GetRevisionCommittedBy() *ActorRef

func (*PathEntryFile) GetRevisionNo

func (p *PathEntryFile) GetRevisionNo() RevisionNo

func (*PathEntryFile) GetSizeBytes

func (p *PathEntryFile) GetSizeBytes() int64

func (*PathEntryFile) MarshalJSON

func (p *PathEntryFile) MarshalJSON() ([]byte, error)

func (*PathEntryFile) SetAttributes

func (p *PathEntryFile) SetAttributes(attributes *Attributes)

SetAttributes sets the Attributes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetAttributesRevisionNo

func (p *PathEntryFile) SetAttributesRevisionNo(attributesRevisionNo *AttributeRevisionNo)

SetAttributesRevisionNo sets the AttributesRevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetAttributesUpdatedAtMs

func (p *PathEntryFile) SetAttributesUpdatedAtMs(attributesUpdatedAtMs *int64)

SetAttributesUpdatedAtMs sets the AttributesUpdatedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetAttributesUpdatedBy

func (p *PathEntryFile) SetAttributesUpdatedBy(attributesUpdatedBy *ActorRef)

SetAttributesUpdatedBy sets the AttributesUpdatedBy field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetBindingGeneration

func (p *PathEntryFile) SetBindingGeneration(bindingGeneration *string)

SetBindingGeneration sets the BindingGeneration field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetContentRef

func (p *PathEntryFile) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetCreatedAtMs

func (p *PathEntryFile) SetCreatedAtMs(createdAtMs int64)

SetCreatedAtMs sets the CreatedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetCreatedBy

func (p *PathEntryFile) SetCreatedBy(createdBy *ActorRef)

SetCreatedBy sets the CreatedBy field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetDisplayName

func (p *PathEntryFile) SetDisplayName(displayName *DisplayName)

SetDisplayName sets the DisplayName field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetHeadSeq

func (p *PathEntryFile) SetHeadSeq(headSeq ChangeSeq)

SetHeadSeq sets the HeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetInodeID

func (p *PathEntryFile) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetNamespaceID

func (p *PathEntryFile) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetParentInodeID

func (p *PathEntryFile) SetParentInodeID(parentInodeID *string)

SetParentInodeID sets the ParentInodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetPath

func (p *PathEntryFile) SetPath(path AbsolutePath)

SetPath sets the Path field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetRevisionCommittedAtMs

func (p *PathEntryFile) SetRevisionCommittedAtMs(revisionCommittedAtMs int64)

SetRevisionCommittedAtMs sets the RevisionCommittedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetRevisionCommittedBy

func (p *PathEntryFile) SetRevisionCommittedBy(revisionCommittedBy *ActorRef)

SetRevisionCommittedBy sets the RevisionCommittedBy field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetRevisionNo

func (p *PathEntryFile) SetRevisionNo(revisionNo RevisionNo)

SetRevisionNo sets the RevisionNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) SetSizeBytes

func (p *PathEntryFile) SetSizeBytes(sizeBytes int64)

SetSizeBytes sets the SizeBytes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*PathEntryFile) String

func (p *PathEntryFile) String() string

func (*PathEntryFile) UnmarshalJSON

func (p *PathEntryFile) UnmarshalJSON(data []byte) error

type PathEntryVisitor

type PathEntryVisitor interface {
	VisitDir(*PathEntryDirectory) error
	VisitFile(*PathEntryFile) error
}

type ReleaseCheckpointRequest

type ReleaseCheckpointRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Checkpoint id
	CheckpointID string `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*ReleaseCheckpointRequest) SetCheckpointID

func (r *ReleaseCheckpointRequest) SetCheckpointID(checkpointID string)

SetCheckpointID sets the CheckpointID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ReleaseCheckpointRequest) SetNamespaceID

func (r *ReleaseCheckpointRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type ReleaseCheckpointResponse

type ReleaseCheckpointResponse struct {
	// Checkpoint the release targeted.
	CheckpointID CheckpointID `json:"checkpoint_id" url:"checkpoint_id"`
	// Namespace the checkpoint belonged to.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// contains filtered or unexported fields
}

func (*ReleaseCheckpointResponse) GetCheckpointID

func (r *ReleaseCheckpointResponse) GetCheckpointID() CheckpointID

func (*ReleaseCheckpointResponse) GetExtraProperties

func (r *ReleaseCheckpointResponse) GetExtraProperties() map[string]interface{}

func (*ReleaseCheckpointResponse) GetNamespaceID

func (r *ReleaseCheckpointResponse) GetNamespaceID() NamespaceID

func (*ReleaseCheckpointResponse) MarshalJSON

func (r *ReleaseCheckpointResponse) MarshalJSON() ([]byte, error)

func (*ReleaseCheckpointResponse) SetCheckpointID

func (r *ReleaseCheckpointResponse) SetCheckpointID(checkpointID CheckpointID)

SetCheckpointID sets the CheckpointID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ReleaseCheckpointResponse) SetNamespaceID

func (r *ReleaseCheckpointResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ReleaseCheckpointResponse) String

func (r *ReleaseCheckpointResponse) String() string

func (*ReleaseCheckpointResponse) UnmarshalJSON

func (r *ReleaseCheckpointResponse) UnmarshalJSON(data []byte) error

type ReleaseSnapshotRequest

type ReleaseSnapshotRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Snapshot id
	SnapshotID string `json:"-" url:"-"`
	// contains filtered or unexported fields
}

func (*ReleaseSnapshotRequest) SetNamespaceID

func (r *ReleaseSnapshotRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ReleaseSnapshotRequest) SetSnapshotID

func (r *ReleaseSnapshotRequest) SetSnapshotID(snapshotID string)

SetSnapshotID sets the SnapshotID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

type ReleaseSnapshotResponse

type ReleaseSnapshotResponse struct {
	// Namespace the snapshot belonged to.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Released snapshot id.
	SnapshotID CheckpointID `json:"snapshot_id" url:"snapshot_id"`
	// contains filtered or unexported fields
}

func (*ReleaseSnapshotResponse) GetExtraProperties

func (r *ReleaseSnapshotResponse) GetExtraProperties() map[string]interface{}

func (*ReleaseSnapshotResponse) GetNamespaceID

func (r *ReleaseSnapshotResponse) GetNamespaceID() NamespaceID

func (*ReleaseSnapshotResponse) GetSnapshotID

func (r *ReleaseSnapshotResponse) GetSnapshotID() CheckpointID

func (*ReleaseSnapshotResponse) MarshalJSON

func (r *ReleaseSnapshotResponse) MarshalJSON() ([]byte, error)

func (*ReleaseSnapshotResponse) SetNamespaceID

func (r *ReleaseSnapshotResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ReleaseSnapshotResponse) SetSnapshotID

func (r *ReleaseSnapshotResponse) SetSnapshotID(snapshotID CheckpointID)

SetSnapshotID sets the SnapshotID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ReleaseSnapshotResponse) String

func (r *ReleaseSnapshotResponse) String() string

func (*ReleaseSnapshotResponse) UnmarshalJSON

func (r *ReleaseSnapshotResponse) UnmarshalJSON(data []byte) error

type ReleasedCheckpointCounts

type ReleasedCheckpointCounts struct {
	// User-owned records released because their expiry passed, or because
	// they sit on a terminally deleted namespace.
	Expired int64 `json:"expired" url:"expired"`
	// Fork-owned records released because their target namespace is
	// provably gone.
	Fork int64 `json:"fork" url:"fork"`
	// Active records released because their basis manifest is verifiably
	// gone.
	MissingBasis int64 `json:"missing_basis" url:"missing_basis"`
	// Snapshot-owned records released because their expiry passed, or
	// because they sit on a terminally deleted namespace.
	Snapshot int64 `json:"snapshot" url:"snapshot"`
	// contains filtered or unexported fields
}

func (*ReleasedCheckpointCounts) GetExpired

func (r *ReleasedCheckpointCounts) GetExpired() int64

func (*ReleasedCheckpointCounts) GetExtraProperties

func (r *ReleasedCheckpointCounts) GetExtraProperties() map[string]interface{}

func (*ReleasedCheckpointCounts) GetFork

func (r *ReleasedCheckpointCounts) GetFork() int64

func (*ReleasedCheckpointCounts) GetMissingBasis

func (r *ReleasedCheckpointCounts) GetMissingBasis() int64

func (*ReleasedCheckpointCounts) GetSnapshot

func (r *ReleasedCheckpointCounts) GetSnapshot() int64

func (*ReleasedCheckpointCounts) MarshalJSON

func (r *ReleasedCheckpointCounts) MarshalJSON() ([]byte, error)

func (*ReleasedCheckpointCounts) SetExpired

func (r *ReleasedCheckpointCounts) SetExpired(expired int64)

SetExpired sets the Expired field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ReleasedCheckpointCounts) SetFork

func (r *ReleasedCheckpointCounts) SetFork(fork int64)

SetFork sets the Fork field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ReleasedCheckpointCounts) SetMissingBasis

func (r *ReleasedCheckpointCounts) SetMissingBasis(missingBasis int64)

SetMissingBasis sets the MissingBasis field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ReleasedCheckpointCounts) SetSnapshot

func (r *ReleasedCheckpointCounts) SetSnapshot(snapshot int64)

SetSnapshot sets the Snapshot field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ReleasedCheckpointCounts) String

func (r *ReleasedCheckpointCounts) String() string

func (*ReleasedCheckpointCounts) UnmarshalJSON

func (r *ReleasedCheckpointCounts) UnmarshalJSON(data []byte) error

type ReorganizeStepOutcome

type ReorganizeStepOutcome struct {
	Outcome              string
	NotNeeded            *ReorganizeStepOutcomeNotNeeded
	UnitPublished        *ReorganizeStepOutcomeUnitPublished
	CompactionStarted    *ReorganizeStepOutcomeCompactionStarted
	CompactionRunning    *ReorganizeStepOutcomeCompactionRunning
	CompactionAtCapacity *ReorganizeStepOutcomeCompactionAtCapacity
	CompactionRequired   *ReorganizeStepOutcomeCompactionRequired
	RootAdvanced         *ReorganizeStepOutcomeRootAdvanced
	// contains filtered or unexported fields
}

What the metadata-reorganization part of a maintenance step did.

Deliberately coarse: the run counts and byte budgets a reorganization consumes are engine policy, not a wire contract.

func (*ReorganizeStepOutcome) Accept

func (*ReorganizeStepOutcome) GetCompactionAtCapacity

func (*ReorganizeStepOutcome) GetCompactionRequired

func (*ReorganizeStepOutcome) GetCompactionRunning

func (*ReorganizeStepOutcome) GetCompactionStarted

func (*ReorganizeStepOutcome) GetNotNeeded

func (*ReorganizeStepOutcome) GetOutcome

func (r *ReorganizeStepOutcome) GetOutcome() string

func (*ReorganizeStepOutcome) GetRootAdvanced

func (*ReorganizeStepOutcome) GetUnitPublished

func (ReorganizeStepOutcome) MarshalJSON

func (r ReorganizeStepOutcome) MarshalJSON() ([]byte, error)

func (*ReorganizeStepOutcome) UnmarshalJSON

func (r *ReorganizeStepOutcome) UnmarshalJSON(data []byte) error

type ReorganizeStepOutcomeCompactionAtCapacity

type ReorganizeStepOutcomeCompactionAtCapacity struct {
	// contains filtered or unexported fields
}

func (*ReorganizeStepOutcomeCompactionAtCapacity) GetExtraProperties

func (r *ReorganizeStepOutcomeCompactionAtCapacity) GetExtraProperties() map[string]interface{}

func (*ReorganizeStepOutcomeCompactionAtCapacity) MarshalJSON

func (*ReorganizeStepOutcomeCompactionAtCapacity) String

func (*ReorganizeStepOutcomeCompactionAtCapacity) UnmarshalJSON

func (r *ReorganizeStepOutcomeCompactionAtCapacity) UnmarshalJSON(data []byte) error

type ReorganizeStepOutcomeCompactionRequired

type ReorganizeStepOutcomeCompactionRequired struct {
	// contains filtered or unexported fields
}

func (*ReorganizeStepOutcomeCompactionRequired) GetExtraProperties

func (r *ReorganizeStepOutcomeCompactionRequired) GetExtraProperties() map[string]interface{}

func (*ReorganizeStepOutcomeCompactionRequired) MarshalJSON

func (r *ReorganizeStepOutcomeCompactionRequired) MarshalJSON() ([]byte, error)

func (*ReorganizeStepOutcomeCompactionRequired) String

func (*ReorganizeStepOutcomeCompactionRequired) UnmarshalJSON

func (r *ReorganizeStepOutcomeCompactionRequired) UnmarshalJSON(data []byte) error

type ReorganizeStepOutcomeCompactionRunning

type ReorganizeStepOutcomeCompactionRunning struct {
	// contains filtered or unexported fields
}

func (*ReorganizeStepOutcomeCompactionRunning) GetExtraProperties

func (r *ReorganizeStepOutcomeCompactionRunning) GetExtraProperties() map[string]interface{}

func (*ReorganizeStepOutcomeCompactionRunning) MarshalJSON

func (r *ReorganizeStepOutcomeCompactionRunning) MarshalJSON() ([]byte, error)

func (*ReorganizeStepOutcomeCompactionRunning) String

func (*ReorganizeStepOutcomeCompactionRunning) UnmarshalJSON

func (r *ReorganizeStepOutcomeCompactionRunning) UnmarshalJSON(data []byte) error

type ReorganizeStepOutcomeCompactionStarted

type ReorganizeStepOutcomeCompactionStarted struct {
	// contains filtered or unexported fields
}

func (*ReorganizeStepOutcomeCompactionStarted) GetExtraProperties

func (r *ReorganizeStepOutcomeCompactionStarted) GetExtraProperties() map[string]interface{}

func (*ReorganizeStepOutcomeCompactionStarted) MarshalJSON

func (r *ReorganizeStepOutcomeCompactionStarted) MarshalJSON() ([]byte, error)

func (*ReorganizeStepOutcomeCompactionStarted) String

func (*ReorganizeStepOutcomeCompactionStarted) UnmarshalJSON

func (r *ReorganizeStepOutcomeCompactionStarted) UnmarshalJSON(data []byte) error

type ReorganizeStepOutcomeNotNeeded

type ReorganizeStepOutcomeNotNeeded struct {
	// contains filtered or unexported fields
}

func (*ReorganizeStepOutcomeNotNeeded) GetExtraProperties

func (r *ReorganizeStepOutcomeNotNeeded) GetExtraProperties() map[string]interface{}

func (*ReorganizeStepOutcomeNotNeeded) MarshalJSON

func (r *ReorganizeStepOutcomeNotNeeded) MarshalJSON() ([]byte, error)

func (*ReorganizeStepOutcomeNotNeeded) String

func (*ReorganizeStepOutcomeNotNeeded) UnmarshalJSON

func (r *ReorganizeStepOutcomeNotNeeded) UnmarshalJSON(data []byte) error

type ReorganizeStepOutcomeRootAdvanced

type ReorganizeStepOutcomeRootAdvanced struct {
	// contains filtered or unexported fields
}

func (*ReorganizeStepOutcomeRootAdvanced) GetExtraProperties

func (r *ReorganizeStepOutcomeRootAdvanced) GetExtraProperties() map[string]interface{}

func (*ReorganizeStepOutcomeRootAdvanced) MarshalJSON

func (r *ReorganizeStepOutcomeRootAdvanced) MarshalJSON() ([]byte, error)

func (*ReorganizeStepOutcomeRootAdvanced) String

func (*ReorganizeStepOutcomeRootAdvanced) UnmarshalJSON

func (r *ReorganizeStepOutcomeRootAdvanced) UnmarshalJSON(data []byte) error

type ReorganizeStepOutcomeUnitPublished

type ReorganizeStepOutcomeUnitPublished struct {
	// contains filtered or unexported fields
}

func (*ReorganizeStepOutcomeUnitPublished) GetExtraProperties

func (r *ReorganizeStepOutcomeUnitPublished) GetExtraProperties() map[string]interface{}

func (*ReorganizeStepOutcomeUnitPublished) MarshalJSON

func (r *ReorganizeStepOutcomeUnitPublished) MarshalJSON() ([]byte, error)

func (*ReorganizeStepOutcomeUnitPublished) String

func (*ReorganizeStepOutcomeUnitPublished) UnmarshalJSON

func (r *ReorganizeStepOutcomeUnitPublished) UnmarshalJSON(data []byte) error

type ReorganizeStepOutcomeVisitor

type ReorganizeStepOutcomeVisitor interface {
	VisitNotNeeded(*ReorganizeStepOutcomeNotNeeded) error
	VisitUnitPublished(*ReorganizeStepOutcomeUnitPublished) error
	VisitCompactionStarted(*ReorganizeStepOutcomeCompactionStarted) error
	VisitCompactionRunning(*ReorganizeStepOutcomeCompactionRunning) error
	VisitCompactionAtCapacity(*ReorganizeStepOutcomeCompactionAtCapacity) error
	VisitCompactionRequired(*ReorganizeStepOutcomeCompactionRequired) error
	VisitRootAdvanced(*ReorganizeStepOutcomeRootAdvanced) error
}

type RetainedCandidates

type RetainedCandidates struct {
	// Checkpoint records that could not be safely released or deleted.
	CheckpointNotReleasable int64 `json:"checkpoint_not_releasable" url:"checkpoint_not_releasable"`
	// Completed sessions skipped because the reference scan exceeded
	// `max_objects`. The response also sets `content_reclamation_deferred`.
	ContentScanDeferred int64 `json:"content_scan_deferred" url:"content_scan_deferred"`
	// Candidates kept because root resolution failed. The response also
	// sets `retention_degraded`.
	DegradedRoots int64 `json:"degraded_roots" url:"degraded_roots"`
	// Unreachable candidates with no provider timestamp. Their age is
	// unknown, so the pass keeps them.
	NoProviderTimestamp int64 `json:"no_provider_timestamp" url:"no_provider_timestamp"`
	// Unreachable candidates that cannot be checked against a manifest old
	// enough to cover the grace window.
	NoReferenceManifest int64 `json:"no_reference_manifest" url:"no_reference_manifest"`
	// Candidates found reachable during the final check before deletion.
	Referenced int64 `json:"referenced" url:"referenced"`
	// Unrecognized keys in a family scanned by GC. These keys are never
	// deleted.
	UnrecognizedKey int64 `json:"unrecognized_key" url:"unrecognized_key"`
	// Upload sessions kept because the pass could not determine whether
	// they were safe to delete.
	UploadSessionUndecided int64 `json:"upload_session_undecided" url:"upload_session_undecided"`
	// Upload sessions still protected by a lease or grace window.
	UploadSessionWindow int64 `json:"upload_session_window" url:"upload_session_window"`
	// Unreachable, but younger than the grace window by the object's own
	// provider timestamp. A later pass deletes it.
	WithinGraceWindow int64 `json:"within_grace_window" url:"within_grace_window"`
	// contains filtered or unexported fields
}

func (*RetainedCandidates) GetCheckpointNotReleasable

func (r *RetainedCandidates) GetCheckpointNotReleasable() int64

func (*RetainedCandidates) GetContentScanDeferred

func (r *RetainedCandidates) GetContentScanDeferred() int64

func (*RetainedCandidates) GetDegradedRoots

func (r *RetainedCandidates) GetDegradedRoots() int64

func (*RetainedCandidates) GetExtraProperties

func (r *RetainedCandidates) GetExtraProperties() map[string]interface{}

func (*RetainedCandidates) GetNoProviderTimestamp

func (r *RetainedCandidates) GetNoProviderTimestamp() int64

func (*RetainedCandidates) GetNoReferenceManifest

func (r *RetainedCandidates) GetNoReferenceManifest() int64

func (*RetainedCandidates) GetReferenced

func (r *RetainedCandidates) GetReferenced() int64

func (*RetainedCandidates) GetUnrecognizedKey

func (r *RetainedCandidates) GetUnrecognizedKey() int64

func (*RetainedCandidates) GetUploadSessionUndecided

func (r *RetainedCandidates) GetUploadSessionUndecided() int64

func (*RetainedCandidates) GetUploadSessionWindow

func (r *RetainedCandidates) GetUploadSessionWindow() int64

func (*RetainedCandidates) GetWithinGraceWindow

func (r *RetainedCandidates) GetWithinGraceWindow() int64

func (*RetainedCandidates) MarshalJSON

func (r *RetainedCandidates) MarshalJSON() ([]byte, error)

func (*RetainedCandidates) SetCheckpointNotReleasable

func (r *RetainedCandidates) SetCheckpointNotReleasable(checkpointNotReleasable int64)

SetCheckpointNotReleasable sets the CheckpointNotReleasable field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*RetainedCandidates) SetContentScanDeferred

func (r *RetainedCandidates) SetContentScanDeferred(contentScanDeferred int64)

SetContentScanDeferred sets the ContentScanDeferred field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*RetainedCandidates) SetDegradedRoots

func (r *RetainedCandidates) SetDegradedRoots(degradedRoots int64)

SetDegradedRoots sets the DegradedRoots field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*RetainedCandidates) SetNoProviderTimestamp

func (r *RetainedCandidates) SetNoProviderTimestamp(noProviderTimestamp int64)

SetNoProviderTimestamp sets the NoProviderTimestamp field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*RetainedCandidates) SetNoReferenceManifest

func (r *RetainedCandidates) SetNoReferenceManifest(noReferenceManifest int64)

SetNoReferenceManifest sets the NoReferenceManifest field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*RetainedCandidates) SetReferenced

func (r *RetainedCandidates) SetReferenced(referenced int64)

SetReferenced sets the Referenced field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*RetainedCandidates) SetUnrecognizedKey

func (r *RetainedCandidates) SetUnrecognizedKey(unrecognizedKey int64)

SetUnrecognizedKey sets the UnrecognizedKey field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*RetainedCandidates) SetUploadSessionUndecided

func (r *RetainedCandidates) SetUploadSessionUndecided(uploadSessionUndecided int64)

SetUploadSessionUndecided sets the UploadSessionUndecided field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*RetainedCandidates) SetUploadSessionWindow

func (r *RetainedCandidates) SetUploadSessionWindow(uploadSessionWindow int64)

SetUploadSessionWindow sets the UploadSessionWindow field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*RetainedCandidates) SetWithinGraceWindow

func (r *RetainedCandidates) SetWithinGraceWindow(withinGraceWindow int64)

SetWithinGraceWindow sets the WithinGraceWindow field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*RetainedCandidates) String

func (r *RetainedCandidates) String() string

func (*RetainedCandidates) UnmarshalJSON

func (r *RetainedCandidates) UnmarshalJSON(data []byte) error

type RevisionNo

type RevisionNo = int64

Revision number for a file's content. It increases whenever the content is replaced or restored.

type RunNo

type RunNo = int64

Monotonic run counter allocated by the manifest that names the run. A run is the set of segments one producer wrote together.

type ServiceUnavailableError

type ServiceUnavailableError struct {
	*core.APIError
	Body any
}

The server cannot complete the request now. Inspect `code` to determine whether the cause is a deadline, shutdown, load, required maintenance, or invalid storage credentials. A mutation may still complete after a deadline or lost acknowledgment, so determine its outcome before retrying.

func (*ServiceUnavailableError) MarshalJSON

func (s *ServiceUnavailableError) MarshalJSON() ([]byte, error)

func (*ServiceUnavailableError) UnmarshalJSON

func (s *ServiceUnavailableError) UnmarshalJSON(data []byte) error

func (*ServiceUnavailableError) Unwrap

func (s *ServiceUnavailableError) Unwrap() error

type ServiceUnavailableErrorBody

type ServiceUnavailableErrorBody struct {
	// Stable machine-readable reason from the [`ErrorCode`](crate::ErrorCode)
	// registry.
	//
	// Carried as a string so clients keep working when a newer server
	// introduces a code they do not know; use
	// [`ErrorCode::parse`](crate::ErrorCode::parse) for typed access.
	Code string `json:"code" url:"code"`
	// Structured context for the code, present when the failure carries
	// machine-usable identity (API spec, "Standard error contract"). Boxed
	// so the rare detailed error does not widen every error-carrying result.
	Details *ErrorDetails `json:"details,omitempty" url:"details,omitempty"`
	// For `not_supported` errors, the capability-document feature key the
	// client should reconcile against.
	Feature *string `json:"feature,omitempty" url:"feature,omitempty"`
	// Human-readable error message.
	Message string `json:"message" url:"message"`
	// Identifies the invalid input. Body fields use JSON Pointer paths;
	// query and path parameters use their names; CLI errors use the flag or
	// argument as written.
	Param *string `json:"param,omitempty" url:"param,omitempty"`
	// Correlation id the server assigned to the failed request; the same
	// value is sent as the `x-request-id` response header.
	RequestID *string `json:"request_id,omitempty" url:"request_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceUnavailableErrorBody) GetCode

func (s *ServiceUnavailableErrorBody) GetCode() string

func (*ServiceUnavailableErrorBody) GetDetails

func (s *ServiceUnavailableErrorBody) GetDetails() *ErrorDetails

func (*ServiceUnavailableErrorBody) GetExtraProperties

func (s *ServiceUnavailableErrorBody) GetExtraProperties() map[string]interface{}

func (*ServiceUnavailableErrorBody) GetFeature

func (s *ServiceUnavailableErrorBody) GetFeature() *string

func (*ServiceUnavailableErrorBody) GetMessage

func (s *ServiceUnavailableErrorBody) GetMessage() string

func (*ServiceUnavailableErrorBody) GetParam

func (s *ServiceUnavailableErrorBody) GetParam() *string

func (*ServiceUnavailableErrorBody) GetRequestID

func (s *ServiceUnavailableErrorBody) GetRequestID() *string

func (*ServiceUnavailableErrorBody) MarshalJSON

func (s *ServiceUnavailableErrorBody) MarshalJSON() ([]byte, error)

func (*ServiceUnavailableErrorBody) SetCode

func (s *ServiceUnavailableErrorBody) SetCode(code string)

SetCode sets the Code field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ServiceUnavailableErrorBody) SetDetails

func (s *ServiceUnavailableErrorBody) SetDetails(details *ErrorDetails)

SetDetails sets the Details field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ServiceUnavailableErrorBody) SetFeature

func (s *ServiceUnavailableErrorBody) SetFeature(feature *string)

SetFeature sets the Feature field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ServiceUnavailableErrorBody) SetMessage

func (s *ServiceUnavailableErrorBody) SetMessage(message string)

SetMessage sets the Message field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ServiceUnavailableErrorBody) SetParam

func (s *ServiceUnavailableErrorBody) SetParam(param *string)

SetParam sets the Param field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ServiceUnavailableErrorBody) SetRequestID

func (s *ServiceUnavailableErrorBody) SetRequestID(requestID *string)

SetRequestID sets the RequestID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*ServiceUnavailableErrorBody) String

func (s *ServiceUnavailableErrorBody) String() string

func (*ServiceUnavailableErrorBody) UnmarshalJSON

func (s *ServiceUnavailableErrorBody) UnmarshalJSON(data []byte) error

type SignUploadPartsRequest

type SignUploadPartsRequest struct {
	// Namespace id
	NamespaceID string `json:"-" url:"-"`
	// Upload session id
	UploadID string `json:"-" url:"-"`
	// Parts to authorize and the checksum for each part. Requesting a part
	// again replaces the previous upload for that part number.
	Parts []*UploadPartChecksumClaim `json:"parts" url:"-"`
	// contains filtered or unexported fields
}

func (*SignUploadPartsRequest) MarshalJSON

func (s *SignUploadPartsRequest) MarshalJSON() ([]byte, error)

func (*SignUploadPartsRequest) SetNamespaceID

func (s *SignUploadPartsRequest) SetNamespaceID(namespaceID string)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SignUploadPartsRequest) SetParts

func (s *SignUploadPartsRequest) SetParts(parts []*UploadPartChecksumClaim)

SetParts sets the Parts field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SignUploadPartsRequest) SetUploadID

func (s *SignUploadPartsRequest) SetUploadID(uploadID string)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SignUploadPartsRequest) UnmarshalJSON

func (s *SignUploadPartsRequest) UnmarshalJSON(data []byte) error

type SignUploadPartsResponse

type SignUploadPartsResponse struct {
	// Namespace that owns the upload session.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Capabilities in the order the request asked for them.
	Parts []*SignedUploadPart `json:"parts" url:"parts"`
	// Session the parts belong to.
	UploadID UploadID `json:"upload_id" url:"upload_id"`
	// contains filtered or unexported fields
}

func (*SignUploadPartsResponse) GetExtraProperties

func (s *SignUploadPartsResponse) GetExtraProperties() map[string]interface{}

func (*SignUploadPartsResponse) GetNamespaceID

func (s *SignUploadPartsResponse) GetNamespaceID() NamespaceID

func (*SignUploadPartsResponse) GetParts

func (s *SignUploadPartsResponse) GetParts() []*SignedUploadPart

func (*SignUploadPartsResponse) GetUploadID

func (s *SignUploadPartsResponse) GetUploadID() UploadID

func (*SignUploadPartsResponse) MarshalJSON

func (s *SignUploadPartsResponse) MarshalJSON() ([]byte, error)

func (*SignUploadPartsResponse) SetNamespaceID

func (s *SignUploadPartsResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SignUploadPartsResponse) SetParts

func (s *SignUploadPartsResponse) SetParts(parts []*SignedUploadPart)

SetParts sets the Parts field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SignUploadPartsResponse) SetUploadID

func (s *SignUploadPartsResponse) SetUploadID(uploadID UploadID)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SignUploadPartsResponse) String

func (s *SignUploadPartsResponse) String() string

func (*SignUploadPartsResponse) UnmarshalJSON

func (s *SignUploadPartsResponse) UnmarshalJSON(data []byte) error

type SignedUploadPart

type SignedUploadPart struct {
	// Short-lived write capability for that part.
	Access *ObjectTransferAccess `json:"access" url:"access"`
	// Part number this capability writes.
	PartNumber int `json:"part_number" url:"part_number"`
	// contains filtered or unexported fields
}

func (*SignedUploadPart) GetAccess

func (s *SignedUploadPart) GetAccess() *ObjectTransferAccess

func (*SignedUploadPart) GetExtraProperties

func (s *SignedUploadPart) GetExtraProperties() map[string]interface{}

func (*SignedUploadPart) GetPartNumber

func (s *SignedUploadPart) GetPartNumber() int

func (*SignedUploadPart) MarshalJSON

func (s *SignedUploadPart) MarshalJSON() ([]byte, error)

func (*SignedUploadPart) SetAccess

func (s *SignedUploadPart) SetAccess(access *ObjectTransferAccess)

SetAccess sets the Access field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SignedUploadPart) SetPartNumber

func (s *SignedUploadPart) SetPartNumber(partNumber int)

SetPartNumber sets the PartNumber field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SignedUploadPart) String

func (s *SignedUploadPart) String() string

func (*SignedUploadPart) UnmarshalJSON

func (s *SignedUploadPart) UnmarshalJSON(data []byte) error

type SnapshotSummary

type SnapshotSummary struct {
	// Time the snapshot record was created, in Unix milliseconds.
	CreatedAtMs int64 `json:"created_at_ms" url:"created_at_ms"`
	// When the snapshot lease expires, in Unix milliseconds.
	ExpiresAtMs int64 `json:"expires_at_ms" url:"expires_at_ms"`
	// Namespace sequence captured by the snapshot.
	HeadSeq ChangeSeq `json:"head_seq" url:"head_seq"`
	// Snapshot label.
	Name string `json:"name" url:"name"`
	// Namespace whose state the snapshot captured.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Snapshot id.
	SnapshotID CheckpointID `json:"snapshot_id" url:"snapshot_id"`
	// contains filtered or unexported fields
}

func (*SnapshotSummary) GetCreatedAtMs

func (s *SnapshotSummary) GetCreatedAtMs() int64

func (*SnapshotSummary) GetExpiresAtMs

func (s *SnapshotSummary) GetExpiresAtMs() int64

func (*SnapshotSummary) GetExtraProperties

func (s *SnapshotSummary) GetExtraProperties() map[string]interface{}

func (*SnapshotSummary) GetHeadSeq

func (s *SnapshotSummary) GetHeadSeq() ChangeSeq

func (*SnapshotSummary) GetName

func (s *SnapshotSummary) GetName() string

func (*SnapshotSummary) GetNamespaceID

func (s *SnapshotSummary) GetNamespaceID() NamespaceID

func (*SnapshotSummary) GetSnapshotID

func (s *SnapshotSummary) GetSnapshotID() CheckpointID

func (*SnapshotSummary) MarshalJSON

func (s *SnapshotSummary) MarshalJSON() ([]byte, error)

func (*SnapshotSummary) SetCreatedAtMs

func (s *SnapshotSummary) SetCreatedAtMs(createdAtMs int64)

SetCreatedAtMs sets the CreatedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SnapshotSummary) SetExpiresAtMs

func (s *SnapshotSummary) SetExpiresAtMs(expiresAtMs int64)

SetExpiresAtMs sets the ExpiresAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SnapshotSummary) SetHeadSeq

func (s *SnapshotSummary) SetHeadSeq(headSeq ChangeSeq)

SetHeadSeq sets the HeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SnapshotSummary) SetName

func (s *SnapshotSummary) SetName(name string)

SetName sets the Name field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SnapshotSummary) SetNamespaceID

func (s *SnapshotSummary) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SnapshotSummary) SetSnapshotID

func (s *SnapshotSummary) SetSnapshotID(snapshotID CheckpointID)

SetSnapshotID sets the SnapshotID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*SnapshotSummary) String

func (s *SnapshotSummary) String() string

func (*SnapshotSummary) UnmarshalJSON

func (s *SnapshotSummary) UnmarshalJSON(data []byte) error

type StoreProbeCheckOutcome

type StoreProbeCheckOutcome string

What one contract check concluded about the store.

const (
	StoreProbeCheckOutcomePassed      StoreProbeCheckOutcome = "passed"
	StoreProbeCheckOutcomeUnsupported StoreProbeCheckOutcome = "unsupported"
	StoreProbeCheckOutcomeFailed      StoreProbeCheckOutcome = "failed"
)

func NewStoreProbeCheckOutcomeFromString

func NewStoreProbeCheckOutcomeFromString(s string) (StoreProbeCheckOutcome, error)

func (StoreProbeCheckOutcome) Ptr

type StoreProbeCheckResult

type StoreProbeCheckResult struct {
	// What was expected and what happened instead. Present only on
	// `failed`.
	Message *string `json:"message,omitempty" url:"message,omitempty"`
	// Stable check name.
	Name string `json:"name" url:"name"`
	// What the store did.
	Outcome StoreProbeCheckOutcome `json:"outcome" url:"outcome"`
	// contains filtered or unexported fields
}

func (*StoreProbeCheckResult) GetExtraProperties

func (s *StoreProbeCheckResult) GetExtraProperties() map[string]interface{}

func (*StoreProbeCheckResult) GetMessage

func (s *StoreProbeCheckResult) GetMessage() *string

func (*StoreProbeCheckResult) GetName

func (s *StoreProbeCheckResult) GetName() string

func (*StoreProbeCheckResult) GetOutcome

func (*StoreProbeCheckResult) MarshalJSON

func (s *StoreProbeCheckResult) MarshalJSON() ([]byte, error)

func (*StoreProbeCheckResult) SetMessage

func (s *StoreProbeCheckResult) SetMessage(message *string)

SetMessage sets the Message field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*StoreProbeCheckResult) SetName

func (s *StoreProbeCheckResult) SetName(name string)

SetName sets the Name field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*StoreProbeCheckResult) SetOutcome

func (s *StoreProbeCheckResult) SetOutcome(outcome StoreProbeCheckOutcome)

SetOutcome sets the Outcome field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*StoreProbeCheckResult) String

func (s *StoreProbeCheckResult) String() string

func (*StoreProbeCheckResult) UnmarshalJSON

func (s *StoreProbeCheckResult) UnmarshalJSON(data []byte) error

type StoreProbeRequest

type StoreProbeRequest = map[string]any

Options for one store contract probe. Empty today; a body is still sent so later options do not change the shape of the request. An option this build does not know is rejected rather than ignored, so a caller never believes it selected something.

type StoreProbeResponse

type StoreProbeResponse struct {
	// Every check the run performed, in the order it performed them. A
	// failed check lives here rather than in an error: the probe answered
	// the question, and the answer is that the store is wrong.
	Checks []*StoreProbeCheckResult `json:"checks" url:"checks"`
	// Label the server minted for this run. It scopes the objects the run
	// wrote, so it identifies the run in provider logs too.
	RunID string `json:"run_id" url:"run_id"`
	// contains filtered or unexported fields
}

func (*StoreProbeResponse) GetChecks

func (s *StoreProbeResponse) GetChecks() []*StoreProbeCheckResult

func (*StoreProbeResponse) GetExtraProperties

func (s *StoreProbeResponse) GetExtraProperties() map[string]interface{}

func (*StoreProbeResponse) GetRunID

func (s *StoreProbeResponse) GetRunID() string

func (*StoreProbeResponse) MarshalJSON

func (s *StoreProbeResponse) MarshalJSON() ([]byte, error)

func (*StoreProbeResponse) SetChecks

func (s *StoreProbeResponse) SetChecks(checks []*StoreProbeCheckResult)

SetChecks sets the Checks field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*StoreProbeResponse) SetRunID

func (s *StoreProbeResponse) SetRunID(runID string)

SetRunID sets the RunID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*StoreProbeResponse) String

func (s *StoreProbeResponse) String() string

func (*StoreProbeResponse) UnmarshalJSON

func (s *StoreProbeResponse) UnmarshalJSON(data []byte) error

type TrashEntry

type TrashEntry struct {
	// Time of the deletion, in Unix milliseconds.
	DeletedAtMs int64 `json:"deleted_at_ms" url:"deleted_at_ms"`
	// Directory binding removed by the deletion, when available.
	DeletedBinding *DirectoryBinding `json:"deleted_binding,omitempty" url:"deleted_binding,omitempty"`
	// Actor responsible for the deletion.
	DeletedBy *ActorRef `json:"deleted_by" url:"deleted_by"`
	// Commit sequence that identifies this deletion.
	DeletionSeq ChangeSeq `json:"deletion_seq" url:"deletion_seq"`
	// Stable inode ID within a namespace
	InodeID string `json:"inode_id" url:"inode_id"`
	// contains filtered or unexported fields
}

func (*TrashEntry) GetDeletedAtMs

func (t *TrashEntry) GetDeletedAtMs() int64

func (*TrashEntry) GetDeletedBinding

func (t *TrashEntry) GetDeletedBinding() *DirectoryBinding

func (*TrashEntry) GetDeletedBy

func (t *TrashEntry) GetDeletedBy() *ActorRef

func (*TrashEntry) GetDeletionSeq

func (t *TrashEntry) GetDeletionSeq() ChangeSeq

func (*TrashEntry) GetExtraProperties

func (t *TrashEntry) GetExtraProperties() map[string]interface{}

func (*TrashEntry) GetInodeID

func (t *TrashEntry) GetInodeID() string

func (*TrashEntry) MarshalJSON

func (t *TrashEntry) MarshalJSON() ([]byte, error)

func (*TrashEntry) SetDeletedAtMs

func (t *TrashEntry) SetDeletedAtMs(deletedAtMs int64)

SetDeletedAtMs sets the DeletedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*TrashEntry) SetDeletedBinding

func (t *TrashEntry) SetDeletedBinding(deletedBinding *DirectoryBinding)

SetDeletedBinding sets the DeletedBinding field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*TrashEntry) SetDeletedBy

func (t *TrashEntry) SetDeletedBy(deletedBy *ActorRef)

SetDeletedBy sets the DeletedBy field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*TrashEntry) SetDeletionSeq

func (t *TrashEntry) SetDeletionSeq(deletionSeq ChangeSeq)

SetDeletionSeq sets the DeletionSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*TrashEntry) SetInodeID

func (t *TrashEntry) SetInodeID(inodeID string)

SetInodeID sets the InodeID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*TrashEntry) String

func (t *TrashEntry) String() string

func (*TrashEntry) UnmarshalJSON

func (t *TrashEntry) UnmarshalJSON(data []byte) error

type UnauthorizedError

type UnauthorizedError struct {
	*core.APIError
	Body *APIError
}

Missing or invalid bearer token

func (*UnauthorizedError) MarshalJSON

func (u *UnauthorizedError) MarshalJSON() ([]byte, error)

func (*UnauthorizedError) UnmarshalJSON

func (u *UnauthorizedError) UnmarshalJSON(data []byte) error

func (*UnauthorizedError) Unwrap

func (u *UnauthorizedError) Unwrap() error

type UploadContentClaim

type UploadContentClaim struct {
	// Whole-payload checksum in the algorithm required by this operation.
	Checksum *Checksum `json:"checksum" url:"checksum"`
	// Complete payload size in bytes.
	SizeBytes int64 `json:"size_bytes" url:"size_bytes"`
	// contains filtered or unexported fields
}

func (*UploadContentClaim) GetChecksum

func (u *UploadContentClaim) GetChecksum() *Checksum

func (*UploadContentClaim) GetExtraProperties

func (u *UploadContentClaim) GetExtraProperties() map[string]interface{}

func (*UploadContentClaim) GetSizeBytes

func (u *UploadContentClaim) GetSizeBytes() int64

func (*UploadContentClaim) MarshalJSON

func (u *UploadContentClaim) MarshalJSON() ([]byte, error)

func (*UploadContentClaim) SetChecksum

func (u *UploadContentClaim) SetChecksum(checksum *Checksum)

SetChecksum sets the Checksum field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadContentClaim) SetSizeBytes

func (u *UploadContentClaim) SetSizeBytes(sizeBytes int64)

SetSizeBytes sets the SizeBytes field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadContentClaim) String

func (u *UploadContentClaim) String() string

func (*UploadContentClaim) UnmarshalJSON

func (u *UploadContentClaim) UnmarshalJSON(data []byte) error

type UploadContentResponse

type UploadContentResponse struct {
	// Digest and byte length computed from the accepted body.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// Namespace that owns the upload session.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Session into which the service staged these bytes.
	UploadID UploadID `json:"upload_id" url:"upload_id"`
	// contains filtered or unexported fields
}

func (*UploadContentResponse) GetContentRef

func (u *UploadContentResponse) GetContentRef() *ContentRef

func (*UploadContentResponse) GetExtraProperties

func (u *UploadContentResponse) GetExtraProperties() map[string]interface{}

func (*UploadContentResponse) GetNamespaceID

func (u *UploadContentResponse) GetNamespaceID() NamespaceID

func (*UploadContentResponse) GetUploadID

func (u *UploadContentResponse) GetUploadID() UploadID

func (*UploadContentResponse) MarshalJSON

func (u *UploadContentResponse) MarshalJSON() ([]byte, error)

func (*UploadContentResponse) SetContentRef

func (u *UploadContentResponse) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadContentResponse) SetNamespaceID

func (u *UploadContentResponse) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadContentResponse) SetUploadID

func (u *UploadContentResponse) SetUploadID(uploadID UploadID)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadContentResponse) String

func (u *UploadContentResponse) String() string

func (*UploadContentResponse) UnmarshalJSON

func (u *UploadContentResponse) UnmarshalJSON(data []byte) error

type UploadID

type UploadID = string

Durable id for one upload session.

type UploadMode

type UploadMode string

Upload transport mode.

const (
	UploadModeServiceProxied  UploadMode = "service_proxied"
	UploadModeDirectPut       UploadMode = "direct_put"
	UploadModeDirectMultipart UploadMode = "direct_multipart"
)

func NewUploadModeFromString

func NewUploadModeFromString(s string) (UploadMode, error)

func (UploadMode) Ptr

func (u UploadMode) Ptr() *UploadMode

type UploadPartChecksumClaim

type UploadPartChecksumClaim struct {
	// Checksum over this part's bytes.
	Checksum *Checksum `json:"checksum" url:"checksum"`
	// One-based part number, at most the provider's 10,000-part limit.
	PartNumber int `json:"part_number" url:"part_number"`
	// contains filtered or unexported fields
}

func (*UploadPartChecksumClaim) GetChecksum

func (u *UploadPartChecksumClaim) GetChecksum() *Checksum

func (*UploadPartChecksumClaim) GetExtraProperties

func (u *UploadPartChecksumClaim) GetExtraProperties() map[string]interface{}

func (*UploadPartChecksumClaim) GetPartNumber

func (u *UploadPartChecksumClaim) GetPartNumber() int

func (*UploadPartChecksumClaim) MarshalJSON

func (u *UploadPartChecksumClaim) MarshalJSON() ([]byte, error)

func (*UploadPartChecksumClaim) SetChecksum

func (u *UploadPartChecksumClaim) SetChecksum(checksum *Checksum)

SetChecksum sets the Checksum field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadPartChecksumClaim) SetPartNumber

func (u *UploadPartChecksumClaim) SetPartNumber(partNumber int)

SetPartNumber sets the PartNumber field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadPartChecksumClaim) String

func (u *UploadPartChecksumClaim) String() string

func (*UploadPartChecksumClaim) UnmarshalJSON

func (u *UploadPartChecksumClaim) UnmarshalJSON(data []byte) error

type UploadSession

type UploadSession struct {
	Status    string
	Open      *UploadSessionStatusOpen
	Completed *UploadSessionStatusCompleted
	Aborted   *UploadSessionStatusAborted
	// contains filtered or unexported fields
}

Current view of one upload session.

func (*UploadSession) Accept

func (u *UploadSession) Accept(visitor UploadSessionVisitor) error

func (*UploadSession) GetAborted

func (u *UploadSession) GetAborted() *UploadSessionStatusAborted

func (*UploadSession) GetCompleted

func (u *UploadSession) GetCompleted() *UploadSessionStatusCompleted

func (*UploadSession) GetOpen

func (u *UploadSession) GetOpen() *UploadSessionStatusOpen

func (*UploadSession) GetStatus

func (u *UploadSession) GetStatus() string

func (UploadSession) MarshalJSON

func (u UploadSession) MarshalJSON() ([]byte, error)

func (*UploadSession) UnmarshalJSON

func (u *UploadSession) UnmarshalJSON(data []byte) error

type UploadSessionStatusAborted

type UploadSessionStatusAborted struct {
	// Unix-millisecond stamp of the abort.
	AbortedAtMs int64 `json:"aborted_at_ms" url:"aborted_at_ms"`
	// Transport selected when the session began.
	Mode UploadMode `json:"mode" url:"mode"`
	// Namespace that owns the session.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Session represented by this view.
	UploadID UploadID `json:"upload_id" url:"upload_id"`
	// contains filtered or unexported fields
}

func (*UploadSessionStatusAborted) GetAbortedAtMs

func (u *UploadSessionStatusAborted) GetAbortedAtMs() int64

func (*UploadSessionStatusAborted) GetExtraProperties

func (u *UploadSessionStatusAborted) GetExtraProperties() map[string]interface{}

func (*UploadSessionStatusAborted) GetMode

func (*UploadSessionStatusAborted) GetNamespaceID

func (u *UploadSessionStatusAborted) GetNamespaceID() NamespaceID

func (*UploadSessionStatusAborted) GetUploadID

func (u *UploadSessionStatusAborted) GetUploadID() UploadID

func (*UploadSessionStatusAborted) MarshalJSON

func (u *UploadSessionStatusAborted) MarshalJSON() ([]byte, error)

func (*UploadSessionStatusAborted) SetAbortedAtMs

func (u *UploadSessionStatusAborted) SetAbortedAtMs(abortedAtMs int64)

SetAbortedAtMs sets the AbortedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusAborted) SetMode

func (u *UploadSessionStatusAborted) SetMode(mode UploadMode)

SetMode sets the Mode field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusAborted) SetNamespaceID

func (u *UploadSessionStatusAborted) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusAborted) SetUploadID

func (u *UploadSessionStatusAborted) SetUploadID(uploadID UploadID)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusAborted) String

func (u *UploadSessionStatusAborted) String() string

func (*UploadSessionStatusAborted) UnmarshalJSON

func (u *UploadSessionStatusAborted) UnmarshalJSON(data []byte) error

type UploadSessionStatusCompleted

type UploadSessionStatusCompleted struct {
	// Unix-millisecond stamp of the completion.
	CompletedAtMs int64 `json:"completed_at_ms" url:"completed_at_ms"`
	// Verified content selected by this session.
	ContentRef *ContentRef `json:"content_ref" url:"content_ref"`
	// Fresh proof for a later commit. This is absent after the token
	// minting window closes, while `content_ref` remains available.
	ContentToken *ContentToken `json:"content_token,omitempty" url:"content_token,omitempty"`
	// Transport selected when the session began.
	Mode UploadMode `json:"mode" url:"mode"`
	// Namespace that owns the session.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Session represented by this view.
	UploadID UploadID `json:"upload_id" url:"upload_id"`
	// contains filtered or unexported fields
}

func (*UploadSessionStatusCompleted) GetCompletedAtMs

func (u *UploadSessionStatusCompleted) GetCompletedAtMs() int64

func (*UploadSessionStatusCompleted) GetContentRef

func (u *UploadSessionStatusCompleted) GetContentRef() *ContentRef

func (*UploadSessionStatusCompleted) GetContentToken

func (u *UploadSessionStatusCompleted) GetContentToken() *ContentToken

func (*UploadSessionStatusCompleted) GetExtraProperties

func (u *UploadSessionStatusCompleted) GetExtraProperties() map[string]interface{}

func (*UploadSessionStatusCompleted) GetMode

func (*UploadSessionStatusCompleted) GetNamespaceID

func (u *UploadSessionStatusCompleted) GetNamespaceID() NamespaceID

func (*UploadSessionStatusCompleted) GetUploadID

func (u *UploadSessionStatusCompleted) GetUploadID() UploadID

func (*UploadSessionStatusCompleted) MarshalJSON

func (u *UploadSessionStatusCompleted) MarshalJSON() ([]byte, error)

func (*UploadSessionStatusCompleted) SetCompletedAtMs

func (u *UploadSessionStatusCompleted) SetCompletedAtMs(completedAtMs int64)

SetCompletedAtMs sets the CompletedAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusCompleted) SetContentRef

func (u *UploadSessionStatusCompleted) SetContentRef(contentRef *ContentRef)

SetContentRef sets the ContentRef field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusCompleted) SetContentToken

func (u *UploadSessionStatusCompleted) SetContentToken(contentToken *ContentToken)

SetContentToken sets the ContentToken field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusCompleted) SetMode

func (u *UploadSessionStatusCompleted) SetMode(mode UploadMode)

SetMode sets the Mode field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusCompleted) SetNamespaceID

func (u *UploadSessionStatusCompleted) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusCompleted) SetUploadID

func (u *UploadSessionStatusCompleted) SetUploadID(uploadID UploadID)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusCompleted) String

func (*UploadSessionStatusCompleted) UnmarshalJSON

func (u *UploadSessionStatusCompleted) UnmarshalJSON(data []byte) error

type UploadSessionStatusOpen

type UploadSessionStatusOpen struct {
	// Unix-millisecond instant after which the session is abandoned and
	// may be aborted by server-side cleanup.
	ExpiresAtMs int64 `json:"expires_at_ms" url:"expires_at_ms"`
	// Transport selected when the session began.
	Mode UploadMode `json:"mode" url:"mode"`
	// Namespace that owns the session.
	NamespaceID NamespaceID `json:"namespace_id" url:"namespace_id"`
	// Session represented by this view.
	UploadID UploadID `json:"upload_id" url:"upload_id"`
	// contains filtered or unexported fields
}

func (*UploadSessionStatusOpen) GetExpiresAtMs

func (u *UploadSessionStatusOpen) GetExpiresAtMs() int64

func (*UploadSessionStatusOpen) GetExtraProperties

func (u *UploadSessionStatusOpen) GetExtraProperties() map[string]interface{}

func (*UploadSessionStatusOpen) GetMode

func (u *UploadSessionStatusOpen) GetMode() UploadMode

func (*UploadSessionStatusOpen) GetNamespaceID

func (u *UploadSessionStatusOpen) GetNamespaceID() NamespaceID

func (*UploadSessionStatusOpen) GetUploadID

func (u *UploadSessionStatusOpen) GetUploadID() UploadID

func (*UploadSessionStatusOpen) MarshalJSON

func (u *UploadSessionStatusOpen) MarshalJSON() ([]byte, error)

func (*UploadSessionStatusOpen) SetExpiresAtMs

func (u *UploadSessionStatusOpen) SetExpiresAtMs(expiresAtMs int64)

SetExpiresAtMs sets the ExpiresAtMs field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusOpen) SetMode

func (u *UploadSessionStatusOpen) SetMode(mode UploadMode)

SetMode sets the Mode field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusOpen) SetNamespaceID

func (u *UploadSessionStatusOpen) SetNamespaceID(namespaceID NamespaceID)

SetNamespaceID sets the NamespaceID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusOpen) SetUploadID

func (u *UploadSessionStatusOpen) SetUploadID(uploadID UploadID)

SetUploadID sets the UploadID field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*UploadSessionStatusOpen) String

func (u *UploadSessionStatusOpen) String() string

func (*UploadSessionStatusOpen) UnmarshalJSON

func (u *UploadSessionStatusOpen) UnmarshalJSON(data []byte) error

type UploadSessionVisitor

type UploadSessionVisitor interface {
	VisitOpen(*UploadSessionStatusOpen) error
	VisitCompleted(*UploadSessionStatusCompleted) error
	VisitAborted(*UploadSessionStatusAborted) error
}

type WalFlushStepOutcome

type WalFlushStepOutcome struct {
	Outcome          string
	NotNeeded        *WalFlushStepOutcomeNotNeeded
	Flushed          *WalFlushStepOutcomeFlushed
	AlreadyPublished *WalFlushStepOutcomeAlreadyPublished
	RetriesExhausted *WalFlushStepOutcomeRetriesExhausted
	// contains filtered or unexported fields
}

What the WAL-flush part of a maintenance step did.

func (*WalFlushStepOutcome) Accept

func (*WalFlushStepOutcome) GetAlreadyPublished

func (w *WalFlushStepOutcome) GetAlreadyPublished() *WalFlushStepOutcomeAlreadyPublished

func (*WalFlushStepOutcome) GetFlushed

func (*WalFlushStepOutcome) GetNotNeeded

func (*WalFlushStepOutcome) GetOutcome

func (w *WalFlushStepOutcome) GetOutcome() string

func (*WalFlushStepOutcome) GetRetriesExhausted

func (w *WalFlushStepOutcome) GetRetriesExhausted() *WalFlushStepOutcomeRetriesExhausted

func (WalFlushStepOutcome) MarshalJSON

func (w WalFlushStepOutcome) MarshalJSON() ([]byte, error)

func (*WalFlushStepOutcome) UnmarshalJSON

func (w *WalFlushStepOutcome) UnmarshalJSON(data []byte) error

type WalFlushStepOutcomeAlreadyPublished

type WalFlushStepOutcomeAlreadyPublished struct {
	// Sequence this step attempted to flush through.
	AttemptedSeq ChangeSeq `json:"attempted_seq" url:"attempted_seq"`
	// Manifest the root currently references.
	CurrentManifestNo ManifestNo `json:"current_manifest_no" url:"current_manifest_no"`
	// contains filtered or unexported fields
}

func (*WalFlushStepOutcomeAlreadyPublished) GetAttemptedSeq

func (w *WalFlushStepOutcomeAlreadyPublished) GetAttemptedSeq() ChangeSeq

func (*WalFlushStepOutcomeAlreadyPublished) GetCurrentManifestNo

func (w *WalFlushStepOutcomeAlreadyPublished) GetCurrentManifestNo() ManifestNo

func (*WalFlushStepOutcomeAlreadyPublished) GetExtraProperties

func (w *WalFlushStepOutcomeAlreadyPublished) GetExtraProperties() map[string]interface{}

func (*WalFlushStepOutcomeAlreadyPublished) MarshalJSON

func (w *WalFlushStepOutcomeAlreadyPublished) MarshalJSON() ([]byte, error)

func (*WalFlushStepOutcomeAlreadyPublished) SetAttemptedSeq

func (w *WalFlushStepOutcomeAlreadyPublished) SetAttemptedSeq(attemptedSeq ChangeSeq)

SetAttemptedSeq sets the AttemptedSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*WalFlushStepOutcomeAlreadyPublished) SetCurrentManifestNo

func (w *WalFlushStepOutcomeAlreadyPublished) SetCurrentManifestNo(currentManifestNo ManifestNo)

SetCurrentManifestNo sets the CurrentManifestNo field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*WalFlushStepOutcomeAlreadyPublished) String

func (*WalFlushStepOutcomeAlreadyPublished) UnmarshalJSON

func (w *WalFlushStepOutcomeAlreadyPublished) UnmarshalJSON(data []byte) error

type WalFlushStepOutcomeFlushed

type WalFlushStepOutcomeFlushed struct {
	// Sequence covered by the published manifest.
	ManifestHeadSeq ChangeSeq `json:"manifest_head_seq" url:"manifest_head_seq"`
	// contains filtered or unexported fields
}

func (*WalFlushStepOutcomeFlushed) GetExtraProperties

func (w *WalFlushStepOutcomeFlushed) GetExtraProperties() map[string]interface{}

func (*WalFlushStepOutcomeFlushed) GetManifestHeadSeq

func (w *WalFlushStepOutcomeFlushed) GetManifestHeadSeq() ChangeSeq

func (*WalFlushStepOutcomeFlushed) MarshalJSON

func (w *WalFlushStepOutcomeFlushed) MarshalJSON() ([]byte, error)

func (*WalFlushStepOutcomeFlushed) SetManifestHeadSeq

func (w *WalFlushStepOutcomeFlushed) SetManifestHeadSeq(manifestHeadSeq ChangeSeq)

SetManifestHeadSeq sets the ManifestHeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*WalFlushStepOutcomeFlushed) String

func (w *WalFlushStepOutcomeFlushed) String() string

func (*WalFlushStepOutcomeFlushed) UnmarshalJSON

func (w *WalFlushStepOutcomeFlushed) UnmarshalJSON(data []byte) error

type WalFlushStepOutcomeNotNeeded

type WalFlushStepOutcomeNotNeeded struct {
	// contains filtered or unexported fields
}

The tail was below the threshold, so there was nothing to flush.

func (*WalFlushStepOutcomeNotNeeded) GetExtraProperties

func (w *WalFlushStepOutcomeNotNeeded) GetExtraProperties() map[string]interface{}

func (*WalFlushStepOutcomeNotNeeded) MarshalJSON

func (w *WalFlushStepOutcomeNotNeeded) MarshalJSON() ([]byte, error)

func (*WalFlushStepOutcomeNotNeeded) String

func (*WalFlushStepOutcomeNotNeeded) UnmarshalJSON

func (w *WalFlushStepOutcomeNotNeeded) UnmarshalJSON(data []byte) error

type WalFlushStepOutcomeRetriesExhausted

type WalFlushStepOutcomeRetriesExhausted struct {
	// Head sequence observed before the step ran.
	ObservedHeadSeq ChangeSeq `json:"observed_head_seq" url:"observed_head_seq"`
	// contains filtered or unexported fields
}

func (*WalFlushStepOutcomeRetriesExhausted) GetExtraProperties

func (w *WalFlushStepOutcomeRetriesExhausted) GetExtraProperties() map[string]interface{}

func (*WalFlushStepOutcomeRetriesExhausted) GetObservedHeadSeq

func (w *WalFlushStepOutcomeRetriesExhausted) GetObservedHeadSeq() ChangeSeq

func (*WalFlushStepOutcomeRetriesExhausted) MarshalJSON

func (w *WalFlushStepOutcomeRetriesExhausted) MarshalJSON() ([]byte, error)

func (*WalFlushStepOutcomeRetriesExhausted) SetObservedHeadSeq

func (w *WalFlushStepOutcomeRetriesExhausted) SetObservedHeadSeq(observedHeadSeq ChangeSeq)

SetObservedHeadSeq sets the ObservedHeadSeq field and marks it as non-optional; this prevents an empty or null value for this field from being omitted during serialization.

func (*WalFlushStepOutcomeRetriesExhausted) String

func (*WalFlushStepOutcomeRetriesExhausted) UnmarshalJSON

func (w *WalFlushStepOutcomeRetriesExhausted) UnmarshalJSON(data []byte) error

type WalFlushStepOutcomeVisitor

type WalFlushStepOutcomeVisitor interface {
	VisitNotNeeded(*WalFlushStepOutcomeNotNeeded) error
	VisitFlushed(*WalFlushStepOutcomeFlushed) error
	VisitAlreadyPublished(*WalFlushStepOutcomeAlreadyPublished) error
	VisitRetriesExhausted(*WalFlushStepOutcomeRetriesExhausted) error
}

type WriterEpoch

type WriterEpoch = int64

Counter used to reject writes from an older writer.

Directories

Path Synopsis
Administrative maintenance APIs
Administrative maintenance APIs
Path-oriented filesystem APIs
Path-oriented filesystem APIs
Identity-oriented inode read APIs
Identity-oriented inode read APIs
Namespace lifecycle and status
Namespace lifecycle and status
Package proxy forwards LoonFS browser requests to a LoonFS server.
Package proxy forwards LoonFS browser requests to a LoonFS server.
Derived-index query APIs
Derived-index query APIs
Server health, readiness, metrics, and capability discovery
Server health, readiness, metrics, and capability discovery
Package transfers provides in-memory file transfer orchestration for the Go SDK.
Package transfers provides in-memory file transfer orchestration for the Go SDK.
Upload session APIs
Upload session APIs

Jump to

Keyboard shortcuts

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