mock_pool

Documentation

Overview

Package mock_pool is a generated GoMock package.

Index

• type MockWorkerNode
  • func NewMockWorkerNode(ctrl *gomock.Controller) *MockWorkerNode
  • func (m *MockWorkerNode) AddWorkerNode(ctx context.Context, node models.NodeEntry) error
  • func (m *MockWorkerNode) CheckRunningTaskInEachWorkerNode(ctx context.Context) map[primitive.ObjectID]bool
  • func (m *MockWorkerNode) DistributeWork(ctx context.Context, jobID models.Job, tasks []models.Task) ([]models.Task, []models.DistributeError, error)
  • func (m *MockWorkerNode) EXPECT() *MockWorkerNodeMockRecorder
  • func (m *MockWorkerNode) InitializePool(ctx context.Context, nodeEntries []models.NodeEntry)
  • func (m *MockWorkerNode) IsAvailableWorkerNode() bool
  • func (m *MockWorkerNode) RemoveNodeFromPool(ctx context.Context, nodeID string)
  • func (m *MockWorkerNode) WorkerNodeAvailabilityCheck(ctx context.Context)
• type MockWorkerNodeMockRecorder
  • func (mr *MockWorkerNodeMockRecorder) AddWorkerNode(ctx, node any) *gomock.Call
  • func (mr *MockWorkerNodeMockRecorder) CheckRunningTaskInEachWorkerNode(ctx any) *gomock.Call
  • func (mr *MockWorkerNodeMockRecorder) DistributeWork(ctx, jobID, tasks any) *gomock.Call
  • func (mr *MockWorkerNodeMockRecorder) InitializePool(ctx, nodeEntries any) *gomock.Call
  • func (mr *MockWorkerNodeMockRecorder) IsAvailableWorkerNode() *gomock.Call
  • func (mr *MockWorkerNodeMockRecorder) RemoveNodeFromPool(ctx, nodeID any) *gomock.Call
  • func (mr *MockWorkerNodeMockRecorder) WorkerNodeAvailabilityCheck(ctx any) *gomock.Call

Types

type MockWorkerNode

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

MockWorkerNode is a mock of WorkerNode interface.

func NewMockWorkerNode

func NewMockWorkerNode(ctrl *gomock.Controller) *MockWorkerNode

NewMockWorkerNode creates a new mock instance.

func (*MockWorkerNode) AddWorkerNode

func (m *MockWorkerNode) AddWorkerNode(ctx context.Context, node models.NodeEntry) error

AddWorkerNode mocks base method.

func (*MockWorkerNode) CheckRunningTaskInEachWorkerNode

func (m *MockWorkerNode) CheckRunningTaskInEachWorkerNode(ctx context.Context) map[primitive.ObjectID]bool

CheckRunningTaskInEachWorkerNode mocks base method.

func (*MockWorkerNode) DistributeWork

func (m *MockWorkerNode) DistributeWork(ctx context.Context, jobID models.Job, tasks []models.Task) ([]models.Task, []models.DistributeError, error)

DistributeWork mocks base method.

func (*MockWorkerNode) EXPECT

func (m *MockWorkerNode) EXPECT() *MockWorkerNodeMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockWorkerNode) InitializePool

func (m *MockWorkerNode) InitializePool(ctx context.Context, nodeEntries []models.NodeEntry)

InitializePool mocks base method.

func (*MockWorkerNode) IsAvailableWorkerNode

func (m *MockWorkerNode) IsAvailableWorkerNode() bool

IsAvailableWorkerNode mocks base method.

func (*MockWorkerNode) RemoveNodeFromPool

func (m *MockWorkerNode) RemoveNodeFromPool(ctx context.Context, nodeID string)

RemoveNodeFromPool mocks base method.

func (*MockWorkerNode) WorkerNodeAvailabilityCheck

func (m *MockWorkerNode) WorkerNodeAvailabilityCheck(ctx context.Context)

WorkerNodeAvailabilityCheck mocks base method.

type MockWorkerNodeMockRecorder

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

MockWorkerNodeMockRecorder is the mock recorder for MockWorkerNode.

func (*MockWorkerNodeMockRecorder) AddWorkerNode

func (mr *MockWorkerNodeMockRecorder) AddWorkerNode(ctx, node any) *gomock.Call

AddWorkerNode indicates an expected call of AddWorkerNode.

func (*MockWorkerNodeMockRecorder) CheckRunningTaskInEachWorkerNode

func (mr *MockWorkerNodeMockRecorder) CheckRunningTaskInEachWorkerNode(ctx any) *gomock.Call

CheckRunningTaskInEachWorkerNode indicates an expected call of CheckRunningTaskInEachWorkerNode.

func (*MockWorkerNodeMockRecorder) DistributeWork

func (mr *MockWorkerNodeMockRecorder) DistributeWork(ctx, jobID, tasks any) *gomock.Call

DistributeWork indicates an expected call of DistributeWork.

func (*MockWorkerNodeMockRecorder) InitializePool

func (mr *MockWorkerNodeMockRecorder) InitializePool(ctx, nodeEntries any) *gomock.Call

InitializePool indicates an expected call of InitializePool.

func (*MockWorkerNodeMockRecorder) IsAvailableWorkerNode

func (mr *MockWorkerNodeMockRecorder) IsAvailableWorkerNode() *gomock.Call

IsAvailableWorkerNode indicates an expected call of IsAvailableWorkerNode.

func (*MockWorkerNodeMockRecorder) RemoveNodeFromPool

func (mr *MockWorkerNodeMockRecorder) RemoveNodeFromPool(ctx, nodeID any) *gomock.Call

RemoveNodeFromPool indicates an expected call of RemoveNodeFromPool.

func (*MockWorkerNodeMockRecorder) WorkerNodeAvailabilityCheck

func (mr *MockWorkerNodeMockRecorder) WorkerNodeAvailabilityCheck(ctx any) *gomock.Call

WorkerNodeAvailabilityCheck indicates an expected call of WorkerNodeAvailabilityCheck.