Documentation
¶
Overview ¶
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Index ¶
- type DeletionRepository
- func (m *DeletionRepository) Create(arg0 context.Context, arg1 *deletion.Deletion) error
- func (m *DeletionRepository) Delete(arg0 context.Context, arg1 *deletion.Deletion) error
- func (m *DeletionRepository) EXPECT() *DeletionRepositoryMockRecorder
- func (m *DeletionRepository) First(arg0 context.Context) (*deletion.Deletion, error)
- type DeletionRepositoryMockRecorder
- type FileRepository
- func (m *FileRepository) All(arg0 context.Context) ([]*file.File, error)
- func (m *FileRepository) CreateOrReplace(arg0 context.Context, arg1 *file.File) error
- func (m *FileRepository) DeleteAll(arg0 context.Context) error
- func (m *FileRepository) DeleteBySignature(arg0 context.Context, arg1 string) error
- func (m *FileRepository) EXPECT() *FileRepositoryMockRecorder
- func (m *FileRepository) FindBySignature(arg0 context.Context, arg1 string) (*file.File, error)
- type FileRepositoryMockRecorder
- func (mr *FileRepositoryMockRecorder) All(arg0 interface{}) *gomock.Call
- func (mr *FileRepositoryMockRecorder) CreateOrReplace(arg0, arg1 interface{}) *gomock.Call
- func (mr *FileRepositoryMockRecorder) DeleteAll(arg0 interface{}) *gomock.Call
- func (mr *FileRepositoryMockRecorder) DeleteBySignature(arg0, arg1 interface{}) *gomock.Call
- func (mr *FileRepositoryMockRecorder) FindBySignature(arg0, arg1 interface{}) *gomock.Call
- type Fs
- func (m *Fs) Chmod(arg0 string, arg1 fs.FileMode) error
- func (m *Fs) Chown(arg0 string, arg1, arg2 int) error
- func (m *Fs) Chtimes(arg0 string, arg1, arg2 time.Time) error
- func (m *Fs) Create(arg0 string) (afero.File, error)
- func (m *Fs) EXPECT() *FsMockRecorder
- func (m *Fs) Mkdir(arg0 string, arg1 fs.FileMode) error
- func (m *Fs) MkdirAll(arg0 string, arg1 fs.FileMode) error
- func (m *Fs) Name() string
- func (m *Fs) Open(arg0 string) (afero.File, error)
- func (m *Fs) OpenFile(arg0 string, arg1 int, arg2 fs.FileMode) (afero.File, error)
- func (m *Fs) Remove(arg0 string) error
- func (m *Fs) RemoveAll(arg0 string) error
- func (m *Fs) Rename(arg0, arg1 string) error
- func (m *Fs) Stat(arg0 string) (fs.FileInfo, error)
- type FsMockRecorder
- func (mr *FsMockRecorder) Chmod(arg0, arg1 interface{}) *gomock.Call
- func (mr *FsMockRecorder) Chown(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *FsMockRecorder) Chtimes(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *FsMockRecorder) Create(arg0 interface{}) *gomock.Call
- func (mr *FsMockRecorder) Mkdir(arg0, arg1 interface{}) *gomock.Call
- func (mr *FsMockRecorder) MkdirAll(arg0, arg1 interface{}) *gomock.Call
- func (mr *FsMockRecorder) Name() *gomock.Call
- func (mr *FsMockRecorder) Open(arg0 interface{}) *gomock.Call
- func (mr *FsMockRecorder) OpenFile(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *FsMockRecorder) Remove(arg0 interface{}) *gomock.Call
- func (mr *FsMockRecorder) RemoveAll(arg0 interface{}) *gomock.Call
- func (mr *FsMockRecorder) Rename(arg0, arg1 interface{}) *gomock.Call
- func (mr *FsMockRecorder) Stat(arg0 interface{}) *gomock.Call
- type IDXKeyRepository
- func (m *IDXKeyRepository) CreateOrReplace(arg0 context.Context, arg1 *idxkey.IDXKey) error
- func (m *IDXKeyRepository) DeleteAll(arg0 context.Context) error
- func (m *IDXKeyRepository) DeleteByKey(arg0 context.Context, arg1 string) error
- func (m *IDXKeyRepository) EXPECT() *IDXKeyRepositoryMockRecorder
- func (m *IDXKeyRepository) FindByKey(arg0 context.Context, arg1 string) (*idxkey.IDXKey, error)
- type IDXKeyRepositoryMockRecorder
- func (mr *IDXKeyRepositoryMockRecorder) CreateOrReplace(arg0, arg1 interface{}) *gomock.Call
- func (mr *IDXKeyRepositoryMockRecorder) DeleteAll(arg0 interface{}) *gomock.Call
- func (mr *IDXKeyRepositoryMockRecorder) DeleteByKey(arg0, arg1 interface{}) *gomock.Call
- func (mr *IDXKeyRepositoryMockRecorder) FindByKey(arg0, arg1 interface{}) *gomock.Call
- type IDXTTLRepository
- func (m *IDXTTLRepository) CreateOrReplace(arg0 context.Context, arg1 *idxttl.IDXTTL) error
- func (m *IDXTTLRepository) Delete(arg0 context.Context, arg1 time.Time) error
- func (m *IDXTTLRepository) EXPECT() *IDXTTLRepositoryMockRecorder
- func (m *IDXTTLRepository) Filter(arg0 context.Context, arg1 time.Time) ([]*idxttl.IDXTTL, error)
- func (m *IDXTTLRepository) Find(arg0 context.Context, arg1 time.Time) (*idxttl.IDXTTL, error)
- type IDXTTLRepositoryMockRecorder
- func (mr *IDXTTLRepositoryMockRecorder) CreateOrReplace(arg0, arg1 interface{}) *gomock.Call
- func (mr *IDXTTLRepositoryMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *IDXTTLRepositoryMockRecorder) Filter(arg0, arg1 interface{}) *gomock.Call
- func (mr *IDXTTLRepositoryMockRecorder) Find(arg0, arg1 interface{}) *gomock.Call
- type IDXVolumeRepository
- func (m *IDXVolumeRepository) CreateOrReplace(arg0 context.Context, arg1 *idxvolume.IDXVolume) error
- func (m *IDXVolumeRepository) DeleteAll(arg0 context.Context) error
- func (m *IDXVolumeRepository) DeleteByKey(arg0 context.Context, arg1 string) error
- func (m *IDXVolumeRepository) EXPECT() *IDXVolumeRepositoryMockRecorder
- func (m *IDXVolumeRepository) FindByVolumeID(arg0 context.Context, arg1 string) (*idxvolume.IDXVolume, error)
- type IDXVolumeRepositoryMockRecorder
- func (mr *IDXVolumeRepositoryMockRecorder) CreateOrReplace(arg0, arg1 interface{}) *gomock.Call
- func (mr *IDXVolumeRepositoryMockRecorder) DeleteAll(arg0 interface{}) *gomock.Call
- func (mr *IDXVolumeRepositoryMockRecorder) DeleteByKey(arg0, arg1 interface{}) *gomock.Call
- func (mr *IDXVolumeRepositoryMockRecorder) FindByVolumeID(arg0, arg1 interface{}) *gomock.Call
- type Membership
- func (m *Membership) AllVolumeIDs() []string
- func (m *Membership) EXPECT() *MembershipMockRecorder
- func (m *Membership) GetNodeState(arg0 string) (*membership.State, error)
- func (m *Membership) GetNodeWithVolumeByID(arg0 string) (*client.Client, error)
- func (m *Membership) Leave()
- func (m *Membership) LocalVolumes() []volume.Local
- func (m *Membership) Nodes() []*client.Client
- func (m *Membership) NodesWithCapacity(arg0 int64) []*client.Client
- func (m *Membership) NodesWithoutVolumeIDs(arg0 []string) []*client.Client
- func (m *Membership) RemovedVolumeIDs() []string
- func (m *Membership) SetDraining(arg0 bool)
- type MembershipMockRecorder
- func (mr *MembershipMockRecorder) AllVolumeIDs() *gomock.Call
- func (mr *MembershipMockRecorder) GetNodeState(arg0 interface{}) *gomock.Call
- func (mr *MembershipMockRecorder) GetNodeWithVolumeByID(arg0 interface{}) *gomock.Call
- func (mr *MembershipMockRecorder) Leave() *gomock.Call
- func (mr *MembershipMockRecorder) LocalVolumes() *gomock.Call
- func (mr *MembershipMockRecorder) Nodes() *gomock.Call
- func (mr *MembershipMockRecorder) NodesWithCapacity(arg0 interface{}) *gomock.Call
- func (mr *MembershipMockRecorder) NodesWithoutVolumeIDs(arg0 interface{}) *gomock.Call
- func (mr *MembershipMockRecorder) RemovedVolumeIDs() *gomock.Call
- func (mr *MembershipMockRecorder) SetDraining(arg0 interface{}) *gomock.Call
- type ReplicaRepository
- func (m *ReplicaRepository) Create(arg0 context.Context, arg1 *replica.Replica) error
- func (m *ReplicaRepository) Delete(arg0 context.Context, arg1 *replica.Replica) error
- func (m *ReplicaRepository) DeleteAll(arg0 context.Context) error
- func (m *ReplicaRepository) EXPECT() *ReplicaRepositoryMockRecorder
- func (m *ReplicaRepository) First(arg0 context.Context) (*replica.Replica, error)
- func (m *ReplicaRepository) HasAny(arg0 context.Context) (bool, error)
- func (m *ReplicaRepository) HasKey(arg0 context.Context, arg1 string) (bool, error)
- type ReplicaRepositoryMockRecorder
- func (mr *ReplicaRepositoryMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call
- func (mr *ReplicaRepositoryMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *ReplicaRepositoryMockRecorder) DeleteAll(arg0 interface{}) *gomock.Call
- func (mr *ReplicaRepositoryMockRecorder) First(arg0 interface{}) *gomock.Call
- func (mr *ReplicaRepositoryMockRecorder) HasAny(arg0 interface{}) *gomock.Call
- func (mr *ReplicaRepositoryMockRecorder) HasKey(arg0, arg1 interface{}) *gomock.Call
- type ScrubRepository
- type ScrubRepositoryMockRecorder
- type StateRepository
- type StateRepositoryMockRecorder
- type Storing
- func (m *Storing) Config(arg0 context.Context) (*config.Config, error)
- func (m *Storing) CreateFile(arg0 context.Context, arg1 string, arg2 io.ReadCloser, arg3 int, ...) error
- func (m *Storing) CreateReplica(arg0 context.Context, arg1 string, arg2 io.ReadCloser, arg3 time.Duration, ...) (string, error)
- func (m *Storing) DeleteFile(arg0 context.Context, arg1 string) error
- func (m *Storing) Drain(arg0 context.Context) error
- func (m *Storing) EXPECT() *StoringMockRecorder
- func (m *Storing) GetFile(arg0 context.Context, arg1 string) (io.ReadCloser, int64, error)
- func (m *Storing) GetReplicaInfo(arg0 context.Context, arg1 string) ([]string, int, error)
- func (m *Storing) HasFile(arg0 context.Context, arg1 string) (string, bool, error)
- func (m *Storing) Ready(arg0 context.Context) error
- func (m *Storing) StatFile(arg0 context.Context, arg1 string) (*volume.FileStat, error)
- func (m *Storing) UpdateFileReplica(arg0 context.Context, arg1 string, arg2 []string, arg3 int) error
- type StoringMockRecorder
- func (mr *StoringMockRecorder) Config(arg0 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) CreateFile(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) CreateReplica(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) DeleteFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) Drain(arg0 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) GetFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) GetReplicaInfo(arg0, arg1 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) HasFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) Ready(arg0 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) StatFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) UpdateFileReplica(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- type UnitOfWork
- func (m *UnitOfWork) Deletions() deletion.Repository
- func (m *UnitOfWork) EXPECT() *UnitOfWorkMockRecorder
- func (m *UnitOfWork) Files() file.Repository
- func (m *UnitOfWork) Fs() afero.Fs
- func (m *UnitOfWork) IDXKeys() idxkey.Repository
- func (m *UnitOfWork) IDXTTLs() idxttl.Repository
- func (m *UnitOfWork) IDXVolumes() idxvolume.Repository
- func (m *UnitOfWork) Replicas() replica.Repository
- func (m *UnitOfWork) Scrubs() scrub.Repository
- func (m *UnitOfWork) State() state.Repository
- type UnitOfWorkMockRecorder
- func (mr *UnitOfWorkMockRecorder) Deletions() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) Files() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) Fs() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) IDXKeys() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) IDXTTLs() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) IDXVolumes() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) Replicas() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) Scrubs() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) State() *gomock.Call
- type Volume
- func (m *Volume) CreateFile(arg0 context.Context, arg1 string, arg2 io.ReadCloser, arg3 int, ...) error
- func (m *Volume) DeleteFile(arg0 context.Context, arg1 string) error
- func (m *Volume) EXPECT() *VolumeMockRecorder
- func (m *Volume) GetFile(arg0 context.Context, arg1 string) (io.ReadCloser, int64, error)
- func (m *Volume) HasFile(arg0 context.Context, arg1 string) (string, bool, error)
- func (m *Volume) StatFile(arg0 context.Context, arg1 string) (*volume.FileStat, error)
- func (m *Volume) UpdateFileReplica(arg0 context.Context, arg1 string, arg2 []string, arg3 int) error
- type VolumeLocal
- func (m *VolumeLocal) AllFiles(arg0 context.Context) ([]*file.File, error)
- func (m *VolumeLocal) Close() error
- func (m *VolumeLocal) CreateFile(arg0 context.Context, arg1 string, arg2 io.ReadCloser, arg3 int, ...) error
- func (m *VolumeLocal) DeleteDeletion(arg0 context.Context, arg1 *deletion.Deletion) error
- func (m *VolumeLocal) DeleteFile(arg0 context.Context, arg1 string) error
- func (m *VolumeLocal) DeleteReplica(arg0 context.Context, arg1 *replica.Replica) error
- func (m *VolumeLocal) DeleteScrub(arg0 context.Context, arg1 *scrub.Scrub) error
- func (m *VolumeLocal) EXPECT() *VolumeLocalMockRecorder
- func (m *VolumeLocal) FileVolumeIDs(arg0 context.Context, arg1 string) ([]string, int, error)
- func (m *VolumeLocal) GetFile(arg0 context.Context, arg1 string) (io.ReadCloser, int64, error)
- func (m *VolumeLocal) GetState(arg0 context.Context) (*state.State, error)
- func (m *VolumeLocal) HasFile(arg0 context.Context, arg1 string) (string, bool, error)
- func (m *VolumeLocal) HasPendingReplicas(arg0 context.Context) (bool, error)
- func (m *VolumeLocal) ID() string
- func (m *VolumeLocal) NextDeletion(arg0 context.Context) (*deletion.Deletion, error)
- func (m *VolumeLocal) NextReplica(arg0 context.Context) (*replica.Replica, error)
- func (m *VolumeLocal) NextScrub(arg0 context.Context) (*scrub.Scrub, error)
- func (m *VolumeLocal) OverwriteFileContent(arg0 context.Context, arg1 string, arg2 io.Reader) error
- func (m *VolumeLocal) PrepareForDrain(arg0 context.Context) error
- func (m *VolumeLocal) PurgeAllFiles(arg0 context.Context) error
- func (m *VolumeLocal) PurgeFile(arg0 context.Context, arg1 string) error
- func (m *VolumeLocal) ReconcileReplicas(arg0 context.Context) error
- func (m *VolumeLocal) Reset(arg0 context.Context) error
- func (m *VolumeLocal) StatFile(arg0 context.Context, arg1 string) (*volume.FileStat, error)
- func (m *VolumeLocal) SynchronizeReplicas(arg0 context.Context, arg1 string) error
- func (m *VolumeLocal) UpdateFileReplica(arg0 context.Context, arg1 string, arg2 []string, arg3 int) error
- func (m *VolumeLocal) UpdateReplica(arg0 context.Context, arg1 *replica.Replica, arg2 string) error
- type VolumeLocalMockRecorder
- func (mr *VolumeLocalMockRecorder) AllFiles(arg0 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) Close() *gomock.Call
- func (mr *VolumeLocalMockRecorder) CreateFile(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) DeleteDeletion(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) DeleteFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) DeleteReplica(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) DeleteScrub(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) FileVolumeIDs(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) GetFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) GetState(arg0 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) HasFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) HasPendingReplicas(arg0 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) ID() *gomock.Call
- func (mr *VolumeLocalMockRecorder) NextDeletion(arg0 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) NextReplica(arg0 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) NextScrub(arg0 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) OverwriteFileContent(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) PrepareForDrain(arg0 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) PurgeAllFiles(arg0 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) PurgeFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) ReconcileReplicas(arg0 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) Reset(arg0 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) StatFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) SynchronizeReplicas(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) UpdateFileReplica(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) UpdateReplica(arg0, arg1, arg2 interface{}) *gomock.Call
- type VolumeMockRecorder
- func (mr *VolumeMockRecorder) CreateFile(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
- func (mr *VolumeMockRecorder) DeleteFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeMockRecorder) GetFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeMockRecorder) HasFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeMockRecorder) StatFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *VolumeMockRecorder) UpdateFileReplica(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeletionRepository ¶ added in v0.4.0
type DeletionRepository struct {
// contains filtered or unexported fields
}
DeletionRepository is a mock of Repository interface.
func NewDeletionRepository ¶ added in v0.4.0
func NewDeletionRepository(ctrl *gomock.Controller) *DeletionRepository
NewDeletionRepository creates a new mock instance.
func (*DeletionRepository) EXPECT ¶ added in v0.4.0
func (m *DeletionRepository) EXPECT() *DeletionRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type DeletionRepositoryMockRecorder ¶ added in v0.4.0
type DeletionRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
DeletionRepositoryMockRecorder is the mock recorder for DeletionRepository.
func (*DeletionRepositoryMockRecorder) Create ¶ added in v0.4.0
func (mr *DeletionRepositoryMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*DeletionRepositoryMockRecorder) Delete ¶ added in v0.4.0
func (mr *DeletionRepositoryMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*DeletionRepositoryMockRecorder) First ¶ added in v0.4.0
func (mr *DeletionRepositoryMockRecorder) First(arg0 interface{}) *gomock.Call
First indicates an expected call of First.
type FileRepository ¶
type FileRepository struct {
// contains filtered or unexported fields
}
FileRepository is a mock of Repository interface.
func NewFileRepository ¶
func NewFileRepository(ctrl *gomock.Controller) *FileRepository
NewFileRepository creates a new mock instance.
func (*FileRepository) CreateOrReplace ¶
CreateOrReplace mocks base method.
func (*FileRepository) DeleteAll ¶ added in v0.3.0
func (m *FileRepository) DeleteAll(arg0 context.Context) error
DeleteAll mocks base method.
func (*FileRepository) DeleteBySignature ¶
func (m *FileRepository) DeleteBySignature(arg0 context.Context, arg1 string) error
DeleteBySignature mocks base method.
func (*FileRepository) EXPECT ¶
func (m *FileRepository) EXPECT() *FileRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*FileRepository) FindBySignature ¶
FindBySignature mocks base method.
type FileRepositoryMockRecorder ¶
type FileRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
FileRepositoryMockRecorder is the mock recorder for FileRepository.
func (*FileRepositoryMockRecorder) All ¶ added in v0.5.0
func (mr *FileRepositoryMockRecorder) All(arg0 interface{}) *gomock.Call
All indicates an expected call of All.
func (*FileRepositoryMockRecorder) CreateOrReplace ¶
func (mr *FileRepositoryMockRecorder) CreateOrReplace(arg0, arg1 interface{}) *gomock.Call
CreateOrReplace indicates an expected call of CreateOrReplace.
func (*FileRepositoryMockRecorder) DeleteAll ¶ added in v0.3.0
func (mr *FileRepositoryMockRecorder) DeleteAll(arg0 interface{}) *gomock.Call
DeleteAll indicates an expected call of DeleteAll.
func (*FileRepositoryMockRecorder) DeleteBySignature ¶
func (mr *FileRepositoryMockRecorder) DeleteBySignature(arg0, arg1 interface{}) *gomock.Call
DeleteBySignature indicates an expected call of DeleteBySignature.
func (*FileRepositoryMockRecorder) FindBySignature ¶
func (mr *FileRepositoryMockRecorder) FindBySignature(arg0, arg1 interface{}) *gomock.Call
FindBySignature indicates an expected call of FindBySignature.
type Fs ¶
type Fs struct {
// contains filtered or unexported fields
}
Fs is a mock of Fs interface.
func (*Fs) EXPECT ¶
func (m *Fs) EXPECT() *FsMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type FsMockRecorder ¶
type FsMockRecorder struct {
// contains filtered or unexported fields
}
FsMockRecorder is the mock recorder for Fs.
func (*FsMockRecorder) Chmod ¶
func (mr *FsMockRecorder) Chmod(arg0, arg1 interface{}) *gomock.Call
Chmod indicates an expected call of Chmod.
func (*FsMockRecorder) Chown ¶ added in v0.2.0
func (mr *FsMockRecorder) Chown(arg0, arg1, arg2 interface{}) *gomock.Call
Chown indicates an expected call of Chown.
func (*FsMockRecorder) Chtimes ¶
func (mr *FsMockRecorder) Chtimes(arg0, arg1, arg2 interface{}) *gomock.Call
Chtimes indicates an expected call of Chtimes.
func (*FsMockRecorder) Create ¶
func (mr *FsMockRecorder) Create(arg0 interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*FsMockRecorder) Mkdir ¶
func (mr *FsMockRecorder) Mkdir(arg0, arg1 interface{}) *gomock.Call
Mkdir indicates an expected call of Mkdir.
func (*FsMockRecorder) MkdirAll ¶
func (mr *FsMockRecorder) MkdirAll(arg0, arg1 interface{}) *gomock.Call
MkdirAll indicates an expected call of MkdirAll.
func (*FsMockRecorder) Name ¶
func (mr *FsMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
func (*FsMockRecorder) Open ¶
func (mr *FsMockRecorder) Open(arg0 interface{}) *gomock.Call
Open indicates an expected call of Open.
func (*FsMockRecorder) OpenFile ¶
func (mr *FsMockRecorder) OpenFile(arg0, arg1, arg2 interface{}) *gomock.Call
OpenFile indicates an expected call of OpenFile.
func (*FsMockRecorder) Remove ¶
func (mr *FsMockRecorder) Remove(arg0 interface{}) *gomock.Call
Remove indicates an expected call of Remove.
func (*FsMockRecorder) RemoveAll ¶
func (mr *FsMockRecorder) RemoveAll(arg0 interface{}) *gomock.Call
RemoveAll indicates an expected call of RemoveAll.
func (*FsMockRecorder) Rename ¶
func (mr *FsMockRecorder) Rename(arg0, arg1 interface{}) *gomock.Call
Rename indicates an expected call of Rename.
func (*FsMockRecorder) Stat ¶
func (mr *FsMockRecorder) Stat(arg0 interface{}) *gomock.Call
Stat indicates an expected call of Stat.
type IDXKeyRepository ¶
type IDXKeyRepository struct {
// contains filtered or unexported fields
}
IDXKeyRepository is a mock of Repository interface.
func NewIDXKeyRepository ¶
func NewIDXKeyRepository(ctrl *gomock.Controller) *IDXKeyRepository
NewIDXKeyRepository creates a new mock instance.
func (*IDXKeyRepository) CreateOrReplace ¶
CreateOrReplace mocks base method.
func (*IDXKeyRepository) DeleteAll ¶ added in v0.3.0
func (m *IDXKeyRepository) DeleteAll(arg0 context.Context) error
DeleteAll mocks base method.
func (*IDXKeyRepository) DeleteByKey ¶
func (m *IDXKeyRepository) DeleteByKey(arg0 context.Context, arg1 string) error
DeleteByKey mocks base method.
func (*IDXKeyRepository) EXPECT ¶
func (m *IDXKeyRepository) EXPECT() *IDXKeyRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type IDXKeyRepositoryMockRecorder ¶
type IDXKeyRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
IDXKeyRepositoryMockRecorder is the mock recorder for IDXKeyRepository.
func (*IDXKeyRepositoryMockRecorder) CreateOrReplace ¶
func (mr *IDXKeyRepositoryMockRecorder) CreateOrReplace(arg0, arg1 interface{}) *gomock.Call
CreateOrReplace indicates an expected call of CreateOrReplace.
func (*IDXKeyRepositoryMockRecorder) DeleteAll ¶ added in v0.3.0
func (mr *IDXKeyRepositoryMockRecorder) DeleteAll(arg0 interface{}) *gomock.Call
DeleteAll indicates an expected call of DeleteAll.
func (*IDXKeyRepositoryMockRecorder) DeleteByKey ¶
func (mr *IDXKeyRepositoryMockRecorder) DeleteByKey(arg0, arg1 interface{}) *gomock.Call
DeleteByKey indicates an expected call of DeleteByKey.
func (*IDXKeyRepositoryMockRecorder) FindByKey ¶
func (mr *IDXKeyRepositoryMockRecorder) FindByKey(arg0, arg1 interface{}) *gomock.Call
FindByKey indicates an expected call of FindByKey.
type IDXTTLRepository ¶ added in v0.4.0
type IDXTTLRepository struct {
// contains filtered or unexported fields
}
IDXTTLRepository is a mock of Repository interface.
func NewIDXTTLRepository ¶ added in v0.4.0
func NewIDXTTLRepository(ctrl *gomock.Controller) *IDXTTLRepository
NewIDXTTLRepository creates a new mock instance.
func (*IDXTTLRepository) CreateOrReplace ¶ added in v0.4.0
CreateOrReplace mocks base method.
func (*IDXTTLRepository) EXPECT ¶ added in v0.4.0
func (m *IDXTTLRepository) EXPECT() *IDXTTLRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type IDXTTLRepositoryMockRecorder ¶ added in v0.4.0
type IDXTTLRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
IDXTTLRepositoryMockRecorder is the mock recorder for IDXTTLRepository.
func (*IDXTTLRepositoryMockRecorder) CreateOrReplace ¶ added in v0.4.0
func (mr *IDXTTLRepositoryMockRecorder) CreateOrReplace(arg0, arg1 interface{}) *gomock.Call
CreateOrReplace indicates an expected call of CreateOrReplace.
func (*IDXTTLRepositoryMockRecorder) Delete ¶ added in v0.4.0
func (mr *IDXTTLRepositoryMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*IDXTTLRepositoryMockRecorder) Filter ¶ added in v0.4.0
func (mr *IDXTTLRepositoryMockRecorder) Filter(arg0, arg1 interface{}) *gomock.Call
Filter indicates an expected call of Filter.
func (*IDXTTLRepositoryMockRecorder) Find ¶ added in v0.4.0
func (mr *IDXTTLRepositoryMockRecorder) Find(arg0, arg1 interface{}) *gomock.Call
Find indicates an expected call of Find.
type IDXVolumeRepository ¶
type IDXVolumeRepository struct {
// contains filtered or unexported fields
}
IDXVolumeRepository is a mock of Repository interface.
func NewIDXVolumeRepository ¶
func NewIDXVolumeRepository(ctrl *gomock.Controller) *IDXVolumeRepository
NewIDXVolumeRepository creates a new mock instance.
func (*IDXVolumeRepository) CreateOrReplace ¶
func (m *IDXVolumeRepository) CreateOrReplace(arg0 context.Context, arg1 *idxvolume.IDXVolume) error
CreateOrReplace mocks base method.
func (*IDXVolumeRepository) DeleteAll ¶ added in v0.3.0
func (m *IDXVolumeRepository) DeleteAll(arg0 context.Context) error
DeleteAll mocks base method.
func (*IDXVolumeRepository) DeleteByKey ¶
func (m *IDXVolumeRepository) DeleteByKey(arg0 context.Context, arg1 string) error
DeleteByKey mocks base method.
func (*IDXVolumeRepository) EXPECT ¶
func (m *IDXVolumeRepository) EXPECT() *IDXVolumeRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*IDXVolumeRepository) FindByVolumeID ¶
func (m *IDXVolumeRepository) FindByVolumeID(arg0 context.Context, arg1 string) (*idxvolume.IDXVolume, error)
FindByVolumeID mocks base method.
type IDXVolumeRepositoryMockRecorder ¶
type IDXVolumeRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
IDXVolumeRepositoryMockRecorder is the mock recorder for IDXVolumeRepository.
func (*IDXVolumeRepositoryMockRecorder) CreateOrReplace ¶
func (mr *IDXVolumeRepositoryMockRecorder) CreateOrReplace(arg0, arg1 interface{}) *gomock.Call
CreateOrReplace indicates an expected call of CreateOrReplace.
func (*IDXVolumeRepositoryMockRecorder) DeleteAll ¶ added in v0.3.0
func (mr *IDXVolumeRepositoryMockRecorder) DeleteAll(arg0 interface{}) *gomock.Call
DeleteAll indicates an expected call of DeleteAll.
func (*IDXVolumeRepositoryMockRecorder) DeleteByKey ¶
func (mr *IDXVolumeRepositoryMockRecorder) DeleteByKey(arg0, arg1 interface{}) *gomock.Call
DeleteByKey indicates an expected call of DeleteByKey.
func (*IDXVolumeRepositoryMockRecorder) FindByVolumeID ¶
func (mr *IDXVolumeRepositoryMockRecorder) FindByVolumeID(arg0, arg1 interface{}) *gomock.Call
FindByVolumeID indicates an expected call of FindByVolumeID.
type Membership ¶
type Membership struct {
// contains filtered or unexported fields
}
Membership is a mock of Membership interface.
func NewMembership ¶
func NewMembership(ctrl *gomock.Controller) *Membership
NewMembership creates a new mock instance.
func (*Membership) AllVolumeIDs ¶ added in v0.5.0
func (m *Membership) AllVolumeIDs() []string
AllVolumeIDs mocks base method.
func (*Membership) EXPECT ¶
func (m *Membership) EXPECT() *MembershipMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*Membership) GetNodeState ¶ added in v0.3.0
func (m *Membership) GetNodeState(arg0 string) (*membership.State, error)
GetNodeState mocks base method.
func (*Membership) GetNodeWithVolumeByID ¶
func (m *Membership) GetNodeWithVolumeByID(arg0 string) (*client.Client, error)
GetNodeWithVolumeByID mocks base method.
func (*Membership) LocalVolumes ¶
func (m *Membership) LocalVolumes() []volume.Local
LocalVolumes mocks base method.
func (*Membership) NodesWithCapacity ¶ added in v0.5.0
func (m *Membership) NodesWithCapacity(arg0 int64) []*client.Client
NodesWithCapacity mocks base method.
func (*Membership) NodesWithoutVolumeIDs ¶ added in v0.3.0
func (m *Membership) NodesWithoutVolumeIDs(arg0 []string) []*client.Client
NodesWithoutVolumeIDs mocks base method.
func (*Membership) RemovedVolumeIDs ¶
func (m *Membership) RemovedVolumeIDs() []string
RemovedVolumeIDs mocks base method.
func (*Membership) SetDraining ¶ added in v0.5.0
func (m *Membership) SetDraining(arg0 bool)
SetDraining mocks base method.
type MembershipMockRecorder ¶
type MembershipMockRecorder struct {
// contains filtered or unexported fields
}
MembershipMockRecorder is the mock recorder for Membership.
func (*MembershipMockRecorder) AllVolumeIDs ¶ added in v0.5.0
func (mr *MembershipMockRecorder) AllVolumeIDs() *gomock.Call
AllVolumeIDs indicates an expected call of AllVolumeIDs.
func (*MembershipMockRecorder) GetNodeState ¶ added in v0.3.0
func (mr *MembershipMockRecorder) GetNodeState(arg0 interface{}) *gomock.Call
GetNodeState indicates an expected call of GetNodeState.
func (*MembershipMockRecorder) GetNodeWithVolumeByID ¶
func (mr *MembershipMockRecorder) GetNodeWithVolumeByID(arg0 interface{}) *gomock.Call
GetNodeWithVolumeByID indicates an expected call of GetNodeWithVolumeByID.
func (*MembershipMockRecorder) Leave ¶
func (mr *MembershipMockRecorder) Leave() *gomock.Call
Leave indicates an expected call of Leave.
func (*MembershipMockRecorder) LocalVolumes ¶
func (mr *MembershipMockRecorder) LocalVolumes() *gomock.Call
LocalVolumes indicates an expected call of LocalVolumes.
func (*MembershipMockRecorder) Nodes ¶
func (mr *MembershipMockRecorder) Nodes() *gomock.Call
Nodes indicates an expected call of Nodes.
func (*MembershipMockRecorder) NodesWithCapacity ¶ added in v0.5.0
func (mr *MembershipMockRecorder) NodesWithCapacity(arg0 interface{}) *gomock.Call
NodesWithCapacity indicates an expected call of NodesWithCapacity.
func (*MembershipMockRecorder) NodesWithoutVolumeIDs ¶ added in v0.3.0
func (mr *MembershipMockRecorder) NodesWithoutVolumeIDs(arg0 interface{}) *gomock.Call
NodesWithoutVolumeIDs indicates an expected call of NodesWithoutVolumeIDs.
func (*MembershipMockRecorder) RemovedVolumeIDs ¶
func (mr *MembershipMockRecorder) RemovedVolumeIDs() *gomock.Call
RemovedVolumeIDs indicates an expected call of RemovedVolumeIDs.
func (*MembershipMockRecorder) SetDraining ¶ added in v0.5.0
func (mr *MembershipMockRecorder) SetDraining(arg0 interface{}) *gomock.Call
SetDraining indicates an expected call of SetDraining.
type ReplicaRepository ¶
type ReplicaRepository struct {
// contains filtered or unexported fields
}
ReplicaRepository is a mock of Repository interface.
func NewReplicaRepository ¶
func NewReplicaRepository(ctrl *gomock.Controller) *ReplicaRepository
NewReplicaRepository creates a new mock instance.
func (*ReplicaRepository) DeleteAll ¶ added in v0.3.0
func (m *ReplicaRepository) DeleteAll(arg0 context.Context) error
DeleteAll mocks base method.
func (*ReplicaRepository) EXPECT ¶
func (m *ReplicaRepository) EXPECT() *ReplicaRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type ReplicaRepositoryMockRecorder ¶
type ReplicaRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
ReplicaRepositoryMockRecorder is the mock recorder for ReplicaRepository.
func (*ReplicaRepositoryMockRecorder) Create ¶
func (mr *ReplicaRepositoryMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*ReplicaRepositoryMockRecorder) Delete ¶
func (mr *ReplicaRepositoryMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*ReplicaRepositoryMockRecorder) DeleteAll ¶ added in v0.3.0
func (mr *ReplicaRepositoryMockRecorder) DeleteAll(arg0 interface{}) *gomock.Call
DeleteAll indicates an expected call of DeleteAll.
func (*ReplicaRepositoryMockRecorder) First ¶
func (mr *ReplicaRepositoryMockRecorder) First(arg0 interface{}) *gomock.Call
First indicates an expected call of First.
func (*ReplicaRepositoryMockRecorder) HasAny ¶ added in v0.5.0
func (mr *ReplicaRepositoryMockRecorder) HasAny(arg0 interface{}) *gomock.Call
HasAny indicates an expected call of HasAny.
func (*ReplicaRepositoryMockRecorder) HasKey ¶ added in v0.5.0
func (mr *ReplicaRepositoryMockRecorder) HasKey(arg0, arg1 interface{}) *gomock.Call
HasKey indicates an expected call of HasKey.
type ScrubRepository ¶ added in v0.5.0
type ScrubRepository struct {
// contains filtered or unexported fields
}
ScrubRepository is a mock of Repository interface.
func NewScrubRepository ¶ added in v0.5.0
func NewScrubRepository(ctrl *gomock.Controller) *ScrubRepository
NewScrubRepository creates a new mock instance.
func (*ScrubRepository) EXPECT ¶ added in v0.5.0
func (m *ScrubRepository) EXPECT() *ScrubRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type ScrubRepositoryMockRecorder ¶ added in v0.5.0
type ScrubRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
ScrubRepositoryMockRecorder is the mock recorder for ScrubRepository.
func (*ScrubRepositoryMockRecorder) Create ¶ added in v0.5.0
func (mr *ScrubRepositoryMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*ScrubRepositoryMockRecorder) Delete ¶ added in v0.5.0
func (mr *ScrubRepositoryMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*ScrubRepositoryMockRecorder) First ¶ added in v0.5.0
func (mr *ScrubRepositoryMockRecorder) First(arg0 interface{}) *gomock.Call
First indicates an expected call of First.
type StateRepository ¶ added in v0.2.0
type StateRepository struct {
// contains filtered or unexported fields
}
StateRepository is a mock of Repository interface.
func NewStateRepository ¶ added in v0.2.0
func NewStateRepository(ctrl *gomock.Controller) *StateRepository
NewStateRepository creates a new mock instance.
func (*StateRepository) DeleteAll ¶ added in v0.3.0
func (m *StateRepository) DeleteAll(arg0 context.Context) error
DeleteAll mocks base method.
func (*StateRepository) EXPECT ¶ added in v0.2.0
func (m *StateRepository) EXPECT() *StateRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type StateRepositoryMockRecorder ¶ added in v0.2.0
type StateRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
StateRepositoryMockRecorder is the mock recorder for StateRepository.
func (*StateRepositoryMockRecorder) DeleteAll ¶ added in v0.3.0
func (mr *StateRepositoryMockRecorder) DeleteAll(arg0 interface{}) *gomock.Call
DeleteAll indicates an expected call of DeleteAll.
func (*StateRepositoryMockRecorder) Find ¶ added in v0.2.0
func (mr *StateRepositoryMockRecorder) Find(arg0 interface{}) *gomock.Call
Find indicates an expected call of Find.
func (*StateRepositoryMockRecorder) Update ¶ added in v0.2.0
func (mr *StateRepositoryMockRecorder) Update(arg0, arg1 interface{}) *gomock.Call
Update indicates an expected call of Update.
type Storing ¶
type Storing struct {
// contains filtered or unexported fields
}
Storing is a mock of Service interface.
func NewStoring ¶
func NewStoring(ctrl *gomock.Controller) *Storing
NewStoring creates a new mock instance.
func (*Storing) CreateFile ¶
func (m *Storing) CreateFile(arg0 context.Context, arg1 string, arg2 io.ReadCloser, arg3 int, arg4 time.Duration, arg5 time.Time) error
CreateFile mocks base method.
func (*Storing) CreateReplica ¶
func (m *Storing) CreateReplica(arg0 context.Context, arg1 string, arg2 io.ReadCloser, arg3 time.Duration, arg4 time.Time) (string, error)
CreateReplica mocks base method.
func (*Storing) DeleteFile ¶
DeleteFile mocks base method.
func (*Storing) EXPECT ¶
func (m *Storing) EXPECT() *StoringMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*Storing) GetReplicaInfo ¶ added in v0.5.0
GetReplicaInfo mocks base method.
type StoringMockRecorder ¶
type StoringMockRecorder struct {
// contains filtered or unexported fields
}
StoringMockRecorder is the mock recorder for Storing.
func (*StoringMockRecorder) Config ¶
func (mr *StoringMockRecorder) Config(arg0 interface{}) *gomock.Call
Config indicates an expected call of Config.
func (*StoringMockRecorder) CreateFile ¶
func (mr *StoringMockRecorder) CreateFile(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
CreateFile indicates an expected call of CreateFile.
func (*StoringMockRecorder) CreateReplica ¶
func (mr *StoringMockRecorder) CreateReplica(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
CreateReplica indicates an expected call of CreateReplica.
func (*StoringMockRecorder) DeleteFile ¶
func (mr *StoringMockRecorder) DeleteFile(arg0, arg1 interface{}) *gomock.Call
DeleteFile indicates an expected call of DeleteFile.
func (*StoringMockRecorder) Drain ¶ added in v0.5.0
func (mr *StoringMockRecorder) Drain(arg0 interface{}) *gomock.Call
Drain indicates an expected call of Drain.
func (*StoringMockRecorder) GetFile ¶
func (mr *StoringMockRecorder) GetFile(arg0, arg1 interface{}) *gomock.Call
GetFile indicates an expected call of GetFile.
func (*StoringMockRecorder) GetReplicaInfo ¶ added in v0.5.0
func (mr *StoringMockRecorder) GetReplicaInfo(arg0, arg1 interface{}) *gomock.Call
GetReplicaInfo indicates an expected call of GetReplicaInfo.
func (*StoringMockRecorder) HasFile ¶
func (mr *StoringMockRecorder) HasFile(arg0, arg1 interface{}) *gomock.Call
HasFile indicates an expected call of HasFile.
func (*StoringMockRecorder) Ready ¶ added in v0.5.0
func (mr *StoringMockRecorder) Ready(arg0 interface{}) *gomock.Call
Ready indicates an expected call of Ready.
func (*StoringMockRecorder) StatFile ¶ added in v0.5.0
func (mr *StoringMockRecorder) StatFile(arg0, arg1 interface{}) *gomock.Call
StatFile indicates an expected call of StatFile.
func (*StoringMockRecorder) UpdateFileReplica ¶
func (mr *StoringMockRecorder) UpdateFileReplica(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
UpdateFileReplica indicates an expected call of UpdateFileReplica.
type UnitOfWork ¶
type UnitOfWork struct {
// contains filtered or unexported fields
}
UnitOfWork is a mock of UnitOfWork interface.
func NewUnitOfWork ¶
func NewUnitOfWork(ctrl *gomock.Controller) *UnitOfWork
NewUnitOfWork creates a new mock instance.
func (*UnitOfWork) Deletions ¶ added in v0.4.0
func (m *UnitOfWork) Deletions() deletion.Repository
Deletions mocks base method.
func (*UnitOfWork) EXPECT ¶
func (m *UnitOfWork) EXPECT() *UnitOfWorkMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*UnitOfWork) IDXKeys ¶
func (m *UnitOfWork) IDXKeys() idxkey.Repository
IDXKeys mocks base method.
func (*UnitOfWork) IDXTTLs ¶ added in v0.4.0
func (m *UnitOfWork) IDXTTLs() idxttl.Repository
IDXTTLs mocks base method.
func (*UnitOfWork) IDXVolumes ¶
func (m *UnitOfWork) IDXVolumes() idxvolume.Repository
IDXVolumes mocks base method.
func (*UnitOfWork) Replicas ¶
func (m *UnitOfWork) Replicas() replica.Repository
Replicas mocks base method.
func (*UnitOfWork) Scrubs ¶ added in v0.5.0
func (m *UnitOfWork) Scrubs() scrub.Repository
Scrubs mocks base method.
func (*UnitOfWork) State ¶ added in v0.2.0
func (m *UnitOfWork) State() state.Repository
State mocks base method.
type UnitOfWorkMockRecorder ¶
type UnitOfWorkMockRecorder struct {
// contains filtered or unexported fields
}
UnitOfWorkMockRecorder is the mock recorder for UnitOfWork.
func (*UnitOfWorkMockRecorder) Deletions ¶ added in v0.4.0
func (mr *UnitOfWorkMockRecorder) Deletions() *gomock.Call
Deletions indicates an expected call of Deletions.
func (*UnitOfWorkMockRecorder) Files ¶
func (mr *UnitOfWorkMockRecorder) Files() *gomock.Call
Files indicates an expected call of Files.
func (*UnitOfWorkMockRecorder) Fs ¶
func (mr *UnitOfWorkMockRecorder) Fs() *gomock.Call
Fs indicates an expected call of Fs.
func (*UnitOfWorkMockRecorder) IDXKeys ¶
func (mr *UnitOfWorkMockRecorder) IDXKeys() *gomock.Call
IDXKeys indicates an expected call of IDXKeys.
func (*UnitOfWorkMockRecorder) IDXTTLs ¶ added in v0.4.0
func (mr *UnitOfWorkMockRecorder) IDXTTLs() *gomock.Call
IDXTTLs indicates an expected call of IDXTTLs.
func (*UnitOfWorkMockRecorder) IDXVolumes ¶
func (mr *UnitOfWorkMockRecorder) IDXVolumes() *gomock.Call
IDXVolumes indicates an expected call of IDXVolumes.
func (*UnitOfWorkMockRecorder) Replicas ¶
func (mr *UnitOfWorkMockRecorder) Replicas() *gomock.Call
Replicas indicates an expected call of Replicas.
func (*UnitOfWorkMockRecorder) Scrubs ¶ added in v0.5.0
func (mr *UnitOfWorkMockRecorder) Scrubs() *gomock.Call
Scrubs indicates an expected call of Scrubs.
func (*UnitOfWorkMockRecorder) State ¶ added in v0.2.0
func (mr *UnitOfWorkMockRecorder) State() *gomock.Call
State indicates an expected call of State.
type Volume ¶
type Volume struct {
// contains filtered or unexported fields
}
Volume is a mock of Volume interface.
func NewVolume ¶
func NewVolume(ctrl *gomock.Controller) *Volume
NewVolume creates a new mock instance.
func (*Volume) CreateFile ¶
func (m *Volume) CreateFile(arg0 context.Context, arg1 string, arg2 io.ReadCloser, arg3 int, arg4 time.Duration, arg5 time.Time) error
CreateFile mocks base method.
func (*Volume) DeleteFile ¶
DeleteFile mocks base method.
func (*Volume) EXPECT ¶
func (m *Volume) EXPECT() *VolumeMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type VolumeLocal ¶
type VolumeLocal struct {
// contains filtered or unexported fields
}
VolumeLocal is a mock of Local interface.
func NewVolumeLocal ¶
func NewVolumeLocal(ctrl *gomock.Controller) *VolumeLocal
NewVolumeLocal creates a new mock instance.
func (*VolumeLocal) CreateFile ¶
func (m *VolumeLocal) CreateFile(arg0 context.Context, arg1 string, arg2 io.ReadCloser, arg3 int, arg4 time.Duration, arg5 time.Time) error
CreateFile mocks base method.
func (*VolumeLocal) DeleteDeletion ¶ added in v0.4.0
DeleteDeletion mocks base method.
func (*VolumeLocal) DeleteFile ¶
func (m *VolumeLocal) DeleteFile(arg0 context.Context, arg1 string) error
DeleteFile mocks base method.
func (*VolumeLocal) DeleteReplica ¶ added in v0.4.0
DeleteReplica mocks base method.
func (*VolumeLocal) DeleteScrub ¶ added in v0.5.0
DeleteScrub mocks base method.
func (*VolumeLocal) EXPECT ¶
func (m *VolumeLocal) EXPECT() *VolumeLocalMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*VolumeLocal) FileVolumeIDs ¶ added in v0.5.0
FileVolumeIDs mocks base method.
func (*VolumeLocal) GetFile ¶
func (m *VolumeLocal) GetFile(arg0 context.Context, arg1 string) (io.ReadCloser, int64, error)
GetFile mocks base method.
func (*VolumeLocal) HasPendingReplicas ¶ added in v0.5.0
func (m *VolumeLocal) HasPendingReplicas(arg0 context.Context) (bool, error)
HasPendingReplicas mocks base method.
func (*VolumeLocal) NextDeletion ¶ added in v0.4.0
NextDeletion mocks base method.
func (*VolumeLocal) NextReplica ¶
NextReplica mocks base method.
func (*VolumeLocal) OverwriteFileContent ¶ added in v0.5.0
OverwriteFileContent mocks base method.
func (*VolumeLocal) PrepareForDrain ¶ added in v0.5.0
func (m *VolumeLocal) PrepareForDrain(arg0 context.Context) error
PrepareForDrain mocks base method.
func (*VolumeLocal) PurgeAllFiles ¶ added in v0.5.0
func (m *VolumeLocal) PurgeAllFiles(arg0 context.Context) error
PurgeAllFiles mocks base method.
func (*VolumeLocal) PurgeFile ¶ added in v0.5.0
func (m *VolumeLocal) PurgeFile(arg0 context.Context, arg1 string) error
PurgeFile mocks base method.
func (*VolumeLocal) ReconcileReplicas ¶ added in v0.5.0
func (m *VolumeLocal) ReconcileReplicas(arg0 context.Context) error
ReconcileReplicas mocks base method.
func (*VolumeLocal) Reset ¶ added in v0.3.0
func (m *VolumeLocal) Reset(arg0 context.Context) error
Reset mocks base method.
func (*VolumeLocal) SynchronizeReplicas ¶
func (m *VolumeLocal) SynchronizeReplicas(arg0 context.Context, arg1 string) error
SynchronizeReplicas mocks base method.
func (*VolumeLocal) UpdateFileReplica ¶
func (m *VolumeLocal) UpdateFileReplica(arg0 context.Context, arg1 string, arg2 []string, arg3 int) error
UpdateFileReplica mocks base method.
func (*VolumeLocal) UpdateReplica ¶
UpdateReplica mocks base method.
type VolumeLocalMockRecorder ¶
type VolumeLocalMockRecorder struct {
// contains filtered or unexported fields
}
VolumeLocalMockRecorder is the mock recorder for VolumeLocal.
func (*VolumeLocalMockRecorder) AllFiles ¶ added in v0.5.0
func (mr *VolumeLocalMockRecorder) AllFiles(arg0 interface{}) *gomock.Call
AllFiles indicates an expected call of AllFiles.
func (*VolumeLocalMockRecorder) Close ¶
func (mr *VolumeLocalMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*VolumeLocalMockRecorder) CreateFile ¶
func (mr *VolumeLocalMockRecorder) CreateFile(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
CreateFile indicates an expected call of CreateFile.
func (*VolumeLocalMockRecorder) DeleteDeletion ¶ added in v0.4.0
func (mr *VolumeLocalMockRecorder) DeleteDeletion(arg0, arg1 interface{}) *gomock.Call
DeleteDeletion indicates an expected call of DeleteDeletion.
func (*VolumeLocalMockRecorder) DeleteFile ¶
func (mr *VolumeLocalMockRecorder) DeleteFile(arg0, arg1 interface{}) *gomock.Call
DeleteFile indicates an expected call of DeleteFile.
func (*VolumeLocalMockRecorder) DeleteReplica ¶ added in v0.4.0
func (mr *VolumeLocalMockRecorder) DeleteReplica(arg0, arg1 interface{}) *gomock.Call
DeleteReplica indicates an expected call of DeleteReplica.
func (*VolumeLocalMockRecorder) DeleteScrub ¶ added in v0.5.0
func (mr *VolumeLocalMockRecorder) DeleteScrub(arg0, arg1 interface{}) *gomock.Call
DeleteScrub indicates an expected call of DeleteScrub.
func (*VolumeLocalMockRecorder) FileVolumeIDs ¶ added in v0.5.0
func (mr *VolumeLocalMockRecorder) FileVolumeIDs(arg0, arg1 interface{}) *gomock.Call
FileVolumeIDs indicates an expected call of FileVolumeIDs.
func (*VolumeLocalMockRecorder) GetFile ¶
func (mr *VolumeLocalMockRecorder) GetFile(arg0, arg1 interface{}) *gomock.Call
GetFile indicates an expected call of GetFile.
func (*VolumeLocalMockRecorder) GetState ¶ added in v0.2.0
func (mr *VolumeLocalMockRecorder) GetState(arg0 interface{}) *gomock.Call
GetState indicates an expected call of GetState.
func (*VolumeLocalMockRecorder) HasFile ¶
func (mr *VolumeLocalMockRecorder) HasFile(arg0, arg1 interface{}) *gomock.Call
HasFile indicates an expected call of HasFile.
func (*VolumeLocalMockRecorder) HasPendingReplicas ¶ added in v0.5.0
func (mr *VolumeLocalMockRecorder) HasPendingReplicas(arg0 interface{}) *gomock.Call
HasPendingReplicas indicates an expected call of HasPendingReplicas.
func (*VolumeLocalMockRecorder) ID ¶
func (mr *VolumeLocalMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*VolumeLocalMockRecorder) NextDeletion ¶ added in v0.4.0
func (mr *VolumeLocalMockRecorder) NextDeletion(arg0 interface{}) *gomock.Call
NextDeletion indicates an expected call of NextDeletion.
func (*VolumeLocalMockRecorder) NextReplica ¶
func (mr *VolumeLocalMockRecorder) NextReplica(arg0 interface{}) *gomock.Call
NextReplica indicates an expected call of NextReplica.
func (*VolumeLocalMockRecorder) NextScrub ¶ added in v0.5.0
func (mr *VolumeLocalMockRecorder) NextScrub(arg0 interface{}) *gomock.Call
NextScrub indicates an expected call of NextScrub.
func (*VolumeLocalMockRecorder) OverwriteFileContent ¶ added in v0.5.0
func (mr *VolumeLocalMockRecorder) OverwriteFileContent(arg0, arg1, arg2 interface{}) *gomock.Call
OverwriteFileContent indicates an expected call of OverwriteFileContent.
func (*VolumeLocalMockRecorder) PrepareForDrain ¶ added in v0.5.0
func (mr *VolumeLocalMockRecorder) PrepareForDrain(arg0 interface{}) *gomock.Call
PrepareForDrain indicates an expected call of PrepareForDrain.
func (*VolumeLocalMockRecorder) PurgeAllFiles ¶ added in v0.5.0
func (mr *VolumeLocalMockRecorder) PurgeAllFiles(arg0 interface{}) *gomock.Call
PurgeAllFiles indicates an expected call of PurgeAllFiles.
func (*VolumeLocalMockRecorder) PurgeFile ¶ added in v0.5.0
func (mr *VolumeLocalMockRecorder) PurgeFile(arg0, arg1 interface{}) *gomock.Call
PurgeFile indicates an expected call of PurgeFile.
func (*VolumeLocalMockRecorder) ReconcileReplicas ¶ added in v0.5.0
func (mr *VolumeLocalMockRecorder) ReconcileReplicas(arg0 interface{}) *gomock.Call
ReconcileReplicas indicates an expected call of ReconcileReplicas.
func (*VolumeLocalMockRecorder) Reset ¶ added in v0.3.0
func (mr *VolumeLocalMockRecorder) Reset(arg0 interface{}) *gomock.Call
Reset indicates an expected call of Reset.
func (*VolumeLocalMockRecorder) StatFile ¶ added in v0.5.0
func (mr *VolumeLocalMockRecorder) StatFile(arg0, arg1 interface{}) *gomock.Call
StatFile indicates an expected call of StatFile.
func (*VolumeLocalMockRecorder) SynchronizeReplicas ¶
func (mr *VolumeLocalMockRecorder) SynchronizeReplicas(arg0, arg1 interface{}) *gomock.Call
SynchronizeReplicas indicates an expected call of SynchronizeReplicas.
func (*VolumeLocalMockRecorder) UpdateFileReplica ¶
func (mr *VolumeLocalMockRecorder) UpdateFileReplica(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
UpdateFileReplica indicates an expected call of UpdateFileReplica.
func (*VolumeLocalMockRecorder) UpdateReplica ¶
func (mr *VolumeLocalMockRecorder) UpdateReplica(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateReplica indicates an expected call of UpdateReplica.
type VolumeMockRecorder ¶
type VolumeMockRecorder struct {
// contains filtered or unexported fields
}
VolumeMockRecorder is the mock recorder for Volume.
func (*VolumeMockRecorder) CreateFile ¶
func (mr *VolumeMockRecorder) CreateFile(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
CreateFile indicates an expected call of CreateFile.
func (*VolumeMockRecorder) DeleteFile ¶
func (mr *VolumeMockRecorder) DeleteFile(arg0, arg1 interface{}) *gomock.Call
DeleteFile indicates an expected call of DeleteFile.
func (*VolumeMockRecorder) GetFile ¶
func (mr *VolumeMockRecorder) GetFile(arg0, arg1 interface{}) *gomock.Call
GetFile indicates an expected call of GetFile.
func (*VolumeMockRecorder) HasFile ¶
func (mr *VolumeMockRecorder) HasFile(arg0, arg1 interface{}) *gomock.Call
HasFile indicates an expected call of HasFile.
func (*VolumeMockRecorder) StatFile ¶ added in v0.5.0
func (mr *VolumeMockRecorder) StatFile(arg0, arg1 interface{}) *gomock.Call
StatFile indicates an expected call of StatFile.
func (*VolumeMockRecorder) UpdateFileReplica ¶
func (mr *VolumeMockRecorder) UpdateFileReplica(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
UpdateFileReplica indicates an expected call of UpdateFileReplica.