Documentation
¶
Overview ¶
Package mockblobclient is a generated GoMock package.
Package mockblobclient is a generated GoMock package.
Package mockblobclient is a generated GoMock package.
Package mockblobclient is a generated GoMock package.
Package mockblobclient is a generated GoMock package.
Index ¶
- type MockClient
- func (m *MockClient) Addr() string
- func (m *MockClient) CheckReadiness() error
- func (m *MockClient) DeleteBlob(d core.Digest) error
- func (m *MockClient) DownloadBlob(arg0 context.Context, arg1 string, arg2 core.Digest, arg3 io.Writer) error
- func (m *MockClient) DuplicateUploadBlob(namespace string, d core.Digest, blob io.Reader, delay time.Duration) error
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) ForceCleanup(ttl time.Duration) error
- func (m *MockClient) GetMetaInfo(namespace string, d core.Digest) (*core.MetaInfo, error)
- func (m *MockClient) GetPeerContext() (core.PeerContext, error)
- func (m *MockClient) Locations(d core.Digest) ([]string, error)
- func (m *MockClient) OverwriteMetaInfo(d core.Digest, pieceLength int64) error
- func (m *MockClient) PrefetchBlob(namespace string, d core.Digest) error
- func (m *MockClient) ReplicateToRemote(namespace string, d core.Digest, remoteDNS string) error
- func (m *MockClient) Stat(namespace string, d core.Digest) (*core.BlobInfo, error)
- func (m *MockClient) StatLocal(namespace string, d core.Digest) (*core.BlobInfo, error)
- func (m *MockClient) TransferBlob(d core.Digest, blob io.Reader) error
- func (m *MockClient) UploadBlob(ctx context.Context, namespace string, d core.Digest, blob io.Reader) error
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) Addr() *gomock.Call
- func (mr *MockClientMockRecorder) CheckReadiness() *gomock.Call
- func (mr *MockClientMockRecorder) DeleteBlob(d any) *gomock.Call
- func (mr *MockClientMockRecorder) DownloadBlob(arg0, arg1, arg2, arg3 any) *gomock.Call
- func (mr *MockClientMockRecorder) DuplicateUploadBlob(namespace, d, blob, delay any) *gomock.Call
- func (mr *MockClientMockRecorder) ForceCleanup(ttl any) *gomock.Call
- func (mr *MockClientMockRecorder) GetMetaInfo(namespace, d any) *gomock.Call
- func (mr *MockClientMockRecorder) GetPeerContext() *gomock.Call
- func (mr *MockClientMockRecorder) Locations(d any) *gomock.Call
- func (mr *MockClientMockRecorder) OverwriteMetaInfo(d, pieceLength any) *gomock.Call
- func (mr *MockClientMockRecorder) PrefetchBlob(namespace, d any) *gomock.Call
- func (mr *MockClientMockRecorder) ReplicateToRemote(namespace, d, remoteDNS any) *gomock.Call
- func (mr *MockClientMockRecorder) Stat(namespace, d any) *gomock.Call
- func (mr *MockClientMockRecorder) StatLocal(namespace, d any) *gomock.Call
- func (mr *MockClientMockRecorder) TransferBlob(d, blob any) *gomock.Call
- func (mr *MockClientMockRecorder) UploadBlob(ctx, namespace, d, blob any) *gomock.Call
- type MockClientResolver
- type MockClientResolverMockRecorder
- type MockClusterClient
- func (m *MockClusterClient) CheckReadiness() error
- func (m *MockClusterClient) DownloadBlob(arg0 context.Context, arg1 string, arg2 core.Digest, arg3 io.Writer) error
- func (m *MockClusterClient) EXPECT() *MockClusterClientMockRecorder
- func (m *MockClusterClient) GetMetaInfo(namespace string, d core.Digest) (*core.MetaInfo, error)
- func (m *MockClusterClient) OverwriteMetaInfo(d core.Digest, pieceLength int64) error
- func (m *MockClusterClient) Owners(d core.Digest) ([]core.PeerContext, error)
- func (m *MockClusterClient) PrefetchBlob(namespace string, d core.Digest) error
- func (m *MockClusterClient) ReplicateToRemote(namespace string, d core.Digest, remoteDNS string) error
- func (m *MockClusterClient) Stat(namespace string, d core.Digest) (*core.BlobInfo, error)
- func (m *MockClusterClient) UploadBlob(ctx context.Context, namespace string, d core.Digest, blob io.ReadSeeker) error
- type MockClusterClientMockRecorder
- func (mr *MockClusterClientMockRecorder) CheckReadiness() *gomock.Call
- func (mr *MockClusterClientMockRecorder) DownloadBlob(arg0, arg1, arg2, arg3 any) *gomock.Call
- func (mr *MockClusterClientMockRecorder) GetMetaInfo(namespace, d any) *gomock.Call
- func (mr *MockClusterClientMockRecorder) OverwriteMetaInfo(d, pieceLength any) *gomock.Call
- func (mr *MockClusterClientMockRecorder) Owners(d any) *gomock.Call
- func (mr *MockClusterClientMockRecorder) PrefetchBlob(namespace, d any) *gomock.Call
- func (mr *MockClusterClientMockRecorder) ReplicateToRemote(namespace, d, remoteDNS any) *gomock.Call
- func (mr *MockClusterClientMockRecorder) Stat(namespace, d any) *gomock.Call
- func (mr *MockClusterClientMockRecorder) UploadBlob(ctx, namespace, d, blob any) *gomock.Call
- type MockClusterProvider
- type MockClusterProviderMockRecorder
- type MockProvider
- type MockProviderMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockClient ¶
type MockClient struct {
// contains filtered or unexported fields
}
MockClient is a mock of Client interface.
func NewMockClient ¶
func NewMockClient(ctrl *gomock.Controller) *MockClient
NewMockClient creates a new mock instance.
func (*MockClient) CheckReadiness ¶ added in v0.1.6
func (m *MockClient) CheckReadiness() error
CheckReadiness mocks base method.
func (*MockClient) DeleteBlob ¶
func (m *MockClient) DeleteBlob(d core.Digest) error
DeleteBlob mocks base method.
func (*MockClient) DownloadBlob ¶
func (m *MockClient) DownloadBlob(arg0 context.Context, arg1 string, arg2 core.Digest, arg3 io.Writer) error
DownloadBlob mocks base method.
func (*MockClient) DuplicateUploadBlob ¶
func (m *MockClient) DuplicateUploadBlob(namespace string, d core.Digest, blob io.Reader, delay time.Duration) error
DuplicateUploadBlob mocks base method.
func (*MockClient) EXPECT ¶
func (m *MockClient) EXPECT() *MockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClient) ForceCleanup ¶
func (m *MockClient) ForceCleanup(ttl time.Duration) error
ForceCleanup mocks base method.
func (*MockClient) GetMetaInfo ¶
GetMetaInfo mocks base method.
func (*MockClient) GetPeerContext ¶
func (m *MockClient) GetPeerContext() (core.PeerContext, error)
GetPeerContext mocks base method.
func (*MockClient) Locations ¶
func (m *MockClient) Locations(d core.Digest) ([]string, error)
Locations mocks base method.
func (*MockClient) OverwriteMetaInfo ¶
func (m *MockClient) OverwriteMetaInfo(d core.Digest, pieceLength int64) error
OverwriteMetaInfo mocks base method.
func (*MockClient) PrefetchBlob ¶ added in v0.1.13
func (m *MockClient) PrefetchBlob(namespace string, d core.Digest) error
PrefetchBlob mocks base method.
func (*MockClient) ReplicateToRemote ¶
ReplicateToRemote mocks base method.
func (*MockClient) TransferBlob ¶
TransferBlob mocks base method.
type MockClientMockRecorder ¶
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient.
func (*MockClientMockRecorder) Addr ¶
func (mr *MockClientMockRecorder) Addr() *gomock.Call
Addr indicates an expected call of Addr.
func (*MockClientMockRecorder) CheckReadiness ¶ added in v0.1.6
func (mr *MockClientMockRecorder) CheckReadiness() *gomock.Call
CheckReadiness indicates an expected call of CheckReadiness.
func (*MockClientMockRecorder) DeleteBlob ¶
func (mr *MockClientMockRecorder) DeleteBlob(d any) *gomock.Call
DeleteBlob indicates an expected call of DeleteBlob.
func (*MockClientMockRecorder) DownloadBlob ¶
func (mr *MockClientMockRecorder) DownloadBlob(arg0, arg1, arg2, arg3 any) *gomock.Call
DownloadBlob indicates an expected call of DownloadBlob.
func (*MockClientMockRecorder) DuplicateUploadBlob ¶
func (mr *MockClientMockRecorder) DuplicateUploadBlob(namespace, d, blob, delay any) *gomock.Call
DuplicateUploadBlob indicates an expected call of DuplicateUploadBlob.
func (*MockClientMockRecorder) ForceCleanup ¶
func (mr *MockClientMockRecorder) ForceCleanup(ttl any) *gomock.Call
ForceCleanup indicates an expected call of ForceCleanup.
func (*MockClientMockRecorder) GetMetaInfo ¶
func (mr *MockClientMockRecorder) GetMetaInfo(namespace, d any) *gomock.Call
GetMetaInfo indicates an expected call of GetMetaInfo.
func (*MockClientMockRecorder) GetPeerContext ¶
func (mr *MockClientMockRecorder) GetPeerContext() *gomock.Call
GetPeerContext indicates an expected call of GetPeerContext.
func (*MockClientMockRecorder) Locations ¶
func (mr *MockClientMockRecorder) Locations(d any) *gomock.Call
Locations indicates an expected call of Locations.
func (*MockClientMockRecorder) OverwriteMetaInfo ¶
func (mr *MockClientMockRecorder) OverwriteMetaInfo(d, pieceLength any) *gomock.Call
OverwriteMetaInfo indicates an expected call of OverwriteMetaInfo.
func (*MockClientMockRecorder) PrefetchBlob ¶ added in v0.1.13
func (mr *MockClientMockRecorder) PrefetchBlob(namespace, d any) *gomock.Call
PrefetchBlob indicates an expected call of PrefetchBlob.
func (*MockClientMockRecorder) ReplicateToRemote ¶
func (mr *MockClientMockRecorder) ReplicateToRemote(namespace, d, remoteDNS any) *gomock.Call
ReplicateToRemote indicates an expected call of ReplicateToRemote.
func (*MockClientMockRecorder) Stat ¶
func (mr *MockClientMockRecorder) Stat(namespace, d any) *gomock.Call
Stat indicates an expected call of Stat.
func (*MockClientMockRecorder) StatLocal ¶
func (mr *MockClientMockRecorder) StatLocal(namespace, d any) *gomock.Call
StatLocal indicates an expected call of StatLocal.
func (*MockClientMockRecorder) TransferBlob ¶
func (mr *MockClientMockRecorder) TransferBlob(d, blob any) *gomock.Call
TransferBlob indicates an expected call of TransferBlob.
func (*MockClientMockRecorder) UploadBlob ¶
func (mr *MockClientMockRecorder) UploadBlob(ctx, namespace, d, blob any) *gomock.Call
UploadBlob indicates an expected call of UploadBlob.
type MockClientResolver ¶
type MockClientResolver struct {
// contains filtered or unexported fields
}
MockClientResolver is a mock of ClientResolver interface
func NewMockClientResolver ¶
func NewMockClientResolver(ctrl *gomock.Controller) *MockClientResolver
NewMockClientResolver creates a new mock instance
func (*MockClientResolver) EXPECT ¶
func (m *MockClientResolver) EXPECT() *MockClientResolverMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockClientResolver) Resolve ¶
func (m *MockClientResolver) Resolve(arg0 core.Digest) ([]blobclient.Client, error)
Resolve mocks base method
type MockClientResolverMockRecorder ¶
type MockClientResolverMockRecorder struct {
// contains filtered or unexported fields
}
MockClientResolverMockRecorder is the mock recorder for MockClientResolver
func (*MockClientResolverMockRecorder) Resolve ¶
func (mr *MockClientResolverMockRecorder) Resolve(arg0 interface{}) *gomock.Call
Resolve indicates an expected call of Resolve
type MockClusterClient ¶
type MockClusterClient struct {
// contains filtered or unexported fields
}
MockClusterClient is a mock of ClusterClient interface.
func NewMockClusterClient ¶
func NewMockClusterClient(ctrl *gomock.Controller) *MockClusterClient
NewMockClusterClient creates a new mock instance.
func (*MockClusterClient) CheckReadiness ¶ added in v0.1.6
func (m *MockClusterClient) CheckReadiness() error
CheckReadiness mocks base method.
func (*MockClusterClient) DownloadBlob ¶
func (m *MockClusterClient) DownloadBlob(arg0 context.Context, arg1 string, arg2 core.Digest, arg3 io.Writer) error
DownloadBlob mocks base method.
func (*MockClusterClient) EXPECT ¶
func (m *MockClusterClient) EXPECT() *MockClusterClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClusterClient) GetMetaInfo ¶
GetMetaInfo mocks base method.
func (*MockClusterClient) OverwriteMetaInfo ¶
func (m *MockClusterClient) OverwriteMetaInfo(d core.Digest, pieceLength int64) error
OverwriteMetaInfo mocks base method.
func (*MockClusterClient) Owners ¶
func (m *MockClusterClient) Owners(d core.Digest) ([]core.PeerContext, error)
Owners mocks base method.
func (*MockClusterClient) PrefetchBlob ¶ added in v0.1.13
func (m *MockClusterClient) PrefetchBlob(namespace string, d core.Digest) error
PrefetchBlob mocks base method.
func (*MockClusterClient) ReplicateToRemote ¶
func (m *MockClusterClient) ReplicateToRemote(namespace string, d core.Digest, remoteDNS string) error
ReplicateToRemote mocks base method.
func (*MockClusterClient) UploadBlob ¶
func (m *MockClusterClient) UploadBlob(ctx context.Context, namespace string, d core.Digest, blob io.ReadSeeker) error
UploadBlob mocks base method.
type MockClusterClientMockRecorder ¶
type MockClusterClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClusterClientMockRecorder is the mock recorder for MockClusterClient.
func (*MockClusterClientMockRecorder) CheckReadiness ¶ added in v0.1.6
func (mr *MockClusterClientMockRecorder) CheckReadiness() *gomock.Call
CheckReadiness indicates an expected call of CheckReadiness.
func (*MockClusterClientMockRecorder) DownloadBlob ¶
func (mr *MockClusterClientMockRecorder) DownloadBlob(arg0, arg1, arg2, arg3 any) *gomock.Call
DownloadBlob indicates an expected call of DownloadBlob.
func (*MockClusterClientMockRecorder) GetMetaInfo ¶
func (mr *MockClusterClientMockRecorder) GetMetaInfo(namespace, d any) *gomock.Call
GetMetaInfo indicates an expected call of GetMetaInfo.
func (*MockClusterClientMockRecorder) OverwriteMetaInfo ¶
func (mr *MockClusterClientMockRecorder) OverwriteMetaInfo(d, pieceLength any) *gomock.Call
OverwriteMetaInfo indicates an expected call of OverwriteMetaInfo.
func (*MockClusterClientMockRecorder) Owners ¶
func (mr *MockClusterClientMockRecorder) Owners(d any) *gomock.Call
Owners indicates an expected call of Owners.
func (*MockClusterClientMockRecorder) PrefetchBlob ¶ added in v0.1.13
func (mr *MockClusterClientMockRecorder) PrefetchBlob(namespace, d any) *gomock.Call
PrefetchBlob indicates an expected call of PrefetchBlob.
func (*MockClusterClientMockRecorder) ReplicateToRemote ¶
func (mr *MockClusterClientMockRecorder) ReplicateToRemote(namespace, d, remoteDNS any) *gomock.Call
ReplicateToRemote indicates an expected call of ReplicateToRemote.
func (*MockClusterClientMockRecorder) Stat ¶
func (mr *MockClusterClientMockRecorder) Stat(namespace, d any) *gomock.Call
Stat indicates an expected call of Stat.
func (*MockClusterClientMockRecorder) UploadBlob ¶
func (mr *MockClusterClientMockRecorder) UploadBlob(ctx, namespace, d, blob any) *gomock.Call
UploadBlob indicates an expected call of UploadBlob.
type MockClusterProvider ¶
type MockClusterProvider struct {
// contains filtered or unexported fields
}
MockClusterProvider is a mock of ClusterProvider interface
func NewMockClusterProvider ¶
func NewMockClusterProvider(ctrl *gomock.Controller) *MockClusterProvider
NewMockClusterProvider creates a new mock instance
func (*MockClusterProvider) EXPECT ¶
func (m *MockClusterProvider) EXPECT() *MockClusterProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockClusterProvider) Provide ¶
func (m *MockClusterProvider) Provide(arg0 string) (blobclient.ClusterClient, error)
Provide mocks base method
type MockClusterProviderMockRecorder ¶
type MockClusterProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockClusterProviderMockRecorder is the mock recorder for MockClusterProvider
func (*MockClusterProviderMockRecorder) Provide ¶
func (mr *MockClusterProviderMockRecorder) Provide(arg0 interface{}) *gomock.Call
Provide indicates an expected call of Provide
type MockProvider ¶
type MockProvider struct {
// contains filtered or unexported fields
}
MockProvider is a mock of Provider interface
func NewMockProvider ¶
func NewMockProvider(ctrl *gomock.Controller) *MockProvider
NewMockProvider creates a new mock instance
func (*MockProvider) EXPECT ¶
func (m *MockProvider) EXPECT() *MockProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockProvider) Provide ¶
func (m *MockProvider) Provide(arg0 string) blobclient.Client
Provide mocks base method
type MockProviderMockRecorder ¶
type MockProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockProviderMockRecorder is the mock recorder for MockProvider
func (*MockProviderMockRecorder) Provide ¶
func (mr *MockProviderMockRecorder) Provide(arg0 interface{}) *gomock.Call
Provide indicates an expected call of Provide