lib

Documentation

Index

• type Orchestrator
  • func NewOrchestrator(n int, thr int, period string, tls bool, binary string, withCurl bool, ...) *Orchestrator
  • func (e *Orchestrator) CheckCurrentBeacon(exclude ...int)
  • func (e *Orchestrator) CheckNewBeacon(exclude ...int)
  • func (e *Orchestrator) CreateResharingGroup(oldToRemove, threshold int)
  • func (e *Orchestrator) PrintLogs()
  • func (e *Orchestrator) RunDKG(timeout string)
  • func (e *Orchestrator) RunResharing(timeout string)
  • func (e *Orchestrator) SetupNewNodes(n int)
  • func (e *Orchestrator) Shutdown()
  • func (e *Orchestrator) StartCurrentNodes(toExclude ...int)
  • func (e *Orchestrator) StartNewNodes()
  • func (e *Orchestrator) StartNode(idxs ...int)
  • func (e *Orchestrator) StopAllNodes(toExclude ...int)
  • func (e *Orchestrator) StopNodes(idxs ...int)
  • func (e *Orchestrator) UpdateBinary(binary string, idx uint, isCandidate bool)
  • func (e *Orchestrator) UpdateGlobalBinary(binary string, isCandidate bool)
  • func (e *Orchestrator) Wait(t time.Duration)
  • func (e *Orchestrator) WaitGenesis()
  • func (e *Orchestrator) WaitPeriod()
  • func (e *Orchestrator) WaitTransition()

Types

type Orchestrator

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

Orchestrator controls a set of nodes

func NewOrchestrator

func NewOrchestrator(n int, thr int, period string, tls bool, binary string, withCurl bool, sch scheme.Scheme, beaconID string, isCandidate bool) *Orchestrator

func (*Orchestrator) CheckCurrentBeacon

func (e *Orchestrator) CheckCurrentBeacon(exclude ...int)

func (*Orchestrator) CheckNewBeacon

func (e *Orchestrator) CheckNewBeacon(exclude ...int)

func (*Orchestrator) CreateResharingGroup

func (e *Orchestrator) CreateResharingGroup(oldToRemove, threshold int)

func (*Orchestrator) PrintLogs

func (e *Orchestrator) PrintLogs()

func (*Orchestrator) RunDKG

func (e *Orchestrator) RunDKG(timeout string)

func (*Orchestrator) RunResharing

func (e *Orchestrator) RunResharing(timeout string)

func (*Orchestrator) SetupNewNodes

func (e *Orchestrator) SetupNewNodes(n int)

func (*Orchestrator) Shutdown

func (e *Orchestrator) Shutdown()

func (*Orchestrator) StartCurrentNodes

func (e *Orchestrator) StartCurrentNodes(toExclude ...int)

func (*Orchestrator) StartNewNodes

func (e *Orchestrator) StartNewNodes()

func (*Orchestrator) StartNode

func (e *Orchestrator) StartNode(idxs ...int)

func (*Orchestrator) StopAllNodes

func (e *Orchestrator) StopAllNodes(toExclude ...int)

func (*Orchestrator) StopNodes

func (e *Orchestrator) StopNodes(idxs ...int)

func (*Orchestrator) UpdateBinary

func (e *Orchestrator) UpdateBinary(binary string, idx uint, isCandidate bool)

UpdateBinary will set the 'binary' to use for the node at 'idx'

func (*Orchestrator) UpdateGlobalBinary

func (e *Orchestrator) UpdateGlobalBinary(binary string, isCandidate bool)

UpdateBinary will set the 'bianry' to use on the orchestrator as a whole

func (*Orchestrator) Wait

func (e *Orchestrator) Wait(t time.Duration)

func (*Orchestrator) WaitGenesis

func (e *Orchestrator) WaitGenesis()

func (*Orchestrator) WaitPeriod

func (e *Orchestrator) WaitPeriod()

func (*Orchestrator) WaitTransition

func (e *Orchestrator) WaitTransition()