Documentation
¶
Index ¶
- func NewAgentStart(p fsm.ExecutorParams, operator ops.Operator) (fsm.PhaseExecutor, error)
- func NewAgentStop(p fsm.ExecutorParams, operator ops.Operator, packages pack.PackageService) (fsm.PhaseExecutor, error)
- func NewChecks(p fsm.ExecutorParams, operator ops.Operator, runner rpc.AgentRepository) (fsm.PhaseExecutor, error)
- func NewElect(p fsm.ExecutorParams, operator ops.Operator) (fsm.PhaseExecutor, error)
- func NewEtcd(p fsm.ExecutorParams, operator ops.Operator, runner rpc.AgentRepository) (fsm.PhaseExecutor, error)
- func NewEtcdBackup(p fsm.ExecutorParams, operator ops.Operator, runner rpc.AgentRepository) (fsm.PhaseExecutor, error)
- func NewWaitK8s(p fsm.ExecutorParams, operator ops.Operator) (fsm.PhaseExecutor, error)
- func NewWaitPlanet(p fsm.ExecutorParams, operator ops.Operator) (fsm.PhaseExecutor, error)
- func NewWaitTeleport(p fsm.ExecutorParams, operator ops.Operator) (fsm.PhaseExecutor, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAgentStart ¶
func NewAgentStart(p fsm.ExecutorParams, operator ops.Operator) (fsm.PhaseExecutor, error)
NewAgentStart returns executor that starts an RPC agent on a node
func NewAgentStop ¶
func NewAgentStop(p fsm.ExecutorParams, operator ops.Operator, packages pack.PackageService) (fsm.PhaseExecutor, error)
NewAgentStop returns executor that stops an RPC agent on a node
func NewChecks ¶
func NewChecks(p fsm.ExecutorParams, operator ops.Operator, runner rpc.AgentRepository) (fsm.PhaseExecutor, error)
NewChecks returns executor that executes preflight checks on the joining node.
func NewElect ¶
func NewElect(p fsm.ExecutorParams, operator ops.Operator) (fsm.PhaseExecutor, error)
NewElect returns executor that turns on leader election on the joined node
func NewEtcd ¶
func NewEtcd(p fsm.ExecutorParams, operator ops.Operator, runner rpc.AgentRepository) (fsm.PhaseExecutor, error)
NewEtcd returns executor that adds a new etcd member to the cluster
func NewEtcdBackup ¶
func NewEtcdBackup(p fsm.ExecutorParams, operator ops.Operator, runner rpc.AgentRepository) (fsm.PhaseExecutor, error)
NewEtcdBackup returns executor that backs up etcd data
func NewWaitK8s ¶
func NewWaitK8s(p fsm.ExecutorParams, operator ops.Operator) (fsm.PhaseExecutor, error)
NewWaitK8s returns executor that waits for Kubernetes node to register
func NewWaitPlanet ¶
func NewWaitPlanet(p fsm.ExecutorParams, operator ops.Operator) (fsm.PhaseExecutor, error)
NewWaitPlanet returns executor that waits for planet to start on the joining node
func NewWaitTeleport ¶
func NewWaitTeleport(p fsm.ExecutorParams, operator ops.Operator) (fsm.PhaseExecutor, error)
NewWaitTeleport returns executor that waits for Teleport node to register
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.