mocks

package
v0.0.17 Latest Latest
Warning

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

 Go to latest Published: Jan 20, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ChannelImpl 

type ChannelImpl struct {
	mock.Mock
}

ChannelImpl is an autogenerated mock type for the ChannelImpl type

func NewChannelImpl 

func NewChannelImpl(t interface {
	mock.TestingT
	Cleanup(func())
}) *ChannelImpl

NewChannelImpl creates a new instance of ChannelImpl. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ChannelImpl) CloseChan 

func (_m *ChannelImpl) CloseChan() <-chan error

CloseChan provides a mock function with given fields:

func (*ChannelImpl) ConsumerBuilder 

func (_m *ChannelImpl) ConsumerBuilder(name string, queue string) rmq.ConsumerBuilderImpl

ConsumerBuilder provides a mock function with given fields: name, queue

func (*ChannelImpl) DirectExchangeBuilder 

func (_m *ChannelImpl) DirectExchangeBuilder(name string) rmq.ExchangeBuilderImpl

DirectExchangeBuilder provides a mock function with given fields: name

func (*ChannelImpl) ExchangeBuilder 

func (_m *ChannelImpl) ExchangeBuilder(name string) rmq.ExchangeBuilderImpl

ExchangeBuilder provides a mock function with given fields: name

func (*ChannelImpl) FanoutExchangeBuilder 

func (_m *ChannelImpl) FanoutExchangeBuilder(name string) rmq.ExchangeBuilderImpl

FanoutExchangeBuilder provides a mock function with given fields: name

func (*ChannelImpl) PublisherBuilder 

func (_m *ChannelImpl) PublisherBuilder(exchange string, routingKey string) rmq.PublisherBuilderImpl

PublisherBuilder provides a mock function with given fields: exchange, routingKey

func (*ChannelImpl) QueueBuilder 

func (_m *ChannelImpl) QueueBuilder() rmq.QueueBuilderImpl

QueueBuilder provides a mock function with given fields:

func (*ChannelImpl) TopicExchangeBuilder 

func (_m *ChannelImpl) TopicExchangeBuilder(name string) rmq.ExchangeBuilderImpl

TopicExchangeBuilder provides a mock function with given fields: name

type ConsumerBuilderImpl 

type ConsumerBuilderImpl struct {
	mock.Mock
}

ConsumerBuilderImpl is an autogenerated mock type for the ConsumerBuilderImpl type

func NewConsumerBuilderImpl 

func NewConsumerBuilderImpl(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerBuilderImpl

NewConsumerBuilderImpl creates a new instance of ConsumerBuilderImpl. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConsumerBuilderImpl) AddArg 

func (_m *ConsumerBuilderImpl) AddArg(key string, val interface{}) rmq.ConsumerBuilderImpl

AddArg provides a mock function with given fields: key, val

func (*ConsumerBuilderImpl) Build 

func (_m *ConsumerBuilderImpl) Build() (rmq.ConsumerImpl, error)

Build provides a mock function with given fields:

func (*ConsumerBuilderImpl) SetAutoAck 

func (_m *ConsumerBuilderImpl) SetAutoAck() rmq.ConsumerBuilderImpl

SetAutoAck provides a mock function with given fields:

func (*ConsumerBuilderImpl) SetExclusive 

func (_m *ConsumerBuilderImpl) SetExclusive() rmq.ConsumerBuilderImpl

SetExclusive provides a mock function with given fields:

func (*ConsumerBuilderImpl) SetNoLocal 

func (_m *ConsumerBuilderImpl) SetNoLocal() rmq.ConsumerBuilderImpl

SetNoLocal provides a mock function with given fields:

func (*ConsumerBuilderImpl) SetNoWait 

func (_m *ConsumerBuilderImpl) SetNoWait() rmq.ConsumerBuilderImpl

SetNoWait provides a mock function with given fields:

func (*ConsumerBuilderImpl) SetPrefetch 

