Documentation ¶
Index ¶
- type DirectRepository
- func (_m *DirectRepository) AlsoLogToContentLog(ctx context.Context) context.Context
- func (_m *DirectRepository) BlobCfg() content.BlobCfgBlob
- func (_m *DirectRepository) BlobReader() blob.Reader
- func (_m *DirectRepository) BlobVolume() blob.Volume
- func (_m *DirectRepository) ClientOptions() repo.ClientOptions
- func (_m *DirectRepository) Close(ctx context.Context) error
- func (_m *DirectRepository) ConfigFilename() string
- func (_m *DirectRepository) ContentInfo(ctx context.Context, contentID index.ID) (index.Info, error)
- func (_m *DirectRepository) ContentReader() content.Reader
- func (_m *DirectRepository) Crypter() *content.Crypter
- func (_m *DirectRepository) DeriveKey(purpose []byte, keyLength int) []byte
- func (_m *DirectRepository) DisableIndexRefresh()
- func (_m *DirectRepository) FindManifests(ctx context.Context, labels map[string]string) ([]*manifest.EntryMetadata, error)
- func (_m *DirectRepository) GetManifest(ctx context.Context, id manifest.ID, data interface{}) (*manifest.EntryMetadata, error)
- func (_m *DirectRepository) IndexBlobs(ctx context.Context, includeInactive bool) ([]content.IndexBlobInfo, error)
- func (_m *DirectRepository) NewDirectWriter(ctx context.Context, opt repo.WriteSessionOptions) (context.Context, repo.DirectRepositoryWriter, error)
- func (_m *DirectRepository) NewWriter(ctx context.Context, opt repo.WriteSessionOptions) (context.Context, repo.RepositoryWriter, error)
- func (_m *DirectRepository) ObjectFormat() object.Format
- func (_m *DirectRepository) OpenObject(ctx context.Context, id object.ID) (object.Reader, error)
- func (_m *DirectRepository) PrefetchContents(ctx context.Context, contentIDs []index.ID, hint string) []index.ID
- func (_m *DirectRepository) PrefetchObjects(ctx context.Context, objectIDs []object.ID, hint string) ([]index.ID, error)
- func (_m *DirectRepository) Refresh(ctx context.Context) error
- func (_m *DirectRepository) Throttler() throttling.SettableThrottler
- func (_m *DirectRepository) Time() time.Time
- func (_m *DirectRepository) Token(password string) (string, error)
- func (_m *DirectRepository) UniqueID() []byte
- func (_m *DirectRepository) UpdateDescription(d string)
- func (_m *DirectRepository) VerifyObject(ctx context.Context, id object.ID) ([]index.ID, error)
- type DirectRepositoryWriter
- func (_m *DirectRepositoryWriter) AlsoLogToContentLog(ctx context.Context) context.Context
- func (_m *DirectRepositoryWriter) BlobCfg() content.BlobCfgBlob
- func (_m *DirectRepositoryWriter) BlobReader() blob.Reader
- func (_m *DirectRepositoryWriter) BlobStorage() blob.Storage
- func (_m *DirectRepositoryWriter) BlobVolume() blob.Volume
- func (_m *DirectRepositoryWriter) ChangePassword(ctx context.Context, newPassword string) error
- func (_m *DirectRepositoryWriter) ClientOptions() repo.ClientOptions
- func (_m *DirectRepositoryWriter) Close(ctx context.Context) error
- func (_m *DirectRepositoryWriter) CommitUpgrade(ctx context.Context) error
- func (_m *DirectRepositoryWriter) ConfigFilename() string
- func (_m *DirectRepositoryWriter) ContentInfo(ctx context.Context, contentID index.ID) (index.Info, error)
- func (_m *DirectRepositoryWriter) ContentManager() *content.WriteManager
- func (_m *DirectRepositoryWriter) ContentReader() content.Reader
- func (_m *DirectRepositoryWriter) Crypter() *content.Crypter
- func (_m *DirectRepositoryWriter) DeleteManifest(ctx context.Context, id manifest.ID) error
- func (_m *DirectRepositoryWriter) DeriveKey(purpose []byte, keyLength int) []byte
- func (_m *DirectRepositoryWriter) DisableIndexRefresh()
- func (_m *DirectRepositoryWriter) FindManifests(ctx context.Context, labels map[string]string) ([]*manifest.EntryMetadata, error)
- func (_m *DirectRepositoryWriter) Flush(ctx context.Context) error
- func (_m *DirectRepositoryWriter) GetManifest(ctx context.Context, id manifest.ID, data interface{}) (*manifest.EntryMetadata, error)
- func (_m *DirectRepositoryWriter) IndexBlobs(ctx context.Context, includeInactive bool) ([]content.IndexBlobInfo, error)
- func (_m *DirectRepositoryWriter) NewDirectWriter(ctx context.Context, opt repo.WriteSessionOptions) (context.Context, repo.DirectRepositoryWriter, error)
- func (_m *DirectRepositoryWriter) NewObjectWriter(ctx context.Context, opt object.WriterOptions) object.Writer
- func (_m *DirectRepositoryWriter) NewWriter(ctx context.Context, opt repo.WriteSessionOptions) (context.Context, repo.RepositoryWriter, error)
- func (_m *DirectRepositoryWriter) ObjectFormat() object.Format
- func (_m *DirectRepositoryWriter) OpenObject(ctx context.Context, id object.ID) (object.Reader, error)
- func (_m *DirectRepositoryWriter) PrefetchContents(ctx context.Context, contentIDs []index.ID, hint string) []index.ID
- func (_m *DirectRepositoryWriter) PrefetchObjects(ctx context.Context, objectIDs []object.ID, hint string) ([]index.ID, error)
- func (_m *DirectRepositoryWriter) PutManifest(ctx context.Context, labels map[string]string, payload interface{}) (manifest.ID, error)
- func (_m *DirectRepositoryWriter) Refresh(ctx context.Context) error
- func (_m *DirectRepositoryWriter) RollbackUpgrade(ctx context.Context) error
- func (_m *DirectRepositoryWriter) SetParameters(ctx context.Context, m content.MutableParameters, blobcfg content.BlobCfgBlob) error
- func (_m *DirectRepositoryWriter) SetUpgradeLockIntent(ctx context.Context, l content.UpgradeLock) (*content.UpgradeLock, error)
- func (_m *DirectRepositoryWriter) Throttler() throttling.SettableThrottler
- func (_m *DirectRepositoryWriter) Time() time.Time
- func (_m *DirectRepositoryWriter) Token(password string) (string, error)
- func (_m *DirectRepositoryWriter) UniqueID() []byte
- func (_m *DirectRepositoryWriter) UpdateDescription(d string)
- func (_m *DirectRepositoryWriter) VerifyObject(ctx context.Context, id object.ID) ([]index.ID, error)
- type Logger
- type Storage
- func (_m *Storage) Close(ctx context.Context) error
- func (_m *Storage) ConnectionInfo() blob.ConnectionInfo
- func (_m *Storage) DeleteBlob(ctx context.Context, blobID blob.ID) error
- func (_m *Storage) DisplayName() string
- func (_m *Storage) FlushCaches(ctx context.Context) error
- func (_m *Storage) GetBlob(ctx context.Context, blobID blob.ID, offset int64, length int64, ...) error
- func (_m *Storage) GetCapacity(ctx context.Context) (blob.Capacity, error)
- func (_m *Storage) GetMetadata(ctx context.Context, blobID blob.ID) (blob.Metadata, error)
- func (_m *Storage) ListBlobs(ctx context.Context, blobIDPrefix blob.ID, cb func(blob.Metadata) error) error
- func (_m *Storage) PutBlob(ctx context.Context, blobID blob.ID, data blob.Bytes, opts blob.PutOptions) error
- type Store
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DirectRepository ¶
DirectRepository is an autogenerated mock type for the DirectRepository type
func NewDirectRepository ¶
func NewDirectRepository(t mockConstructorTestingTNewDirectRepository) *DirectRepository
NewDirectRepository creates a new instance of DirectRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*DirectRepository) AlsoLogToContentLog ¶
func (_m *DirectRepository) AlsoLogToContentLog(ctx context.Context) context.Context
AlsoLogToContentLog provides a mock function with given fields: ctx
func (*DirectRepository) BlobCfg ¶
func (_m *DirectRepository) BlobCfg() content.BlobCfgBlob
BlobCfg provides a mock function with given fields:
func (*DirectRepository) BlobReader ¶
func (_m *DirectRepository) BlobReader() blob.Reader
BlobReader provides a mock function with given fields:
func (*DirectRepository) BlobVolume ¶
func (_m *DirectRepository) BlobVolume() blob.Volume
BlobVolume provides a mock function with given fields:
func (*DirectRepository) ClientOptions ¶
func (_m *DirectRepository) ClientOptions() repo.ClientOptions
ClientOptions provides a mock function with given fields:
func (*DirectRepository) Close ¶
func (_m *DirectRepository) Close(ctx context.Context) error
Close provides a mock function with given fields: ctx
func (*DirectRepository) ConfigFilename ¶
func (_m *DirectRepository) ConfigFilename() string
ConfigFilename provides a mock function with given fields:
func (*DirectRepository) ContentInfo ¶
func (_m *DirectRepository) ContentInfo(ctx context.Context, contentID index.ID) (index.Info, error)
ContentInfo provides a mock function with given fields: ctx, contentID
func (*DirectRepository) ContentReader ¶
func (_m *DirectRepository) ContentReader() content.Reader
ContentReader provides a mock function with given fields:
func (*DirectRepository) Crypter ¶
func (_m *DirectRepository) Crypter() *content.Crypter
Crypter provides a mock function with given fields:
func (*DirectRepository) DeriveKey ¶
func (_m *DirectRepository) DeriveKey(purpose []byte, keyLength int) []byte
DeriveKey provides a mock function with given fields: purpose, keyLength
func (*DirectRepository) DisableIndexRefresh ¶
func (_m *DirectRepository) DisableIndexRefresh()
DisableIndexRefresh provides a mock function with given fields:
func (*DirectRepository) FindManifests ¶
func (_m *DirectRepository) FindManifests(ctx context.Context, labels map[string]string) ([]*manifest.EntryMetadata, error)
FindManifests provides a mock function with given fields: ctx, labels
func (*DirectRepository) GetManifest ¶
func (_m *DirectRepository) GetManifest(ctx context.Context, id manifest.ID, data interface{}) (*manifest.EntryMetadata, error)
GetManifest provides a mock function with given fields: ctx, id, data
func (*DirectRepository) IndexBlobs ¶
func (_m *DirectRepository) IndexBlobs(ctx context.Context, includeInactive bool) ([]content.IndexBlobInfo, error)
IndexBlobs provides a mock function with given fields: ctx, includeInactive
func (*DirectRepository) NewDirectWriter ¶
func (_m *DirectRepository) NewDirectWriter(ctx context.Context, opt repo.WriteSessionOptions) (context.Context, repo.DirectRepositoryWriter, error)
NewDirectWriter provides a mock function with given fields: ctx, opt
func (*DirectRepository) NewWriter ¶
func (_m *DirectRepository) NewWriter(ctx context.Context, opt repo.WriteSessionOptions) (context.Context, repo.RepositoryWriter, error)
NewWriter provides a mock function with given fields: ctx, opt
func (*DirectRepository) ObjectFormat ¶
func (_m *DirectRepository) ObjectFormat() object.Format
ObjectFormat provides a mock function with given fields:
func (*DirectRepository) OpenObject ¶
OpenObject provides a mock function with given fields: ctx, id
func (*DirectRepository) PrefetchContents ¶
func (_m *DirectRepository) PrefetchContents(ctx context.Context, contentIDs []index.ID, hint string) []index.ID
PrefetchContents provides a mock function with given fields: ctx, contentIDs, hint
func (*DirectRepository) PrefetchObjects ¶
func (_m *DirectRepository) PrefetchObjects(ctx context.Context, objectIDs []object.ID, hint string) ([]index.ID, error)
PrefetchObjects provides a mock function with given fields: ctx, objectIDs, hint
func (*DirectRepository) Refresh ¶
func (_m *DirectRepository) Refresh(ctx context.Context) error
Refresh provides a mock function with given fields: ctx
func (*DirectRepository) Throttler ¶
func (_m *DirectRepository) Throttler() throttling.SettableThrottler
Throttler provides a mock function with given fields:
func (*DirectRepository) Time ¶
func (_m *DirectRepository) Time() time.Time
Time provides a mock function with given fields:
func (*DirectRepository) Token ¶
func (_m *DirectRepository) Token(password string) (string, error)
Token provides a mock function with given fields: password
func (*DirectRepository) UniqueID ¶
func (_m *DirectRepository) UniqueID() []byte
UniqueID provides a mock function with given fields:
func (*DirectRepository) UpdateDescription ¶
func (_m *DirectRepository) UpdateDescription(d string)
UpdateDescription provides a mock function with given fields: d
func (*DirectRepository) VerifyObject ¶
VerifyObject provides a mock function with given fields: ctx, id
type DirectRepositoryWriter ¶
DirectRepositoryWriter is an autogenerated mock type for the DirectRepositoryWriter type
func NewDirectRepositoryWriter ¶
func NewDirectRepositoryWriter(t mockConstructorTestingTNewDirectRepositoryWriter) *DirectRepositoryWriter
NewDirectRepositoryWriter creates a new instance of DirectRepositoryWriter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*DirectRepositoryWriter) AlsoLogToContentLog ¶
func (_m *DirectRepositoryWriter) AlsoLogToContentLog(ctx context.Context) context.Context
AlsoLogToContentLog provides a mock function with given fields: ctx
func (*DirectRepositoryWriter) BlobCfg ¶
func (_m *DirectRepositoryWriter) BlobCfg() content.BlobCfgBlob
BlobCfg provides a mock function with given fields:
func (*DirectRepositoryWriter) BlobReader ¶
func (_m *DirectRepositoryWriter) BlobReader() blob.Reader
BlobReader provides a mock function with given fields:
func (*DirectRepositoryWriter) BlobStorage ¶
func (_m *DirectRepositoryWriter) BlobStorage() blob.Storage
BlobStorage provides a mock function with given fields:
func (*DirectRepositoryWriter) BlobVolume ¶
func (_m *DirectRepositoryWriter) BlobVolume() blob.Volume
BlobVolume provides a mock function with given fields:
func (*DirectRepositoryWriter) ChangePassword ¶
func (_m *DirectRepositoryWriter) ChangePassword(ctx context.Context, newPassword string) error
ChangePassword provides a mock function with given fields: ctx, newPassword
func (*DirectRepositoryWriter) ClientOptions ¶
func (_m *DirectRepositoryWriter) ClientOptions() repo.ClientOptions
ClientOptions provides a mock function with given fields:
func (*DirectRepositoryWriter) Close ¶
func (_m *DirectRepositoryWriter) Close(ctx context.Context) error
Close provides a mock function with given fields: ctx
func (*DirectRepositoryWriter) CommitUpgrade ¶
func (_m *DirectRepositoryWriter) CommitUpgrade(ctx context.Context) error
CommitUpgrade provides a mock function with given fields: ctx
func (*DirectRepositoryWriter) ConfigFilename ¶
func (_m *DirectRepositoryWriter) ConfigFilename() string
ConfigFilename provides a mock function with given fields:
func (*DirectRepositoryWriter) ContentInfo ¶
func (_m *DirectRepositoryWriter) ContentInfo(ctx context.Context, contentID index.ID) (index.Info, error)
ContentInfo provides a mock function with given fields: ctx, contentID
func (*DirectRepositoryWriter) ContentManager ¶
func (_m *DirectRepositoryWriter) ContentManager() *content.WriteManager
ContentManager provides a mock function with given fields:
func (*DirectRepositoryWriter) ContentReader ¶
func (_m *DirectRepositoryWriter) ContentReader() content.Reader
ContentReader provides a mock function with given fields:
func (*DirectRepositoryWriter) Crypter ¶
func (_m *DirectRepositoryWriter) Crypter() *content.Crypter
Crypter provides a mock function with given fields:
func (*DirectRepositoryWriter) DeleteManifest ¶
DeleteManifest provides a mock function with given fields: ctx, id
func (*DirectRepositoryWriter) DeriveKey ¶
func (_m *DirectRepositoryWriter) DeriveKey(purpose []byte, keyLength int) []byte
DeriveKey provides a mock function with given fields: purpose, keyLength
func (*DirectRepositoryWriter) DisableIndexRefresh ¶
func (_m *DirectRepositoryWriter) DisableIndexRefresh()
DisableIndexRefresh provides a mock function with given fields:
func (*DirectRepositoryWriter) FindManifests ¶
func (_m *DirectRepositoryWriter) FindManifests(ctx context.Context, labels map[string]string) ([]*manifest.EntryMetadata, error)
FindManifests provides a mock function with given fields: ctx, labels
func (*DirectRepositoryWriter) Flush ¶
func (_m *DirectRepositoryWriter) Flush(ctx context.Context) error
Flush provides a mock function with given fields: ctx
func (*DirectRepositoryWriter) GetManifest ¶
func (_m *DirectRepositoryWriter) GetManifest(ctx context.Context, id manifest.ID, data interface{}) (*manifest.EntryMetadata, error)
GetManifest provides a mock function with given fields: ctx, id, data
func (*DirectRepositoryWriter) IndexBlobs ¶
func (_m *DirectRepositoryWriter) IndexBlobs(ctx context.Context, includeInactive bool) ([]content.IndexBlobInfo, error)
IndexBlobs provides a mock function with given fields: ctx, includeInactive
func (*DirectRepositoryWriter) NewDirectWriter ¶
func (_m *DirectRepositoryWriter) NewDirectWriter(ctx context.Context, opt repo.WriteSessionOptions) (context.Context, repo.DirectRepositoryWriter, error)
NewDirectWriter provides a mock function with given fields: ctx, opt
func (*DirectRepositoryWriter) NewObjectWriter ¶
func (_m *DirectRepositoryWriter) NewObjectWriter(ctx context.Context, opt object.WriterOptions) object.Writer
NewObjectWriter provides a mock function with given fields: ctx, opt
func (*DirectRepositoryWriter) NewWriter ¶
func (_m *DirectRepositoryWriter) NewWriter(ctx context.Context, opt repo.WriteSessionOptions) (context.Context, repo.RepositoryWriter, error)
NewWriter provides a mock function with given fields: ctx, opt
func (*DirectRepositoryWriter) ObjectFormat ¶
func (_m *DirectRepositoryWriter) ObjectFormat() object.Format
ObjectFormat provides a mock function with given fields:
func (*DirectRepositoryWriter) OpenObject ¶
func (_m *DirectRepositoryWriter) OpenObject(ctx context.Context, id object.ID) (object.Reader, error)
OpenObject provides a mock function with given fields: ctx, id
func (*DirectRepositoryWriter) PrefetchContents ¶
func (_m *DirectRepositoryWriter) PrefetchContents(ctx context.Context, contentIDs []index.ID, hint string) []index.ID
PrefetchContents provides a mock function with given fields: ctx, contentIDs, hint
func (*DirectRepositoryWriter) PrefetchObjects ¶
func (_m *DirectRepositoryWriter) PrefetchObjects(ctx context.Context, objectIDs []object.ID, hint string) ([]index.ID, error)
PrefetchObjects provides a mock function with given fields: ctx, objectIDs, hint
func (*DirectRepositoryWriter) PutManifest ¶
func (_m *DirectRepositoryWriter) PutManifest(ctx context.Context, labels map[string]string, payload interface{}) (manifest.ID, error)
PutManifest provides a mock function with given fields: ctx, labels, payload
func (*DirectRepositoryWriter) Refresh ¶
func (_m *DirectRepositoryWriter) Refresh(ctx context.Context) error
Refresh provides a mock function with given fields: ctx
func (*DirectRepositoryWriter) RollbackUpgrade ¶
func (_m *DirectRepositoryWriter) RollbackUpgrade(ctx context.Context) error
RollbackUpgrade provides a mock function with given fields: ctx
func (*DirectRepositoryWriter) SetParameters ¶
func (_m *DirectRepositoryWriter) SetParameters(ctx context.Context, m content.MutableParameters, blobcfg content.BlobCfgBlob) error
SetParameters provides a mock function with given fields: ctx, m, blobcfg
func (*DirectRepositoryWriter) SetUpgradeLockIntent ¶
func (_m *DirectRepositoryWriter) SetUpgradeLockIntent(ctx context.Context, l content.UpgradeLock) (*content.UpgradeLock, error)
SetUpgradeLockIntent provides a mock function with given fields: ctx, l
func (*DirectRepositoryWriter) Throttler ¶
func (_m *DirectRepositoryWriter) Throttler() throttling.SettableThrottler
Throttler provides a mock function with given fields:
func (*DirectRepositoryWriter) Time ¶
func (_m *DirectRepositoryWriter) Time() time.Time
Time provides a mock function with given fields:
func (*DirectRepositoryWriter) Token ¶
func (_m *DirectRepositoryWriter) Token(password string) (string, error)
Token provides a mock function with given fields: password
func (*DirectRepositoryWriter) UniqueID ¶
func (_m *DirectRepositoryWriter) UniqueID() []byte
UniqueID provides a mock function with given fields:
func (*DirectRepositoryWriter) UpdateDescription ¶
func (_m *DirectRepositoryWriter) UpdateDescription(d string)
UpdateDescription provides a mock function with given fields: d
func (*DirectRepositoryWriter) VerifyObject ¶
func (_m *DirectRepositoryWriter) VerifyObject(ctx context.Context, id object.ID) ([]index.ID, error)
VerifyObject provides a mock function with given fields: ctx, id
type Logger ¶
Logger is an autogenerated mock type for the Logger type
func NewLogger ¶
func NewLogger(t mockConstructorTestingTNewLogger) *Logger
NewLogger creates a new instance of Logger. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
type Storage ¶
Storage is an autogenerated mock type for the Storage type
func NewStorage ¶
func NewStorage(t mockConstructorTestingTNewStorage) *Storage
NewStorage creates a new instance of Storage. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Storage) ConnectionInfo ¶
func (_m *Storage) ConnectionInfo() blob.ConnectionInfo
ConnectionInfo provides a mock function with given fields:
func (*Storage) DeleteBlob ¶
DeleteBlob provides a mock function with given fields: ctx, blobID
func (*Storage) DisplayName ¶
DisplayName provides a mock function with given fields:
func (*Storage) FlushCaches ¶
FlushCaches provides a mock function with given fields: ctx
func (*Storage) GetBlob ¶
func (_m *Storage) GetBlob(ctx context.Context, blobID blob.ID, offset int64, length int64, output blob.OutputBuffer) error
GetBlob provides a mock function with given fields: ctx, blobID, offset, length, output
func (*Storage) GetCapacity ¶
GetCapacity provides a mock function with given fields: ctx
func (*Storage) GetMetadata ¶
GetMetadata provides a mock function with given fields: ctx, blobID
type Store ¶
Store is an autogenerated mock type for the Store type
func NewStore ¶
func NewStore(t mockConstructorTestingTNewStore) *Store
NewStore creates a new instance of Store. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.