tests

package
v0.0.0-...-7055b2f Latest Latest
Warning

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

 Go to latest Published: Jul 21, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package tests is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockBreaker 

type MockBreaker struct {
	// contains filtered or unexported fields
}

MockBreaker is a mock of Breaker interface

func NewMockBreaker 

func NewMockBreaker(ctrl *gomock.Controller) *MockBreaker

NewMockBreaker creates a new mock instance

func (*MockBreaker) EXPECT 

func (m *MockBreaker) EXPECT() *MockBreakerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockBreaker) Mark 

func (m *MockBreaker) Mark()

Mark mocks base method

type MockBreakerMockRecorder 

type MockBreakerMockRecorder struct {
	// contains filtered or unexported fields
}

MockBreakerMockRecorder is the mock recorder for MockBreaker

func (*MockBreakerMockRecorder) Mark 

func (mr *MockBreakerMockRecorder) Mark() *gomock.Call

Mark indicates an expected call of Mark

type MockCheckpointStore 

type MockCheckpointStore struct {
	// contains filtered or unexported fields
}

MockCheckpointStore is a mock of CheckpointStore interface

func NewMockCheckpointStore 

func NewMockCheckpointStore(ctrl *gomock.Controller) *MockCheckpointStore

NewMockCheckpointStore creates a new mock instance

func (*MockCheckpointStore) EXPECT 

func (m *MockCheckpointStore) EXPECT() *MockCheckpointStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockCheckpointStore) Load 

func (m *MockCheckpointStore) Load(region, topic string, partition uint32) *core.Checkpoint

Load mocks base method

func (*MockCheckpointStore) Save 

func (m *MockCheckpointStore) Save(checkpoint core.Checkpoint) error

Save mocks base method

type MockCheckpointStoreMockRecorder 

type MockCheckpointStoreMockRecorder struct {
	// contains filtered or unexported fields
}

MockCheckpointStoreMockRecorder is the mock recorder for MockCheckpointStore

func (*MockCheckpointStoreMockRecorder) Load 

func (mr *MockCheckpointStoreMockRecorder) Load(region, topic, partition interface{}) *gomock.Call

Load indicates an expected call of Load

func (*MockCheckpointStoreMockRecorder) Save 

func (mr *MockCheckpointStoreMockRecorder) Save(checkpoint interface{}) *gomock.Call

Save indicates an expected call of Save

type MockConsumer 

type MockConsumer struct {
	// contains filtered or unexported fields
}

MockConsumer is a mock of Consumer interface

func NewMockConsumer 

func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer

NewMockConsumer creates a new mock instance

func (*MockConsumer) Assign 

func (m *MockConsumer) Assign(partitions []kafka.TopicPartition) error

Assign mocks base method

func (*MockConsumer) Commit 

func (m *MockConsumer) Commit(topic string, partition uint32, offset kafka.Offset) error

Commit mocks base method

func (*MockConsumer) EXPECT 

func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockConsumer) Pause 

func (m *MockConsumer) Pause(partitions []kafka.TopicPartition) error

Pause mocks base method

func (*MockConsumer) Poll 

func (m *MockConsumer) Poll() kafka.Event

Poll mocks base method

func (*MockConsumer) Seek 

func (m *MockConsumer) Seek(topic string, partition uint32, offset kafka.Offset) error

Seek mocks base method

func (*MockConsumer) Subscribe 

func (m *MockConsumer) Subscribe(topics ...string) error

Subscribe mocks base method

func (*MockConsumer) Unassign 

func (m *MockConsumer) Unassign() error

Unassign mocks base method

type MockConsumerMockRecorder 

type MockConsumerMockRecorder struct {
	// contains filtered or unexported fields
}

MockConsumerMockRecorder is the mock recorder for MockConsumer

func (*MockConsumerMockRecorder) Assign 

func (mr *MockConsumerMockRecorder) Assign(partitions interface{}) *gomock.Call

Assign indicates an expected call of Assign

func (*MockConsumerMockRecorder) Commit 

func (mr *MockConsumerMockRecorder) Commit(topic, partition, offset interface{}) *gomock.Call

Commit indicates an expected call of Commit

func (*MockConsumerMockRecorder) Pause 

func (mr *MockConsumerMockRecorder) Pause(partitions interface{}) *gomock.Call

Pause indicates an expected call of Pause

func (*MockConsumerMockRecorder) Poll 

func (mr *MockConsumerMockRecorder) Poll() *gomock.Call

Poll indicates an expected call of Poll

func (*MockConsumerMockRecorder) Seek 

func (mr *MockConsumerMockRecorder) Seek(topic, partition, offset interface{}) *gomock.Call

Seek indicates an expected call of Seek