func (_m *ConsumerBuilderImpl) SetPrefetch(prefetch int) rmq.ConsumerBuilderImpl

SetPrefetch provides a mock function with given fields: prefetch

type ConsumerImpl 

type ConsumerImpl struct {
	mock.Mock
}

ConsumerImpl is an autogenerated mock type for the ConsumerImpl type

func NewConsumerImpl 

func NewConsumerImpl(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerImpl

NewConsumerImpl creates a new instance of ConsumerImpl. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConsumerImpl) Cancel 

func (_m *ConsumerImpl) Cancel() error

Cancel provides a mock function with given fields:

func (*ConsumerImpl) ErrorChan 

func (_m *ConsumerImpl) ErrorChan() <-chan error

ErrorChan provides a mock function with given fields:

func (*ConsumerImpl) Messages 

func (_m *ConsumerImpl) Messages() <-chan amqp091.Delivery

Messages provides a mock function with given fields:

type ExchangeBuilderImpl 

type ExchangeBuilderImpl struct {
	mock.Mock
}

ExchangeBuilderImpl is an autogenerated mock type for the ExchangeBuilderImpl type

func NewExchangeBuilderImpl 

func NewExchangeBuilderImpl(t interface {
	mock.TestingT
	Cleanup(func())
}) *ExchangeBuilderImpl

NewExchangeBuilderImpl creates a new instance of ExchangeBuilderImpl. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ExchangeBuilderImpl) AddArg 

func (_m *ExchangeBuilderImpl) AddArg(key string, val interface{}) rmq.ExchangeBuilderImpl

AddArg provides a mock function with given fields: key, val

func (*ExchangeBuilderImpl) Declare 

func (_m *ExchangeBuilderImpl) Declare() error

Declare provides a mock function with given fields:

func (*ExchangeBuilderImpl) DeleteOnDeclare 

func (_m *ExchangeBuilderImpl) DeleteOnDeclare(ifUnused bool, noWait bool) rmq.ExchangeBuilderImpl

DeleteOnDeclare provides a mock function with given fields: ifUnused, noWait

func (*ExchangeBuilderImpl) SetAutoDelete 

func (_m *ExchangeBuilderImpl) SetAutoDelete() rmq.ExchangeBuilderImpl

SetAutoDelete provides a mock function with given fields:

func (*ExchangeBuilderImpl) SetDurable 

func (_m *ExchangeBuilderImpl) SetDurable() rmq.ExchangeBuilderImpl

SetDurable provides a mock function with given fields:

func (*ExchangeBuilderImpl) SetInternal 

func (_m *ExchangeBuilderImpl) SetInternal() rmq.ExchangeBuilderImpl

SetInternal provides a mock function with given fields:

func (*ExchangeBuilderImpl) SetNoWait 

func (_m *ExchangeBuilderImpl) SetNoWait() rmq.ExchangeBuilderImpl

SetNoWait provides a mock function with given fields:

type PublishFieldsImpl 

type PublishFieldsImpl struct {
	mock.Mock
}

PublishFieldsImpl is an autogenerated mock type for the PublishFieldsImpl type

func NewPublishFieldsImpl 

func NewPublishFieldsImpl(t interface {
	mock.TestingT
	Cleanup(func())
}) *PublishFieldsImpl

NewPublishFieldsImpl creates a new instance of PublishFieldsImpl. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PublishFieldsImpl) AddHeader 

func (_m *PublishFieldsImpl) AddHeader(key string, val interface{}) rmq.PublisherBuilderImpl

AddHeader provides a mock function with given fields: key, val

func (*PublishFieldsImpl) DeliveryModePersistent 

func (_m *PublishFieldsImpl) DeliveryModePersistent() rmq.PublisherBuilderImpl

DeliveryModePersistent provides a mock function with given fields:

func (*PublishFieldsImpl) DeliveryModeTransient 

func (_m *PublishFieldsImpl) DeliveryModeTransient() rmq.PublisherBuilderImpl

DeliveryModeTransient provides a mock function with given fields:

