model

Documentation

Index

• func FormatTime(val time.Time) string
• func Params(params []string) string
• func Time(t time.Time) *time.Time
• type Node
  • func FromNode(node scheduler.NodeData) *Node
  • func FromNodes(nodes []scheduler.NodeData) []*Node
  • func FromNodesOrSteps(nodes []scheduler.NodeData, steps []dag.Step) []*Node
  • func FromSteps(steps []dag.Step) []*Node
  • func NewNode(step dag.Step) *Node
  • func (n *Node) ToNode() *scheduler.Node
• type PID
  • func (p PID) IsRunning() bool
  • func (p PID) String() string
• type Status
  • func NewStatus(workflow *dag.DAG, nodes []scheduler.NodeData, status scheduler.Status, ...) *Status
  • func NewStatusDefault(workflow *dag.DAG) *Status
  • func StatusFromJSON(s string) (*Status, error)
  • func (st *Status) CorrectRunningStatus()
  • func (st *Status) ToJSON() ([]byte, error)
• type StatusFile
• type StatusResponse

Functions

func FormatTime

func FormatTime(val time.Time) string

func Params

func Params(params []string) string

func Time

func Time(t time.Time) *time.Time

Types

type Node

type Node struct {
	Step       dag.Step             `json:"Step"`
	Log        string               `json:"Log"`
	StartedAt  string               `json:"StartedAt"`
	FinishedAt string               `json:"FinishedAt"`
	Status     scheduler.NodeStatus `json:"Status"`
	RetryCount int                  `json:"RetryCount"`
	DoneCount  int                  `json:"DoneCount"`
	Error      string               `json:"Error"`
	StatusText string               `json:"StatusText"`
}

func FromNode

func FromNode(node scheduler.NodeData) *Node

func FromNodes

func FromNodes(nodes []scheduler.NodeData) []*Node

func FromNodesOrSteps

func FromNodesOrSteps(nodes []scheduler.NodeData, steps []dag.Step) []*Node

func FromSteps

func FromSteps(steps []dag.Step) []*Node

func NewNode

func NewNode(step dag.Step) *Node

func (*Node) ToNode

func (n *Node) ToNode() *scheduler.Node

type PID

type PID int

func (PID) IsRunning

func (p PID) IsRunning() bool

func (PID) String

func (p PID) String() string

type Status

type Status struct {
	RequestID  string           `json:"RequestId"`
	Name       string           `json:"Name"`
	Status     scheduler.Status `json:"Status"`
	StatusText string           `json:"StatusText"`
	PID        PID              `json:"Pid"`
	Nodes      []*Node          `json:"Nodes"`
	OnExit     *Node            `json:"OnExit"`
	OnSuccess  *Node            `json:"OnSuccess"`
	OnFailure  *Node            `json:"OnFailure"`
	OnCancel   *Node            `json:"OnCancel"`
	StartedAt  string           `json:"StartedAt"`
	FinishedAt string           `json:"FinishedAt"`
	Log        string           `json:"Log"`
	Params     string           `json:"Params"`
	// contains filtered or unexported fields
}

func NewStatus

func NewStatus(
	workflow *dag.DAG,
	nodes []scheduler.NodeData,
	status scheduler.Status,
	pid int,
	startTime, endTime *time.Time,
) *Status

func NewStatusDefault

func NewStatusDefault(workflow *dag.DAG) *Status

func StatusFromJSON

func StatusFromJSON(s string) (*Status, error)

func (*Status) CorrectRunningStatus

func (st *Status) CorrectRunningStatus()

func (*Status) ToJSON

func (st *Status) ToJSON() ([]byte, error)

type StatusFile

type StatusFile struct {
	File   string
	Status *Status
}

type StatusResponse

type StatusResponse struct {
	Status *Status `json:"status"`
}