controllerhost

Documentation

Index

• type MockControllerHost
  • func (m *MockControllerHost) CreateConsumerGroup(ctx thrift.Context, createRequest *shared.CreateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)
  • func (m *MockControllerHost) CreateDestination(ctx thrift.Context, createRequest *shared.CreateDestinationRequest) (*shared.DestinationDescription, error)
  • func (m *MockControllerHost) CreateRemoteZoneConsumerGroupExtent(ctx thrift.Context, createRequest *shared.CreateConsumerGroupExtentRequest) error
  • func (m *MockControllerHost) CreateRemoteZoneExtent(ctx thrift.Context, createRequest *shared.CreateExtentRequest) (*shared.CreateExtentResult_, error)
  • func (m *MockControllerHost) DeleteConsumerGroup(ctx thrift.Context, deleteRequest *shared.DeleteConsumerGroupRequest) error
  • func (m *MockControllerHost) DeleteDestination(ctx thrift.Context, deleteRequest *shared.DeleteDestinationRequest) error
  • func (m *MockControllerHost) GetCapacities(ctx thrift.Context, getCapacitiesRequest *controller.GetCapacitiesRequest) (*controller.GetCapacitiesResult_, error)
  • func (m *MockControllerHost) GetInputHosts(ctx thrift.Context, getHostsRequest *controller.GetInputHostsRequest) (*controller.GetInputHostsResult_, error)
  • func (m *MockControllerHost) GetOutputHosts(ctx thrift.Context, getHostsRequest *controller.GetOutputHostsRequest) (*controller.GetOutputHostsResult_, error)
  • func (m *MockControllerHost) GetQueueDepthInfo(ctx thrift.Context, infoRequest *controller.GetQueueDepthInfoRequest) (*controller.GetQueueDepthInfoResult_, error)
  • func (m *MockControllerHost) RemoveCapacities(ctx thrift.Context, ...) error
  • func (m *MockControllerHost) ReportConsumerGroupExtentMetric(ctx thrift.Context, ...) error
  • func (m *MockControllerHost) ReportConsumerGroupMetric(ctx thrift.Context, ...) error
  • func (m *MockControllerHost) ReportDestinationExtentMetric(ctx thrift.Context, ...) error
  • func (m *MockControllerHost) ReportDestinationMetric(ctx thrift.Context, ...) error
  • func (m *MockControllerHost) ReportNodeMetric(ctx thrift.Context, reportMetricRequest *controller.ReportNodeMetricRequest) error
  • func (m *MockControllerHost) ReportStoreExtentMetric(ctx thrift.Context, ...) error
  • func (m *MockControllerHost) UpdateConsumerGroup(ctx thrift.Context, updateRequest *shared.UpdateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)
  • func (m *MockControllerHost) UpdateDestination(ctx thrift.Context, updateRequest *shared.UpdateDestinationRequest) (*shared.DestinationDescription, error)
  • func (m *MockControllerHost) UpsertInputHostCapacities(ctx thrift.Context, ...) error
  • func (m *MockControllerHost) UpsertOutputHostCapacities(ctx thrift.Context, ...) error
  • func (m *MockControllerHost) UpsertStoreCapacities(ctx thrift.Context, ...) error

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

func (m *MockControllerHost) CreateRemoteZoneConsumerGroupExtent(ctx thrift.Context, createRequest *shared.CreateConsumerGroupExtentRequest) error

CreateRemoteZoneExtent 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