beat

package
v0.0.0-...-05bc493 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 20, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Ack 

type Ack struct {
	// contains filtered or unexported fields
}

func NewAck 

func NewAck(fn AckFunc) (Ack, func(ack bool))

func (Ack) Acquire 

func (v Ack) Acquire() AckFunc

func (Ack) DoneChan 

func (v Ack) DoneChan() synckit.SignalChannel

func (Ack) IsAcquired 

func (v Ack) IsAcquired() bool

func (Ack) IsDone 

func (v Ack) IsDone() (isDone, isAck bool)

func (Ack) IsZero 

func (v Ack) IsZero() bool

type AckData 

type AckData struct {
	api.UpstreamState
}

type AckFunc 

type AckFunc = func(AckData)

type Appender 

type Appender interface {
	History
	AddExpectedBeat(Beat) error
	AddCommittedBeat(Beat) error
	EnsureLatestTimeBeat(Beat) error
}

Appender provides method for appending pulses to storage.

type AppenderMock 

type AppenderMock struct {
	AddCommittedBeatMock mAppenderMockAddCommittedBeat

	AddExpectedBeatMock mAppenderMockAddExpectedBeat

	EnsureLatestTimeBeatMock mAppenderMockEnsureLatestTimeBeat

	LatestTimeBeatMock mAppenderMockLatestTimeBeat

	TimeBeatMock mAppenderMockTimeBeat
	// contains filtered or unexported fields
}

AppenderMock implements Appender

func NewAppenderMock 

func NewAppenderMock(t minimock.Tester) *AppenderMock

NewAppenderMock returns a mock for Appender

func (*AppenderMock) AddCommittedBeat 

func (mmAddCommittedBeat *AppenderMock) AddCommittedBeat(b1 Beat) (err error)

AddCommittedBeat implements Appender

func (*AppenderMock) AddCommittedBeatAfterCounter 

func (mmAddCommittedBeat *AppenderMock) AddCommittedBeatAfterCounter() uint64

AddCommittedBeatAfterCounter returns a count of finished AppenderMock.AddCommittedBeat invocations

func (*AppenderMock) AddCommittedBeatBeforeCounter 

func (mmAddCommittedBeat *AppenderMock) AddCommittedBeatBeforeCounter() uint64

AddCommittedBeatBeforeCounter returns a count of AppenderMock.AddCommittedBeat invocations

func (*AppenderMock) AddExpectedBeat 

func (mmAddExpectedBeat *AppenderMock) AddExpectedBeat(b1 Beat) (err error)

AddExpectedBeat implements Appender

func (*AppenderMock) AddExpectedBeatAfterCounter 

func (mmAddExpectedBeat *AppenderMock) AddExpectedBeatAfterCounter() uint64

AddExpectedBeatAfterCounter returns a count of finished AppenderMock.AddExpectedBeat invocations

func (*AppenderMock) AddExpectedBeatBeforeCounter 

func (mmAddExpectedBeat *AppenderMock) AddExpectedBeatBeforeCounter() uint64

AddExpectedBeatBeforeCounter returns a count of AppenderMock.AddExpectedBeat invocations

func (*AppenderMock) EnsureLatestTimeBeat 

func (mmEnsureLatestTimeBeat *AppenderMock) EnsureLatestTimeBeat(b1 Beat) (err error)

EnsureLatestTimeBeat implements Appender

func (*AppenderMock) EnsureLatestTimeBeatAfterCounter 

func (mmEnsureLatestTimeBeat *AppenderMock) EnsureLatestTimeBeatAfterCounter() uint64

EnsureLatestTimeBeatAfterCounter returns a count of finished AppenderMock.EnsureLatestTimeBeat invocations

func (*AppenderMock) EnsureLatestTimeBeatBeforeCounter 

func (mmEnsureLatestTimeBeat *AppenderMock) EnsureLatestTimeBeatBeforeCounter() uint64

EnsureLatestTimeBeatBeforeCounter returns a count of AppenderMock.EnsureLatestTimeBeat invocations

func (*AppenderMock) LatestTimeBeat 

func (mmLatestTimeBeat *AppenderMock) LatestTimeBeat() (b1 Beat, err error)

LatestTimeBeat implements Appender

func (*AppenderMock) LatestTimeBeatAfterCounter 

func (mmLatestTimeBeat *AppenderMock) LatestTimeBeatAfterCounter() uint64

LatestTimeBeatAfterCounter returns a count of finished AppenderMock.LatestTimeBeat invocations

func (*AppenderMock) LatestTimeBeatBeforeCounter 

func (mmLatestTimeBeat *AppenderMock) LatestTimeBeatBeforeCounter() uint64

LatestTimeBeatBeforeCounter returns a count of AppenderMock.LatestTimeBeat invocations

func (*AppenderMock) MinimockAddCommittedBeatDone 

func (m *AppenderMock) MinimockAddCommittedBeatDone() bool

MinimockAddCommittedBeatDone returns true if the count of the AddCommittedBeat invocations corresponds the number of defined expectations

func (*AppenderMock) MinimockAddCommittedBeatInspect 

func (m *AppenderMock) MinimockAddCommittedBeatInspect()

MinimockAddCommittedBeatInspect logs each unmet expectation

func (*AppenderMock) MinimockAddExpectedBeatDone 

func (m *AppenderMock) MinimockAddExpectedBeatDone() bool

MinimockAddExpectedBeatDone returns true if the count of the AddExpectedBeat invocations corresponds the number of defined expectations

func (*AppenderMock) MinimockAddExpectedBeatInspect 

func (m *AppenderMock) MinimockAddExpectedBeatInspect()

MinimockAddExpectedBeatInspect logs each unmet expectation

func (*AppenderMock) MinimockEnsureLatestTimeBeatDone 

func (m *AppenderMock) MinimockEnsureLatestTimeBeatDone() bool

MinimockEnsureLatestTimeBeatDone returns true if the count of the EnsureLatestTimeBeat invocations corresponds the number of defined expectations

func (*AppenderMock) MinimockEnsureLatestTimeBeatInspect 

func (m *AppenderMock) MinimockEnsureLatestTimeBeatInspect()

MinimockEnsureLatestTimeBeatInspect logs each unmet expectation

func (*AppenderMock) MinimockFinish 

func (m *AppenderMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*AppenderMock) MinimockLatestTimeBeatDone 

func (m *AppenderMock) MinimockLatestTimeBeatDone() bool

MinimockLatestTimeBeatDone returns true if the count of the LatestTimeBeat invocations corresponds the number of defined expectations

func (*AppenderMock) MinimockLatestTimeBeatInspect 

func (m *AppenderMock) MinimockLatestTimeBeatInspect()

MinimockLatestTimeBeatInspect logs each unmet expectation

func (*AppenderMock) MinimockTimeBeatDone 

func (m *AppenderMock) MinimockTimeBeatDone() bool

