mocks

package
v0.0.0-...-8f4c080 Latest Latest
Warning

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

Go to latest
Published: Nov 17, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Consumer

type Consumer struct {
	mock.Mock
}

Consumer is an autogenerated mock type for the Consumer type

func (*Consumer) Close

func (_m *Consumer) Close() error

Close provides a mock function with given fields:

func (*Consumer) Receive

func (_m *Consumer) Receive(ctx context.Context) (queue.Message, error)

Receive provides a mock function with given fields: ctx

type Message

type Message struct {
	mock.Mock
}

Message is an autogenerated mock type for the Message type

func (*Message) Ack

func (_m *Message) Ack() error

Ack provides a mock function with given fields:

func (*Message) Interrupt

func (_m *Message) Interrupt() error

Interrupt provides a mock function with given fields:

func (*Message) Nack

func (_m *Message) Nack() error

Nack provides a mock function with given fields:

func (*Message) Payload

func (_m *Message) Payload() []byte

Payload provides a mock function with given fields:

type Producer

type Producer struct {
	mock.Mock
}

Producer is an autogenerated mock type for the Producer type

func (*Producer) Close

func (_m *Producer) Close() error

Close provides a mock function with given fields:

func (*Producer) Flush

func (_m *Producer) Flush(ctx context.Context)

Flush provides a mock function with given fields: ctx

func (*Producer) Send

func (_m *Producer) Send(payload []byte) error

Send provides a mock function with given fields: payload

func (*Producer) SendAsync

func (_m *Producer) SendAsync(payload []byte, deliveryCh chan kafka.Event)

SendAsync provides a mock function with given fields: payload, deliveryCh

type Queue

type Queue struct {
	mock.Mock
}

Queue is an autogenerated mock type for the Queue type

func (*Queue) Consumer

func (_m *Queue) Consumer() (queue.Consumer, error)

Consumer provides a mock function with given fields:

func (*Queue) Producer

func (_m *Queue) Producer() (queue.Producer, error)

Producer provides a mock function with given fields:

type Service

type Service struct {
	mock.Mock
}

Service is an autogenerated mock type for the Service type

func (*Service) GetOrCreateQueue

func (_m *Service) GetOrCreateQueue(id string) queue.Queue

GetOrCreateQueue provides a mock function with given fields: id

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL