task

type Base struct {
	Name              string
	TaskType          Type
	Actions           []action.Action
	Status            Status
	Err               *pb.Error
	LogFileDir        string
	CreationTimestamp time.Time
	SubTasks          []Task
	Priority          int
	Parent            string
}

type CheckNetworkRequirementsTask struct {
	Base

	Nodes          []*pb.Node
	NetworkOptions *pb.NetworkOptions
}

type CheckNetworkRequirementsTaskConfig struct {
	Nodes           []*pb.Node
	NetworkOptions  *pb.NetworkOptions
	LogFileBasePath string
}

type DeployEtcdTask struct {
	Base

	Nodes []*pb.Node
}

type DeployEtcdTaskConfig struct {
	Nodes           []*pb.Node
	LogFileBasePath string
	Priority        int
	Parent          string
}

type DeployMasterTaskConfig struct {
	CertKey         string
	EtcdNodes       []*pb.Node
	Nodes           []*pb.Node
	ClusterConfig   *pb.ClusterConfig
	LogFileBasePath string
	Priority        int
	Parent          string
}

type DeployTask struct {
	Base
	NodeConfigs   []*pb.NodeDeployConfig
	ClusterConfig *pb.ClusterConfig
}

type DeployTaskConfig struct {
	NodeConfigs     []*pb.NodeDeployConfig
	ClusterConfig   *pb.ClusterConfig
	LogFileBasePath string
	Priority        int
}

type DeployWorkerProcessor struct {
}

type DeployWorkerTaskConfig struct {
	MasterNodes     []*protos.Node
	Nodes           []*protos.NodeDeployConfig
	ClusterConfig   *protos.ClusterConfig
	LogFileBasePath string
	Priority        int
	Parent          string
}

type ExtraResult interface {
	ProcessExtraResult(task Task) error
}

type FetchKubeConfigTask struct {
	Base

	Node *pb.Node
	// KubeConfig stores the task result: content of kube config file.
	KubeConfig []byte
}

type FetchKubeConfigTaskConfig struct {
	Node            *pb.Node
	LogFileBasePath string
	Priority        int
}

type InitMasterTask struct {
	Base
	CertKey       string
	Operation     Operation
	EtcdNodes     []*pb.Node
	MasterNodes   []*pb.Node
	ClusterConfig *pb.ClusterConfig
	Node          *pb.Node
}

type InitMasterTaskConfig struct {
	MasterNodes []*pb.Node

	Priority int
	// contains filtered or unexported fields
}

type JoinMasterTask struct {
	Base
	CertKey       string
	Operation     Operation
	Node          *pb.Node
	MasterNodes   []*pb.Node
	ClusterConfig *pb.ClusterConfig
}

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

type NodeCheckTask struct {
	Base
	NodeConfigs    []*pb.NodeCheckConfig
	NetworkOptions *pb.NetworkOptions
}

type NodeCheckTaskConfig struct {
	NodeConfigs     []*pb.NodeCheckConfig
	NetworkOptions  *pb.NetworkOptions
	LogFileBasePath string
	Priority        int
}

type NodeInitTask struct {
	Base
	NodeConfigs   []*pb.NodeDeployConfig
	ClusterConfig *pb.ClusterConfig
}

type NodeInitTaskConfig struct {
	NodeConfigs     []*pb.NodeDeployConfig
	ClusterConfig   *pb.ClusterConfig
	LogFileBasePath string
	Priority        int
	Parent          string
}

type Operation string

type Priority int

type Processor interface {
	// No need to set the task status in this method, the caller should do that.
	SplitTask(task Task) error
}

type Status string

type Store interface {
	GetTask(name string) Task
	// Add a task, if the task already exists (task name is same), return an error
	AddTask(task Task) error
	// Update a task, if the task doesn't exist (task name is same), return an error
	UpdateTask(task Task) error
	// Update a task, if the task doesn't exist (task name is same), add it.
	UpdateOrAddTask(task Task) error
}

type Task interface {
	GetName() string
	GetType() Type
	GetStatus() Status
	SetStatus(Status)
	GetErr() *pb.Error
	SetErr(*pb.Error)
	GetLogFileDir() string
	SetLogFileDir(string)
	GetActions() []action.Action
	GetCreationTimestamp() time.Time
	// Sub tasks are Task too.
	GetSubTasks() []Task
	// GetPriority returns the priority of the task: smaller value means higher prioirty.
	// A task should wait until all higher priority tasks are done
	GetPriority() int
	// If a task is not a sub task, this will return ""
	GetParent() string
}

type TestConnectionTask struct {
	Base

	Node *pb.Node
}

type TestConnectionTaskConfig struct {
	Node            *pb.Node
	LogFileBasePath string
	Priority        int
}

type Type string