MinimockTimeBeatDone returns true if the count of the TimeBeat invocations corresponds the number of defined expectations

func (*AppenderMock) MinimockTimeBeatInspect 

func (m *AppenderMock) MinimockTimeBeatInspect()

MinimockTimeBeatInspect logs each unmet expectation

func (*AppenderMock) MinimockWait 

func (m *AppenderMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*AppenderMock) TimeBeat 

func (mmTimeBeat *AppenderMock) TimeBeat(n1 pulse.Number) (b1 Beat, err error)

TimeBeat implements Appender

func (*AppenderMock) TimeBeatAfterCounter 

func (mmTimeBeat *AppenderMock) TimeBeatAfterCounter() uint64

TimeBeatAfterCounter returns a count of finished AppenderMock.TimeBeat invocations

func (*AppenderMock) TimeBeatBeforeCounter 

func (mmTimeBeat *AppenderMock) TimeBeatBeforeCounter() uint64

TimeBeatBeforeCounter returns a count of AppenderMock.TimeBeat invocations

type AppenderMockAddCommittedBeatExpectation 

type AppenderMockAddCommittedBeatExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

AppenderMockAddCommittedBeatExpectation specifies expectation struct of the Appender.AddCommittedBeat

func (*AppenderMockAddCommittedBeatExpectation) Then 

func (e *AppenderMockAddCommittedBeatExpectation) Then(err error) *AppenderMock

Then sets up Appender.AddCommittedBeat return parameters for the expectation previously defined by the When method

type AppenderMockAddCommittedBeatParams 

type AppenderMockAddCommittedBeatParams struct {
	// contains filtered or unexported fields
}

AppenderMockAddCommittedBeatParams contains parameters of the Appender.AddCommittedBeat

type AppenderMockAddCommittedBeatResults 

type AppenderMockAddCommittedBeatResults struct {
	// contains filtered or unexported fields
}

AppenderMockAddCommittedBeatResults contains results of the Appender.AddCommittedBeat

type AppenderMockAddExpectedBeatExpectation 

type AppenderMockAddExpectedBeatExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

AppenderMockAddExpectedBeatExpectation specifies expectation struct of the Appender.AddExpectedBeat

func (*AppenderMockAddExpectedBeatExpectation) Then 

func (e *AppenderMockAddExpectedBeatExpectation) Then(err error) *AppenderMock

Then sets up Appender.AddExpectedBeat return parameters for the expectation previously defined by the When method

type AppenderMockAddExpectedBeatParams 

type AppenderMockAddExpectedBeatParams struct {
	// contains filtered or unexported fields
}

AppenderMockAddExpectedBeatParams contains parameters of the Appender.AddExpectedBeat

type AppenderMockAddExpectedBeatResults 

type AppenderMockAddExpectedBeatResults struct {
	// contains filtered or unexported fields
}

AppenderMockAddExpectedBeatResults contains results of the Appender.AddExpectedBeat

type AppenderMockEnsureLatestTimeBeatExpectation 

type AppenderMockEnsureLatestTimeBeatExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

AppenderMockEnsureLatestTimeBeatExpectation specifies expectation struct of the Appender.EnsureLatestTimeBeat

func (*AppenderMockEnsureLatestTimeBeatExpectation) Then 

func (e *AppenderMockEnsureLatestTimeBeatExpectation) Then(err error) *AppenderMock

Then sets up Appender.EnsureLatestTimeBeat return parameters for the expectation previously defined by the When method

type AppenderMockEnsureLatestTimeBeatParams 

type AppenderMockEnsureLatestTimeBeatParams struct {
	// contains filtered or unexported fields
}

AppenderMockEnsureLatestTimeBeatParams contains parameters of the Appender.EnsureLatestTimeBeat

type AppenderMockEnsureLatestTimeBeatResults 

type AppenderMockEnsureLatestTimeBeatResults struct {
	// contains filtered or unexported fields
}

AppenderMockEnsureLatestTimeBeatResults contains results of the Appender.EnsureLatestTimeBeat

type AppenderMockLatestTimeBeatExpectation 

type AppenderMockLatestTimeBeatExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

AppenderMockLatestTimeBeatExpectation specifies expectation struct of the Appender.LatestTimeBeat

type AppenderMockLatestTimeBeatResults 

type AppenderMockLatestTimeBeatResults struct {
	// contains filtered or unexported fields
}

AppenderMockLatestTimeBeatResults contains results of the Appender.LatestTimeBeat

type AppenderMockTimeBeatExpectation 

type AppenderMockTimeBeatExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

AppenderMockTimeBeatExpectation specifies expectation struct of the Appender.TimeBeat

func (*AppenderMockTimeBeatExpectation) Then 

func (e *AppenderMockTimeBeatExpectation) Then(b1 Beat, err error) *AppenderMock

Then sets up Appender.TimeBeat return parameters for the expectation previously defined by the When method

type AppenderMockTimeBeatParams 

type AppenderMockTimeBeatParams struct {
	// contains filtered or unexported fields
}

AppenderMockTimeBeatParams contains parameters of the Appender.TimeBeat

type AppenderMockTimeBeatResults 

type AppenderMockTimeBeatResults struct {
	// contains filtered or unexported fields
}

AppenderMockTimeBeatResults contains results of the Appender.TimeBeat

type Beat 

type Beat struct {
	BeatSeq uint32
	pulse.Data
	Range       pulse.Range
	StartedAt   time.Time
	Online      census.OnlinePopulation
	PulseOrigin []byte
}

func (Beat) IsZero 

func (v Beat) IsZero() bool

type Dispatcher 

type Dispatcher interface {
	PrepareBeat(Ack)
	CancelBeat()
	CommitBeat(Beat)
	Process(Message) error
}

type DispatcherMock 

type DispatcherMock struct {
	CancelBeatMock mDispatcherMockCancelBeat

	CommitBeatMock mDispatcherMockCommitBeat

	PrepareBeatMock mDispatcherMockPrepareBeat

	ProcessMock mDispatcherMockProcess
	// contains filtered or unexported fields
}

DispatcherMock implements Dispatcher

func NewDispatcherMock 

func NewDispatcherMock(t minimock.Tester) *DispatcherMock

NewDispatcherMock returns a mock for Dispatcher

func (*DispatcherMock) CancelBeat 

func (mmCancelBeat *DispatcherMock) CancelBeat()

CancelBeat implements Dispatcher

func (*DispatcherMock) CancelBeatAfterCounter 

func (mmCancelBeat *DispatcherMock) CancelBeatAfterCounter() uint64

CancelBeatAfterCounter returns a count of finished DispatcherMock.CancelBeat invocations

func (*DispatcherMock) CancelBeatBeforeCounter 

func (mmCancelBeat *DispatcherMock) CancelBeatBeforeCounter() uint64

CancelBeatBeforeCounter returns a count of DispatcherMock.CancelBeat invocations

