Versions in this module Expand all Collapse all v0 v0.3.0 Mar 9, 2022 v0.2.0 Jan 5, 2022 Changes in this version + type MockClient struct + func NewMockClient(ctrl *gomock.Controller) *MockClient + func (m *MockClient) AddSchedulingRule(group uint64, ruleName, groupByLabel string) error + func (m *MockClient) AllocID() (uint64, error) + func (m *MockClient) AskBatchSplit(res metadata.Resource, count uint32) ([]rpcpb.SplitID, error) + func (m *MockClient) AsyncAddResources(resources ...metadata.Resource) error + func (m *MockClient) AsyncAddResourcesWithLeastPeers(resources []metadata.Resource, leastPeers []int) error + func (m *MockClient) AsyncRemoveResources(ids ...uint64) error + func (m *MockClient) CheckResourceState(resources *roaring64.Bitmap) (rpcpb.CheckResourceStateRsp, error) + func (m *MockClient) Close() error + func (m *MockClient) ContainerHeartbeat(hb rpcpb.ContainerHeartbeatReq) (rpcpb.ContainerHeartbeatRsp, error) + func (m *MockClient) CreateDestroying(id, index uint64, removeData bool, replicas []uint64) (metapb.ResourceState, error) + func (m *MockClient) CreateJob(arg0 metapb.Job) error + func (m *MockClient) EXPECT() *MockClientMockRecorder + func (m *MockClient) ExecuteJob(arg0 metapb.Job, arg1 []byte) ([]byte, error) + func (m *MockClient) GetAppliedRules(id uint64) ([]rpcpb.PlacementRule, error) + func (m *MockClient) GetContainer(containerID uint64) (metadata.Container, error) + func (m *MockClient) GetDestroying(id uint64) (*metapb.DestroyingStatus, error) + func (m *MockClient) GetResourceHeartbeatRspNotifier() (chan rpcpb.ResourceHeartbeatRsp, error) + func (m *MockClient) GetSchedulingRules() ([]metapb.ScheduleGroupRule, error) + func (m *MockClient) NewWatcher(flag uint32) (prophet.Watcher, error) + func (m *MockClient) PutContainer(container metadata.Container) error + func (m *MockClient) PutPlacementRule(rule rpcpb.PlacementRule) error + func (m *MockClient) RemoveJob(arg0 metapb.Job) error + func (m *MockClient) ReportDestroyed(id, replicaID uint64) (metapb.ResourceState, error) + func (m *MockClient) ResourceHeartbeat(meta metadata.Resource, hb rpcpb.ResourceHeartbeatReq) error + type MockClientMockRecorder struct + func (mr *MockClientMockRecorder) AddSchedulingRule(group, ruleName, groupByLabel interface{}) *gomock.Call + func (mr *MockClientMockRecorder) AllocID() *gomock.Call + func (mr *MockClientMockRecorder) AskBatchSplit(res, count interface{}) *gomock.Call + func (mr *MockClientMockRecorder) AsyncAddResources(resources ...interface{}) *gomock.Call + func (mr *MockClientMockRecorder) AsyncAddResourcesWithLeastPeers(resources, leastPeers interface{}) *gomock.Call + func (mr *MockClientMockRecorder) AsyncRemoveResources(ids ...interface{}) *gomock.Call + func (mr *MockClientMockRecorder) CheckResourceState(resources interface{}) *gomock.Call + func (mr *MockClientMockRecorder) Close() *gomock.Call + func (mr *MockClientMockRecorder) ContainerHeartbeat(hb interface{}) *gomock.Call + func (mr *MockClientMockRecorder) CreateDestroying(id, index, removeData, replicas interface{}) *gomock.Call + func (mr *MockClientMockRecorder) CreateJob(arg0 interface{}) *gomock.Call + func (mr *MockClientMockRecorder) ExecuteJob(arg0, arg1 interface{}) *gomock.Call + func (mr *MockClientMockRecorder) GetAppliedRules(id interface{}) *gomock.Call + func (mr *MockClientMockRecorder) GetContainer(containerID interface{}) *gomock.Call + func (mr *MockClientMockRecorder) GetDestroying(id interface{}) *gomock.Call + func (mr *MockClientMockRecorder) GetResourceHeartbeatRspNotifier() *gomock.Call + func (mr *MockClientMockRecorder) GetSchedulingRules() *gomock.Call + func (mr *MockClientMockRecorder) NewWatcher(flag interface{}) *gomock.Call + func (mr *MockClientMockRecorder) PutContainer(container interface{}) *gomock.Call + func (mr *MockClientMockRecorder) PutPlacementRule(rule interface{}) *gomock.Call + func (mr *MockClientMockRecorder) RemoveJob(arg0 interface{}) *gomock.Call + func (mr *MockClientMockRecorder) ReportDestroyed(id, replicaID interface{}) *gomock.Call + func (mr *MockClientMockRecorder) ResourceHeartbeat(meta, hb interface{}) *gomock.Call
Go to main page