messagesfakes

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

• type FakeKafkaConnection
  • func (fake *FakeKafkaConnection) Close() error
  • func (fake *FakeKafkaConnection) CloseCallCount() int
  • func (fake *FakeKafkaConnection) CloseCalls(stub func() error)
  • func (fake *FakeKafkaConnection) CloseReturns(result1 error)
  • func (fake *FakeKafkaConnection) CloseReturnsOnCall(i int, result1 error)
  • func (fake *FakeKafkaConnection) CreateTopics(arg1 ...kafka.TopicConfig) error
  • func (fake *FakeKafkaConnection) CreateTopicsArgsForCall(i int) []kafka.TopicConfig
  • func (fake *FakeKafkaConnection) CreateTopicsCallCount() int
  • func (fake *FakeKafkaConnection) CreateTopicsCalls(stub func(...kafka.TopicConfig) error)
  • func (fake *FakeKafkaConnection) CreateTopicsReturns(result1 error)
  • func (fake *FakeKafkaConnection) CreateTopicsReturnsOnCall(i int, result1 error)
  • func (fake *FakeKafkaConnection) Invocations() map[string][][]interface{}
• type FakeReader
  • func (fake *FakeReader) Close() error
  • func (fake *FakeReader) CloseCallCount() int
  • func (fake *FakeReader) CloseCalls(stub func() error)
  • func (fake *FakeReader) CloseReturns(result1 error)
  • func (fake *FakeReader) CloseReturnsOnCall(i int, result1 error)
  • func (fake *FakeReader) Invocations() map[string][][]interface{}
  • func (fake *FakeReader) ReadMessage(arg1 context.Context) (kafka.Message, error)
  • func (fake *FakeReader) ReadMessageArgsForCall(i int) context.Context
  • func (fake *FakeReader) ReadMessageCallCount() int
  • func (fake *FakeReader) ReadMessageCalls(stub func(context.Context) (kafka.Message, error))
  • func (fake *FakeReader) ReadMessageReturns(result1 kafka.Message, result2 error)
  • func (fake *FakeReader) ReadMessageReturnsOnCall(i int, result1 kafka.Message, result2 error)
• type FakeWriter
  • func (fake *FakeWriter) Close() error
  • func (fake *FakeWriter) CloseCallCount() int
  • func (fake *FakeWriter) CloseCalls(stub func() error)
  • func (fake *FakeWriter) CloseReturns(result1 error)
  • func (fake *FakeWriter) CloseReturnsOnCall(i int, result1 error)
  • func (fake *FakeWriter) Invocations() map[string][][]interface{}
  • func (fake *FakeWriter) WriteMessages(arg1 context.Context, arg2 ...kafka.Message) error
  • func (fake *FakeWriter) WriteMessagesArgsForCall(i int) (context.Context, []kafka.Message)
  • func (fake *FakeWriter) WriteMessagesCallCount() int
  • func (fake *FakeWriter) WriteMessagesCalls(stub func(context.Context, ...kafka.Message) error)
  • func (fake *FakeWriter) WriteMessagesReturns(result1 error)
  • func (fake *FakeWriter) WriteMessagesReturnsOnCall(i int, result1 error)

Types

type FakeKafkaConnection

type FakeKafkaConnection struct {
	CloseStub func() error

	CreateTopicsStub func(...kafka.TopicConfig) error
	// contains filtered or unexported fields
}

func (*FakeKafkaConnection) Close

func (fake *FakeKafkaConnection) Close() error

func (*FakeKafkaConnection) CloseCallCount

func (fake *FakeKafkaConnection) CloseCallCount() int

func (*FakeKafkaConnection) CloseCalls

func (fake *FakeKafkaConnection) CloseCalls(stub func() error)

func (*FakeKafkaConnection) CloseReturns

func (fake *FakeKafkaConnection) CloseReturns(result1 error)

func (*FakeKafkaConnection) CloseReturnsOnCall

func (fake *FakeKafkaConnection) CloseReturnsOnCall(i int, result1 error)

func (*FakeKafkaConnection) CreateTopics

func (fake *FakeKafkaConnection) CreateTopics(arg1 ...kafka.TopicConfig) error

func (*FakeKafkaConnection) CreateTopicsArgsForCall