func (*DispatcherMock) CommitBeat 

func (mmCommitBeat *DispatcherMock) CommitBeat(b1 Beat)

CommitBeat implements Dispatcher

func (*DispatcherMock) CommitBeatAfterCounter 

func (mmCommitBeat *DispatcherMock) CommitBeatAfterCounter() uint64

CommitBeatAfterCounter returns a count of finished DispatcherMock.CommitBeat invocations

func (*DispatcherMock) CommitBeatBeforeCounter 

func (mmCommitBeat *DispatcherMock) CommitBeatBeforeCounter() uint64

CommitBeatBeforeCounter returns a count of DispatcherMock.CommitBeat invocations

func (*DispatcherMock) MinimockCancelBeatDone 

func (m *DispatcherMock) MinimockCancelBeatDone() bool

MinimockCancelBeatDone returns true if the count of the CancelBeat invocations corresponds the number of defined expectations

func (*DispatcherMock) MinimockCancelBeatInspect 

func (m *DispatcherMock) MinimockCancelBeatInspect()

MinimockCancelBeatInspect logs each unmet expectation

func (*DispatcherMock) MinimockCommitBeatDone 

func (m *DispatcherMock) MinimockCommitBeatDone() bool

MinimockCommitBeatDone returns true if the count of the CommitBeat invocations corresponds the number of defined expectations

func (*DispatcherMock) MinimockCommitBeatInspect 

func (m *DispatcherMock) MinimockCommitBeatInspect()

MinimockCommitBeatInspect logs each unmet expectation

func (*DispatcherMock) MinimockFinish 

func (m *DispatcherMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*DispatcherMock) MinimockPrepareBeatDone 

func (m *DispatcherMock) MinimockPrepareBeatDone() bool

MinimockPrepareBeatDone returns true if the count of the PrepareBeat invocations corresponds the number of defined expectations

func (*DispatcherMock) MinimockPrepareBeatInspect 

func (m *DispatcherMock) MinimockPrepareBeatInspect()

MinimockPrepareBeatInspect logs each unmet expectation

func (*DispatcherMock) MinimockProcessDone 

func (m *DispatcherMock) MinimockProcessDone() bool

MinimockProcessDone returns true if the count of the Process invocations corresponds the number of defined expectations

func (*DispatcherMock) MinimockProcessInspect 

func (m *DispatcherMock) MinimockProcessInspect()

MinimockProcessInspect logs each unmet expectation

func (*DispatcherMock) MinimockWait 

func (m *DispatcherMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*DispatcherMock) PrepareBeat 

func (mmPrepareBeat *DispatcherMock) PrepareBeat(a1 Ack)

PrepareBeat implements Dispatcher

func (*DispatcherMock) PrepareBeatAfterCounter 

func (mmPrepareBeat *DispatcherMock) PrepareBeatAfterCounter() uint64

PrepareBeatAfterCounter returns a count of finished DispatcherMock.PrepareBeat invocations

func (*DispatcherMock) PrepareBeatBeforeCounter 

func (mmPrepareBeat *DispatcherMock) PrepareBeatBeforeCounter() uint64

PrepareBeatBeforeCounter returns a count of DispatcherMock.PrepareBeat invocations

func (*DispatcherMock) Process 

func (mmProcess *DispatcherMock) Process(m1 Message) (err error)

Process implements Dispatcher

func (*DispatcherMock) ProcessAfterCounter 

func (mmProcess *DispatcherMock) ProcessAfterCounter() uint64

ProcessAfterCounter returns a count of finished DispatcherMock.Process invocations

func (*DispatcherMock) ProcessBeforeCounter 

func (mmProcess *DispatcherMock) ProcessBeforeCounter() uint64

ProcessBeforeCounter returns a count of DispatcherMock.Process invocations

type DispatcherMockCancelBeatExpectation 

type DispatcherMockCancelBeatExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

DispatcherMockCancelBeatExpectation specifies expectation struct of the Dispatcher.CancelBeat

type DispatcherMockCommitBeatExpectation 

type DispatcherMockCommitBeatExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

DispatcherMockCommitBeatExpectation specifies expectation struct of the Dispatcher.CommitBeat

type DispatcherMockCommitBeatParams 

type DispatcherMockCommitBeatParams struct {
	// contains filtered or unexported fields
}

DispatcherMockCommitBeatParams contains parameters of the Dispatcher.CommitBeat

type DispatcherMockPrepareBeatExpectation 

type DispatcherMockPrepareBeatExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

DispatcherMockPrepareBeatExpectation specifies expectation struct of the Dispatcher.PrepareBeat

type DispatcherMockPrepareBeatParams 

type DispatcherMockPrepareBeatParams struct {
	// contains filtered or unexported fields
}

DispatcherMockPrepareBeatParams contains parameters of the Dispatcher.PrepareBeat

type DispatcherMockProcessExpectation 

type DispatcherMockProcessExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

DispatcherMockProcessExpectation specifies expectation struct of the Dispatcher.Process

func (*DispatcherMockProcessExpectation) Then 

func (e *DispatcherMockProcessExpectation) Then(err error) *DispatcherMock

Then sets up Dispatcher.Process return parameters for the expectation previously defined by the When method

type DispatcherMockProcessParams 

type DispatcherMockProcessParams struct {
	// contains filtered or unexported fields
}

DispatcherMockProcessParams contains parameters of the Dispatcher.Process

type DispatcherMockProcessResults 

type DispatcherMockProcessResults struct {
	// contains filtered or unexported fields
}

DispatcherMockProcessResults contains results of the Dispatcher.Process

type History 

type History interface {
	TimeBeat(pulse.Number) (Beat, error)
	LatestTimeBeat() (Beat, error)
}

History provides methods for accessing pulses.

type Message 

type Message struct {
	UUID     string
	Metadata map[string]string
	Payload  []byte
	// contains filtered or unexported fields
}

func NewMessage 

func NewMessage(uuid string, payload []byte) Message

func NewMessageExt 

func NewMessageExt(uuid string, payload []byte, ack MessageAcker) Message

func (Message) Ack 

func (v Message) Ack() bool

func (Message) Acked 

func (v Message) Acked() synckit.SignalChannel

type MessageAcker 

type MessageAcker interface {
	Ack() bool
	Acked() <-chan struct{}
}

type NodeHistory 

type NodeHistory interface {
	GetNodeSnapshot(pulse.Number) (NodeSnapshot, error)
	FindAnyLatestNodeSnapshot() NodeSnapshot
	FindLatestNodeSnapshot() NodeSnapshot
}

type NodeKeeper 

type NodeKeeper interface {
	NodeNetwork

	AddExpectedBeat(Beat) error
	AddCommittedBeat(Beat) error
}

type NodeKeeperMock 

