chorus

type Conductor interface {
	NodeStater

	// Set set's new pulse and closes current jet drop.
	CommitPulseChange(beat.Beat) error
	CommitFirstPulseChange(beat.Beat) error
}

type ConductorMock struct {
	CancelNodeStateMock mConductorMockCancelNodeState

	CommitFirstPulseChangeMock mConductorMockCommitFirstPulseChange

	CommitPulseChangeMock mConductorMockCommitPulseChange

	RequestNodeStateMock mConductorMockRequestNodeState
	// contains filtered or unexported fields
}

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

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

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

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

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

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

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

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

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

type NodeStateFunc = func(api.UpstreamState)

type NodeStater interface {
	RequestNodeState(NodeStateFunc)
	CancelNodeState()
}