func (fake *FakeKafkaConnection) CreateTopicsArgsForCall(i int) []kafka.TopicConfig

func (*FakeKafkaConnection) CreateTopicsCallCount

func (fake *FakeKafkaConnection) CreateTopicsCallCount() int

func (*FakeKafkaConnection) CreateTopicsCalls

func (fake *FakeKafkaConnection) CreateTopicsCalls(stub func(...kafka.TopicConfig) error)

func (*FakeKafkaConnection) CreateTopicsReturns

func (fake *FakeKafkaConnection) CreateTopicsReturns(result1 error)

func (*FakeKafkaConnection) CreateTopicsReturnsOnCall

func (fake *FakeKafkaConnection) CreateTopicsReturnsOnCall(i int, result1 error)

func (*FakeKafkaConnection) Invocations

func (fake *FakeKafkaConnection) Invocations() map[string][][]interface{}

type FakeReader

type FakeReader struct {
	CloseStub func() error

	ReadMessageStub func(context.Context) (kafka.Message, error)
	// contains filtered or unexported fields
}

func (*FakeReader) Close

func (fake *FakeReader) Close() error

func (*FakeReader) CloseCallCount

func (fake *FakeReader) CloseCallCount() int

func (*FakeReader) CloseCalls

func (fake *FakeReader) CloseCalls(stub func() error)

func (*FakeReader) CloseReturns

func (fake *FakeReader) CloseReturns(result1 error)

func (*FakeReader) CloseReturnsOnCall

func (fake *FakeReader) CloseReturnsOnCall(i int, result1 error)

func (*FakeReader) Invocations

func (fake *FakeReader) Invocations() map[string][][]interface{}

func (*FakeReader) ReadMessage

func (fake *FakeReader) ReadMessage(arg1 context.Context) (kafka.Message, error)

func (*FakeReader) ReadMessageArgsForCall

func (fake *FakeReader) ReadMessageArgsForCall(i int) context.Context

func (*FakeReader) ReadMessageCallCount

func (fake *FakeReader) ReadMessageCallCount() int

func (*FakeReader) ReadMessageCalls

func (fake *FakeReader) ReadMessageCalls(stub func(context.Context) (kafka.Message, error))

func (*FakeReader) ReadMessageReturns

func (fake *FakeReader) ReadMessageReturns(result1 kafka.Message, result2 error)

func (*FakeReader) ReadMessageReturnsOnCall

func (fake *FakeReader) ReadMessageReturnsOnCall(i int, result1 kafka.Message, result2 error)

type FakeWriter

type FakeWriter struct {
	CloseStub func() error

	WriteMessagesStub func(context.Context, ...kafka.Message) error
	// contains filtered or unexported fields
}

func (*FakeWriter) Close

func (fake *FakeWriter) Close() error

func (*FakeWriter) CloseCallCount

func (fake *FakeWriter) CloseCallCount() int

func (*FakeWriter) CloseCalls

func (fake *FakeWriter) CloseCalls(stub func() error)

func (*FakeWriter) CloseReturns

func (fake *FakeWriter) CloseReturns(result1 error)

func (*FakeWriter) CloseReturnsOnCall

func (fake *FakeWriter) CloseReturnsOnCall(i int, result1 error)

func (*FakeWriter) Invocations

func (fake *FakeWriter) Invocations() map[string][][]interface{}

func (*FakeWriter) WriteMessages

func (fake *FakeWriter) WriteMessages(arg1 context.Context, arg2 ...kafka.Message) error

func (*FakeWriter) WriteMessagesArgsForCall

func (fake *FakeWriter) WriteMessagesArgsForCall(i int) (context.Context, []kafka.Message)

func (*FakeWriter) WriteMessagesCallCount

func (fake *FakeWriter) WriteMessagesCallCount() int

func (*FakeWriter) WriteMessagesCalls

func (fake *FakeWriter) WriteMessagesCalls(stub func(context.Context, ...kafka.Message) error)

func (*FakeWriter) WriteMessagesReturns

func (fake *FakeWriter) WriteMessagesReturns(result1 error)

func (*FakeWriter) WriteMessagesReturnsOnCall

func (fake *FakeWriter) WriteMessagesReturnsOnCall(i int, result1 error)