exported

Documentation

Index

• type FlowMetaInsight
  • func (f FlowMetaInsight) JsonWrite(w io.Writer) error
• type FlowRunningInsight
  • func (f FlowRunningInsight) JsonWrite(w io.Writer) error
• type InspectStdFunction
  • func (i InspectStdFunction) JsonWrite(w io.Writer) error
• type ListStdFunctions
  • func (l ListStdFunctions) JsonWrite(w io.Writer) error
• type NodeRunningInsight
• type SimpleError
  • func (s SimpleError) JsonWrite(w io.Writer) error
• type SimpleSucceed
  • func (s SimpleSucceed) JsonWrite(w io.Writer) error

Types

type FlowMetaInsight

type FlowMetaInsight struct {
	Name   string `json:"name"`
	ID     string `json:"id"`
	Total  int    `json:"total"`
	Source string `json:"source"`
	Desc   string `json:"desc"`
}

func (FlowMetaInsight) JsonWrite

func (f FlowMetaInsight) JsonWrite(w io.Writer) error

type FlowRunningInsight

type FlowRunningInsight struct {
	Name      string               `json:"name"`
	ID        string               `json:"id"`
	Status    string               `json:"status"`
	LastError error                `json:"last_error"`
	Begin     time.Time            `json:"begin_time"`
	Duration  int64                `json:"duration"`
	Total     int                  `json:"total"`
	Running   int                  `json:"running"`
	Done      int                  `json:"done"`
	Nodes     []NodeRunningInsight `json:"nodes"`
}

func (FlowRunningInsight) JsonWrite

func (f FlowRunningInsight) JsonWrite(w io.Writer) error

type InspectStdFunction

type InspectStdFunction manifest.Manifest

func (InspectStdFunction) JsonWrite

func (i InspectStdFunction) JsonWrite(w io.Writer) error

type ListStdFunctions

type ListStdFunctions struct {
	Category string `json:"category"`
	Name     string `json:"name"`
	Desc     string `json:"desc"`
}

func (ListStdFunctions) JsonWrite

func (l ListStdFunctions) JsonWrite(w io.Writer) error

type NodeRunningInsight

type NodeRunningInsight struct {
	Seq       int    `json:"seq"`
	Step      int    `json:"step"`
	Name      string `json:"name"`
	Function  string `json:"function"`
	Driver    string `json:"driver"`
	LastError error  `json:"last_error"`
	Status    string `json:"status"`
	Runs      int    `json:"runs"`
	Duration  int64  `json:"duration"`
}

type SimpleError

type SimpleError struct {
	Error string   `json:"error"`
	Desc  []string `json:"desc"`
}

func (SimpleError) JsonWrite

func (s SimpleError) JsonWrite(w io.Writer) error

type SimpleSucceed

type SimpleSucceed struct {
	Message string   `json:"message"`
	Desc    []string `json:"desc"`
}

func (SimpleSucceed) JsonWrite

func (s SimpleSucceed) JsonWrite(w io.Writer) error