mockclient

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 9, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package mockclient is a generated GoMock package.

Index

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) AddSchedulingRule 

func (m *MockClient) AddSchedulingRule(group uint64, ruleName, groupByLabel string) error

AddSchedulingRule mocks base method.

func (*MockClient) AllocID 

func (m *MockClient) AllocID() (uint64, error)

AllocID mocks base method.

func (*MockClient) AskBatchSplit 

func (m *MockClient) AskBatchSplit(res metadata.Resource, count uint32) ([]rpcpb.SplitID, error)

AskBatchSplit mocks base method.

func (*MockClient) AsyncAddResources 

func (m *MockClient) AsyncAddResources(resources ...metadata.Resource) error

AsyncAddResources mocks base method.

func (*MockClient) AsyncAddResourcesWithLeastPeers 

func (m *MockClient) AsyncAddResourcesWithLeastPeers(resources []metadata.Resource, leastPeers []int) error

AsyncAddResourcesWithLeastPeers mocks base method.

func (*MockClient) AsyncRemoveResources 

func (m *MockClient) AsyncRemoveResources(ids ...uint64) error

AsyncRemoveResources mocks base method.

func (*MockClient) CheckResourceState 

func (m *MockClient) CheckResourceState(resources *roaring64.Bitmap) (rpcpb.CheckResourceStateRsp, error)

CheckResourceState mocks base method.

func (*MockClient) Close 

func (m *MockClient) Close() error

Close mocks base method.

func (*MockClient) ContainerHeartbeat 

func (m *MockClient) ContainerHeartbeat(hb rpcpb.ContainerHeartbeatReq) (rpcpb.ContainerHeartbeatRsp, error)

ContainerHeartbeat mocks base method.

func (*MockClient) CreateDestroying 

func (m *MockClient) CreateDestroying(id, index uint64, removeData bool, replicas []uint64) (metapb.ResourceState, error)

CreateDestroying mocks base method.

func (*MockClient) CreateJob 

func (m *MockClient) CreateJob(arg0 metapb.Job) error

CreateJob 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) ExecuteJob 

func (m *MockClient) ExecuteJob(arg0 metapb.Job, arg1 []byte) ([]byte, error)

ExecuteJob mocks base method.

func (*MockClient) GetAppliedRules 

func (m *MockClient) GetAppliedRules(id uint64) ([]rpcpb.PlacementRule, error)

GetAppliedRules mocks base method.

func (*MockClient) GetContainer 

func (m *MockClient) GetContainer(containerID uint64) (metadata.Container, error)

GetContainer mocks base method.

func (*MockClient) GetDestroying 

func (m *MockClient) GetDestroying(id uint64) (*metapb.DestroyingStatus, error)

GetDestroying mocks base method.

func (*MockClient) GetResourceHeartbeatRspNotifier 

func (m *MockClient) GetResourceHeartbeatRspNotifier() (chan rpcpb.ResourceHeartbeatRsp, error)

GetResourceHeartbeatRspNotifier mocks base method.

func (*MockClient) GetSchedulingRules 

func (m *MockClient) GetSchedulingRules() ([]metapb.ScheduleGroupRule, error)

GetSchedulingRules mocks base method.

func (*MockClient) NewWatcher 

func (m *MockClient) NewWatcher(flag uint32) (prophet.Watcher, error)

NewWatcher mocks base method.

func (*MockClient) PutContainer 

func (m *MockClient) PutContainer(container metadata.Container) error

PutContainer mocks base method.

func (*MockClient) PutPlacementRule 

func (m *MockClient) PutPlacementRule(rule rpcpb.PlacementRule) error

PutPlacementRule mocks base method.

func (*MockClient) RemoveJob 

func (m *MockClient) RemoveJob(arg0 metapb.Job) error

RemoveJob mocks base method.

func (*MockClient) ReportDestroyed 

func (m *MockClient) ReportDestroyed(id, replicaID uint64) (metapb.ResourceState, error)

ReportDestroyed mocks base method.

func (*MockClient) ResourceHeartbeat 

func (m *MockClient) ResourceHeartbeat(meta metadata.Resource, hb rpcpb.ResourceHeartbeatReq) error

ResourceHeartbeat mocks base method.

type MockClientMockRecorder 

type MockClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) AddSchedulingRule 

func (mr *MockClientMockRecorder) AddSchedulingRule(group, ruleName, groupByLabel interface{}) *gomock.Call

AddSchedulingRule indicates an expected call of AddSchedulingRule.

func (*MockClientMockRecorder) AllocID 

func (mr *MockClientMockRecorder) AllocID() *gomock.Call

AllocID indicates an expected call of AllocID.

func (*MockClientMockRecorder) AskBatchSplit 