func (*PublishFieldsImpl) SetContentType 

func (_m *PublishFieldsImpl) SetContentType(contentType string) rmq.PublisherBuilderImpl

SetContentType provides a mock function with given fields: contentType

func (*PublishFieldsImpl) SetCorrelationID 

func (_m *PublishFieldsImpl) SetCorrelationID(id string) rmq.PublisherBuilderImpl

SetCorrelationID provides a mock function with given fields: id

func (*PublishFieldsImpl) SetDataTypeBytes 

func (_m *PublishFieldsImpl) SetDataTypeBytes() rmq.PublisherBuilderImpl

SetDataTypeBytes provides a mock function with given fields:

func (*PublishFieldsImpl) SetDataTypeJSON 

func (_m *PublishFieldsImpl) SetDataTypeJSON() rmq.PublisherBuilderImpl

SetDataTypeJSON provides a mock function with given fields:

func (*PublishFieldsImpl) SetExpiration 

func (_m *PublishFieldsImpl) SetExpiration(dur time.Duration) rmq.PublisherBuilderImpl

SetExpiration provides a mock function with given fields: dur

func (*PublishFieldsImpl) SetImmediate 

func (_m *PublishFieldsImpl) SetImmediate() rmq.PublisherBuilderImpl

SetImmediate provides a mock function with given fields:

func (*PublishFieldsImpl) SetMandatory 

func (_m *PublishFieldsImpl) SetMandatory() rmq.PublisherBuilderImpl

SetMandatory provides a mock function with given fields:

func (*PublishFieldsImpl) SetReplyToID 

func (_m *PublishFieldsImpl) SetReplyToID(id string) rmq.PublisherBuilderImpl

SetReplyToID provides a mock function with given fields: id

type PublisherBuilderImpl 

type PublisherBuilderImpl struct {
	mock.Mock
}

PublisherBuilderImpl is an autogenerated mock type for the PublisherBuilderImpl type

func NewPublisherBuilderImpl 

func NewPublisherBuilderImpl(t interface {
	mock.TestingT
	Cleanup(func())
}) *PublisherBuilderImpl

NewPublisherBuilderImpl creates a new instance of PublisherBuilderImpl. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PublisherBuilderImpl) New 

func (_m *PublisherBuilderImpl) New() rmq.PublisherImpl

New provides a mock function with given fields:

func (*PublisherBuilderImpl) NewWithDefaultFields 

func (_m *PublisherBuilderImpl) NewWithDefaultFields() rmq.PublisherImpl

NewWithDefaultFields provides a mock function with given fields:

func (*PublisherBuilderImpl) WithFields 

func (_m *PublisherBuilderImpl) WithFields(fields *rmq.PublishFields) rmq.PublisherBuilderImpl

WithFields provides a mock function with given fields: fields

type PublisherImpl 

type PublisherImpl struct {
	mock.Mock
}

PublisherImpl is an autogenerated mock type for the PublisherImpl type

func NewPublisherImpl 

func NewPublisherImpl(t interface {
	mock.TestingT
	Cleanup(func())
}) *PublisherImpl

NewPublisherImpl creates a new instance of PublisherImpl. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PublisherImpl) Fields 

func (_m *PublisherImpl) Fields() rmq.PublishFieldsImpl

Fields provides a mock function with given fields:

func (*PublisherImpl) Publish 

func (_m *PublisherImpl) Publish(ctx context.Context, data interface{}) error

Publish provides a mock function with given fields: ctx, data

func (*PublisherImpl) PublishAwaitResponse 

func (_m *PublisherImpl) PublishAwaitResponse(ctx context.Context, data interface{}, responseMap *sync.Map[chan amqp091.Delivery]) (amqp091.Delivery, error)

PublishAwaitResponse provides a mock function with given fields: ctx, data, responseMap

func (*PublisherImpl) PublishWithConfirmation 

func (_m *PublisherImpl) PublishWithConfirmation(ctx context.Context, data interface{}) (bool, error)