type NodeKeeperMock struct {
	AddCommittedBeatMock mNodeKeeperMockAddCommittedBeat

	AddExpectedBeatMock mNodeKeeperMockAddExpectedBeat

	FindAnyLatestNodeSnapshotMock mNodeKeeperMockFindAnyLatestNodeSnapshot

	GetLocalNodeReferenceMock mNodeKeeperMockGetLocalNodeReference

	GetLocalNodeRoleMock mNodeKeeperMockGetLocalNodeRole

	GetNodeSnapshotMock mNodeKeeperMockGetNodeSnapshot
	// contains filtered or unexported fields
}

NodeKeeperMock implements NodeKeeper

func NewNodeKeeperMock 

func NewNodeKeeperMock(t minimock.Tester) *NodeKeeperMock

NewNodeKeeperMock returns a mock for NodeKeeper

func (*NodeKeeperMock) AddCommittedBeat 

func (mmAddCommittedBeat *NodeKeeperMock) AddCommittedBeat(b1 Beat) (err error)

AddCommittedBeat implements NodeKeeper

func (*NodeKeeperMock) AddCommittedBeatAfterCounter 

func (mmAddCommittedBeat *NodeKeeperMock) AddCommittedBeatAfterCounter() uint64

AddCommittedBeatAfterCounter returns a count of finished NodeKeeperMock.AddCommittedBeat invocations

func (*NodeKeeperMock) AddCommittedBeatBeforeCounter 

func (mmAddCommittedBeat *NodeKeeperMock) AddCommittedBeatBeforeCounter() uint64

AddCommittedBeatBeforeCounter returns a count of NodeKeeperMock.AddCommittedBeat invocations

func (*NodeKeeperMock) AddExpectedBeat 

func (mmAddExpectedBeat *NodeKeeperMock) AddExpectedBeat(b1 Beat) (err error)

AddExpectedBeat implements NodeKeeper

func (*NodeKeeperMock) AddExpectedBeatAfterCounter 

func (mmAddExpectedBeat *NodeKeeperMock) AddExpectedBeatAfterCounter() uint64

AddExpectedBeatAfterCounter returns a count of finished NodeKeeperMock.AddExpectedBeat invocations

func (*NodeKeeperMock) AddExpectedBeatBeforeCounter 

func (mmAddExpectedBeat *NodeKeeperMock) AddExpectedBeatBeforeCounter() uint64

AddExpectedBeatBeforeCounter returns a count of NodeKeeperMock.AddExpectedBeat invocations

func (*NodeKeeperMock) FindAnyLatestNodeSnapshot 

func (mmFindAnyLatestNodeSnapshot *NodeKeeperMock) FindAnyLatestNodeSnapshot() (n1 NodeSnapshot)

FindAnyLatestNodeSnapshot implements NodeKeeper

func (*NodeKeeperMock) FindAnyLatestNodeSnapshotAfterCounter 

func (mmFindAnyLatestNodeSnapshot *NodeKeeperMock) FindAnyLatestNodeSnapshotAfterCounter() uint64

FindAnyLatestNodeSnapshotAfterCounter returns a count of finished NodeKeeperMock.FindAnyLatestNodeSnapshot invocations

func (*NodeKeeperMock) FindAnyLatestNodeSnapshotBeforeCounter 

func (mmFindAnyLatestNodeSnapshot *NodeKeeperMock) FindAnyLatestNodeSnapshotBeforeCounter() uint64

FindAnyLatestNodeSnapshotBeforeCounter returns a count of NodeKeeperMock.FindAnyLatestNodeSnapshot invocations

func (*NodeKeeperMock) GetLocalNodeReference 

func (mmGetLocalNodeReference *NodeKeeperMock) GetLocalNodeReference() (h1 reference.Holder)

GetLocalNodeReference implements NodeKeeper

func (*NodeKeeperMock) GetLocalNodeReferenceAfterCounter 

func (mmGetLocalNodeReference *NodeKeeperMock) GetLocalNodeReferenceAfterCounter() uint64

GetLocalNodeReferenceAfterCounter returns a count of finished NodeKeeperMock.GetLocalNodeReference invocations

func (*NodeKeeperMock) GetLocalNodeReferenceBeforeCounter 

func (mmGetLocalNodeReference *NodeKeeperMock) GetLocalNodeReferenceBeforeCounter() uint64

GetLocalNodeReferenceBeforeCounter returns a count of NodeKeeperMock.GetLocalNodeReference invocations

func (*NodeKeeperMock) GetLocalNodeRole 

func (mmGetLocalNodeRole *NodeKeeperMock) GetLocalNodeRole() (p1 member.PrimaryRole)

GetLocalNodeRole implements NodeKeeper

func (*NodeKeeperMock) GetLocalNodeRoleAfterCounter 

func (mmGetLocalNodeRole *NodeKeeperMock) GetLocalNodeRoleAfterCounter() uint64

GetLocalNodeRoleAfterCounter returns a count of finished NodeKeeperMock.GetLocalNodeRole invocations

func (*NodeKeeperMock) GetLocalNodeRoleBeforeCounter 

func (mmGetLocalNodeRole *NodeKeeperMock) GetLocalNodeRoleBeforeCounter() uint64

GetLocalNodeRoleBeforeCounter returns a count of NodeKeeperMock.GetLocalNodeRole invocations

func (*NodeKeeperMock) GetNodeSnapshot 

func (mmGetNodeSnapshot *NodeKeeperMock) GetNodeSnapshot(n1 pulse.Number) (n2 NodeSnapshot)

GetNodeSnapshot implements NodeKeeper

func (*NodeKeeperMock) GetNodeSnapshotAfterCounter 

func (mmGetNodeSnapshot *NodeKeeperMock) GetNodeSnapshotAfterCounter() uint64

GetNodeSnapshotAfterCounter returns a count of finished NodeKeeperMock.GetNodeSnapshot invocations

func (*NodeKeeperMock) GetNodeSnapshotBeforeCounter 

func (mmGetNodeSnapshot *NodeKeeperMock) GetNodeSnapshotBeforeCounter() uint64

GetNodeSnapshotBeforeCounter returns a count of NodeKeeperMock.GetNodeSnapshot invocations

func (*NodeKeeperMock) MinimockAddCommittedBeatDone 

func (m *NodeKeeperMock) MinimockAddCommittedBeatDone() bool

MinimockAddCommittedBeatDone returns true if the count of the AddCommittedBeat invocations corresponds the number of defined expectations

func (*NodeKeeperMock) MinimockAddCommittedBeatInspect 

func (m *NodeKeeperMock) MinimockAddCommittedBeatInspect()

MinimockAddCommittedBeatInspect logs each unmet expectation

func (*NodeKeeperMock) MinimockAddExpectedBeatDone 

func (m *NodeKeeperMock) MinimockAddExpectedBeatDone() bool

MinimockAddExpectedBeatDone returns true if the count of the AddExpectedBeat invocations corresponds the number of defined expectations

func (*NodeKeeperMock) MinimockAddExpectedBeatInspect 

