mocks

package
v0.25.1 Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockCruiseControlScaler 

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

MockCruiseControlScaler is a mock of CruiseControlScaler interface.

func NewMockCruiseControlScaler 

func NewMockCruiseControlScaler(ctrl *gomock.Controller) *MockCruiseControlScaler

NewMockCruiseControlScaler creates a new mock instance.

func (*MockCruiseControlScaler) AddBrokers 

func (m *MockCruiseControlScaler) AddBrokers(ctx context.Context, brokerIDs ...string) (*scale.Result, error)

AddBrokers mocks base method.

func (*MockCruiseControlScaler) AddBrokersWithParams 

func (m *MockCruiseControlScaler) AddBrokersWithParams(ctx context.Context, params map[string]string) (*scale.Result, error)

AddBrokersWithParams mocks base method.

func (*MockCruiseControlScaler) BrokerWithLeastPartitionReplicas 

func (m *MockCruiseControlScaler) BrokerWithLeastPartitionReplicas(ctx context.Context) (string, error)

BrokerWithLeastPartitionReplicas mocks base method.

func (*MockCruiseControlScaler) BrokersWithState 

func (m *MockCruiseControlScaler) BrokersWithState(ctx context.Context, states ...scale.KafkaBrokerState) ([]string, error)

BrokersWithState mocks base method.

func (*MockCruiseControlScaler) EXPECT 

func (m *MockCruiseControlScaler) EXPECT() *MockCruiseControlScalerMockRecorder

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

func (*MockCruiseControlScaler) IsReady 

func (m *MockCruiseControlScaler) IsReady(ctx context.Context) bool

IsReady mocks base method.

func (*MockCruiseControlScaler) IsUp 

func (m *MockCruiseControlScaler) IsUp(ctx context.Context) bool

IsUp mocks base method.

func (*MockCruiseControlScaler) KafkaClusterLoad 

func (m *MockCruiseControlScaler) KafkaClusterLoad(ctx context.Context) (*api.KafkaClusterLoadResponse, error)

KafkaClusterLoad mocks base method.

func (*MockCruiseControlScaler) KafkaClusterState 

func (m *MockCruiseControlScaler) KafkaClusterState(ctx context.Context) (*types.KafkaClusterState, error)

KafkaClusterState mocks base method.

func (*MockCruiseControlScaler) LogDirsByBroker 

func (m *MockCruiseControlScaler) LogDirsByBroker(ctx context.Context) (map[string]map[scale.LogDirState][]string, error)

LogDirsByBroker mocks base method.

func (*MockCruiseControlScaler) PartitionReplicasByBroker 

func (m *MockCruiseControlScaler) PartitionReplicasByBroker(ctx context.Context) (map[string]int32, error)

PartitionReplicasByBroker mocks base method.

func (*MockCruiseControlScaler) RebalanceDisks 

func (m *MockCruiseControlScaler) RebalanceDisks(ctx context.Context, brokerIDs ...string) (*scale.Result, error)

RebalanceDisks mocks base method.

func (*MockCruiseControlScaler) RebalanceWithParams 

func (m *MockCruiseControlScaler) RebalanceWithParams(ctx context.Context, params map[string]string) (*scale.Result, error)

RebalanceWithParams mocks base method.

func (*MockCruiseControlScaler) RemoveBrokers 

func (m *MockCruiseControlScaler) RemoveBrokers(ctx context.Context, brokerIDs ...string) (*scale.Result, error)

RemoveBrokers mocks base method.

func (*MockCruiseControlScaler) RemoveBrokersWithParams 

func (m *MockCruiseControlScaler) RemoveBrokersWithParams(ctx context.Context, params map[string]string) (*scale.Result, error)

RemoveBrokersWithParams mocks base method.

func (*MockCruiseControlScaler) Status 

func (m *MockCruiseControlScaler) Status(ctx context.Context) (scale.StatusTaskResult, error)

Status mocks base method.

func (*MockCruiseControlScaler) StatusTask added in v0.25.0 

func (m *MockCruiseControlScaler) StatusTask(ctx context.Context, taskId string) (scale.StatusTaskResult, error)

StatusTask mocks base method.

func (*MockCruiseControlScaler) StopExecution 

func (m *MockCruiseControlScaler) StopExecution(ctx context.Context) (*scale.Result, error)

StopExecution mocks base method.

func (*MockCruiseControlScaler) UserTasks 

func (m *MockCruiseControlScaler) UserTasks(ctx context.Context, taskIDs ...string) ([]*scale.Result, error)

UserTasks mocks base method.

type MockCruiseControlScalerMockRecorder 

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

MockCruiseControlScalerMockRecorder is the mock recorder for MockCruiseControlScaler.

func (*MockCruiseControlScalerMockRecorder) AddBrokers 