func (*MockConsumerMockRecorder) Subscribe 

func (mr *MockConsumerMockRecorder) Subscribe(topics ...interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe

func (*MockConsumerMockRecorder) Unassign 

func (mr *MockConsumerMockRecorder) Unassign() *gomock.Call

Unassign indicates an expected call of Unassign

type MockFactory 

type MockFactory struct {
	// contains filtered or unexported fields
}

MockFactory is a mock of Factory interface

func NewMockFactory 

func NewMockFactory(ctrl *gomock.Controller) *MockFactory

NewMockFactory creates a new mock instance

func (*MockFactory) EXPECT 

func (m *MockFactory) EXPECT() *MockFactoryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockFactory) Get 

func (m *MockFactory) Get() (interface{}, error)

Get mocks base method

type MockFactoryMockRecorder 

type MockFactoryMockRecorder struct {
	// contains filtered or unexported fields
}

MockFactoryMockRecorder is the mock recorder for MockFactory

func (*MockFactoryMockRecorder) Get 

func (mr *MockFactoryMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get

type MockLifecycle 

type MockLifecycle struct {
	// contains filtered or unexported fields
}

MockLifecycle is a mock of Lifecycle interface

func NewMockLifecycle 

func NewMockLifecycle(ctrl *gomock.Controller) *MockLifecycle

NewMockLifecycle creates a new mock instance

func (*MockLifecycle) EXPECT 

func (m *MockLifecycle) EXPECT() *MockLifecycleMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockLifecycle) Start 

func (m *MockLifecycle) Start() error

Start mocks base method

func (*MockLifecycle) Stop 

func (m *MockLifecycle) Stop()

Stop mocks base method

type MockLifecycleMockRecorder 

type MockLifecycleMockRecorder struct {
	// contains filtered or unexported fields
}

MockLifecycleMockRecorder is the mock recorder for MockLifecycle

func (*MockLifecycleMockRecorder) Start 

func (mr *MockLifecycleMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockLifecycleMockRecorder) Stop 

func (mr *MockLifecycleMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

type MockProducer 

type MockProducer struct {
	// contains filtered or unexported fields
}

MockProducer is a mock of Producer interface

func NewMockProducer 

func NewMockProducer(ctrl *gomock.Controller) *MockProducer

NewMockProducer creates a new mock instance

func (*MockProducer) EXPECT 

func (m *MockProducer) EXPECT() *MockProducerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockProducer) Produce 

func (m *MockProducer) Produce(topic string, key, value []byte) error

Produce mocks base method

func (*MockProducer) ProduceMessages 

func (m *MockProducer) ProduceMessages(topic string, partition uint32, messages ...core.Message) error

ProduceMessages mocks base method

type MockProducerMockRecorder 

type MockProducerMockRecorder struct {
	// contains filtered or unexported fields
}

MockProducerMockRecorder is the mock recorder for MockProducer

func (*MockProducerMockRecorder) Produce 

func (mr *MockProducerMockRecorder) Produce(topic, key, value interface{}) *gomock.Call

Produce indicates an expected call of Produce

func (*MockProducerMockRecorder) ProduceMessages 

func (mr *MockProducerMockRecorder) ProduceMessages(topic, partition interface{}, messages ...interface{}) *gomock.Call

ProduceMessages indicates an expected call of ProduceMessages

type MockPubSub 

type MockPubSub struct {
	// contains filtered or unexported fields
}

MockPubSub is a mock of PubSub interface

func NewMockPubSub 

func NewMockPubSub(ctrl *gomock.Controller) *MockPubSub

NewMockPubSub creates a new mock instance

func (*MockPubSub) EXPECT 

func (m *MockPubSub) EXPECT() *MockPubSubMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockPubSub) Events 

func (m *MockPubSub) Events() <-chan kafka.Event

Events mocks base method

func (*MockPubSub) Publish 

func (m *MockPubSub) Publish(topic string, key, value []byte) error

Publish mocks base method

func (*MockPubSub) Subscribe 

func (m *MockPubSub) Subscribe(topic string) error

Subscribe mocks base method

type MockPubSubMockRecorder 

type MockPubSubMockRecorder struct {
	// contains filtered or unexported fields
}

MockPubSubMockRecorder is the mock recorder for MockPubSub

func (*MockPubSubMockRecorder) Events 

func (mr *MockPubSubMockRecorder) Events() *gomock.Call

Events indicates an expected call of Events

func (*MockPubSubMockRecorder) Publish 

func (mr *MockPubSubMockRecorder) Publish(topic, key, value interface{}) *gomock.Call

Publish indicates an expected call of Publish

func (*MockPubSubMockRecorder) Subscribe 

