mocks

Documentation

Overview

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0

Index

• type Consumer
  • func (_m *Consumer) Close() error
  • func (_m *Consumer) Consume(_a0 context.Context, _a1 messaging.OptionCreator) (<-chan messaging.Event, error)
• type Event
  • func (_m *Event) Metadata() map[string]interface{}
  • func (_m *Event) Payload() []byte
  • func (_m *Event) Raw() interface{}
• type Manager
  • func (_m *Manager) Close() error
  • func (_m *Manager) CreateTopics(_a0 context.Context, _a1 messaging.OptionCreator, _a2 ...string) error
  • func (_m *Manager) DeleteTopics(_a0 context.Context, _a1 ...string) error
  • func (_m *Manager) ListTopics(_a0 context.Context) (interface{}, error)
• type Messager
  • func (_m *Messager) Message() interface{}
• type OptionCreator
  • func (_m *OptionCreator) Options() interface{}
• type Producer
  • func (_m *Producer) Close() error
  • func (_m *Producer) Produce(_a0 context.Context, _a1 messaging.Messager, _a2 ...messaging.Event) error
• type StreamReader
  • func (_m *StreamReader) Close() error
  • func (_m *StreamReader) Read(p []byte) (int, error)
• type StreamWriter
  • func (_m *StreamWriter) Close() error
  • func (_m *StreamWriter) Write(p []byte) (int, error)

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) Consume

func (_m *Consumer) Consume(_a0 context.Context, _a1 messaging.OptionCreator) (<-chan messaging.Event, error)

Consume provides a mock function with given fields: _a0, _a1

type Event

type Event struct {
	mock.Mock
}

Event is an autogenerated mock type for the Event type

func (*Event) Metadata

func (_m *Event) Metadata() map[string]interface{}

Metadata provides a mock function with given fields:

func (*Event) Payload

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

Payload provides a mock function with given fields:

func (*Event) Raw

func (_m *Event) Raw() interface{}

Raw provides a mock function with given fields:

type Manager

type Manager struct {
	mock.Mock
}

Manager is an autogenerated mock type for the Manager type

func (*Manager) Close

func (_m *Manager) Close() error

Close provides a mock function with given fields:

func (*Manager) CreateTopics

func (_m *Manager) CreateTopics(_a0 context.Context, _a1 messaging.OptionCreator, _a2 ...string) error

CreateTopics provides a mock function with given fields: _a0, _a1, _a2

func (*Manager) DeleteTopics

func (_m *Manager) DeleteTopics(_a0 context.Context, _a1 ...string) error

DeleteTopics provides a mock function with given fields: _a0, _a1

func (*Manager) ListTopics

func (_m *Manager) ListTopics(_a0 context.Context) (interface{}, error)

ListTopics provides a mock function with given fields: _a0

type Messager

type Messager struct {
	mock.Mock
}

Messager is an autogenerated mock type for the Messager type

func (*Messager) Message

func (_m *Messager) Message() interface{}

Message provides a mock function with given fields:

type OptionCreator

type OptionCreator struct {
	mock.Mock
}

OptionCreator is an autogenerated mock type for the OptionCreator type

func (*OptionCreator) Options

func (_m *OptionCreator) Options() interface{}

Options 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) Produce

func (_m *Producer) Produce(_a0 context.Context, _a1 messaging.Messager, _a2 ...messaging.Event) error

Produce provides a mock function with given fields: _a0, _a1, _a2

type StreamReader

type StreamReader struct {
	mock.Mock
}

StreamReader is an autogenerated mock type for the StreamReader type

func (*StreamReader) Close

func (_m *StreamReader) Close() error

Close provides a mock function with given fields:

func (*StreamReader) Read

func (_m *StreamReader) Read(p []byte) (int, error)

Read provides a mock function with given fields: p

type StreamWriter

type StreamWriter struct {
	mock.Mock
}

StreamWriter is an autogenerated mock type for the StreamWriter type

func (*StreamWriter) Close

func (_m *StreamWriter) Close() error

Close provides a mock function with given fields:

func (*StreamWriter) Write

func (_m *StreamWriter) Write(p []byte) (int, error)

Write provides a mock function with given fields: p