func (m *NodeKeeperMock) MinimockAddExpectedBeatInspect()

MinimockAddExpectedBeatInspect logs each unmet expectation

func (*NodeKeeperMock) MinimockFindAnyLatestNodeSnapshotDone 

func (m *NodeKeeperMock) MinimockFindAnyLatestNodeSnapshotDone() bool

MinimockFindAnyLatestNodeSnapshotDone returns true if the count of the FindAnyLatestNodeSnapshot invocations corresponds the number of defined expectations

func (*NodeKeeperMock) MinimockFindAnyLatestNodeSnapshotInspect 

func (m *NodeKeeperMock) MinimockFindAnyLatestNodeSnapshotInspect()

MinimockFindAnyLatestNodeSnapshotInspect logs each unmet expectation

func (*NodeKeeperMock) MinimockFinish 

func (m *NodeKeeperMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*NodeKeeperMock) MinimockGetLocalNodeReferenceDone 

func (m *NodeKeeperMock) MinimockGetLocalNodeReferenceDone() bool

MinimockGetLocalNodeReferenceDone returns true if the count of the GetLocalNodeReference invocations corresponds the number of defined expectations

func (*NodeKeeperMock) MinimockGetLocalNodeReferenceInspect 

func (m *NodeKeeperMock) MinimockGetLocalNodeReferenceInspect()

MinimockGetLocalNodeReferenceInspect logs each unmet expectation

func (*NodeKeeperMock) MinimockGetLocalNodeRoleDone 

func (m *NodeKeeperMock) MinimockGetLocalNodeRoleDone() bool

MinimockGetLocalNodeRoleDone returns true if the count of the GetLocalNodeRole invocations corresponds the number of defined expectations

func (*NodeKeeperMock) MinimockGetLocalNodeRoleInspect 

func (m *NodeKeeperMock) MinimockGetLocalNodeRoleInspect()

MinimockGetLocalNodeRoleInspect logs each unmet expectation

func (*NodeKeeperMock) MinimockGetNodeSnapshotDone 

func (m *NodeKeeperMock) MinimockGetNodeSnapshotDone() bool

MinimockGetNodeSnapshotDone returns true if the count of the GetNodeSnapshot invocations corresponds the number of defined expectations

func (*NodeKeeperMock) MinimockGetNodeSnapshotInspect 

func (m *NodeKeeperMock) MinimockGetNodeSnapshotInspect()

MinimockGetNodeSnapshotInspect logs each unmet expectation

func (*NodeKeeperMock) MinimockWait 