func (mr *MockPubSubMockRecorder) Subscribe(topic interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe

type MockRetrier 

type MockRetrier struct {
	// contains filtered or unexported fields
}

MockRetrier is a mock of Retrier interface

func NewMockRetrier 

func NewMockRetrier(ctrl *gomock.Controller) *MockRetrier

NewMockRetrier creates a new mock instance

func (*MockRetrier) EXPECT 

func (m *MockRetrier) EXPECT() *MockRetrierMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockRetrier) Forever 

func (m *MockRetrier) Forever(ctx context.Context, work func() error) bool

Forever mocks base method

type MockRetrierMockRecorder 

type MockRetrierMockRecorder struct {
	// contains filtered or unexported fields
}

MockRetrierMockRecorder is the mock recorder for MockRetrier

func (*MockRetrierMockRecorder) Forever 

func (mr *MockRetrierMockRecorder) Forever(ctx, work interface{}) *gomock.Call

Forever indicates an expected call of Forever

type MockSegmentEventSource 

type MockSegmentEventSource struct {
	// contains filtered or unexported fields
}

MockSegmentEventSource is a mock of SegmentEventSource interface

func NewMockSegmentEventSource 

func NewMockSegmentEventSource(ctrl *gomock.Controller) *MockSegmentEventSource

NewMockSegmentEventSource creates a new mock instance

func (*MockSegmentEventSource) EXPECT 

func (m *MockSegmentEventSource) EXPECT() *MockSegmentEventSourceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSegmentEventSource) Events 

func (m *MockSegmentEventSource) Events() <-chan core.SegmentEventRequest

Events mocks base method

type MockSegmentEventSourceMockRecorder 

type MockSegmentEventSourceMockRecorder struct {
	// contains filtered or unexported fields
}

MockSegmentEventSourceMockRecorder is the mock recorder for MockSegmentEventSource

func (*MockSegmentEventSourceMockRecorder) Events 

func (mr *MockSegmentEventSourceMockRecorder) Events() *gomock.Call

Events indicates an expected call of Events

type MockSegmentFormat 

type MockSegmentFormat struct {
	// contains filtered or unexported fields
}

MockSegmentFormat is a mock of SegmentFormat interface

func NewMockSegmentFormat 

func NewMockSegmentFormat(ctrl *gomock.Controller) *MockSegmentFormat

NewMockSegmentFormat creates a new mock instance

func (*MockSegmentFormat) EXPECT 

func (m *MockSegmentFormat) EXPECT() *MockSegmentFormatMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSegmentFormat) NewReader 

func (m *MockSegmentFormat) NewReader(ctx context.Context, path string) (core.SegmentReader, error)

NewReader mocks base method

func (*MockSegmentFormat) NewWriter 

func (m *MockSegmentFormat) NewWriter(ctx context.Context, path string) (core.SegmentWriter, error)

NewWriter mocks base method

type MockSegmentFormatMockRecorder 

type MockSegmentFormatMockRecorder struct {
	// contains filtered or unexported fields
}

MockSegmentFormatMockRecorder is the mock recorder for MockSegmentFormat

func (*MockSegmentFormatMockRecorder) NewReader 

func (mr *MockSegmentFormatMockRecorder) NewReader(ctx, path interface{}) *gomock.Call

NewReader indicates an expected call of NewReader

func (*MockSegmentFormatMockRecorder) NewWriter 

func (mr *MockSegmentFormatMockRecorder) NewWriter(ctx, path interface{}) *gomock.Call

NewWriter indicates an expected call of NewWriter

type MockSegmentReader 

type MockSegmentReader struct {
	// contains filtered or unexported fields
}

MockSegmentReader is a mock of SegmentReader interface

func NewMockSegmentReader 

func NewMockSegmentReader(ctrl *gomock.Controller) *MockSegmentReader

NewMockSegmentReader creates a new mock instance

func (*MockSegmentReader) Close 

func (m *MockSegmentReader) Close(ctx context.Context)

Close mocks base method

func (*MockSegmentReader) EXPECT 

func (m *MockSegmentReader) EXPECT() *MockSegmentReaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSegmentReader) Metadata 

func (m *MockSegmentReader) Metadata() core.SegmentMetadata

Metadata mocks base method

func (*MockSegmentReader) Read 

func (m *MockSegmentReader) Read(ctx context.Context, count int) ([]core.Message, error)

Read mocks base method

type MockSegmentReaderMockRecorder 

type MockSegmentReaderMockRecorder struct {
	// contains filtered or unexported fields
}

MockSegmentReaderMockRecorder is the mock recorder for MockSegmentReader

func (*MockSegmentReaderMockRecorder) Close 

func (mr *MockSegmentReaderMockRecorder) Close(ctx interface{}) *gomock.Call

