Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type MockCluster
- func (m *MockCluster) AddEventListener(arg0 cluster.ClusterListener) error
- func (m *MockCluster) ClusterNotifyClusterDomainsUpdate(arg0 types.ClusterDomainsActiveMap) error
- func (m *MockCluster) ClusterNotifyNodeDown(arg0 string) (string, error)
- func (m *MockCluster) Collect(arg0 context.Context, arg1 *api.SdkDiagsCollectRequest) (*api.SdkDiagsCollectResponse, error)
- func (m *MockCluster) CordonAttachments(arg0 context.Context, arg1 *api.SdkNodeCordonAttachmentsRequest) (*api.SdkNodeCordonAttachmentsResponse, error)
- func (m *MockCluster) CreatePair(arg0 *api.ClusterPairCreateRequest) (*api.ClusterPairCreateResponse, error)
- func (m *MockCluster) DeleteDomain(arg0 string) error
- func (m *MockCluster) DeleteNodeConf(arg0 string) error
- func (m *MockCluster) DeletePair(arg0 string) error
- func (m *MockCluster) DisableUpdates() error
- func (m *MockCluster) DrainAttachments(arg0 context.Context, arg1 *api.SdkNodeDrainAttachmentsRequest) (*api.SdkJobResponse, error)
- func (m *MockCluster) EXPECT() *MockClusterMockRecorder
- func (m *MockCluster) EnableUpdates() error
- func (m *MockCluster) Enumerate() (api.Cluster, error)
- func (m *MockCluster) EnumerateAlerts(arg0, arg1 time.Time, arg2 api.ResourceType) (*api.Alerts, error)
- func (m *MockCluster) EnumerateDomains() ([]*clusterdomain.ClusterDomainInfo, error)
- func (m *MockCluster) EnumerateJobs(arg0 context.Context, arg1 *api.SdkEnumerateJobsRequest) (*api.SdkEnumerateJobsResponse, error)
- func (m *MockCluster) EnumerateNodeConf() (*osdconfig.NodesConfig, error)
- func (m *MockCluster) EnumeratePairs() (*api.ClusterPairsEnumerateResponse, error)
- func (m *MockCluster) EnumerateRebalanceJobs(arg0 context.Context, arg1 *api.SdkEnumerateRebalanceJobsRequest) (*api.SdkEnumerateRebalanceJobsResponse, error)
- func (m *MockCluster) EraseAlert(arg0 api.ResourceType, arg1 int64) error
- func (m *MockCluster) GetClusterConf() (*osdconfig.ClusterConfig, error)
- func (m *MockCluster) GetData() (map[string]*api.Node, error)
- func (m *MockCluster) GetGossipState() *cluster.ClusterState
- func (m *MockCluster) GetJobStatus(arg0 context.Context, arg1 *api.SdkGetJobStatusRequest) (*api.SdkGetJobStatusResponse, error)
- func (m *MockCluster) GetNodeConf(arg0 string) (*osdconfig.NodeConfig, error)
- func (m *MockCluster) GetNodeIdFromIp(arg0 string) (string, error)
- func (m *MockCluster) GetPair(arg0 string) (*api.ClusterPairGetResponse, error)
- func (m *MockCluster) GetPairToken(arg0 bool) (*api.ClusterPairTokenGetResponse, error)
- func (m *MockCluster) GetRebalanceJobStatus(arg0 context.Context, arg1 *api.SdkGetRebalanceJobStatusRequest) (*api.SdkGetRebalanceJobStatusResponse, error)
- func (m *MockCluster) GetSelfDomain() (*clusterdomain.ClusterDomainInfo, error)
- func (m *MockCluster) Inspect(arg0 string) (api.Node, error)
- func (m *MockCluster) InspectDomain(arg0 string) (*clusterdomain.ClusterDomainInfo, error)
- func (m *MockCluster) NodeRemoveDone(arg0 string, arg1 error)
- func (m *MockCluster) NodeStatus() (api.Status, error)
- func (m *MockCluster) ObjectStoreCreate(arg0 string) (*api.ObjectstoreInfo, error)
- func (m *MockCluster) ObjectStoreDelete(arg0 string) error
- func (m *MockCluster) ObjectStoreInspect(arg0 string) (*api.ObjectstoreInfo, error)
- func (m *MockCluster) ObjectStoreUpdate(arg0 string, arg1 bool) error
- func (m *MockCluster) PeerStatus(arg0 string) (map[string]api.Status, error)
- func (m *MockCluster) ProcessPairRequest(arg0 *api.ClusterPairProcessRequest) (*api.ClusterPairProcessResponse, error)
- func (m *MockCluster) Rebalance(arg0 context.Context, arg1 *api.SdkStorageRebalanceRequest) (*api.SdkStorageRebalanceResponse, error)
- func (m *MockCluster) RefreshPair(arg0 string) error
- func (m *MockCluster) Remove(arg0 []api.Node, arg1 bool) error
- func (m *MockCluster) Resize(arg0 context.Context, arg1 *api.SdkStoragePoolResizeRequest) (*api.SdkStoragePoolResizeResponse, error)
- func (m *MockCluster) SchedPolicyCreate(arg0, arg1 string) error
- func (m *MockCluster) SchedPolicyDelete(arg0 string) error
- func (m *MockCluster) SchedPolicyEnumerate() ([]*schedpolicy.SchedPolicy, error)
- func (m *MockCluster) SchedPolicyGet(arg0 string) (*schedpolicy.SchedPolicy, error)
- func (m *MockCluster) SchedPolicyUpdate(arg0, arg1 string) error
- func (m *MockCluster) SecretCheckLogin() error
- func (m *MockCluster) SecretGet(arg0 string) (interface{}, error)
- func (m *MockCluster) SecretGetDefaultSecretKey() (interface{}, error)
- func (m *MockCluster) SecretLogin(arg0 string, arg1 map[string]string) error
- func (m *MockCluster) SecretSet(arg0 string, arg1 interface{}) error
- func (m *MockCluster) SecretSetDefaultSecretKey(arg0 string, arg1 bool) error
- func (m *MockCluster) SetClusterConf(arg0 *osdconfig.ClusterConfig) error
- func (m *MockCluster) SetNodeConf(arg0 *osdconfig.NodeConfig) error
- func (m *MockCluster) SetSize(arg0 int) error
- func (m *MockCluster) Shutdown() error
- func (m *MockCluster) Start(arg0 bool, arg1, arg2 string) error
- func (m *MockCluster) StartWithConfiguration(arg0 bool, arg1 string, arg2 []string, arg3 string, ...) error
- func (m *MockCluster) UncordonAttachments(arg0 context.Context, arg1 *api.SdkNodeUncordonAttachmentsRequest) (*api.SdkNodeUncordonAttachmentsResponse, error)
- func (m *MockCluster) UpdateData(arg0 map[string]interface{}) error
- func (m *MockCluster) UpdateDomainState(arg0 string, arg1 types.ClusterDomainState) error
- func (m *MockCluster) UpdateJobState(arg0 context.Context, arg1 *api.SdkUpdateJobRequest) (*api.SdkUpdateJobResponse, error)
- func (m *MockCluster) UpdateLabels(arg0 map[string]string) error
- func (m *MockCluster) UpdateRebalanceJobState(arg0 context.Context, arg1 *api.SdkUpdateRebalanceJobRequest) (*api.SdkUpdateRebalanceJobResponse, error)
- func (m *MockCluster) UpdateSchedulerNodeName(arg0 string) error
- func (m *MockCluster) Uuid() string
- func (m *MockCluster) ValidatePair(arg0 string) error
- type MockClusterMockRecorder
- func (mr *MockClusterMockRecorder) AddEventListener(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) ClusterNotifyClusterDomainsUpdate(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) ClusterNotifyNodeDown(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) Collect(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) CordonAttachments(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) CreatePair(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) DeleteDomain(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) DeleteNodeConf(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) DeletePair(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) DisableUpdates() *gomock.Call
- func (mr *MockClusterMockRecorder) DrainAttachments(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) EnableUpdates() *gomock.Call
- func (mr *MockClusterMockRecorder) Enumerate() *gomock.Call
- func (mr *MockClusterMockRecorder) EnumerateAlerts(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) EnumerateDomains() *gomock.Call
- func (mr *MockClusterMockRecorder) EnumerateJobs(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) EnumerateNodeConf() *gomock.Call
- func (mr *MockClusterMockRecorder) EnumeratePairs() *gomock.Call
- func (mr *MockClusterMockRecorder) EnumerateRebalanceJobs(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) EraseAlert(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) GetClusterConf() *gomock.Call
- func (mr *MockClusterMockRecorder) GetData() *gomock.Call
- func (mr *MockClusterMockRecorder) GetGossipState() *gomock.Call
- func (mr *MockClusterMockRecorder) GetJobStatus(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) GetNodeConf(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) GetNodeIdFromIp(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) GetPair(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) GetPairToken(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) GetRebalanceJobStatus(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) GetSelfDomain() *gomock.Call
- func (mr *MockClusterMockRecorder) Inspect(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) InspectDomain(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) NodeRemoveDone(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) NodeStatus() *gomock.Call
- func (mr *MockClusterMockRecorder) ObjectStoreCreate(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) ObjectStoreDelete(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) ObjectStoreInspect(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) ObjectStoreUpdate(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) PeerStatus(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) ProcessPairRequest(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) Rebalance(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) RefreshPair(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) Remove(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) Resize(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) SchedPolicyCreate(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) SchedPolicyDelete(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) SchedPolicyEnumerate() *gomock.Call
- func (mr *MockClusterMockRecorder) SchedPolicyGet(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) SchedPolicyUpdate(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) SecretCheckLogin() *gomock.Call
- func (mr *MockClusterMockRecorder) SecretGet(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) SecretGetDefaultSecretKey() *gomock.Call
- func (mr *MockClusterMockRecorder) SecretLogin(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) SecretSet(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) SecretSetDefaultSecretKey(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) SetClusterConf(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) SetNodeConf(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) SetSize(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) Shutdown() *gomock.Call
- func (mr *MockClusterMockRecorder) Start(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) StartWithConfiguration(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) UncordonAttachments(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) UpdateData(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) UpdateDomainState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) UpdateJobState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) UpdateLabels(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) UpdateRebalanceJobState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) UpdateSchedulerNodeName(arg0 interface{}) *gomock.Call
- func (mr *MockClusterMockRecorder) Uuid() *gomock.Call
- func (mr *MockClusterMockRecorder) ValidatePair(arg0 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockCluster ¶
type MockCluster struct {
// contains filtered or unexported fields
}
MockCluster is a mock of Cluster interface.
func NewMockCluster ¶
func NewMockCluster(ctrl *gomock.Controller) *MockCluster
NewMockCluster creates a new mock instance.
func (*MockCluster) AddEventListener ¶
func (m *MockCluster) AddEventListener(arg0 cluster.ClusterListener) error
AddEventListener mocks base method.
func (*MockCluster) ClusterNotifyClusterDomainsUpdate ¶
func (m *MockCluster) ClusterNotifyClusterDomainsUpdate(arg0 types.ClusterDomainsActiveMap) error
ClusterNotifyClusterDomainsUpdate mocks base method.
func (*MockCluster) ClusterNotifyNodeDown ¶
func (m *MockCluster) ClusterNotifyNodeDown(arg0 string) (string, error)
ClusterNotifyNodeDown mocks base method.
func (*MockCluster) Collect ¶
func (m *MockCluster) Collect(arg0 context.Context, arg1 *api.SdkDiagsCollectRequest) (*api.SdkDiagsCollectResponse, error)
Collect mocks base method.
func (*MockCluster) CordonAttachments ¶
func (m *MockCluster) CordonAttachments(arg0 context.Context, arg1 *api.SdkNodeCordonAttachmentsRequest) (*api.SdkNodeCordonAttachmentsResponse, error)
CordonAttachments mocks base method.
func (*MockCluster) CreatePair ¶
func (m *MockCluster) CreatePair(arg0 *api.ClusterPairCreateRequest) (*api.ClusterPairCreateResponse, error)
CreatePair mocks base method.
func (*MockCluster) DeleteDomain ¶
func (m *MockCluster) DeleteDomain(arg0 string) error
DeleteDomain mocks base method.
func (*MockCluster) DeleteNodeConf ¶
func (m *MockCluster) DeleteNodeConf(arg0 string) error
DeleteNodeConf mocks base method.
func (*MockCluster) DeletePair ¶
func (m *MockCluster) DeletePair(arg0 string) error
DeletePair mocks base method.
func (*MockCluster) DisableUpdates ¶
func (m *MockCluster) DisableUpdates() error
DisableUpdates mocks base method.
func (*MockCluster) DrainAttachments ¶
func (m *MockCluster) DrainAttachments(arg0 context.Context, arg1 *api.SdkNodeDrainAttachmentsRequest) (*api.SdkJobResponse, error)
DrainAttachments mocks base method.
func (*MockCluster) EXPECT ¶
func (m *MockCluster) EXPECT() *MockClusterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCluster) EnableUpdates ¶
func (m *MockCluster) EnableUpdates() error
EnableUpdates mocks base method.
func (*MockCluster) Enumerate ¶
func (m *MockCluster) Enumerate() (api.Cluster, error)
Enumerate mocks base method.
func (*MockCluster) EnumerateAlerts ¶
func (m *MockCluster) EnumerateAlerts(arg0, arg1 time.Time, arg2 api.ResourceType) (*api.Alerts, error)
EnumerateAlerts mocks base method.
func (*MockCluster) EnumerateDomains ¶
func (m *MockCluster) EnumerateDomains() ([]*clusterdomain.ClusterDomainInfo, error)
EnumerateDomains mocks base method.
func (*MockCluster) EnumerateJobs ¶
func (m *MockCluster) EnumerateJobs(arg0 context.Context, arg1 *api.SdkEnumerateJobsRequest) (*api.SdkEnumerateJobsResponse, error)
EnumerateJobs mocks base method.
func (*MockCluster) EnumerateNodeConf ¶
func (m *MockCluster) EnumerateNodeConf() (*osdconfig.NodesConfig, error)
EnumerateNodeConf mocks base method.
func (*MockCluster) EnumeratePairs ¶
func (m *MockCluster) EnumeratePairs() (*api.ClusterPairsEnumerateResponse, error)
EnumeratePairs mocks base method.
func (*MockCluster) EnumerateRebalanceJobs ¶
func (m *MockCluster) EnumerateRebalanceJobs(arg0 context.Context, arg1 *api.SdkEnumerateRebalanceJobsRequest) (*api.SdkEnumerateRebalanceJobsResponse, error)
EnumerateRebalanceJobs mocks base method.
func (*MockCluster) EraseAlert ¶
func (m *MockCluster) EraseAlert(arg0 api.ResourceType, arg1 int64) error
EraseAlert mocks base method.
func (*MockCluster) GetClusterConf ¶
func (m *MockCluster) GetClusterConf() (*osdconfig.ClusterConfig, error)
GetClusterConf mocks base method.
func (*MockCluster) GetData ¶
func (m *MockCluster) GetData() (map[string]*api.Node, error)
GetData mocks base method.
func (*MockCluster) GetGossipState ¶
func (m *MockCluster) GetGossipState() *cluster.ClusterState
GetGossipState mocks base method.
func (*MockCluster) GetJobStatus ¶
func (m *MockCluster) GetJobStatus(arg0 context.Context, arg1 *api.SdkGetJobStatusRequest) (*api.SdkGetJobStatusResponse, error)
GetJobStatus mocks base method.
func (*MockCluster) GetNodeConf ¶
func (m *MockCluster) GetNodeConf(arg0 string) (*osdconfig.NodeConfig, error)
GetNodeConf mocks base method.
func (*MockCluster) GetNodeIdFromIp ¶
func (m *MockCluster) GetNodeIdFromIp(arg0 string) (string, error)
GetNodeIdFromIp mocks base method.
func (*MockCluster) GetPair ¶
func (m *MockCluster) GetPair(arg0 string) (*api.ClusterPairGetResponse, error)
GetPair mocks base method.
func (*MockCluster) GetPairToken ¶
func (m *MockCluster) GetPairToken(arg0 bool) (*api.ClusterPairTokenGetResponse, error)
GetPairToken mocks base method.
func (*MockCluster) GetRebalanceJobStatus ¶
func (m *MockCluster) GetRebalanceJobStatus(arg0 context.Context, arg1 *api.SdkGetRebalanceJobStatusRequest) (*api.SdkGetRebalanceJobStatusResponse, error)
GetRebalanceJobStatus mocks base method.
func (*MockCluster) GetSelfDomain ¶
func (m *MockCluster) GetSelfDomain() (*clusterdomain.ClusterDomainInfo, error)
GetSelfDomain mocks base method.
func (*MockCluster) Inspect ¶
func (m *MockCluster) Inspect(arg0 string) (api.Node, error)
Inspect mocks base method.
func (*MockCluster) InspectDomain ¶
func (m *MockCluster) InspectDomain(arg0 string) (*clusterdomain.ClusterDomainInfo, error)
InspectDomain mocks base method.
func (*MockCluster) NodeRemoveDone ¶
func (m *MockCluster) NodeRemoveDone(arg0 string, arg1 error)
NodeRemoveDone mocks base method.
func (*MockCluster) NodeStatus ¶
func (m *MockCluster) NodeStatus() (api.Status, error)
NodeStatus mocks base method.
func (*MockCluster) ObjectStoreCreate ¶
func (m *MockCluster) ObjectStoreCreate(arg0 string) (*api.ObjectstoreInfo, error)
ObjectStoreCreate mocks base method.
func (*MockCluster) ObjectStoreDelete ¶
func (m *MockCluster) ObjectStoreDelete(arg0 string) error
ObjectStoreDelete mocks base method.
func (*MockCluster) ObjectStoreInspect ¶
func (m *MockCluster) ObjectStoreInspect(arg0 string) (*api.ObjectstoreInfo, error)
ObjectStoreInspect mocks base method.
func (*MockCluster) ObjectStoreUpdate ¶
func (m *MockCluster) ObjectStoreUpdate(arg0 string, arg1 bool) error
ObjectStoreUpdate mocks base method.
func (*MockCluster) PeerStatus ¶
PeerStatus mocks base method.
func (*MockCluster) ProcessPairRequest ¶
func (m *MockCluster) ProcessPairRequest(arg0 *api.ClusterPairProcessRequest) (*api.ClusterPairProcessResponse, error)
ProcessPairRequest mocks base method.
func (*MockCluster) Rebalance ¶
func (m *MockCluster) Rebalance(arg0 context.Context, arg1 *api.SdkStorageRebalanceRequest) (*api.SdkStorageRebalanceResponse, error)
Rebalance mocks base method.
func (*MockCluster) RefreshPair ¶
func (m *MockCluster) RefreshPair(arg0 string) error
RefreshPair mocks base method.
func (*MockCluster) Remove ¶
func (m *MockCluster) Remove(arg0 []api.Node, arg1 bool) error
Remove mocks base method.
func (*MockCluster) Resize ¶
func (m *MockCluster) Resize(arg0 context.Context, arg1 *api.SdkStoragePoolResizeRequest) (*api.SdkStoragePoolResizeResponse, error)
Resize mocks base method.
func (*MockCluster) SchedPolicyCreate ¶
func (m *MockCluster) SchedPolicyCreate(arg0, arg1 string) error
SchedPolicyCreate mocks base method.
func (*MockCluster) SchedPolicyDelete ¶
func (m *MockCluster) SchedPolicyDelete(arg0 string) error
SchedPolicyDelete mocks base method.
func (*MockCluster) SchedPolicyEnumerate ¶
func (m *MockCluster) SchedPolicyEnumerate() ([]*schedpolicy.SchedPolicy, error)
SchedPolicyEnumerate mocks base method.
func (*MockCluster) SchedPolicyGet ¶
func (m *MockCluster) SchedPolicyGet(arg0 string) (*schedpolicy.SchedPolicy, error)
SchedPolicyGet mocks base method.
func (*MockCluster) SchedPolicyUpdate ¶
func (m *MockCluster) SchedPolicyUpdate(arg0, arg1 string) error
SchedPolicyUpdate mocks base method.
func (*MockCluster) SecretCheckLogin ¶
func (m *MockCluster) SecretCheckLogin() error
SecretCheckLogin mocks base method.
func (*MockCluster) SecretGet ¶
func (m *MockCluster) SecretGet(arg0 string) (interface{}, error)
SecretGet mocks base method.
func (*MockCluster) SecretGetDefaultSecretKey ¶
func (m *MockCluster) SecretGetDefaultSecretKey() (interface{}, error)
SecretGetDefaultSecretKey mocks base method.
func (*MockCluster) SecretLogin ¶
func (m *MockCluster) SecretLogin(arg0 string, arg1 map[string]string) error
SecretLogin mocks base method.
func (*MockCluster) SecretSet ¶
func (m *MockCluster) SecretSet(arg0 string, arg1 interface{}) error
SecretSet mocks base method.
func (*MockCluster) SecretSetDefaultSecretKey ¶
func (m *MockCluster) SecretSetDefaultSecretKey(arg0 string, arg1 bool) error
SecretSetDefaultSecretKey mocks base method.
func (*MockCluster) SetClusterConf ¶
func (m *MockCluster) SetClusterConf(arg0 *osdconfig.ClusterConfig) error
SetClusterConf mocks base method.
func (*MockCluster) SetNodeConf ¶
func (m *MockCluster) SetNodeConf(arg0 *osdconfig.NodeConfig) error
SetNodeConf mocks base method.
func (*MockCluster) SetSize ¶
func (m *MockCluster) SetSize(arg0 int) error
SetSize mocks base method.
func (*MockCluster) Start ¶
func (m *MockCluster) Start(arg0 bool, arg1, arg2 string) error
Start mocks base method.
func (*MockCluster) StartWithConfiguration ¶
func (m *MockCluster) StartWithConfiguration(arg0 bool, arg1 string, arg2 []string, arg3 string, arg4 *cluster.ClusterServerConfiguration) error
StartWithConfiguration mocks base method.
func (*MockCluster) UncordonAttachments ¶
func (m *MockCluster) UncordonAttachments(arg0 context.Context, arg1 *api.SdkNodeUncordonAttachmentsRequest) (*api.SdkNodeUncordonAttachmentsResponse, error)
UncordonAttachments mocks base method.
func (*MockCluster) UpdateData ¶
func (m *MockCluster) UpdateData(arg0 map[string]interface{}) error
UpdateData mocks base method.
func (*MockCluster) UpdateDomainState ¶
func (m *MockCluster) UpdateDomainState(arg0 string, arg1 types.ClusterDomainState) error
UpdateDomainState mocks base method.
func (*MockCluster) UpdateJobState ¶
func (m *MockCluster) UpdateJobState(arg0 context.Context, arg1 *api.SdkUpdateJobRequest) (*api.SdkUpdateJobResponse, error)
UpdateJobState mocks base method.
func (*MockCluster) UpdateLabels ¶
func (m *MockCluster) UpdateLabels(arg0 map[string]string) error
UpdateLabels mocks base method.
func (*MockCluster) UpdateRebalanceJobState ¶
func (m *MockCluster) UpdateRebalanceJobState(arg0 context.Context, arg1 *api.SdkUpdateRebalanceJobRequest) (*api.SdkUpdateRebalanceJobResponse, error)
UpdateRebalanceJobState mocks base method.
func (*MockCluster) UpdateSchedulerNodeName ¶
func (m *MockCluster) UpdateSchedulerNodeName(arg0 string) error
UpdateSchedulerNodeName mocks base method.
func (*MockCluster) ValidatePair ¶
func (m *MockCluster) ValidatePair(arg0 string) error
ValidatePair mocks base method.
type MockClusterMockRecorder ¶
type MockClusterMockRecorder struct {
// contains filtered or unexported fields
}
MockClusterMockRecorder is the mock recorder for MockCluster.
func (*MockClusterMockRecorder) AddEventListener ¶
func (mr *MockClusterMockRecorder) AddEventListener(arg0 interface{}) *gomock.Call
AddEventListener indicates an expected call of AddEventListener.
func (*MockClusterMockRecorder) ClusterNotifyClusterDomainsUpdate ¶
func (mr *MockClusterMockRecorder) ClusterNotifyClusterDomainsUpdate(arg0 interface{}) *gomock.Call
ClusterNotifyClusterDomainsUpdate indicates an expected call of ClusterNotifyClusterDomainsUpdate.
func (*MockClusterMockRecorder) ClusterNotifyNodeDown ¶
func (mr *MockClusterMockRecorder) ClusterNotifyNodeDown(arg0 interface{}) *gomock.Call
ClusterNotifyNodeDown indicates an expected call of ClusterNotifyNodeDown.
func (*MockClusterMockRecorder) Collect ¶
func (mr *MockClusterMockRecorder) Collect(arg0, arg1 interface{}) *gomock.Call
Collect indicates an expected call of Collect.
func (*MockClusterMockRecorder) CordonAttachments ¶
func (mr *MockClusterMockRecorder) CordonAttachments(arg0, arg1 interface{}) *gomock.Call
CordonAttachments indicates an expected call of CordonAttachments.
func (*MockClusterMockRecorder) CreatePair ¶
func (mr *MockClusterMockRecorder) CreatePair(arg0 interface{}) *gomock.Call
CreatePair indicates an expected call of CreatePair.
func (*MockClusterMockRecorder) DeleteDomain ¶
func (mr *MockClusterMockRecorder) DeleteDomain(arg0 interface{}) *gomock.Call
DeleteDomain indicates an expected call of DeleteDomain.
func (*MockClusterMockRecorder) DeleteNodeConf ¶
func (mr *MockClusterMockRecorder) DeleteNodeConf(arg0 interface{}) *gomock.Call
DeleteNodeConf indicates an expected call of DeleteNodeConf.
func (*MockClusterMockRecorder) DeletePair ¶
func (mr *MockClusterMockRecorder) DeletePair(arg0 interface{}) *gomock.Call
DeletePair indicates an expected call of DeletePair.
func (*MockClusterMockRecorder) DisableUpdates ¶
func (mr *MockClusterMockRecorder) DisableUpdates() *gomock.Call
DisableUpdates indicates an expected call of DisableUpdates.
func (*MockClusterMockRecorder) DrainAttachments ¶
func (mr *MockClusterMockRecorder) DrainAttachments(arg0, arg1 interface{}) *gomock.Call
DrainAttachments indicates an expected call of DrainAttachments.
func (*MockClusterMockRecorder) EnableUpdates ¶
func (mr *MockClusterMockRecorder) EnableUpdates() *gomock.Call
EnableUpdates indicates an expected call of EnableUpdates.
func (*MockClusterMockRecorder) Enumerate ¶
func (mr *MockClusterMockRecorder) Enumerate() *gomock.Call
Enumerate indicates an expected call of Enumerate.
func (*MockClusterMockRecorder) EnumerateAlerts ¶
func (mr *MockClusterMockRecorder) EnumerateAlerts(arg0, arg1, arg2 interface{}) *gomock.Call
EnumerateAlerts indicates an expected call of EnumerateAlerts.
func (*MockClusterMockRecorder) EnumerateDomains ¶
func (mr *MockClusterMockRecorder) EnumerateDomains() *gomock.Call
EnumerateDomains indicates an expected call of EnumerateDomains.
func (*MockClusterMockRecorder) EnumerateJobs ¶
func (mr *MockClusterMockRecorder) EnumerateJobs(arg0, arg1 interface{}) *gomock.Call
EnumerateJobs indicates an expected call of EnumerateJobs.
func (*MockClusterMockRecorder) EnumerateNodeConf ¶
func (mr *MockClusterMockRecorder) EnumerateNodeConf() *gomock.Call
EnumerateNodeConf indicates an expected call of EnumerateNodeConf.
func (*MockClusterMockRecorder) EnumeratePairs ¶
func (mr *MockClusterMockRecorder) EnumeratePairs() *gomock.Call
EnumeratePairs indicates an expected call of EnumeratePairs.
func (*MockClusterMockRecorder) EnumerateRebalanceJobs ¶
func (mr *MockClusterMockRecorder) EnumerateRebalanceJobs(arg0, arg1 interface{}) *gomock.Call
EnumerateRebalanceJobs indicates an expected call of EnumerateRebalanceJobs.
func (*MockClusterMockRecorder) EraseAlert ¶
func (mr *MockClusterMockRecorder) EraseAlert(arg0, arg1 interface{}) *gomock.Call
EraseAlert indicates an expected call of EraseAlert.
func (*MockClusterMockRecorder) GetClusterConf ¶
func (mr *MockClusterMockRecorder) GetClusterConf() *gomock.Call
GetClusterConf indicates an expected call of GetClusterConf.
func (*MockClusterMockRecorder) GetData ¶
func (mr *MockClusterMockRecorder) GetData() *gomock.Call
GetData indicates an expected call of GetData.
func (*MockClusterMockRecorder) GetGossipState ¶
func (mr *MockClusterMockRecorder) GetGossipState() *gomock.Call
GetGossipState indicates an expected call of GetGossipState.
func (*MockClusterMockRecorder) GetJobStatus ¶
func (mr *MockClusterMockRecorder) GetJobStatus(arg0, arg1 interface{}) *gomock.Call
GetJobStatus indicates an expected call of GetJobStatus.
func (*MockClusterMockRecorder) GetNodeConf ¶
func (mr *MockClusterMockRecorder) GetNodeConf(arg0 interface{}) *gomock.Call
GetNodeConf indicates an expected call of GetNodeConf.
func (*MockClusterMockRecorder) GetNodeIdFromIp ¶
func (mr *MockClusterMockRecorder) GetNodeIdFromIp(arg0 interface{}) *gomock.Call
GetNodeIdFromIp indicates an expected call of GetNodeIdFromIp.
func (*MockClusterMockRecorder) GetPair ¶
func (mr *MockClusterMockRecorder) GetPair(arg0 interface{}) *gomock.Call
GetPair indicates an expected call of GetPair.
func (*MockClusterMockRecorder) GetPairToken ¶
func (mr *MockClusterMockRecorder) GetPairToken(arg0 interface{}) *gomock.Call
GetPairToken indicates an expected call of GetPairToken.
func (*MockClusterMockRecorder) GetRebalanceJobStatus ¶
func (mr *MockClusterMockRecorder) GetRebalanceJobStatus(arg0, arg1 interface{}) *gomock.Call
GetRebalanceJobStatus indicates an expected call of GetRebalanceJobStatus.
func (*MockClusterMockRecorder) GetSelfDomain ¶
func (mr *MockClusterMockRecorder) GetSelfDomain() *gomock.Call
GetSelfDomain indicates an expected call of GetSelfDomain.
func (*MockClusterMockRecorder) Inspect ¶
func (mr *MockClusterMockRecorder) Inspect(arg0 interface{}) *gomock.Call
Inspect indicates an expected call of Inspect.
func (*MockClusterMockRecorder) InspectDomain ¶
func (mr *MockClusterMockRecorder) InspectDomain(arg0 interface{}) *gomock.Call
InspectDomain indicates an expected call of InspectDomain.
func (*MockClusterMockRecorder) NodeRemoveDone ¶
func (mr *MockClusterMockRecorder) NodeRemoveDone(arg0, arg1 interface{}) *gomock.Call
NodeRemoveDone indicates an expected call of NodeRemoveDone.
func (*MockClusterMockRecorder) NodeStatus ¶
func (mr *MockClusterMockRecorder) NodeStatus() *gomock.Call
NodeStatus indicates an expected call of NodeStatus.
func (*MockClusterMockRecorder) ObjectStoreCreate ¶
func (mr *MockClusterMockRecorder) ObjectStoreCreate(arg0 interface{}) *gomock.Call
ObjectStoreCreate indicates an expected call of ObjectStoreCreate.
func (*MockClusterMockRecorder) ObjectStoreDelete ¶
func (mr *MockClusterMockRecorder) ObjectStoreDelete(arg0 interface{}) *gomock.Call
ObjectStoreDelete indicates an expected call of ObjectStoreDelete.
func (*MockClusterMockRecorder) ObjectStoreInspect ¶
func (mr *MockClusterMockRecorder) ObjectStoreInspect(arg0 interface{}) *gomock.Call
ObjectStoreInspect indicates an expected call of ObjectStoreInspect.
func (*MockClusterMockRecorder) ObjectStoreUpdate ¶
func (mr *MockClusterMockRecorder) ObjectStoreUpdate(arg0, arg1 interface{}) *gomock.Call
ObjectStoreUpdate indicates an expected call of ObjectStoreUpdate.
func (*MockClusterMockRecorder) PeerStatus ¶
func (mr *MockClusterMockRecorder) PeerStatus(arg0 interface{}) *gomock.Call
PeerStatus indicates an expected call of PeerStatus.
func (*MockClusterMockRecorder) ProcessPairRequest ¶
func (mr *MockClusterMockRecorder) ProcessPairRequest(arg0 interface{}) *gomock.Call
ProcessPairRequest indicates an expected call of ProcessPairRequest.
func (*MockClusterMockRecorder) Rebalance ¶
func (mr *MockClusterMockRecorder) Rebalance(arg0, arg1 interface{}) *gomock.Call
Rebalance indicates an expected call of Rebalance.
func (*MockClusterMockRecorder) RefreshPair ¶
func (mr *MockClusterMockRecorder) RefreshPair(arg0 interface{}) *gomock.Call
RefreshPair indicates an expected call of RefreshPair.
func (*MockClusterMockRecorder) Remove ¶
func (mr *MockClusterMockRecorder) Remove(arg0, arg1 interface{}) *gomock.Call
Remove indicates an expected call of Remove.
func (*MockClusterMockRecorder) Resize ¶
func (mr *MockClusterMockRecorder) Resize(arg0, arg1 interface{}) *gomock.Call
Resize indicates an expected call of Resize.
func (*MockClusterMockRecorder) SchedPolicyCreate ¶
func (mr *MockClusterMockRecorder) SchedPolicyCreate(arg0, arg1 interface{}) *gomock.Call
SchedPolicyCreate indicates an expected call of SchedPolicyCreate.
func (*MockClusterMockRecorder) SchedPolicyDelete ¶
func (mr *MockClusterMockRecorder) SchedPolicyDelete(arg0 interface{}) *gomock.Call
SchedPolicyDelete indicates an expected call of SchedPolicyDelete.
func (*MockClusterMockRecorder) SchedPolicyEnumerate ¶
func (mr *MockClusterMockRecorder) SchedPolicyEnumerate() *gomock.Call
SchedPolicyEnumerate indicates an expected call of SchedPolicyEnumerate.
func (*MockClusterMockRecorder) SchedPolicyGet ¶
func (mr *MockClusterMockRecorder) SchedPolicyGet(arg0 interface{}) *gomock.Call
SchedPolicyGet indicates an expected call of SchedPolicyGet.
func (*MockClusterMockRecorder) SchedPolicyUpdate ¶
func (mr *MockClusterMockRecorder) SchedPolicyUpdate(arg0, arg1 interface{}) *gomock.Call
SchedPolicyUpdate indicates an expected call of SchedPolicyUpdate.
func (*MockClusterMockRecorder) SecretCheckLogin ¶
func (mr *MockClusterMockRecorder) SecretCheckLogin() *gomock.Call
SecretCheckLogin indicates an expected call of SecretCheckLogin.
func (*MockClusterMockRecorder) SecretGet ¶
func (mr *MockClusterMockRecorder) SecretGet(arg0 interface{}) *gomock.Call
SecretGet indicates an expected call of SecretGet.
func (*MockClusterMockRecorder) SecretGetDefaultSecretKey ¶
func (mr *MockClusterMockRecorder) SecretGetDefaultSecretKey() *gomock.Call
SecretGetDefaultSecretKey indicates an expected call of SecretGetDefaultSecretKey.
func (*MockClusterMockRecorder) SecretLogin ¶
func (mr *MockClusterMockRecorder) SecretLogin(arg0, arg1 interface{}) *gomock.Call
SecretLogin indicates an expected call of SecretLogin.
func (*MockClusterMockRecorder) SecretSet ¶
func (mr *MockClusterMockRecorder) SecretSet(arg0, arg1 interface{}) *gomock.Call
SecretSet indicates an expected call of SecretSet.
func (*MockClusterMockRecorder) SecretSetDefaultSecretKey ¶
func (mr *MockClusterMockRecorder) SecretSetDefaultSecretKey(arg0, arg1 interface{}) *gomock.Call
SecretSetDefaultSecretKey indicates an expected call of SecretSetDefaultSecretKey.
func (*MockClusterMockRecorder) SetClusterConf ¶
func (mr *MockClusterMockRecorder) SetClusterConf(arg0 interface{}) *gomock.Call
SetClusterConf indicates an expected call of SetClusterConf.
func (*MockClusterMockRecorder) SetNodeConf ¶
func (mr *MockClusterMockRecorder) SetNodeConf(arg0 interface{}) *gomock.Call
SetNodeConf indicates an expected call of SetNodeConf.
func (*MockClusterMockRecorder) SetSize ¶
func (mr *MockClusterMockRecorder) SetSize(arg0 interface{}) *gomock.Call
SetSize indicates an expected call of SetSize.
func (*MockClusterMockRecorder) Shutdown ¶
func (mr *MockClusterMockRecorder) Shutdown() *gomock.Call
Shutdown indicates an expected call of Shutdown.
func (*MockClusterMockRecorder) Start ¶
func (mr *MockClusterMockRecorder) Start(arg0, arg1, arg2 interface{}) *gomock.Call
Start indicates an expected call of Start.
func (*MockClusterMockRecorder) StartWithConfiguration ¶
func (mr *MockClusterMockRecorder) StartWithConfiguration(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
StartWithConfiguration indicates an expected call of StartWithConfiguration.
func (*MockClusterMockRecorder) UncordonAttachments ¶
func (mr *MockClusterMockRecorder) UncordonAttachments(arg0, arg1 interface{}) *gomock.Call
UncordonAttachments indicates an expected call of UncordonAttachments.
func (*MockClusterMockRecorder) UpdateData ¶
func (mr *MockClusterMockRecorder) UpdateData(arg0 interface{}) *gomock.Call
UpdateData indicates an expected call of UpdateData.
func (*MockClusterMockRecorder) UpdateDomainState ¶
func (mr *MockClusterMockRecorder) UpdateDomainState(arg0, arg1 interface{}) *gomock.Call
UpdateDomainState indicates an expected call of UpdateDomainState.
func (*MockClusterMockRecorder) UpdateJobState ¶
func (mr *MockClusterMockRecorder) UpdateJobState(arg0, arg1 interface{}) *gomock.Call
UpdateJobState indicates an expected call of UpdateJobState.
func (*MockClusterMockRecorder) UpdateLabels ¶
func (mr *MockClusterMockRecorder) UpdateLabels(arg0 interface{}) *gomock.Call
UpdateLabels indicates an expected call of UpdateLabels.
func (*MockClusterMockRecorder) UpdateRebalanceJobState ¶
func (mr *MockClusterMockRecorder) UpdateRebalanceJobState(arg0, arg1 interface{}) *gomock.Call
UpdateRebalanceJobState indicates an expected call of UpdateRebalanceJobState.
func (*MockClusterMockRecorder) UpdateSchedulerNodeName ¶
func (mr *MockClusterMockRecorder) UpdateSchedulerNodeName(arg0 interface{}) *gomock.Call
UpdateSchedulerNodeName indicates an expected call of UpdateSchedulerNodeName.
func (*MockClusterMockRecorder) Uuid ¶
func (mr *MockClusterMockRecorder) Uuid() *gomock.Call
Uuid indicates an expected call of Uuid.
func (*MockClusterMockRecorder) ValidatePair ¶
func (mr *MockClusterMockRecorder) ValidatePair(arg0 interface{}) *gomock.Call
ValidatePair indicates an expected call of ValidatePair.