controllerhost

package
v1.16.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2017 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockControllerHost 

type MockControllerHost struct {
	mock.Mock
}

MockControllerHost is the mock implementation for controller host and used for testing

func (*MockControllerHost) CreateConsumerGroup 

func (m *MockControllerHost) CreateConsumerGroup(ctx thrift.Context, createRequest *shared.CreateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

CreateConsumerGroup is the mock for corresponding ControllerHost API

func (*MockControllerHost) CreateDestination 

func (m *MockControllerHost) CreateDestination(ctx thrift.Context, createRequest *shared.CreateDestinationRequest) (*shared.DestinationDescription, error)

CreateDestination is the mock for corresponding ControllerHost API

func (*MockControllerHost) CreateRemoteZoneExtent 

func (m *MockControllerHost) CreateRemoteZoneExtent(ctx thrift.Context, createRequest *shared.CreateExtentRequest) (*shared.CreateExtentResult_, error)

CreateRemoteZoneExtent is the mock for corresponding ControllerHost API

func (*MockControllerHost) DeleteConsumerGroup 

func (m *MockControllerHost) DeleteConsumerGroup(ctx thrift.Context, deleteRequest *shared.DeleteConsumerGroupRequest) error

DeleteConsumerGroup is the mock for corresponding ControllerHost API

func (*MockControllerHost) DeleteDestination 

func (m *MockControllerHost) DeleteDestination(ctx thrift.Context, deleteRequest *shared.DeleteDestinationRequest) error

DeleteDestination is the mock for corresponding ControllerHost API

func (*MockControllerHost) GetCapacities 

func (m *MockControllerHost) GetCapacities(ctx thrift.Context, getCapacitiesRequest *controller.GetCapacitiesRequest) (*controller.GetCapacitiesResult_, error)

GetCapacities is the mock for corresponding ControllerHost API

func (*MockControllerHost) GetInputHosts 

func (m *MockControllerHost) GetInputHosts(ctx thrift.Context, getHostsRequest *controller.GetInputHostsRequest) (*controller.GetInputHostsResult_, error)

GetInputHosts is the mock for corresponding ControllerHost API

func (*MockControllerHost) GetOutputHosts 

func (m *MockControllerHost) GetOutputHosts(ctx thrift.Context, getHostsRequest *controller.GetOutputHostsRequest) (*controller.GetOutputHostsResult_, error)

GetOutputHosts is the mock for corresponding ControllerHost API

func (*MockControllerHost) GetQueueDepthInfo 

func (m *MockControllerHost) GetQueueDepthInfo(ctx thrift.Context, infoRequest *controller.GetQueueDepthInfoRequest) (*controller.GetQueueDepthInfoResult_, error)

GetQueueDepthInfo to return queue depth backlog infor for consumer group

func (*MockControllerHost) RemoveCapacities 

func (m *MockControllerHost) RemoveCapacities(ctx thrift.Context, removeCapacitiesRequest *controller.RemoveCapacitiesRequest) error

RemoveCapacities is the mock for corresponding ControllerHost API

func (*MockControllerHost) ReportConsumerGroupExtentMetric 

func (m *MockControllerHost) ReportConsumerGroupExtentMetric(ctx thrift.Context, reportMetricRequest *controller.ReportConsumerGroupExtentMetricRequest) error

ReportConsumerGroupExtentMetric is the mock for corresponding ControllerHost API

func (*MockControllerHost) ReportConsumerGroupMetric 

func (m *MockControllerHost) ReportConsumerGroupMetric(ctx thrift.Context, reportMetricRequest *controller.ReportConsumerGroupMetricRequest) error

ReportConsumerGroupMetric is the mock for corresponding ControllerHost API

func (*MockControllerHost) ReportDestinationExtentMetric 

func (m *MockControllerHost) ReportDestinationExtentMetric(ctx thrift.Context, reportMetricRequest *controller.ReportDestinationExtentMetricRequest) error

ReportDestinationExtentMetric is the mock for corresponding ControllerHost API

func (*MockControllerHost) ReportDestinationMetric 

func (m *MockControllerHost) ReportDestinationMetric(ctx thrift.Context, reportMetricRequest *controller.ReportDestinationMetricRequest) error

ReportDestinationMetric is the mock for corresponding ControllerHost API

func (*MockControllerHost) ReportNodeMetric 

func (m *MockControllerHost) ReportNodeMetric(ctx thrift.Context, reportMetricRequest *controller.ReportNodeMetricRequest) error

ReportNodeMetric is the mock for corresponding ControllerHost API

func (*MockControllerHost) ReportStoreExtentMetric 

func (m *MockControllerHost) ReportStoreExtentMetric(ctx thrift.Context, reportMetricRequest *controller.ReportStoreExtentMetricRequest) error

ReportStoreExtentMetric is the mock for corresponding ControllerHost API

func (*MockControllerHost) UpdateConsumerGroup 

func (m *MockControllerHost) UpdateConsumerGroup(ctx thrift.Context, updateRequest *shared.UpdateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

UpdateConsumerGroup is the mock for corresponding ControllerHost API

func (*MockControllerHost) UpdateDestination 

func (m *MockControllerHost) UpdateDestination(ctx thrift.Context, updateRequest *shared.UpdateDestinationRequest) (*shared.DestinationDescription, error)

UpdateDestination is the mock for corresponding ControllerHost API

func (*MockControllerHost) UpsertInputHostCapacities 

func (m *MockControllerHost) UpsertInputHostCapacities(ctx thrift.Context, upsertCapacitiesRequest *controller.UpsertInputHostCapacitiesRequest) error

UpsertInputHostCapacities is the mock for corresponding ControllerHost API

func (*MockControllerHost) UpsertOutputHostCapacities 

func (m *MockControllerHost) UpsertOutputHostCapacities(ctx thrift.Context, upsertCapacitiesRequest *controller.UpsertOutputHostCapacitiesRequest) error

UpsertOutputHostCapacities is the mock for corresponding ControllerHost API

func (*MockControllerHost) UpsertStoreCapacities 

func (m *MockControllerHost) UpsertStoreCapacities(ctx thrift.Context, upsertCapacitiesRequest *controller.UpsertStoreCapacitiesRequest) error

UpsertStoreCapacities is the mock for corresponding ControllerHost API

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.