Close indicates an expected call of Close

func (*MockSegmentReaderMockRecorder) Metadata 

func (mr *MockSegmentReaderMockRecorder) Metadata() *gomock.Call

Metadata indicates an expected call of Metadata

func (*MockSegmentReaderMockRecorder) Read 

func (mr *MockSegmentReaderMockRecorder) Read(ctx, count interface{}) *gomock.Call

Read indicates an expected call of Read

type MockSegmentStore 

type MockSegmentStore struct {
	// contains filtered or unexported fields
}

MockSegmentStore is a mock of SegmentStore interface

func NewMockSegmentStore 

func NewMockSegmentStore(ctrl *gomock.Controller) *MockSegmentStore

NewMockSegmentStore creates a new mock instance

func (*MockSegmentStore) Create 

func (m *MockSegmentStore) Create(ctx context.Context) (core.SegmentWriter, error)

Create mocks base method

func (*MockSegmentStore) Delete 

func (m *MockSegmentStore) Delete(ctx context.Context, segment core.Segment) error

Delete mocks base method

func (*MockSegmentStore) EXPECT 

func (m *MockSegmentStore) EXPECT() *MockSegmentStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSegmentStore) Events 

func (m *MockSegmentStore) Events() <-chan core.SegmentEventRequest

Events mocks base method

func (*MockSegmentStore) ListSegments 

func (m *MockSegmentStore) ListSegments(ctx context.Context, region, topic string, partition uint32) (map[core.Segment]core.SegmentInfo, error)

ListSegments mocks base method

func (*MockSegmentStore) Open 

func (m *MockSegmentStore) Open(ctx context.Context, segment core.Segment) (core.SegmentReader, error)

Open mocks base method

type MockSegmentStoreMockRecorder 

type MockSegmentStoreMockRecorder struct {
	// contains filtered or unexported fields
}

MockSegmentStoreMockRecorder is the mock recorder for MockSegmentStore

func (*MockSegmentStoreMockRecorder) Create 

func (mr *MockSegmentStoreMockRecorder) Create(ctx interface{}) *gomock.Call

Create indicates an expected call of Create

func (*MockSegmentStoreMockRecorder) Delete 

func (mr *MockSegmentStoreMockRecorder) Delete(ctx, segment interface{}) *gomock.Call

Delete indicates an expected call of Delete

func (*MockSegmentStoreMockRecorder) Events 

func (mr *MockSegmentStoreMockRecorder) Events() *gomock.Call

Events indicates an expected call of Events

func (*MockSegmentStoreMockRecorder) ListSegments 

func (mr *MockSegmentStoreMockRecorder) ListSegments(ctx, region, topic, partition interface{}) *gomock.Call

ListSegments indicates an expected call of ListSegments

func (*MockSegmentStoreMockRecorder) Open 

func (mr *MockSegmentStoreMockRecorder) Open(ctx, segment interface{}) *gomock.Call

Open indicates an expected call of Open

type MockSegmentWriter 

type MockSegmentWriter struct {
	// contains filtered or unexported fields
}

MockSegmentWriter is a mock of SegmentWriter interface

func NewMockSegmentWriter 

func NewMockSegmentWriter(ctrl *gomock.Controller) *MockSegmentWriter

NewMockSegmentWriter creates a new mock instance

func (*MockSegmentWriter) Abort 

func (m *MockSegmentWriter) Abort(ctx context.Context)

Abort mocks base method

func (*MockSegmentWriter) Close 

func (m *MockSegmentWriter) Close(ctx context.Context, metadata core.SegmentMetadata) error

Close mocks base method

func (*MockSegmentWriter) EXPECT 

func (m *MockSegmentWriter) EXPECT() *MockSegmentWriterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSegmentWriter) Write 

func (m *MockSegmentWriter) Write(ctx context.Context, message core.Message) error

Write mocks base method

type MockSegmentWriterMockRecorder 

type MockSegmentWriterMockRecorder struct {
	// contains filtered or unexported fields
}

MockSegmentWriterMockRecorder is the mock recorder for MockSegmentWriter

func (*MockSegmentWriterMockRecorder) Abort 

func (mr *MockSegmentWriterMockRecorder) Abort(ctx interface{}) *gomock.Call

Abort indicates an expected call of Abort

func (*MockSegmentWriterMockRecorder) Close 

func (mr *MockSegmentWriterMockRecorder) Close(ctx, metadata interface{}) *gomock.Call

Close indicates an expected call of Close

func (*MockSegmentWriterMockRecorder) Write 

func (mr *MockSegmentWriterMockRecorder) Write(ctx, message interface{}) *gomock.Call

Write indicates an expected call of Write

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.