Versions in this module Expand all Collapse all v0 v0.7.0 Apr 14, 2023 v0.6.0 Dec 9, 2022 Changes in this version + type Discoverer interface + RegisterListener func(l TopologyChangeListener) + func NewDiscoverer(config conf.DiscovererConfig, localDb localdb.Client) Discoverer + type GenerationState interface + Generation func(token Token) *Generation + GenerationInfo func(id GenId) *Generation + GenerationProposed func(token Token) (committed *Generation, proposed *Generation) + GetTokenHistory func(token Token, clusterSize int) (*Generation, error) + HasTokenHistory func(token Token, clusterSize int) (bool, error) + IsTokenInRange func(token Token) bool + NextGeneration func(id GenId) []Generation + ParentRanges func(gen *Generation, indices []RangeIndex) []GenerationRanges + RepairCommitted func(gen *Generation) error + SetAsCommitted func(token1 Token, token2 *Token, tx UUID, origin int) error + SetGenerationProposed func(gen *Generation, gen2 *Generation, expectedTx *UUID) error + type TopologyChangeListener interface + OnTopologyChange func(previousTopology *TopologyInfo, newTopology *TopologyInfo) + type TopologyGetter interface + Brokers func() []BrokerInfo + CurrentOrPastBroker func(ordinal int) *BrokerInfo + Leader func(partitionKey string) ReplicationInfo + LocalInfo func() *BrokerInfo + Topology func() *TopologyInfo
Go to main page