mocks

Documentation

Index

• type Discoverer
  • func NewDiscoverer(t mockConstructorTestingTNewDiscoverer) *Discoverer
  • func (_m *Discoverer) Brokers() []types.BrokerInfo
  • func (_m *Discoverer) Close()
  • func (_m *Discoverer) CurrentOrPastBroker(ordinal int) *types.BrokerInfo
  • func (_m *Discoverer) Generation(token types.Token) *types.Generation
  • func (_m *Discoverer) GenerationInfo(id types.GenId) *types.Generation
  • func (_m *Discoverer) GenerationProposed(token types.Token) (*types.Generation, *types.Generation)
  • func (_m *Discoverer) GetTokenHistory(token types.Token, clusterSize int) (*types.Generation, error)
  • func (_m *Discoverer) HasTokenHistory(token types.Token, clusterSize int) (bool, error)
  • func (_m *Discoverer) Init() error
  • func (_m *Discoverer) IsTokenInRange(token types.Token) bool
  • func (_m *Discoverer) Leader(partitionKey string) types.ReplicationInfo
  • func (_m *Discoverer) LocalInfo() *types.BrokerInfo
  • func (_m *Discoverer) NextGeneration(id types.GenId) []types.Generation
  • func (_m *Discoverer) ParentRanges(gen *types.Generation, indices []types.RangeIndex) []types.GenerationRanges
  • func (_m *Discoverer) RegisterListener(l discovery.TopologyChangeListener)
  • func (_m *Discoverer) RepairCommitted(gen *types.Generation) error
  • func (_m *Discoverer) SetAsCommitted(token1 types.Token, token2 *types.Token, tx uuid.UUID, origin int) error
  • func (_m *Discoverer) SetGenerationProposed(gen *types.Generation, gen2 *types.Generation, expectedTx *uuid.UUID) error
  • func (_m *Discoverer) Topology() *types.TopologyInfo

Types

type Discoverer

type Discoverer struct {
	mock.Mock
}

Discoverer is an autogenerated mock type for the Discoverer type

func NewDiscoverer

func NewDiscoverer(t mockConstructorTestingTNewDiscoverer) *Discoverer

NewDiscoverer creates a new instance of Discoverer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Discoverer) Brokers

func (_m *Discoverer) Brokers() []types.BrokerInfo

Brokers provides a mock function with given fields:

func (*Discoverer) Close

func (_m *Discoverer) Close()

Close provides a mock function with given fields:

func (*Discoverer) CurrentOrPastBroker

func (_m *Discoverer) CurrentOrPastBroker(ordinal int) *types.BrokerInfo

CurrentOrPastBroker provides a mock function with given fields: ordinal

func (*Discoverer) Generation

func (_m *Discoverer) Generation(token types.Token) *types.Generation

Generation provides a mock function with given fields: token

func (*Discoverer) GenerationInfo

func (_m *Discoverer) GenerationInfo(id types.GenId) *types.Generation

GenerationInfo provides a mock function with given fields: id

func (*Discoverer) GenerationProposed

func (_m *Discoverer) GenerationProposed(token types.Token) (*types.Generation, *types.Generation)

GenerationProposed provides a mock function with given fields: token

func (*Discoverer) GetTokenHistory

func (_m *Discoverer) GetTokenHistory(token types.Token, clusterSize int) (*types.Generation, error)

GetTokenHistory provides a mock function with given fields: token, clusterSize

func (*Discoverer) HasTokenHistory

func (_m *Discoverer) HasTokenHistory(token types.Token, clusterSize int) (bool, error)

HasTokenHistory provides a mock function with given fields: token, clusterSize

func (*Discoverer) Init

func (_m *Discoverer) Init() error

Init provides a mock function with given fields:

func (*Discoverer) IsTokenInRange

func (_m *Discoverer) IsTokenInRange(token types.Token) bool

IsTokenInRange provides a mock function with given fields: token

func (*Discoverer) Leader

func (_m *Discoverer) Leader(partitionKey string) types.ReplicationInfo

Leader provides a mock function with given fields: partitionKey

func (*Discoverer) LocalInfo

func (_m *Discoverer) LocalInfo() *types.BrokerInfo

LocalInfo provides a mock function with given fields:

func (*Discoverer) NextGeneration

func (_m *Discoverer) NextGeneration(id types.GenId) []types.Generation

NextGeneration provides a mock function with given fields: id

func (*Discoverer) ParentRanges

func (_m *Discoverer) ParentRanges(gen *types.Generation, indices []types.RangeIndex) []types.GenerationRanges

ParentRanges provides a mock function with given fields: gen, indices

func (*Discoverer) RegisterListener

func (_m *Discoverer) RegisterListener(l discovery.TopologyChangeListener)

RegisterListener provides a mock function with given fields: l

func (*Discoverer) RepairCommitted

func (_m *Discoverer) RepairCommitted(gen *types.Generation) error

RepairCommitted provides a mock function with given fields: gen

func (*Discoverer) SetAsCommitted

func (_m *Discoverer) SetAsCommitted(token1 types.Token, token2 *types.Token, tx uuid.UUID, origin int) error

SetAsCommitted provides a mock function with given fields: token1, token2, tx, origin

func (*Discoverer) SetGenerationProposed

func (_m *Discoverer) SetGenerationProposed(gen *types.Generation, gen2 *types.Generation, expectedTx *uuid.UUID) error

SetGenerationProposed provides a mock function with given fields: gen, gen2, expectedTx

func (*Discoverer) Topology

func (_m *Discoverer) Topology() *types.TopologyInfo

Topology provides a mock function with given fields: