filesystem

Documentation

Index

• type StorageDriver
  • func (d *StorageDriver) AbortBlobUpload(ctx context.Context, account models.ReducedAccount, storageID string, ...) error
  • func (d *StorageDriver) AppendToBlob(ctx context.Context, account models.ReducedAccount, storageID string, ...) error
  • func (d *StorageDriver) CanSetupAccount(ctx context.Context, account models.ReducedAccount) error
  • func (d *StorageDriver) CleanupAccount(ctx context.Context, account models.ReducedAccount) error
  • func (d *StorageDriver) DeleteBlob(ctx context.Context, account models.ReducedAccount, storageID string) error
  • func (d *StorageDriver) DeleteManifest(ctx context.Context, account models.ReducedAccount, repoName string, ...) error
  • func (d *StorageDriver) FinalizeBlob(ctx context.Context, account models.ReducedAccount, storageID string, ...) error
  • func (d *StorageDriver) Init(ad keppel.AuthDriver, cfg keppel.Configuration) (err error)
  • func (d *StorageDriver) ListStorageContents(ctx context.Context, account models.ReducedAccount) ([]keppel.StoredBlobInfo, []keppel.StoredManifestInfo, error)
  • func (d *StorageDriver) PluginTypeID() string
  • func (d *StorageDriver) ReadBlob(ctx context.Context, account models.ReducedAccount, storageID string) (io.ReadCloser, uint64, error)
  • func (d *StorageDriver) ReadManifest(ctx context.Context, account models.ReducedAccount, repoName string, ...) ([]byte, error)
  • func (d *StorageDriver) URLForBlob(ctx context.Context, account models.ReducedAccount, storageID string) (string, error)
  • func (d *StorageDriver) WriteManifest(ctx context.Context, account models.ReducedAccount, repoName string, ...) error

Types

type StorageDriver

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

StorageDriver (driver ID "filesystem") is a keppel.StorageDriver that stores its contents in the local filesystem.

func (*StorageDriver) AbortBlobUpload

func (d *StorageDriver) AbortBlobUpload(ctx context.Context, account models.ReducedAccount, storageID string, chunkCount uint32) error

AbortBlobUpload implements the keppel.StorageDriver interface.

func (*StorageDriver) AppendToBlob

func (d *StorageDriver) AppendToBlob(ctx context.Context, account models.ReducedAccount, storageID string, chunkNumber uint32, chunkLength *uint64, chunk io.Reader) error

AppendToBlob implements the keppel.StorageDriver interface.

func (*StorageDriver) CanSetupAccount

func (d *StorageDriver) CanSetupAccount(ctx context.Context, account models.ReducedAccount) error

CanSetupAccount implements the keppel.StorageDriver interface.

func (*StorageDriver) CleanupAccount

func (d *StorageDriver) CleanupAccount(ctx context.Context, account models.ReducedAccount) error

CleanupAccount implements the keppel.StorageDriver interface.

func (*StorageDriver) DeleteBlob

func (d *StorageDriver) DeleteBlob(ctx context.Context, account models.ReducedAccount, storageID string) error

DeleteBlob implements the keppel.StorageDriver interface.

func (*StorageDriver) DeleteManifest

func (d *StorageDriver) DeleteManifest(ctx context.Context, account models.ReducedAccount, repoName string, manifestDigest digest.Digest) error

DeleteManifest implements the keppel.StorageDriver interface.

func (*StorageDriver) FinalizeBlob

func (d *StorageDriver) FinalizeBlob(ctx context.Context, account models.ReducedAccount, storageID string, chunkCount uint32) error

FinalizeBlob implements the keppel.StorageDriver interface.

func (*StorageDriver) Init

func (d *StorageDriver) Init(ad keppel.AuthDriver, cfg keppel.Configuration) (err error)

Init implements the keppel.StorageDriver interface.

func (*StorageDriver) ListStorageContents

func (d *StorageDriver) ListStorageContents(ctx context.Context, account models.ReducedAccount) ([]keppel.StoredBlobInfo, []keppel.StoredManifestInfo, error)

ListStorageContents implements the keppel.StorageDriver interface.

func (*StorageDriver) PluginTypeID

func (d *StorageDriver) PluginTypeID() string

PluginTypeID implements the keppel.StorageDriver interface.

func (*StorageDriver) ReadBlob

func (d *StorageDriver) ReadBlob(ctx context.Context, account models.ReducedAccount, storageID string) (io.ReadCloser, uint64, error)

ReadBlob implements the keppel.StorageDriver interface.

func (*StorageDriver) ReadManifest

func (d *StorageDriver) ReadManifest(ctx context.Context, account models.ReducedAccount, repoName string, manifestDigest digest.Digest) ([]byte, error)

ReadManifest implements the keppel.StorageDriver interface.

func (*StorageDriver) URLForBlob

func (d *StorageDriver) URLForBlob(ctx context.Context, account models.ReducedAccount, storageID string) (string, error)

URLForBlob implements the keppel.StorageDriver interface.

func (*StorageDriver) WriteManifest

func (d *StorageDriver) WriteManifest(ctx context.Context, account models.ReducedAccount, repoName string, manifestDigest digest.Digest, contents []byte) error

WriteManifest implements the keppel.StorageDriver interface.