mocks

package
v0.0.0-...-0bb0fe6 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2019 License: BSD-2-Clause Imports: 8 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Consumer 

type Consumer struct {
	ConsumeStub func(context.Context) error
	// contains filtered or unexported fields
}

func (*Consumer) Consume 

func (fake *Consumer) Consume(arg1 context.Context) error

func (*Consumer) ConsumeArgsForCall 

func (fake *Consumer) ConsumeArgsForCall(i int) context.Context

func (*Consumer) ConsumeCallCount 

func (fake *Consumer) ConsumeCallCount() int

func (*Consumer) ConsumeCalls 

func (fake *Consumer) ConsumeCalls(stub func(context.Context) error)

func (*Consumer) ConsumeReturns 

func (fake *Consumer) ConsumeReturns(result1 error)

func (*Consumer) ConsumeReturnsOnCall 

func (fake *Consumer) ConsumeReturnsOnCall(i int, result1 error)

func (*Consumer) Invocations 

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

type MessageHandler 

type MessageHandler struct {
	ConsumeMessageStub func(context.Context, *sarama.ConsumerMessage) error
	// contains filtered or unexported fields
}

func (*MessageHandler) ConsumeMessage 

func (fake *MessageHandler) ConsumeMessage(arg1 context.Context, arg2 *sarama.ConsumerMessage) error

func (*MessageHandler) ConsumeMessageArgsForCall 

func (fake *MessageHandler) ConsumeMessageArgsForCall(i int) (context.Context, *sarama.ConsumerMessage)

func (*MessageHandler) ConsumeMessageCallCount 

func (fake *MessageHandler) ConsumeMessageCallCount() int

func (*MessageHandler) ConsumeMessageCalls 

func (fake *MessageHandler) ConsumeMessageCalls(stub func(context.Context, *sarama.ConsumerMessage) error)

func (*MessageHandler) ConsumeMessageReturns 

func (fake *MessageHandler) ConsumeMessageReturns(result1 error)

func (*MessageHandler) ConsumeMessageReturnsOnCall 

func (fake *MessageHandler) ConsumeMessageReturnsOnCall(i int, result1 error)

func (*MessageHandler) Invocations 

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

type PersistentMessageHandler 

type PersistentMessageHandler struct {
	ConsumeMessageStub func(context.Context, *bolt.Tx, *sarama.ConsumerMessage) error
	// contains filtered or unexported fields
}

func (*PersistentMessageHandler) ConsumeMessage 

func (fake *PersistentMessageHandler) ConsumeMessage(arg1 context.Context, arg2 *bolt.Tx, arg3 *sarama.ConsumerMessage) error

func (*PersistentMessageHandler) ConsumeMessageArgsForCall 

func (fake *PersistentMessageHandler) ConsumeMessageArgsForCall(i int) (context.Context, *bolt.Tx, *sarama.ConsumerMessage)

func (*PersistentMessageHandler) ConsumeMessageCallCount 

func (fake *PersistentMessageHandler) ConsumeMessageCallCount() int

func (*PersistentMessageHandler) ConsumeMessageCalls 

func (fake *PersistentMessageHandler) ConsumeMessageCalls(stub func(context.Context, *bolt.Tx, *sarama.ConsumerMessage) error)

func (*PersistentMessageHandler) ConsumeMessageReturns 

func (fake *PersistentMessageHandler) ConsumeMessageReturns(result1 error)

func (*PersistentMessageHandler) ConsumeMessageReturnsOnCall 

func (fake *PersistentMessageHandler) ConsumeMessageReturnsOnCall(i int, result1 error)

func (*PersistentMessageHandler) Invocations 

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

type SchemaAvro 

type SchemaAvro struct {
	SchemaStub func() string

	SerializeStub func(io.Writer) error
	// contains filtered or unexported fields
}

func (*SchemaAvro) Invocations 

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

func (*SchemaAvro) Schema 

func (fake *SchemaAvro) Schema() string

