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.
Index ¶
- type FileRepository
- 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) 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 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) 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) NodesWithoutVolumeIDs(arg0 []string) []*client.Client
- func (m *Membership) RemovedVolumeIDs() []string
- type MembershipMockRecorder
- 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) NodesWithoutVolumeIDs(arg0 interface{}) *gomock.Call
- func (mr *MembershipMockRecorder) RemovedVolumeIDs() *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)
- 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
- 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) (string, error)
- func (m *Storing) DeleteFile(arg0 context.Context, arg1 string) error
- func (m *Storing) EXPECT() *StoringMockRecorder
- func (m *Storing) GetFile(arg0 context.Context, arg1 string) (io.ReadCloser, error)
- func (m *Storing) HasFile(arg0 context.Context, arg1 string) (string, bool, 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 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) CreateReplica(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) DeleteFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) GetFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) HasFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *StoringMockRecorder) UpdateFileReplica(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- type UnitOfWork
- 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) IDXVolumes() idxvolume.Repository
- func (m *UnitOfWork) Replicas() replica.Repository
- func (m *UnitOfWork) State() state.Repository
- type UnitOfWorkMockRecorder
- func (mr *UnitOfWorkMockRecorder) Files() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) Fs() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) IDXKeys() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) IDXVolumes() *gomock.Call
- func (mr *UnitOfWorkMockRecorder) Replicas() *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, error)
- func (m *Volume) HasFile(arg0 context.Context, arg1 string) (string, bool, error)
- func (m *Volume) UpdateFileReplica(arg0 context.Context, arg1 string, arg2 []string, arg3 int) error
- type VolumeLocal
- func (m *VolumeLocal) Close() error
- func (m *VolumeLocal) CreateFile(arg0 context.Context, arg1 string, arg2 io.ReadCloser, arg3 int) error
- func (m *VolumeLocal) DeleteFile(arg0 context.Context, arg1 string) error
- func (m *VolumeLocal) EXPECT() *VolumeLocalMockRecorder
- func (m *VolumeLocal) GetFile(arg0 context.Context, arg1 string) (io.ReadCloser, 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) ID() string
- func (m *VolumeLocal) NextReplica(arg0 context.Context) (*replica.Replica, error)
- func (m *VolumeLocal) Reset(arg0 context.Context) 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) Close() *gomock.Call
- func (mr *VolumeLocalMockRecorder) CreateFile(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) DeleteFile(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) ID() *gomock.Call
- func (mr *VolumeLocalMockRecorder) NextReplica(arg0 interface{}) *gomock.Call
- func (mr *VolumeLocalMockRecorder) Reset(arg0 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 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) 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 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) 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 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) 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) 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.
type MembershipMockRecorder ¶
type MembershipMockRecorder struct {
// contains filtered or unexported fields
}
MembershipMockRecorder is the mock recorder for Membership.
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) 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.
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.
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 ¶
CreateFile mocks base method.
func (*Storing) CreateReplica ¶
func (m *Storing) CreateReplica(arg0 context.Context, arg1 string, arg2 io.ReadCloser) (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.
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 interface{}) *gomock.Call
CreateFile indicates an expected call of CreateFile.
func (*StoringMockRecorder) CreateReplica ¶
func (mr *StoringMockRecorder) CreateReplica(arg0, arg1, arg2 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) GetFile ¶
func (mr *StoringMockRecorder) GetFile(arg0, arg1 interface{}) *gomock.Call
GetFile indicates an expected call of GetFile.
func (*StoringMockRecorder) HasFile ¶
func (mr *StoringMockRecorder) HasFile(arg0, arg1 interface{}) *gomock.Call
HasFile indicates an expected call of HasFile.
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) 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) 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) 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) 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) 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) 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 ¶
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) error
CreateFile mocks base method.
func (*VolumeLocal) DeleteFile ¶
func (m *VolumeLocal) DeleteFile(arg0 context.Context, arg1 string) error
DeleteFile 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) GetFile ¶
func (m *VolumeLocal) GetFile(arg0 context.Context, arg1 string) (io.ReadCloser, error)
GetFile mocks base method.
func (*VolumeLocal) NextReplica ¶
NextReplica 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) 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 interface{}) *gomock.Call
CreateFile indicates an expected call of CreateFile.
func (*VolumeLocalMockRecorder) DeleteFile ¶
func (mr *VolumeLocalMockRecorder) DeleteFile(arg0, arg1 interface{}) *gomock.Call
DeleteFile indicates an expected call of DeleteFile.
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) ID ¶
func (mr *VolumeLocalMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*VolumeLocalMockRecorder) NextReplica ¶
func (mr *VolumeLocalMockRecorder) NextReplica(arg0 interface{}) *gomock.Call
NextReplica indicates an expected call of NextReplica.
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) 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 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) UpdateFileReplica ¶
func (mr *VolumeMockRecorder) UpdateFileReplica(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
UpdateFileReplica indicates an expected call of UpdateFileReplica.