flow

type ComputeOptions struct {

	// true when the master runs inside cluster
	InCluster bool
	// contains filtered or unexported fields
}

type Flow struct {
	Id      string
	Version string
}

type FlowAttrs struct {
	Flow Flow

	// mounted file systems
	OpenMounts map[string]string

	// value - look at constants above
	Status FlowStatus

	Created   time.Time
	Started   time.Time
	Completed time.Time
	Failed    time.Time

	CompletionText string

	EnvVars map[string]string

	// support multiple tasks in future releases
	Tasks map[string]TaskAttrs `json:"Tasks"`

	FlowConfig *FlowConfig `json:"FlowConfig"`
	// contains filtered or unexported fields
}

type FlowAttrsMessage struct {
	Type       FlowMessageType
	FlowAttrs  *FlowAttrs
	TasksAttrs *[]tasks.TaskAttrs
	TaskAttrs  *tasks.TaskAttrs
}

type FlowConfig struct {
	MountMap MountMap
}

type FlowEngine interface {
	StartFlow(flowId, taskId string) (*FlowAttrs, error)
	LaunchFlow(repoName string, branchName string, commitId string, cmdString string, evars map[string]string) (*FlowAttrs, error)
	LogStream(flowId string) (io.ReadCloser, error)
}

type FlowMessage struct {
	Type          FlowMessageType
	Flow          *Flow
	Tasks         *[]tasks.Task
	FlowStatusStr string
	Task          *tasks.Task
	TaskStatusStr string
	EnvVars       map[string]string

	Repos  []*ws.RepoMessage
	CmdStr string
}

type FlowMessageType int

type FlowOutRepoRequest struct {
}

type FlowOutRepoResponse struct {
	Repo   *ws.Repo
	Branch *ws.Branch
	Commit *ws.Commit
}

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

type FlowStatus int

type FlowTaskWorker struct {
	Worker  Worker    `json:"Worker"`
	Flow    Flow      `json:"Flow"`
	Task    Task      `json:"Task"`
	Created time.Time `json:"created"`
}

type NewFlowLaunchRequest struct {
	Repo      ws.Repo
	Branch    ws.Branch
	Commit    ws.Commit
	CmdString string
}

type NewFlowLaunchResponse struct {
	TaskStatus    tasks.TaskStatus
	TaskStatusStr string
	Task          *tasks.Task
	Flow          *Flow
}

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

type TaskStatusChangeRequest struct {
	Flow       Flow
	Task       tasks.Task
	TaskStatus tasks.TaskStatus
	Message    string
}

type TaskStatusChangeResponse struct {
	FlowAttrs *FlowAttrs
}

type Worker struct {
	Id       string
	PodId    string
	PodPhase string
}

type WorkerAttrs struct {
	Worker    Worker       `json:"Worker"`
	Flow      Flow         `json:"Flow"`
	Ip        string       `json:"ip"`
	Task      Task         `json:"Task"`
	Started   time.Time    `json:"started"`
	Completed time.Time    `json:"completed"`
	Error     string       `json:"error"`
	Status    WorkerStatus `json:"WorkerStatus"` // REGISTERED, RUNNING, FAILED, STOPPED
}

type WorkerEvent struct {
	Type WorkerEventType

	Worker Worker
	Flow   Flow
	Task   tsk_pkg.Task
}

type WorkerEventType string

type WorkerPool interface {
	WorkerExists(flowId, taskId string) bool
	AssignWorker(taskId string, flowAttrs *FlowAttrs, masterIp string, masterPort, masterExtPort int32) error
	ReleaseWorker(flow Flow) error

	Watch(eventCh chan WorkerEvent)
	CloseWatch()

	SaveWorkerLog(worker Worker, flow Flow) error
	LogStream(flowId string) (io.ReadCloser, error)
}

type WorkerStatus int