func (m *NodeKeeperMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

type NodeKeeperMockAddCommittedBeatExpectation 

type NodeKeeperMockAddCommittedBeatExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeKeeperMockAddCommittedBeatExpectation specifies expectation struct of the NodeKeeper.AddCommittedBeat

func (*NodeKeeperMockAddCommittedBeatExpectation) Then 

func (e *NodeKeeperMockAddCommittedBeatExpectation) Then(err error) *NodeKeeperMock

Then sets up NodeKeeper.AddCommittedBeat return parameters for the expectation previously defined by the When method

type NodeKeeperMockAddCommittedBeatParams 

type NodeKeeperMockAddCommittedBeatParams struct {
	// contains filtered or unexported fields
}

NodeKeeperMockAddCommittedBeatParams contains parameters of the NodeKeeper.AddCommittedBeat

type NodeKeeperMockAddCommittedBeatResults 

type NodeKeeperMockAddCommittedBeatResults struct {
	// contains filtered or unexported fields
}

NodeKeeperMockAddCommittedBeatResults contains results of the NodeKeeper.AddCommittedBeat

type NodeKeeperMockAddExpectedBeatExpectation 

type NodeKeeperMockAddExpectedBeatExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeKeeperMockAddExpectedBeatExpectation specifies expectation struct of the NodeKeeper.AddExpectedBeat

func (*NodeKeeperMockAddExpectedBeatExpectation) Then 

func (e *NodeKeeperMockAddExpectedBeatExpectation) Then(err error) *NodeKeeperMock

Then sets up NodeKeeper.AddExpectedBeat return parameters for the expectation previously defined by the When method

type NodeKeeperMockAddExpectedBeatParams 

type NodeKeeperMockAddExpectedBeatParams struct {
	// contains filtered or unexported fields
}

NodeKeeperMockAddExpectedBeatParams contains parameters of the NodeKeeper.AddExpectedBeat

type NodeKeeperMockAddExpectedBeatResults 

type NodeKeeperMockAddExpectedBeatResults struct {
	// contains filtered or unexported fields
}

NodeKeeperMockAddExpectedBeatResults contains results of the NodeKeeper.AddExpectedBeat

type NodeKeeperMockFindAnyLatestNodeSnapshotExpectation 

type NodeKeeperMockFindAnyLatestNodeSnapshotExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeKeeperMockFindAnyLatestNodeSnapshotExpectation specifies expectation struct of the NodeKeeper.FindAnyLatestNodeSnapshot

type NodeKeeperMockFindAnyLatestNodeSnapshotResults 

type NodeKeeperMockFindAnyLatestNodeSnapshotResults struct {
	// contains filtered or unexported fields
}

NodeKeeperMockFindAnyLatestNodeSnapshotResults contains results of the NodeKeeper.FindAnyLatestNodeSnapshot

type NodeKeeperMockGetLocalNodeReferenceExpectation 

type NodeKeeperMockGetLocalNodeReferenceExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeKeeperMockGetLocalNodeReferenceExpectation specifies expectation struct of the NodeKeeper.GetLocalNodeReference

type NodeKeeperMockGetLocalNodeReferenceResults 

type NodeKeeperMockGetLocalNodeReferenceResults struct {
	// contains filtered or unexported fields
}

NodeKeeperMockGetLocalNodeReferenceResults contains results of the NodeKeeper.GetLocalNodeReference

type NodeKeeperMockGetLocalNodeRoleExpectation 

type NodeKeeperMockGetLocalNodeRoleExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeKeeperMockGetLocalNodeRoleExpectation specifies expectation struct of the NodeKeeper.GetLocalNodeRole

type NodeKeeperMockGetLocalNodeRoleResults 

type NodeKeeperMockGetLocalNodeRoleResults struct {
	// contains filtered or unexported fields
}

NodeKeeperMockGetLocalNodeRoleResults contains results of the NodeKeeper.GetLocalNodeRole

type NodeKeeperMockGetNodeSnapshotExpectation 

type NodeKeeperMockGetNodeSnapshotExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeKeeperMockGetNodeSnapshotExpectation specifies expectation struct of the NodeKeeper.GetNodeSnapshot

func (*NodeKeeperMockGetNodeSnapshotExpectation) Then 

func (e *NodeKeeperMockGetNodeSnapshotExpectation) Then(n2 NodeSnapshot) *NodeKeeperMock

Then sets up NodeKeeper.GetNodeSnapshot return parameters for the expectation previously defined by the When method

type NodeKeeperMockGetNodeSnapshotParams 

type NodeKeeperMockGetNodeSnapshotParams struct {
	// contains filtered or unexported fields
}

NodeKeeperMockGetNodeSnapshotParams contains parameters of the NodeKeeper.GetNodeSnapshot

type NodeKeeperMockGetNodeSnapshotResults 

type NodeKeeperMockGetNodeSnapshotResults struct {
	// contains filtered or unexported fields
}

NodeKeeperMockGetNodeSnapshotResults contains results of the NodeKeeper.GetNodeSnapshot

type NodeNetwork 

type NodeNetwork interface {
	// GetLocalNodeReference returns a node reference for this/local node. Safe to call at any time. Immutable.
	GetLocalNodeReference() reference.Holder
	// GetLocalNodeRole returns a role for this/local node. Safe to call at any time. Immutable.
	GetLocalNodeRole() member.PrimaryRole

	// GetNodeSnapshot get a snapshot of nodes for the given pulse number. Can return expected snapshot as well. Panics on unknown pulse.
	GetNodeSnapshot(pulse.Number) NodeSnapshot
	// GetAnyLatestNodeSnapshot returns the latest set of nodes. Will return nil when nothing was added yet.
	FindAnyLatestNodeSnapshot() NodeSnapshot
}

type NodeNetworkMock 

type NodeNetworkMock struct {
	FindAnyLatestNodeSnapshotMock mNodeNetworkMockFindAnyLatestNodeSnapshot

	GetLocalNodeReferenceMock mNodeNetworkMockGetLocalNodeReference

	GetLocalNodeRoleMock mNodeNetworkMockGetLocalNodeRole

	GetNodeSnapshotMock mNodeNetworkMockGetNodeSnapshot
	// contains filtered or unexported fields
}

NodeNetworkMock implements NodeNetwork

func NewNodeNetworkMock 

func NewNodeNetworkMock(t minimock.Tester) *NodeNetworkMock

NewNodeNetworkMock returns a mock for NodeNetwork

func (*NodeNetworkMock) FindAnyLatestNodeSnapshot 

func (mmFindAnyLatestNodeSnapshot *NodeNetworkMock) FindAnyLatestNodeSnapshot() (n1 NodeSnapshot)

FindAnyLatestNodeSnapshot implements NodeNetwork

func (*NodeNetworkMock) FindAnyLatestNodeSnapshotAfterCounter 

func (mmFindAnyLatestNodeSnapshot *NodeNetworkMock) FindAnyLatestNodeSnapshotAfterCounter() uint64

FindAnyLatestNodeSnapshotAfterCounter returns a count of finished NodeNetworkMock.FindAnyLatestNodeSnapshot invocations

func (*NodeNetworkMock) FindAnyLatestNodeSnapshotBeforeCounter 

func (mmFindAnyLatestNodeSnapshot *NodeNetworkMock) FindAnyLatestNodeSnapshotBeforeCounter() uint64

FindAnyLatestNodeSnapshotBeforeCounter returns a count of NodeNetworkMock.FindAnyLatestNodeSnapshot invocations

func (*NodeNetworkMock) GetLocalNodeReference 

func (mmGetLocalNodeReference *NodeNetworkMock) GetLocalNodeReference() (h1 reference.Holder)

GetLocalNodeReference implements NodeNetwork

func (*NodeNetworkMock) GetLocalNodeReferenceAfterCounter 

func (mmGetLocalNodeReference *NodeNetworkMock) GetLocalNodeReferenceAfterCounter() uint64

GetLocalNodeReferenceAfterCounter returns a count of finished NodeNetworkMock.GetLocalNodeReference invocations

func (*NodeNetworkMock) GetLocalNodeReferenceBeforeCounter 

func (mmGetLocalNodeReference *NodeNetworkMock) GetLocalNodeReferenceBeforeCounter() uint64

GetLocalNodeReferenceBeforeCounter returns a count of NodeNetworkMock.GetLocalNodeReference invocations

func (*NodeNetworkMock) GetLocalNodeRole 

func (mmGetLocalNodeRole *NodeNetworkMock) GetLocalNodeRole() (p1 member.PrimaryRole)

GetLocalNodeRole implements NodeNetwork

func (*NodeNetworkMock) GetLocalNodeRoleAfterCounter 

func (mmGetLocalNodeRole *NodeNetworkMock) GetLocalNodeRoleAfterCounter() uint64

GetLocalNodeRoleAfterCounter returns a count of finished NodeNetworkMock.GetLocalNodeRole invocations

func (*NodeNetworkMock) GetLocalNodeRoleBeforeCounter 

func (mmGetLocalNodeRole *NodeNetworkMock) GetLocalNodeRoleBeforeCounter() uint64

GetLocalNodeRoleBeforeCounter returns a count of NodeNetworkMock.GetLocalNodeRole invocations

func (*NodeNetworkMock) GetNodeSnapshot 

func (mmGetNodeSnapshot *NodeNetworkMock) GetNodeSnapshot(n1 pulse.Number) (n2 NodeSnapshot)

GetNodeSnapshot implements NodeNetwork

func (*NodeNetworkMock) GetNodeSnapshotAfterCounter 

func (mmGetNodeSnapshot *NodeNetworkMock) GetNodeSnapshotAfterCounter() uint64

GetNodeSnapshotAfterCounter returns a count of finished NodeNetworkMock.GetNodeSnapshot invocations

func (*NodeNetworkMock) GetNodeSnapshotBeforeCounter 

func (mmGetNodeSnapshot *NodeNetworkMock) GetNodeSnapshotBeforeCounter() uint64

GetNodeSnapshotBeforeCounter returns a count of NodeNetworkMock.GetNodeSnapshot invocations

func (*NodeNetworkMock) MinimockFindAnyLatestNodeSnapshotDone 

func (m *NodeNetworkMock) MinimockFindAnyLatestNodeSnapshotDone() bool

MinimockFindAnyLatestNodeSnapshotDone returns true if the count of the FindAnyLatestNodeSnapshot invocations corresponds the number of defined expectations

func (*NodeNetworkMock) MinimockFindAnyLatestNodeSnapshotInspect 

func (m *NodeNetworkMock) MinimockFindAnyLatestNodeSnapshotInspect()

MinimockFindAnyLatestNodeSnapshotInspect logs each unmet expectation

func (*NodeNetworkMock) MinimockFinish 

func (m *NodeNetworkMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*NodeNetworkMock) MinimockGetLocalNodeReferenceDone 

func (m *NodeNetworkMock) MinimockGetLocalNodeReferenceDone() bool

MinimockGetLocalNodeReferenceDone returns true if the count of the GetLocalNodeReference invocations corresponds the number of defined expectations

func (*NodeNetworkMock) MinimockGetLocalNodeReferenceInspect 

func (m *NodeNetworkMock) MinimockGetLocalNodeReferenceInspect()

MinimockGetLocalNodeReferenceInspect logs each unmet expectation

func (*NodeNetworkMock) MinimockGetLocalNodeRoleDone 

func (m *NodeNetworkMock) MinimockGetLocalNodeRoleDone() bool

MinimockGetLocalNodeRoleDone returns true if the count of the GetLocalNodeRole invocations corresponds the number of defined expectations

func (*NodeNetworkMock) MinimockGetLocalNodeRoleInspect 

func (m *NodeNetworkMock) MinimockGetLocalNodeRoleInspect()

MinimockGetLocalNodeRoleInspect logs each unmet expectation

func (*NodeNetworkMock) MinimockGetNodeSnapshotDone 

func (m *NodeNetworkMock) MinimockGetNodeSnapshotDone() bool

MinimockGetNodeSnapshotDone returns true if the count of the GetNodeSnapshot invocations corresponds the number of defined expectations

func (*NodeNetworkMock) MinimockGetNodeSnapshotInspect 

func (m *NodeNetworkMock) MinimockGetNodeSnapshotInspect()

MinimockGetNodeSnapshotInspect logs each unmet expectation

func (*NodeNetworkMock) MinimockWait 

func (m *NodeNetworkMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

type NodeNetworkMockFindAnyLatestNodeSnapshotExpectation 

type NodeNetworkMockFindAnyLatestNodeSnapshotExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeNetworkMockFindAnyLatestNodeSnapshotExpectation specifies expectation struct of the NodeNetwork.FindAnyLatestNodeSnapshot

type NodeNetworkMockFindAnyLatestNodeSnapshotResults 

type NodeNetworkMockFindAnyLatestNodeSnapshotResults struct {
	// contains filtered or unexported fields
}

NodeNetworkMockFindAnyLatestNodeSnapshotResults contains results of the NodeNetwork.FindAnyLatestNodeSnapshot

type NodeNetworkMockGetLocalNodeReferenceExpectation 

type NodeNetworkMockGetLocalNodeReferenceExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeNetworkMockGetLocalNodeReferenceExpectation specifies expectation struct of the NodeNetwork.GetLocalNodeReference

type NodeNetworkMockGetLocalNodeReferenceResults 

type NodeNetworkMockGetLocalNodeReferenceResults struct {
	// contains filtered or unexported fields
}

NodeNetworkMockGetLocalNodeReferenceResults contains results of the NodeNetwork.GetLocalNodeReference

type NodeNetworkMockGetLocalNodeRoleExpectation 

type NodeNetworkMockGetLocalNodeRoleExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeNetworkMockGetLocalNodeRoleExpectation specifies expectation struct of the NodeNetwork.GetLocalNodeRole

type NodeNetworkMockGetLocalNodeRoleResults 

type NodeNetworkMockGetLocalNodeRoleResults struct {
	// contains filtered or unexported fields
}

NodeNetworkMockGetLocalNodeRoleResults contains results of the NodeNetwork.GetLocalNodeRole

type NodeNetworkMockGetNodeSnapshotExpectation 

type NodeNetworkMockGetNodeSnapshotExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeNetworkMockGetNodeSnapshotExpectation specifies expectation struct of the NodeNetwork.GetNodeSnapshot

func (*NodeNetworkMockGetNodeSnapshotExpectation) Then 

func (e *NodeNetworkMockGetNodeSnapshotExpectation) Then(n2 NodeSnapshot) *NodeNetworkMock

Then sets up NodeNetwork.GetNodeSnapshot return parameters for the expectation previously defined by the When method

type NodeNetworkMockGetNodeSnapshotParams 

type NodeNetworkMockGetNodeSnapshotParams struct {
	// contains filtered or unexported fields
}

NodeNetworkMockGetNodeSnapshotParams contains parameters of the NodeNetwork.GetNodeSnapshot

type NodeNetworkMockGetNodeSnapshotResults 

type NodeNetworkMockGetNodeSnapshotResults struct {
	// contains filtered or unexported fields
}

NodeNetworkMockGetNodeSnapshotResults contains results of the NodeNetwork.GetNodeSnapshot

type NodeSnapshot 

type NodeSnapshot interface {
	GetPulseNumber() pulse.Number
	GetPopulation() census.OnlinePopulation

	// FindNodeByRef returns an active node by reference. Returns nil when not found.
	FindNodeByRef(reference.Global) profiles.ActiveNode
	// FindNodeByAddr get active node by addr. Returns nil when not found.
	FindNodeByAddr(address string) profiles.ActiveNode
}

type NodeSnapshotMock 

type NodeSnapshotMock struct {
	FindNodeByAddrMock mNodeSnapshotMockFindNodeByAddr

	FindNodeByRefMock mNodeSnapshotMockFindNodeByRef

	GetPopulationMock mNodeSnapshotMockGetPopulation

	GetPulseNumberMock mNodeSnapshotMockGetPulseNumber
	// contains filtered or unexported fields
}

NodeSnapshotMock implements NodeSnapshot

func NewNodeSnapshotMock 

func NewNodeSnapshotMock(t minimock.Tester) *NodeSnapshotMock

NewNodeSnapshotMock returns a mock for NodeSnapshot

func (*NodeSnapshotMock) FindNodeByAddr 

func (mmFindNodeByAddr *NodeSnapshotMock) FindNodeByAddr(address string) (a1 profiles.ActiveNode)

FindNodeByAddr implements NodeSnapshot

func (*NodeSnapshotMock) FindNodeByAddrAfterCounter 

func (mmFindNodeByAddr *NodeSnapshotMock) FindNodeByAddrAfterCounter() uint64

FindNodeByAddrAfterCounter returns a count of finished NodeSnapshotMock.FindNodeByAddr invocations

func (*NodeSnapshotMock) FindNodeByAddrBeforeCounter 

func (mmFindNodeByAddr *NodeSnapshotMock) FindNodeByAddrBeforeCounter() uint64

FindNodeByAddrBeforeCounter returns a count of NodeSnapshotMock.FindNodeByAddr invocations

func (*NodeSnapshotMock) FindNodeByRef 

func (mmFindNodeByRef *NodeSnapshotMock) FindNodeByRef(g1 reference.Global) (a1 profiles.ActiveNode)

FindNodeByRef implements NodeSnapshot

func (*NodeSnapshotMock) FindNodeByRefAfterCounter 

func (mmFindNodeByRef *NodeSnapshotMock) FindNodeByRefAfterCounter() uint64

FindNodeByRefAfterCounter returns a count of finished NodeSnapshotMock.FindNodeByRef invocations

func (*NodeSnapshotMock) FindNodeByRefBeforeCounter 

func (mmFindNodeByRef *NodeSnapshotMock) FindNodeByRefBeforeCounter() uint64

FindNodeByRefBeforeCounter returns a count of NodeSnapshotMock.FindNodeByRef invocations

func (*NodeSnapshotMock) GetPopulation 

func (mmGetPopulation *NodeSnapshotMock) GetPopulation() (o1 census.OnlinePopulation)

GetPopulation implements NodeSnapshot

func (*NodeSnapshotMock) GetPopulationAfterCounter 

func (mmGetPopulation *NodeSnapshotMock) GetPopulationAfterCounter() uint64

GetPopulationAfterCounter returns a count of finished NodeSnapshotMock.GetPopulation invocations

func (*NodeSnapshotMock) GetPopulationBeforeCounter 

func (mmGetPopulation *NodeSnapshotMock) GetPopulationBeforeCounter() uint64

GetPopulationBeforeCounter returns a count of NodeSnapshotMock.GetPopulation invocations

func (*NodeSnapshotMock) GetPulseNumber 

func (mmGetPulseNumber *NodeSnapshotMock) GetPulseNumber() (n1 pulse.Number)

GetPulseNumber implements NodeSnapshot

func (*NodeSnapshotMock) GetPulseNumberAfterCounter 

func (mmGetPulseNumber *NodeSnapshotMock) GetPulseNumberAfterCounter() uint64

GetPulseNumberAfterCounter returns a count of finished NodeSnapshotMock.GetPulseNumber invocations

func (*NodeSnapshotMock) GetPulseNumberBeforeCounter 

func (mmGetPulseNumber *NodeSnapshotMock) GetPulseNumberBeforeCounter() uint64

GetPulseNumberBeforeCounter returns a count of NodeSnapshotMock.GetPulseNumber invocations

func (*NodeSnapshotMock) MinimockFindNodeByAddrDone 

func (m *NodeSnapshotMock) MinimockFindNodeByAddrDone() bool

MinimockFindNodeByAddrDone returns true if the count of the FindNodeByAddr invocations corresponds the number of defined expectations

func (*NodeSnapshotMock) MinimockFindNodeByAddrInspect 

func (m *NodeSnapshotMock) MinimockFindNodeByAddrInspect()

MinimockFindNodeByAddrInspect logs each unmet expectation

func (*NodeSnapshotMock) MinimockFindNodeByRefDone 

func (m *NodeSnapshotMock) MinimockFindNodeByRefDone() bool

MinimockFindNodeByRefDone returns true if the count of the FindNodeByRef invocations corresponds the number of defined expectations

func (*NodeSnapshotMock) MinimockFindNodeByRefInspect 

func (m *NodeSnapshotMock) MinimockFindNodeByRefInspect()

MinimockFindNodeByRefInspect logs each unmet expectation

func (*NodeSnapshotMock) MinimockFinish 

func (m *NodeSnapshotMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*NodeSnapshotMock) MinimockGetPopulationDone 

func (m *NodeSnapshotMock) MinimockGetPopulationDone() bool

MinimockGetPopulationDone returns true if the count of the GetPopulation invocations corresponds the number of defined expectations

func (*NodeSnapshotMock) MinimockGetPopulationInspect 

func (m *NodeSnapshotMock) MinimockGetPopulationInspect()

MinimockGetPopulationInspect logs each unmet expectation

func (*NodeSnapshotMock) MinimockGetPulseNumberDone 

func (m *NodeSnapshotMock) MinimockGetPulseNumberDone() bool

MinimockGetPulseNumberDone returns true if the count of the GetPulseNumber invocations corresponds the number of defined expectations

func (*NodeSnapshotMock) MinimockGetPulseNumberInspect 

func (m *NodeSnapshotMock) MinimockGetPulseNumberInspect()

MinimockGetPulseNumberInspect logs each unmet expectation

func (*NodeSnapshotMock) MinimockWait 

func (m *NodeSnapshotMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

type NodeSnapshotMockFindNodeByAddrExpectation 

type NodeSnapshotMockFindNodeByAddrExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeSnapshotMockFindNodeByAddrExpectation specifies expectation struct of the NodeSnapshot.FindNodeByAddr

func (*NodeSnapshotMockFindNodeByAddrExpectation) Then 

func (e *NodeSnapshotMockFindNodeByAddrExpectation) Then(a1 profiles.ActiveNode) *NodeSnapshotMock

Then sets up NodeSnapshot.FindNodeByAddr return parameters for the expectation previously defined by the When method

type NodeSnapshotMockFindNodeByAddrParams 

type NodeSnapshotMockFindNodeByAddrParams struct {
	// contains filtered or unexported fields
}

NodeSnapshotMockFindNodeByAddrParams contains parameters of the NodeSnapshot.FindNodeByAddr

type NodeSnapshotMockFindNodeByAddrResults 

type NodeSnapshotMockFindNodeByAddrResults struct {
	// contains filtered or unexported fields
}

NodeSnapshotMockFindNodeByAddrResults contains results of the NodeSnapshot.FindNodeByAddr

type NodeSnapshotMockFindNodeByRefExpectation 

type NodeSnapshotMockFindNodeByRefExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeSnapshotMockFindNodeByRefExpectation specifies expectation struct of the NodeSnapshot.FindNodeByRef

func (*NodeSnapshotMockFindNodeByRefExpectation) Then 

func (e *NodeSnapshotMockFindNodeByRefExpectation) Then(a1 profiles.ActiveNode) *NodeSnapshotMock

Then sets up NodeSnapshot.FindNodeByRef return parameters for the expectation previously defined by the When method

type NodeSnapshotMockFindNodeByRefParams 

type NodeSnapshotMockFindNodeByRefParams struct {
	// contains filtered or unexported fields
}

NodeSnapshotMockFindNodeByRefParams contains parameters of the NodeSnapshot.FindNodeByRef

type NodeSnapshotMockFindNodeByRefResults 

type NodeSnapshotMockFindNodeByRefResults struct {
	// contains filtered or unexported fields
}

NodeSnapshotMockFindNodeByRefResults contains results of the NodeSnapshot.FindNodeByRef

type NodeSnapshotMockGetPopulationExpectation 

type NodeSnapshotMockGetPopulationExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeSnapshotMockGetPopulationExpectation specifies expectation struct of the NodeSnapshot.GetPopulation

type NodeSnapshotMockGetPopulationResults 

type NodeSnapshotMockGetPopulationResults struct {
	// contains filtered or unexported fields
}

NodeSnapshotMockGetPopulationResults contains results of the NodeSnapshot.GetPopulation

type NodeSnapshotMockGetPulseNumberExpectation 

type NodeSnapshotMockGetPulseNumberExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

NodeSnapshotMockGetPulseNumberExpectation specifies expectation struct of the NodeSnapshot.GetPulseNumber

type NodeSnapshotMockGetPulseNumberResults 

type NodeSnapshotMockGetPulseNumberResults struct {
	// contains filtered or unexported fields
}

NodeSnapshotMockGetPulseNumberResults contains results of the NodeSnapshot.GetPulseNumber

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.