task

Documentation

Index

• type Context
  • func BuildContext(clusterName string, topo topologyyaml.Topology, ...) (*Context, error)
  • func (c *Context) SetClusterStatus(status topologyyaml.ClusterStatus)
  • func (c *Context) SetTopoYaml(topo topologyyaml.Topology)
• type Task

Types

type Context

type Context struct {
	ClusterName   string
	TopoYaml      topologyyaml.Topology
	SSHClients    map[string]*ssh.SSHClient
	PackageStore  *store.PackageStore
	ManifestStore store.ManifestStore

	ClusterStatus topologyyaml.ClusterStatus
}

TODO: perhaps wrap Context into interface, and disallow updates explicitly

func BuildContext

func BuildContext(clusterName string, topo topologyyaml.Topology,
	packageStore *store.PackageStore, manifestStore store.ManifestStore) (*Context, error)

func (*Context) SetClusterStatus

func (c *Context) SetClusterStatus(status topologyyaml.ClusterStatus)

func (*Context) SetTopoYaml

func (c *Context) SetTopoYaml(topo topologyyaml.Topology)

Warn: do not use this method unless it's REALLY needed. It's only used in pkg/cluster/step/takeover.go at the time of writing.

type Task

type Task interface {
	Name() string
	Execute(ctx context.Context) error
}