mocks

Documentation

Index

• type BFrontendListConsumerGroupsInCall
  • func (_m *BFrontendListConsumerGroupsInCall) Done() error
  • func (_m *BFrontendListConsumerGroupsInCall) Flush() error
  • func (_m *BFrontendListConsumerGroupsInCall) SetResponseHeaders(headers map[string]string) error
  • func (_m *BFrontendListConsumerGroupsInCall) Write(arg *cherami.ConsumerGroupDescription) error
• type BFrontendListDestinationsInCall
  • func (_m *BFrontendListDestinationsInCall) Done() error
  • func (_m *BFrontendListDestinationsInCall) Flush() error
  • func (_m *BFrontendListDestinationsInCall) SetResponseHeaders(headers map[string]string) error
  • func (_m *BFrontendListDestinationsInCall) Write(arg *cherami.DestinationDescription) error
• type MockCheramiClient
  • func (m *MockCheramiClient) Close()
  • func (m *MockCheramiClient) CreateConsumer(request *cli.CreateConsumerRequest) cli.Consumer
  • func (m *MockCheramiClient) CreateConsumerGroup(request *cherami.CreateConsumerGroupRequest) (*cherami.ConsumerGroupDescription, error)
  • func (m *MockCheramiClient) CreateDestination(request *cherami.CreateDestinationRequest) (*cherami.DestinationDescription, error)
  • func (m *MockCheramiClient) CreatePublisher(request *cli.CreatePublisherRequest) cli.Publisher
  • func (m *MockCheramiClient) CreateTaskExecutor(request *cli.CreateTaskExecutorRequest) cli.TaskExecutor
  • func (m *MockCheramiClient) CreateTaskScheduler(request *cli.CreateTaskSchedulerRequest) cli.TaskScheduler
  • func (m *MockCheramiClient) DeleteConsumerGroup(request *cherami.DeleteConsumerGroupRequest) error
  • func (m *MockCheramiClient) DeleteDestination(request *cherami.DeleteDestinationRequest) error
  • func (c *MockCheramiClient) GetQueueDepthInfo(request *cherami.GetQueueDepthInfoRequest) (*cherami.GetQueueDepthInfoResult_, error)
  • func (m *MockCheramiClient) ListConsumerGroups(request *cherami.ListConsumerGroupRequest) (*cherami.ListConsumerGroupResult_, error)
  • func (m *MockCheramiClient) ListDestinations(request *cherami.ListDestinationsRequest) (*cherami.ListDestinationsResult_, error)
  • func (m *MockCheramiClient) ReadConsumerGroup(request *cherami.ReadConsumerGroupRequest) (*cherami.ConsumerGroupDescription, error)
  • func (m *MockCheramiClient) ReadDestination(request *cherami.ReadDestinationRequest) (*cherami.DestinationDescription, error)
  • func (m *MockCheramiClient) UpdateConsumerGroup(request *cherami.UpdateConsumerGroupRequest) (*cherami.ConsumerGroupDescription, error)
  • func (m *MockCheramiClient) UpdateDestination(request *cherami.UpdateDestinationRequest) (*cherami.DestinationDescription, error)
• type MockConsumer
  • func (m *MockConsumer) AckDelivery(deliveryToken string) error
  • func (m *MockConsumer) Close()
  • func (m *MockConsumer) NackDelivery(deliveryToken string) error
  • func (m *MockConsumer) Open(deliveryCh chan cli.Delivery) (chan cli.Delivery, error)
• type MockDelivery
  • func (m *MockDelivery) Ack() error
  • func (m *MockDelivery) GetDeliveryToken() string
  • func (m *MockDelivery) GetMessage() *cherami.ConsumerMessage
  • func (m *MockDelivery) Nack() error
• type MockPublisher
  • func (m *MockPublisher) Close()
  • func (m *MockPublisher) Open() error
  • func (m *MockPublisher) Publish(message *cli.PublisherMessage) *cli.PublisherReceipt
  • func (m *MockPublisher) PublishAsync(message *cli.PublisherMessage, done chan<- *cli.PublisherReceipt) (string, error)

Types

type BFrontendListConsumerGroupsInCall

type BFrontendListConsumerGroupsInCall struct {
	mock.Mock
}

func (*BFrontendListConsumerGroupsInCall) Done

func (_m *BFrontendListConsumerGroupsInCall) Done() error

func (*BFrontendListConsumerGroupsInCall) Flush

func (_m *BFrontendListConsumerGroupsInCall) Flush() error

func (*BFrontendListConsumerGroupsInCall) SetResponseHeaders

func (_m *BFrontendListConsumerGroupsInCall) SetResponseHeaders(headers map[string]string) error

func (*BFrontendListConsumerGroupsInCall) Write

func (_m *BFrontendListConsumerGroupsInCall) Write(arg *cherami.ConsumerGroupDescription) error

type BFrontendListDestinationsInCall

type BFrontendListDestinationsInCall struct {
	mock.Mock
}

func (*BFrontendListDestinationsInCall) Done

func (_m *BFrontendListDestinationsInCall) Done() error

func (*BFrontendListDestinationsInCall) Flush

func (_m *BFrontendListDestinationsInCall) Flush() error

