pipeline

Documentation

Index

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

Functions

func CompleteInfo

func CompleteInfo(i *Item) (err error)

CompleteInfo complete info for item

func CompleteInfoList

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

CompleteInfoList complete pipeline list info

func CompletePipelineBind

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

CompletePipelineBind complete pipeline bind info

func PipeStatus

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

PipeStatus get pipeline status by pipeline name

Types

type Info

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

Info for front display

type Item

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

Item for front display

func GetItemByName

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

GetItemByName get item by pipeline name