bucket

Documentation

Index

• Variables
• func IsNoSuchKey(err error) bool
• type Client
  • func OpenShared() *Client
  • func (c *Client) DownloadBlob(ctx context.Context, digests digest.ForRestore, file *os.File) error
  • func (c *Client) GetManifests(ctx context.Context, identity manifests.NodeIdentity, ...) ([]manifests.Manifest, error)
  • func (c *Client) ListHostNames(ctx context.Context, cluster string) ([]manifests.NodeIdentity, error)
  • func (c *Client) ListManifests(ctx context.Context, identity manifests.NodeIdentity, ...) (manifests.ManifestKeys, error)
  • func (c *Client) PutBlob(ctx context.Context, file paranoid.File, digests digest.ForUpload) error
  • func (c *Client) PutManifest(ctx context.Context, identity manifests.NodeIdentity, ...) error
• type ExistsCache
  • func (e *ExistsCache) Get(restore digest.ForRestore) bool
  • func (e *ExistsCache) Put(restore digest.ForRestore, lockedUntil time.Time)

Variables

var UploadSkipped = errors.New("upload skipped")

Functions

func IsNoSuchKey

func IsNoSuchKey(err error) bool

Types

type Client

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

var (
	Shared *Client
)

func OpenShared

func OpenShared() *Client

func (*Client) DownloadBlob

func (c *Client) DownloadBlob(ctx context.Context, digests digest.ForRestore, file *os.File) error

func (*Client) GetManifests

func (c *Client) GetManifests(ctx context.Context, identity manifests.NodeIdentity, keys manifests.ManifestKeys) ([]manifests.Manifest, error)

func (*Client) ListHostNames

func (c *Client) ListHostNames(ctx context.Context, cluster string) ([]manifests.NodeIdentity, error)

func (*Client) ListManifests

func (c *Client) ListManifests(ctx context.Context, identity manifests.NodeIdentity, startAfter, notAfter unixtime.Seconds) (manifests.ManifestKeys, error)

func (*Client) PutBlob

func (c *Client) PutBlob(ctx context.Context, file paranoid.File, digests digest.ForUpload) error

func (*Client) PutManifest

func (c *Client) PutManifest(ctx context.Context, identity manifests.NodeIdentity, manifest manifests.Manifest) error

type ExistsCache

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

func (*ExistsCache) Get

func (e *ExistsCache) Get(restore digest.ForRestore) bool

func (*ExistsCache) Put

func (e *ExistsCache) Put(restore digest.ForRestore, lockedUntil time.Time)