func (*BFrontendListDestinationsInCall) SetResponseHeaders

func (_m *BFrontendListDestinationsInCall) SetResponseHeaders(headers map[string]string) error

func (*BFrontendListDestinationsInCall) Write

func (_m *BFrontendListDestinationsInCall) Write(arg *cherami.DestinationDescription) error

type MockCheramiClient

type MockCheramiClient struct {
	mock.Mock
}

MockCheramiClient is the mock of cli.MockCheramiClient interface

func (*MockCheramiClient) Close

func (m *MockCheramiClient) Close()

func (*MockCheramiClient) CreateConsumer

func (m *MockCheramiClient) CreateConsumer(request *cli.CreateConsumerRequest) cli.Consumer

func (*MockCheramiClient) CreateConsumerGroup

func (m *MockCheramiClient) CreateConsumerGroup(request *cherami.CreateConsumerGroupRequest) (*cherami.ConsumerGroupDescription, error)

func (*MockCheramiClient) CreateDestination

func (m *MockCheramiClient) CreateDestination(request *cherami.CreateDestinationRequest) (*cherami.DestinationDescription, error)

func (*MockCheramiClient) CreatePublisher

func (m *MockCheramiClient) CreatePublisher(request *cli.CreatePublisherRequest) cli.Publisher

func (*MockCheramiClient) CreateTaskExecutor

func (m *MockCheramiClient) CreateTaskExecutor(request *cli.CreateTaskExecutorRequest) cli.TaskExecutor

func (*MockCheramiClient) CreateTaskScheduler

func (m *MockCheramiClient) CreateTaskScheduler(request *cli.CreateTaskSchedulerRequest) cli.TaskScheduler

func (*MockCheramiClient) DeleteConsumerGroup

func (m *MockCheramiClient) DeleteConsumerGroup(request *cherami.DeleteConsumerGroupRequest) error

func (*MockCheramiClient) DeleteDestination

func (m *MockCheramiClient) DeleteDestination(request *cherami.DeleteDestinationRequest) error

func (*MockCheramiClient) GetQueueDepthInfo

func (c *MockCheramiClient) GetQueueDepthInfo(request *cherami.GetQueueDepthInfoRequest) (*cherami.GetQueueDepthInfoResult_, error)

func (*MockCheramiClient) ListConsumerGroups

func (m *MockCheramiClient) ListConsumerGroups(request *cherami.ListConsumerGroupRequest) (*cherami.ListConsumerGroupResult_, error)

func (*MockCheramiClient) ListDestinations

func (m *MockCheramiClient) ListDestinations(request *cherami.ListDestinationsRequest) (*cherami.ListDestinationsResult_, error)

func (*MockCheramiClient) ReadConsumerGroup

func (m *MockCheramiClient) ReadConsumerGroup(request *cherami.ReadConsumerGroupRequest) (*cherami.ConsumerGroupDescription, error)

func (*MockCheramiClient) ReadDestination

func (m *MockCheramiClient) ReadDestination(request *cherami.ReadDestinationRequest) (*cherami.DestinationDescription, error)

func (*MockCheramiClient) UpdateConsumerGroup

func (m *MockCheramiClient) UpdateConsumerGroup(request *cherami.UpdateConsumerGroupRequest) (*cherami.ConsumerGroupDescription, error)

func (*MockCheramiClient) UpdateDestination

func (m *MockCheramiClient) UpdateDestination(request *cherami.UpdateDestinationRequest) (*cherami.DestinationDescription, error)

type MockConsumer

type MockConsumer struct {
	mock.Mock
}

MockConsumer is the mock of cli.Consumer interface

func (*MockConsumer) AckDelivery

func (m *MockConsumer) AckDelivery(deliveryToken string) error

func (*MockConsumer) Close

func (m *MockConsumer) Close()

func (*MockConsumer) NackDelivery

func (m *MockConsumer) NackDelivery(deliveryToken string) error

func (*MockConsumer) Open

func (m *MockConsumer) Open(deliveryCh chan cli.Delivery) (chan cli.Delivery, error)

type MockDelivery

type MockDelivery struct {
	mock.Mock
}

MockDelivery is the mock of cli.Delivery interface

func (*MockDelivery) Ack

func (m *MockDelivery) Ack() error

func (*MockDelivery) GetDeliveryToken

func (m *MockDelivery) GetDeliveryToken() string

func (*MockDelivery) GetMessage

func (m *MockDelivery) GetMessage() *cherami.ConsumerMessage

func (*MockDelivery) Nack

func (m *MockDelivery) Nack() error

type MockPublisher

type MockPublisher struct {
	mock.Mock
}

MockPublisher is the mock of cli.Publisher interface

func (*MockPublisher) Close

func (m *MockPublisher) Close()

func (*MockPublisher) Open

func (m *MockPublisher) Open() error

func (*MockPublisher) Publish

func (m *MockPublisher) Publish(message *cli.PublisherMessage) *cli.PublisherReceipt

func (*MockPublisher) PublishAsync

func (m *MockPublisher) PublishAsync(message *cli.PublisherMessage, done chan<- *cli.PublisherReceipt) (string, error)