Documentation
¶
Index ¶
- type Gossiper
- func (_m *Gossiper) AcceptConnections() error
- func (_m *Gossiper) Close()
- func (_m *Gossiper) GetGenerations(ordinal int, token types.Token) interbroker.GenReadResult
- func (_m *Gossiper) HasTokenHistoryForToken(ordinal int, token types.Token, clusterSize int) (bool, error)
- func (_m *Gossiper) Init() error
- func (_m *Gossiper) IsHostUp(ordinal int) bool
- func (_m *Gossiper) IsTokenRangeCovered(ordinal int, token types.Token) (bool, error)
- func (_m *Gossiper) MergeTopicFiles(peers []int, topic *types.TopicDataId, offset int64) error
- func (_m *Gossiper) OpenConnections()
- func (_m *Gossiper) RangeSplitStart(ordinal int) error
- func (_m *Gossiper) ReadBrokerIsUp(ordinal int, brokerUpOrdinal int) (bool, error)
- func (_m *Gossiper) ReadProducerOffset(ordinal int, topic *types.TopicDataId) (int64, error)
- func (_m *Gossiper) ReadTokenHistory(ordinal int, token types.Token, clusterSize int) (*types.Generation, error)
- func (_m *Gossiper) RegisterConsumerInfoListener(listener interbroker.ConsumerInfoListener)
- func (_m *Gossiper) RegisterGenListener(listener interbroker.GenListener)
- func (_m *Gossiper) RegisterHostUpDownListener(listener interbroker.PeerStateListener)
- func (_m *Gossiper) RegisterReroutedMessageListener(listener interbroker.ReroutingListener)
- func (_m *Gossiper) SendCommittedOffset(ordinal int, offsetKv *types.OffsetStoreKeyValue) error
- func (_m *Gossiper) SendConsumerCommit(ordinal int, id string) error
- func (_m *Gossiper) SendConsumerGroups(ordinal int, groups []types.ConsumerGroup) error
- func (_m *Gossiper) SendConsumerRegister(ordinal int, id string, group string, topics []string, ...) error
- func (_m *Gossiper) SendConsumerUnregister(ordinal int, id string) error
- func (_m *Gossiper) SendGoobye()
- func (_m *Gossiper) SendToFollowers(replicationInfo types.ReplicationInfo, topic types.TopicDataId, ...) error
- func (_m *Gossiper) SendToLeader(replicationInfo types.ReplicationInfo, topic string, querystring url.Values, ...) error
- func (_m *Gossiper) SetAsCommitted(ordinal int, token1 types.Token, token2 *types.Token, tx uuid.UUID) error
- func (_m *Gossiper) SetGenerationAsProposed(ordinal int, newGen *types.Generation, newGen2 *types.Generation, ...) error
- func (_m *Gossiper) StreamFile(peers []int, segmentId int64, topic *types.TopicDataId, startOffset int64, ...) (int, error)
- func (_m *Gossiper) WaitForPeersUp()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Gossiper ¶
Gossiper is an autogenerated mock type for the Gossiper type
func NewGossiper ¶
func NewGossiper(t mockConstructorTestingTNewGossiper) *Gossiper
NewGossiper creates a new instance of Gossiper. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Gossiper) AcceptConnections ¶
AcceptConnections provides a mock function with given fields:
func (*Gossiper) Close ¶
func (_m *Gossiper) Close()
Close provides a mock function with given fields:
func (*Gossiper) GetGenerations ¶
func (_m *Gossiper) GetGenerations(ordinal int, token types.Token) interbroker.GenReadResult
GetGenerations provides a mock function with given fields: ordinal, token
func (*Gossiper) HasTokenHistoryForToken ¶
func (_m *Gossiper) HasTokenHistoryForToken(ordinal int, token types.Token, clusterSize int) (bool, error)
HasTokenHistoryForToken provides a mock function with given fields: ordinal, token, clusterSize
func (*Gossiper) IsTokenRangeCovered ¶
IsTokenRangeCovered provides a mock function with given fields: ordinal, token
func (*Gossiper) MergeTopicFiles ¶
MergeTopicFiles provides a mock function with given fields: peers, topic, offset
func (*Gossiper) OpenConnections ¶
func (_m *Gossiper) OpenConnections()
OpenConnections provides a mock function with given fields:
func (*Gossiper) RangeSplitStart ¶
RangeSplitStart provides a mock function with given fields: ordinal
func (*Gossiper) ReadBrokerIsUp ¶
ReadBrokerIsUp provides a mock function with given fields: ordinal, brokerUpOrdinal
func (*Gossiper) ReadProducerOffset ¶
ReadProducerOffset provides a mock function with given fields: ordinal, topic
func (*Gossiper) ReadTokenHistory ¶
func (_m *Gossiper) ReadTokenHistory(ordinal int, token types.Token, clusterSize int) (*types.Generation, error)
ReadTokenHistory provides a mock function with given fields: ordinal, token, clusterSize
func (*Gossiper) RegisterConsumerInfoListener ¶
func (_m *Gossiper) RegisterConsumerInfoListener(listener interbroker.ConsumerInfoListener)
RegisterConsumerInfoListener provides a mock function with given fields: listener
func (*Gossiper) RegisterGenListener ¶
func (_m *Gossiper) RegisterGenListener(listener interbroker.GenListener)
RegisterGenListener provides a mock function with given fields: listener
func (*Gossiper) RegisterHostUpDownListener ¶
func (_m *Gossiper) RegisterHostUpDownListener(listener interbroker.PeerStateListener)
RegisterHostUpDownListener provides a mock function with given fields: listener
func (*Gossiper) RegisterReroutedMessageListener ¶
func (_m *Gossiper) RegisterReroutedMessageListener(listener interbroker.ReroutingListener)
RegisterReroutedMessageListener provides a mock function with given fields: listener
func (*Gossiper) SendCommittedOffset ¶
func (_m *Gossiper) SendCommittedOffset(ordinal int, offsetKv *types.OffsetStoreKeyValue) error
SendCommittedOffset provides a mock function with given fields: ordinal, offsetKv
func (*Gossiper) SendConsumerCommit ¶
SendConsumerCommit provides a mock function with given fields: ordinal, id
func (*Gossiper) SendConsumerGroups ¶
func (_m *Gossiper) SendConsumerGroups(ordinal int, groups []types.ConsumerGroup) error
SendConsumerGroups provides a mock function with given fields: ordinal, groups
func (*Gossiper) SendConsumerRegister ¶
func (_m *Gossiper) SendConsumerRegister(ordinal int, id string, group string, topics []string, onNewGroup types.OffsetResetPolicy) error
SendConsumerRegister provides a mock function with given fields: ordinal, id, group, topics, onNewGroup
func (*Gossiper) SendConsumerUnregister ¶
SendConsumerUnregister provides a mock function with given fields: ordinal, id
func (*Gossiper) SendGoobye ¶
func (_m *Gossiper) SendGoobye()
SendGoobye provides a mock function with given fields:
func (*Gossiper) SendToFollowers ¶
func (_m *Gossiper) 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
func (*Gossiper) SendToLeader ¶
func (_m *Gossiper) SendToLeader(replicationInfo types.ReplicationInfo, topic string, querystring url.Values, contentLength int64, contentType string, body io.Reader) error
SendToLeader provides a mock function with given fields: replicationInfo, topic, querystring, contentLength, contentType, body
func (*Gossiper) SetAsCommitted ¶
func (_m *Gossiper) SetAsCommitted(ordinal int, token1 types.Token, token2 *types.Token, tx uuid.UUID) error
SetAsCommitted provides a mock function with given fields: ordinal, token1, token2, tx
func (*Gossiper) SetGenerationAsProposed ¶
func (_m *Gossiper) SetGenerationAsProposed(ordinal int, newGen *types.Generation, newGen2 *types.Generation, expectedTx *uuid.UUID) error
SetGenerationAsProposed provides a mock function with given fields: ordinal, newGen, newGen2, expectedTx
func (*Gossiper) StreamFile ¶
func (_m *Gossiper) StreamFile(peers []int, segmentId int64, topic *types.TopicDataId, startOffset int64, maxRecords int, buf []byte) (int, error)
StreamFile provides a mock function with given fields: peers, segmentId, topic, startOffset, maxRecords, buf
func (*Gossiper) WaitForPeersUp ¶
func (_m *Gossiper) WaitForPeersUp()
WaitForPeersUp provides a mock function with given fields:
Source Files