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 int)
  • 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) *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 int)

UpdateBinary will either set the 'bianry' to use for the node at 'idx', or on the orchestrator as a whole if idx is negative.

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()