func (mr *MockClientMockRecorder) AskBatchSplit(res, count interface{}) *gomock.Call

AskBatchSplit indicates an expected call of AskBatchSplit.

func (*MockClientMockRecorder) AsyncAddResources 

func (mr *MockClientMockRecorder) AsyncAddResources(resources ...interface{}) *gomock.Call

AsyncAddResources indicates an expected call of AsyncAddResources.

func (*MockClientMockRecorder) AsyncAddResourcesWithLeastPeers 

func (mr *MockClientMockRecorder) AsyncAddResourcesWithLeastPeers(resources, leastPeers interface{}) *gomock.Call

AsyncAddResourcesWithLeastPeers indicates an expected call of AsyncAddResourcesWithLeastPeers.

func (*MockClientMockRecorder) AsyncRemoveResources 

func (mr *MockClientMockRecorder) AsyncRemoveResources(ids ...interface{}) *gomock.Call

AsyncRemoveResources indicates an expected call of AsyncRemoveResources.

func (*MockClientMockRecorder) CheckResourceState 

func (mr *MockClientMockRecorder) CheckResourceState(resources interface{}) *gomock.Call

CheckResourceState indicates an expected call of CheckResourceState.

func (*MockClientMockRecorder) Close 

func (mr *MockClientMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockClientMockRecorder) ContainerHeartbeat 

func (mr *MockClientMockRecorder) ContainerHeartbeat(hb interface{}) *gomock.Call

ContainerHeartbeat indicates an expected call of ContainerHeartbeat.

func (*MockClientMockRecorder) CreateDestroying 

func (mr *MockClientMockRecorder) CreateDestroying(id, index, removeData, replicas interface{}) *gomock.Call

CreateDestroying indicates an expected call of CreateDestroying.

func (*MockClientMockRecorder) CreateJob 

func (mr *MockClientMockRecorder) CreateJob(arg0 interface{}) *gomock.Call

CreateJob indicates an expected call of CreateJob.

func (*MockClientMockRecorder) ExecuteJob 

func (mr *MockClientMockRecorder) ExecuteJob(arg0, arg1 interface{}) *gomock.Call

ExecuteJob indicates an expected call of ExecuteJob.

func (*MockClientMockRecorder) GetAppliedRules 

func (mr *MockClientMockRecorder) GetAppliedRules(id interface{}) *gomock.Call

GetAppliedRules indicates an expected call of GetAppliedRules.

func (*MockClientMockRecorder) GetContainer 

func (mr *MockClientMockRecorder) GetContainer(containerID interface{}) *gomock.Call

GetContainer indicates an expected call of GetContainer.

func (*MockClientMockRecorder) GetDestroying 

func (mr *MockClientMockRecorder) GetDestroying(id interface{}) *gomock.Call

GetDestroying indicates an expected call of GetDestroying.

func (*MockClientMockRecorder) GetResourceHeartbeatRspNotifier 

func (mr *MockClientMockRecorder) GetResourceHeartbeatRspNotifier() *gomock.Call

GetResourceHeartbeatRspNotifier indicates an expected call of GetResourceHeartbeatRspNotifier.

func (*MockClientMockRecorder) GetSchedulingRules 

func (mr *MockClientMockRecorder) GetSchedulingRules() *gomock.Call

GetSchedulingRules indicates an expected call of GetSchedulingRules.

func (*MockClientMockRecorder) NewWatcher 

func (mr *MockClientMockRecorder) NewWatcher(flag interface{}) *gomock.Call

NewWatcher indicates an expected call of NewWatcher.

func (*MockClientMockRecorder) PutContainer 

func (mr *MockClientMockRecorder) PutContainer(container interface{}) *gomock.Call

PutContainer indicates an expected call of PutContainer.

func (*MockClientMockRecorder) PutPlacementRule 

func (mr *MockClientMockRecorder) PutPlacementRule(rule interface{}) *gomock.Call

PutPlacementRule indicates an expected call of PutPlacementRule.

func (*MockClientMockRecorder) RemoveJob 

func (mr *MockClientMockRecorder) RemoveJob(arg0 interface{}) *gomock.Call

RemoveJob indicates an expected call of RemoveJob.

func (*MockClientMockRecorder) ReportDestroyed 

func (mr *MockClientMockRecorder) ReportDestroyed(id, replicaID interface{}) *gomock.Call

ReportDestroyed indicates an expected call of ReportDestroyed.

func (*MockClientMockRecorder) ResourceHeartbeat 

func (mr *MockClientMockRecorder) ResourceHeartbeat(meta, hb interface{}) *gomock.Call

ResourceHeartbeat indicates an expected call of ResourceHeartbeat.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.