Documentation
¶
Index ¶
- type OffsetState
- func (_m *OffsetState) Get(group string, topic string, token types.Token, index types.RangeIndex, ...) (*types.Offset, bool)
- func (_m *OffsetState) GetAllWithDefaults(group string, topic string, token types.Token, rangeIndex types.RangeIndex, ...) []types.Offset
- func (_m *OffsetState) Init() error
- func (_m *OffsetState) MaxProducedOffset(topicId *types.TopicDataId) (int64, error)
- func (_m *OffsetState) Set(group string, topic string, value types.Offset, commit types.OffsetCommitType) bool
- func (_m *OffsetState) String() string
- type Replicator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OffsetState ¶
OffsetState is an autogenerated mock type for the OffsetState type
func NewOffsetState ¶
func NewOffsetState(t mockConstructorTestingTNewOffsetState) *OffsetState
NewOffsetState creates a new instance of OffsetState. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*OffsetState) Get ¶
func (_m *OffsetState) Get(group string, topic string, token types.Token, index types.RangeIndex, clusterSize int) (*types.Offset, bool)
Get provides a mock function with given fields: group, topic, token, index, clusterSize
func (*OffsetState) GetAllWithDefaults ¶
func (_m *OffsetState) GetAllWithDefaults(group string, topic string, token types.Token, rangeIndex types.RangeIndex, clusterSize int, policy types.OffsetResetPolicy) []types.Offset
GetAllWithDefaults provides a mock function with given fields: group, topic, token, rangeIndex, clusterSize, policy
func (*OffsetState) Init ¶
func (_m *OffsetState) Init() error
Init provides a mock function with given fields:
func (*OffsetState) MaxProducedOffset ¶
func (_m *OffsetState) MaxProducedOffset(topicId *types.TopicDataId) (int64, error)
MaxProducedOffset provides a mock function with given fields: topicId
func (*OffsetState) Set ¶
func (_m *OffsetState) Set(group string, topic string, value types.Offset, commit types.OffsetCommitType) bool
Set provides a mock function with given fields: group, topic, value, commit
func (*OffsetState) String ¶
func (_m *OffsetState) String() string
String provides a mock function with given fields:
type Replicator ¶
Replicator is an autogenerated mock type for the Replicator type
func (*Replicator) SendToFollowers ¶
func (_m *Replicator) SendToFollowers(replicationInfo types.ReplicationInfo, topic types.TopicDataId, segmentId int64, chunk types.SegmentChunk) error
SendToFollowers provides a mock function with given fields: replicationInfo, topic, segmentId, chunk
Source Files