mocks

Documentation

Index

• type AssignedPartition
  • func (_m *AssignedPartition) AddMessage(msg *kafka.Message, now time.Time) error
  • func (_m *AssignedPartition) Close()
  • func (_m *AssignedPartition) Redeliver(now time.Time)
  • func (_m *AssignedPartition) SmallestMarkerOffset() (int64, bool)
• type MarkerConsumer
  • func (_m *MarkerConsumer) Start()
  • func (_m *MarkerConsumer) Stop()
• type MarkersQueue
  • func (_m *MarkersQueue) AddMarker(offset int64, timestamp time.Time, marker *proto.Marker)
  • func (_m *MarkersQueue) MarkersToRedeliver(now time.Time) []*proto.Marker
  • func (_m *MarkersQueue) Partition() int32
  • func (_m *MarkersQueue) SmallestMarkerOffset() (int64, bool)
• type OffsetCommitter
  • func (_m *OffsetCommitter) AddMarker(_a0 redelivery.RecordID)
  • func (_m *OffsetCommitter) DropOffsets(partition int32)
• type Redeliverer
  • func (_m *Redeliverer) Redeliver(markers []*proto.Marker)
  • func (_m *Redeliverer) Stop()

Types

type AssignedPartition

type AssignedPartition struct {
	mock.Mock
}

AssignedPartition is an autogenerated mock type for the AssignedPartition type

func (*AssignedPartition) AddMessage

func (_m *AssignedPartition) AddMessage(msg *kafka.Message, now time.Time) error

AddMessage provides a mock function with given fields: msg, now

func (*AssignedPartition) Close

func (_m *AssignedPartition) Close()

Close provides a mock function with given fields:

func (*AssignedPartition) Redeliver

func (_m *AssignedPartition) Redeliver(now time.Time)

Redeliver provides a mock function with given fields: now

func (*AssignedPartition) SmallestMarkerOffset

func (_m *AssignedPartition) SmallestMarkerOffset() (int64, bool)

SmallestMarkerOffset provides a mock function with given fields:

type MarkerConsumer

type MarkerConsumer struct {
	mock.Mock
}

MarkerConsumer is an autogenerated mock type for the MarkerConsumer type

func (*MarkerConsumer) Start

func (_m *MarkerConsumer) Start()

Start provides a mock function with given fields:

func (*MarkerConsumer) Stop

func (_m *MarkerConsumer) Stop()

Stop provides a mock function with given fields:

type MarkersQueue

type MarkersQueue struct {
	mock.Mock
}

MarkersQueue is an autogenerated mock type for the MarkersQueue type

func (*MarkersQueue) AddMarker

func (_m *MarkersQueue) AddMarker(offset int64, timestamp time.Time, marker *proto.Marker)

AddMarker provides a mock function with given fields: offset, timestamp, marker

func (*MarkersQueue) MarkersToRedeliver

func (_m *MarkersQueue) MarkersToRedeliver(now time.Time) []*proto.Marker

MarkersToRedeliver provides a mock function with given fields: now

func (*MarkersQueue) Partition

func (_m *MarkersQueue) Partition() int32

Partition provides a mock function with given fields:

func (*MarkersQueue) SmallestMarkerOffset

func (_m *MarkersQueue) SmallestMarkerOffset() (int64, bool)

SmallestMarkerOffset provides a mock function with given fields:

type OffsetCommitter

type OffsetCommitter struct {
	mock.Mock
}

OffsetCommitter is an autogenerated mock type for the OffsetCommitter type

func (*OffsetCommitter) AddMarker

func (_m *OffsetCommitter) AddMarker(_a0 redelivery.RecordID)

AddMarker provides a mock function with given fields: _a0

func (*OffsetCommitter) DropOffsets

func (_m *OffsetCommitter) DropOffsets(partition int32)

DropOffsets provides a mock function with given fields: partition

type Redeliverer

type Redeliverer struct {
	mock.Mock
}

Redeliverer is an autogenerated mock type for the Redeliverer type

func (*Redeliverer) Redeliver

func (_m *Redeliverer) Redeliver(markers []*proto.Marker)

Redeliver provides a mock function with given fields: markers

func (*Redeliverer) Stop

func (_m *Redeliverer) Stop()

Stop provides a mock function with given fields: