dispatch

type ClusterDispatcher interface {
	// GetNodes returns all nodes in the cluster.
	GetNodes() []Node
	// GetMasterNode returns the master node in the cluster.
	GetMasterNode() Node
	// GetWorkerNodes returns all worker nodes in the cluster.
	GetWorkerNodes() []Node
	// Ready checks if the cluster is ready to accept commands.
	Ready() bool
	// SendCommands sends commands to a node in the cluster.
	SendCommands(node Node, cmds ...Command) error
	// SendCommandsContext sends commands to a node in the cluster with a custom context.
	SendCommandsContext(ctx context.Context, node Node, cmds ...Command) error
	// SendFile sends a file to a node in the cluster.
	SendFile(node Node, src, dst string) error
	// DownloadProject sets up the log-console project into the given node. If the source begins with
	// local://, it'll mount the local directory into the node. For all other sources, it'll git
	// clone the URL.
	DownloadProject(node Node, source string) error
	// Cleanup disposes of any held resources.
	Cleanup() error
}

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

type Node struct {
	Name string
	// Kubename is the name of the node in the Kubernetes cluster.
	// Must always follow the format `master` for the master node, and
	// `worker-<n>` for worker nodes (1-indexed).
	Kubename string
	Remote   UserQualifiedHostname
}

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

type UserQualifiedHostname struct {
	User string
	FQDN string
}