PublishWithConfirmation provides a mock function with given fields: ctx, data

func (*PublisherImpl) WithFields 

func (_m *PublisherImpl) WithFields(fields rmq.PublishFieldsImpl) rmq.PublisherImpl

WithFields provides a mock function with given fields: fields

type QueueBuilderImpl 

type QueueBuilderImpl struct {
	mock.Mock
}

QueueBuilderImpl is an autogenerated mock type for the QueueBuilderImpl type

func NewQueueBuilderImpl 

func NewQueueBuilderImpl(t interface {
	mock.TestingT
	Cleanup(func())
}) *QueueBuilderImpl

NewQueueBuilderImpl creates a new instance of QueueBuilderImpl. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*QueueBuilderImpl) AddArg 

func (_m *QueueBuilderImpl) AddArg(key string, val interface{}) rmq.QueueBuilderImpl

AddArg provides a mock function with given fields: key, val

func (*QueueBuilderImpl) Declare 

func (_m *QueueBuilderImpl) Declare() (rmq.QueueImpl, error)

Declare provides a mock function with given fields:

func (*QueueBuilderImpl) SetAutoDelete 

func (_m *QueueBuilderImpl) SetAutoDelete() rmq.QueueBuilderImpl

SetAutoDelete provides a mock function with given fields:

func (*QueueBuilderImpl) SetDurable 

func (_m *QueueBuilderImpl) SetDurable() rmq.QueueBuilderImpl

SetDurable provides a mock function with given fields:

func (*QueueBuilderImpl) SetExclusive 

func (_m *QueueBuilderImpl) SetExclusive() rmq.QueueBuilderImpl

SetExclusive provides a mock function with given fields:

func (*QueueBuilderImpl) SetName 

func (_m *QueueBuilderImpl) SetName(name string) rmq.QueueBuilderImpl

SetName provides a mock function with given fields: name

func (*QueueBuilderImpl) SetNoWait 

func (_m *QueueBuilderImpl) SetNoWait() rmq.QueueBuilderImpl

SetNoWait provides a mock function with given fields:

type QueueImpl 

type QueueImpl struct {
	mock.Mock
}

QueueImpl is an autogenerated mock type for the QueueImpl type

func NewQueueImpl 

func NewQueueImpl(t interface {
	mock.TestingT
	Cleanup(func())
}) *QueueImpl

NewQueueImpl creates a new instance of QueueImpl. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*QueueImpl) BindToExchange 

func (_m *QueueImpl) BindToExchange(exchange string, routingKey string, noWait bool, args map[string]interface{}) error

BindToExchange provides a mock function with given fields: exchange, routingKey, noWait, args

func (*QueueImpl) Name 

func (_m *QueueImpl) Name() string

Name provides a mock function with given fields:

type RmqImpl 

type RmqImpl struct {
	mock.Mock
}

RmqImpl is an autogenerated mock type for the RmqImpl type

func NewRmqImpl 

func NewRmqImpl(t interface {
	mock.TestingT
	Cleanup(func())
}) *RmqImpl

NewRmqImpl creates a new instance of RmqImpl. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RmqImpl) Close 

func (_m *RmqImpl) Close() error

Close provides a mock function with given fields:

func (*RmqImpl) Connect 

func (_m *RmqImpl) Connect(retryCount int, retryDelay time.Duration, onRetryError func(error)) (<-chan error, error)

Connect provides a mock function with given fields: retryCount, retryDelay, onRetryError

func (*RmqImpl) NewChannel 

func (_m *RmqImpl) NewChannel() (rmq.ChannelImpl, error)

NewChannel provides a mock function with given fields:

func (*RmqImpl) NewChannelWithConfirm 

func (_m *RmqImpl) NewChannelWithConfirm() (rmq.ChannelImpl, error)

NewChannelWithConfirm provides a mock function with given fields:

func (*RmqImpl) SetOnError 

func (_m *RmqImpl) SetOnError(onError func(error))

SetOnError provides a mock function with given fields: onError

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.