func (mr *MockCruiseControlScalerMockRecorder) AddBrokers(ctx interface{}, brokerIDs ...interface{}) *gomock.Call

AddBrokers indicates an expected call of AddBrokers.

func (*MockCruiseControlScalerMockRecorder) AddBrokersWithParams 

func (mr *MockCruiseControlScalerMockRecorder) AddBrokersWithParams(ctx, params interface{}) *gomock.Call

AddBrokersWithParams indicates an expected call of AddBrokersWithParams.

func (*MockCruiseControlScalerMockRecorder) BrokerWithLeastPartitionReplicas 

func (mr *MockCruiseControlScalerMockRecorder) BrokerWithLeastPartitionReplicas(ctx interface{}) *gomock.Call

BrokerWithLeastPartitionReplicas indicates an expected call of BrokerWithLeastPartitionReplicas.

func (*MockCruiseControlScalerMockRecorder) BrokersWithState 

func (mr *MockCruiseControlScalerMockRecorder) BrokersWithState(ctx interface{}, states ...interface{}) *gomock.Call

BrokersWithState indicates an expected call of BrokersWithState.

func (*MockCruiseControlScalerMockRecorder) IsReady 

func (mr *MockCruiseControlScalerMockRecorder) IsReady(ctx interface{}) *gomock.Call

IsReady indicates an expected call of IsReady.

func (*MockCruiseControlScalerMockRecorder) IsUp 

func (mr *MockCruiseControlScalerMockRecorder) IsUp(ctx interface{}) *gomock.Call

IsUp indicates an expected call of IsUp.

func (*MockCruiseControlScalerMockRecorder) KafkaClusterLoad 

func (mr *MockCruiseControlScalerMockRecorder) KafkaClusterLoad(ctx interface{}) *gomock.Call

KafkaClusterLoad indicates an expected call of KafkaClusterLoad.

func (*MockCruiseControlScalerMockRecorder) KafkaClusterState 

func (mr *MockCruiseControlScalerMockRecorder) KafkaClusterState(ctx interface{}) *gomock.Call

KafkaClusterState indicates an expected call of KafkaClusterState.

func (*MockCruiseControlScalerMockRecorder) LogDirsByBroker 

func (mr *MockCruiseControlScalerMockRecorder) LogDirsByBroker(ctx interface{}) *gomock.Call

LogDirsByBroker indicates an expected call of LogDirsByBroker.

func (*MockCruiseControlScalerMockRecorder) PartitionReplicasByBroker 

func (mr *MockCruiseControlScalerMockRecorder) PartitionReplicasByBroker(ctx interface{}) *gomock.Call

PartitionReplicasByBroker indicates an expected call of PartitionReplicasByBroker.

func (*MockCruiseControlScalerMockRecorder) RebalanceDisks 

func (mr *MockCruiseControlScalerMockRecorder) RebalanceDisks(ctx interface{}, brokerIDs ...interface{}) *gomock.Call

RebalanceDisks indicates an expected call of RebalanceDisks.

func (*MockCruiseControlScalerMockRecorder) RebalanceWithParams 

func (mr *MockCruiseControlScalerMockRecorder) RebalanceWithParams(ctx, params interface{}) *gomock.Call

RebalanceWithParams indicates an expected call of RebalanceWithParams.

func (*MockCruiseControlScalerMockRecorder) RemoveBrokers 

func (mr *MockCruiseControlScalerMockRecorder) RemoveBrokers(ctx interface{}, brokerIDs ...interface{}) *gomock.Call

RemoveBrokers indicates an expected call of RemoveBrokers.

func (*MockCruiseControlScalerMockRecorder) RemoveBrokersWithParams 

func (mr *MockCruiseControlScalerMockRecorder) RemoveBrokersWithParams(ctx, params interface{}) *gomock.Call

RemoveBrokersWithParams indicates an expected call of RemoveBrokersWithParams.

func (*MockCruiseControlScalerMockRecorder) Status 

func (mr *MockCruiseControlScalerMockRecorder) Status(ctx interface{}) *gomock.Call

Status indicates an expected call of Status.

func (*MockCruiseControlScalerMockRecorder) StatusTask added in v0.25.0 

func (mr *MockCruiseControlScalerMockRecorder) StatusTask(ctx, taskId interface{}) *gomock.Call

StatusTask indicates an expected call of StatusTask.

func (*MockCruiseControlScalerMockRecorder) StopExecution 

func (mr *MockCruiseControlScalerMockRecorder) StopExecution(ctx interface{}) *gomock.Call

StopExecution indicates an expected call of StopExecution.

func (*MockCruiseControlScalerMockRecorder) UserTasks 

func (mr *MockCruiseControlScalerMockRecorder) UserTasks(ctx interface{}, taskIDs ...interface{}) *gomock.Call

UserTasks indicates an expected call of UserTasks.

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.