Documentation ¶
Index ¶
- type Orchestrator
- func (e *Orchestrator) CheckCurrentBeacon(exclude ...int)
- func (e *Orchestrator) CheckNewBeacon(exclude ...int)
- func (e *Orchestrator) CreateResharingGroup(oldToRemove, threshold int) (*ResharingGroup, error)
- func (e *Orchestrator) PrintLogs()
- func (e *Orchestrator) RunDKG(timeout time.Duration) error
- func (e *Orchestrator) RunResharing(resharingGroup *ResharingGroup, timeout time.Duration)
- func (e *Orchestrator) SetupNewNodes(n int)
- func (e *Orchestrator) Shutdown()
- func (e *Orchestrator) StartCurrentNodes(toExclude ...int) error
- func (e *Orchestrator) StartNewNodes() error
- 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()
- type ResharingGroup
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Orchestrator ¶
type Orchestrator struct {
// contains filtered or unexported fields
}
Orchestrator controls a set of nodes
func NewOrchestrator ¶
func NewOrchestrator(c cfg.Config) *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) (*ResharingGroup, error)
func (*Orchestrator) PrintLogs ¶
func (e *Orchestrator) PrintLogs()
func (*Orchestrator) RunResharing ¶
func (e *Orchestrator) RunResharing(resharingGroup *ResharingGroup, timeout time.Duration)
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) error
func (*Orchestrator) StartNewNodes ¶
func (e *Orchestrator) StartNewNodes() error
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)
UpdateGlobalBinary will set the 'binary' 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()
type ResharingGroup ¶
type ResharingGroup struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.