func (*SchemaAvro) SchemaCallCount 

func (fake *SchemaAvro) SchemaCallCount() int

func (*SchemaAvro) SchemaCalls 

func (fake *SchemaAvro) SchemaCalls(stub func() string)

func (*SchemaAvro) SchemaReturns 

func (fake *SchemaAvro) SchemaReturns(result1 string)

func (*SchemaAvro) SchemaReturnsOnCall 

func (fake *SchemaAvro) SchemaReturnsOnCall(i int, result1 string)

func (*SchemaAvro) Serialize 

func (fake *SchemaAvro) Serialize(arg1 io.Writer) error

func (*SchemaAvro) SerializeArgsForCall 

func (fake *SchemaAvro) SerializeArgsForCall(i int) io.Writer

func (*SchemaAvro) SerializeCallCount 

func (fake *SchemaAvro) SerializeCallCount() int

func (*SchemaAvro) SerializeCalls 

func (fake *SchemaAvro) SerializeCalls(stub func(io.Writer) error)

func (*SchemaAvro) SerializeReturns 

func (fake *SchemaAvro) SerializeReturns(result1 error)

func (*SchemaAvro) SerializeReturnsOnCall 

func (fake *SchemaAvro) SerializeReturnsOnCall(i int, result1 error)

type SchemaAvroEncoderBuilder 

type SchemaAvroEncoderBuilder struct {
	BuildEncoderStub func(string, schema.Avro) (sarama.Encoder, error)
	// contains filtered or unexported fields
}

func (*SchemaAvroEncoderBuilder) BuildEncoder 

func (fake *SchemaAvroEncoderBuilder) BuildEncoder(arg1 string, arg2 schema.Avro) (sarama.Encoder, error)

func (*SchemaAvroEncoderBuilder) BuildEncoderArgsForCall 

func (fake *SchemaAvroEncoderBuilder) BuildEncoderArgsForCall(i int) (string, schema.Avro)

func (*SchemaAvroEncoderBuilder) BuildEncoderCallCount 

func (fake *SchemaAvroEncoderBuilder) BuildEncoderCallCount() int

func (*SchemaAvroEncoderBuilder) BuildEncoderCalls 

func (fake *SchemaAvroEncoderBuilder) BuildEncoderCalls(stub func(string, schema.Avro) (sarama.Encoder, error))

func (*SchemaAvroEncoderBuilder) BuildEncoderReturns 

func (fake *SchemaAvroEncoderBuilder) BuildEncoderReturns(result1 sarama.Encoder, result2 error)

func (*SchemaAvroEncoderBuilder) BuildEncoderReturnsOnCall 

func (fake *SchemaAvroEncoderBuilder) BuildEncoderReturnsOnCall(i int, result1 sarama.Encoder, result2 error)

func (*SchemaAvroEncoderBuilder) Invocations 

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

type SchemaRegistry 

type SchemaRegistry struct {
	SchemaIdStub func(string, string) (uint32, error)
	// contains filtered or unexported fields
}

func (*SchemaRegistry) Invocations 

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

func (*SchemaRegistry) SchemaId 

func (fake *SchemaRegistry) SchemaId(arg1 string, arg2 string) (uint32, error)

func (*SchemaRegistry) SchemaIdArgsForCall 

func (fake *SchemaRegistry) SchemaIdArgsForCall(i int) (string, string)

func (*SchemaRegistry) SchemaIdCallCount 

func (fake *SchemaRegistry) SchemaIdCallCount() int

func (*SchemaRegistry) SchemaIdCalls 

func (fake *SchemaRegistry) SchemaIdCalls(stub func(string, string) (uint32, error))

func (*SchemaRegistry) SchemaIdReturns 

func (fake *SchemaRegistry) SchemaIdReturns(result1 uint32, result2 error)

func (*SchemaRegistry) SchemaIdReturnsOnCall 

func (fake *SchemaRegistry) SchemaIdReturnsOnCall(i int, result1 uint32, result2 error)

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.