mocks

package
v1.25.0-rc0 Latest Latest
Warning

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

 Go to latest Published: Sep 7, 2017 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

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.