pipeline

Documentation

Index

• Constants
• func CompleteInfo(i *Item) (err error)
• func CompleteInfoList(list []*Item) (err error)
• func CompletePipelineBind(i *Item, pb *scheduler.PipelineBind) (err error)
• func CompletePipelineRun(i *Item, pMap map[string]*pipeline.Instance) (err error)
• func CompletePipelineStatus(i *Item) (err error)
• func PipeStatus(name string) (status pipeline.Status, err error)
• type Info
• type Item
  • func GetItemByName(name string) (item *Item, err error)
• type Status

Constants

const (
	STATUS_RUN        = "run"
	STATUS_STOP       = "stop"
	STATUS_STOPPING   = "stopping"
	STATUS_SCHEDULING = "scheduling"
	STATUS_SCHEDULED  = "scheduled"
	STATUS_DELETING   = "deleting"
)

Functions

func CompleteInfo

func CompleteInfo(i *Item) (err error)

func CompleteInfoList

func CompleteInfoList(list []*Item) (err error)

func CompletePipelineBind

func CompletePipelineBind(i *Item, pb *scheduler.PipelineBind) (err error)

func CompletePipelineRun

func CompletePipelineRun(i *Item, pMap map[string]*pipeline.Instance) (err error)

func CompletePipelineStatus

func CompletePipelineStatus(i *Item) (err error)

func PipeStatus

func PipeStatus(name string) (status pipeline.Status, err error)

Types

type Info

type Info struct {
	BindNode *node.Node         `json:"bind_node"`
	Instance *pipeline.Instance `json:"instance"`
	Status   Status             `json:"status"`
}

type Item

type Item struct {
	Pipeline *pipeline.Pipeline `json:"pipeline"`
	Info     *Info              `json:"info"`
}

func GetItemByName

func GetItemByName(name string) (item *Item, err error)

type Status

type Status string