mocks

Documentation

Index

• type ClientFactory
  • func (_m *ClientFactory) GetConsumer(client cherami.Client, config internal.ConsumerConfig) (cherami.Consumer, chan cherami.Delivery, error)
  • func (_m *ClientFactory) GetPublisher(client cherami.Client, destination string) (cherami.Publisher, error)
• type Consumer
  • func (_m *Consumer) AckDelivery(deliveryToken string) error
  • func (_m *Consumer) Close()
  • func (_m *Consumer) NackDelivery(deliveryToken string) error
  • func (_m *Consumer) Open(deliveryCh chan cherami.Delivery) (chan cherami.Delivery, error)
  • func (_m *Consumer) Pause()
  • func (_m *Consumer) Resume()
• type Publisher
  • func (_m *Publisher) Close()
  • func (_m *Publisher) Open() error
  • func (_m *Publisher) Pause()
  • func (_m *Publisher) Publish(message *cherami.PublisherMessage) *cherami.PublisherReceipt
  • func (_m *Publisher) PublishAsync(message *cherami.PublisherMessage, done chan<- *cherami.PublisherReceipt) (string, error)
  • func (_m *Publisher) Resume()

Types

type ClientFactory

type ClientFactory struct {
	mock.Mock
}

ClientFactory is an autogenerated mock type for the ClientFactory type

func (*ClientFactory) GetConsumer

func (_m *ClientFactory) GetConsumer(client cherami.Client, config internal.ConsumerConfig) (cherami.Consumer, chan cherami.Delivery, error)

GetConsumer provides a mock function with given fields: client, config

func (*ClientFactory) GetPublisher

func (_m *ClientFactory) GetPublisher(client cherami.Client, destination string) (cherami.Publisher, error)

GetPublisher provides a mock function with given fields: client, destination

type Consumer

type Consumer struct {
	mock.Mock
}

Consumer is an autogenerated mock type for the Consumer type

func (*Consumer) AckDelivery

func (_m *Consumer) AckDelivery(deliveryToken string) error

AckDelivery provides a mock function with given fields: deliveryToken

func (*Consumer) Close

func (_m *Consumer) Close()

Close provides a mock function with given fields:

func (*Consumer) NackDelivery

func (_m *Consumer) NackDelivery(deliveryToken string) error

NackDelivery provides a mock function with given fields: deliveryToken

func (*Consumer) Open

func (_m *Consumer) Open(deliveryCh chan cherami.Delivery) (chan cherami.Delivery, error)

Open provides a mock function with given fields: deliveryCh

func (*Consumer) Pause

func (_m *Consumer) Pause()

Pause provides a mock function with given fields:

func (*Consumer) Resume

func (_m *Consumer) Resume()

Resume provides a mock function with given fields:

type Publisher

type Publisher struct {
	mock.Mock
}

Publisher is an autogenerated mock type for the Publisher type

func (*Publisher) Close

func (_m *Publisher) Close()

Close provides a mock function with given fields:

func (*Publisher) Open

func (_m *Publisher) Open() error

Open provides a mock function with given fields:

func (*Publisher) Pause

func (_m *Publisher) Pause()

Pause provides a mock function with given fields:

func (*Publisher) Publish

func (_m *Publisher) Publish(message *cherami.PublisherMessage) *cherami.PublisherReceipt

Publish provides a mock function with given fields: message

func (*Publisher) PublishAsync

func (_m *Publisher) PublishAsync(message *cherami.PublisherMessage, done chan<- *cherami.PublisherReceipt) (string, error)

PublishAsync provides a mock function with given fields: message, done

func (*Publisher) Resume

func (_m *Publisher) Resume()

Resume provides a mock function with given fields: