adagio

package
v0.0.0-...-a93a756 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 15, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ErrMissingNode is returned when a node is not found
	ErrMissingNode = errors.New("node not found")
	// ErrNodeNotReady is returned when a claim is made on a node that is not ready
	ErrNodeNotReady = errors.New("node not ready")
	// ErrRunDoesNotExist is returned when a run is referenced which does not exist
	ErrRunDoesNotExist = errors.New("run does not exist")
)
View Source 
var Event_Type_name = map[int32]string{
	0: "NODE_READY",
	1: "NODE_ORPHANED",
}
View Source 
var Event_Type_value = map[string]int32{
	"NODE_READY":    0,
	"NODE_ORPHANED": 1,
}
View Source 
var Node_Result_Conclusion_name = map[int32]string{
	0: "NONE",
	1: "SUCCESS",
	2: "FAIL",
	3: "ERROR",
}
View Source 
var Node_Result_Conclusion_value = map[string]int32{
	"NONE":    0,
	"SUCCESS": 1,
	"FAIL":    2,
	"ERROR":   3,
}
View Source 
var Node_Status_name = map[int32]string{
	0: "NONE",
	1: "WAITING",
	2: "READY",
	3: "RUNNING",
	4: "COMPLETED",
}
View Source 
var Node_Status_value = map[string]int32{
	"NONE":      0,
	"WAITING":   1,
	"READY":     2,
	"RUNNING":   3,
	"COMPLETED": 4,
}
View Source 
var Result_Conclusion_name = map[int32]string{
	0: "NONE",
	1: "SUCCESS",
	2: "FAIL",
}
View Source 
var Result_Conclusion_value = map[string]int32{
	"NONE":    0,
	"SUCCESS": 1,
	"FAIL":    2,
}
View Source 
var Run_Status_name = map[int32]string{
	0: "WAITING",
	1: "RUNNING",
	2: "COMPLETED",
}
View Source 
var Run_Status_value = map[string]int32{
	"WAITING":   0,
	"RUNNING":   1,
	"COMPLETED": 2,
}

Functions

func CanRetry 

func CanRetry(node *Node) (canRetry bool)

CanRetry returns true if the node can be retried

func GraphFrom 

func GraphFrom(run *Run) *graph.Graph

GraphFrom takes a run and builds a *graph.Graph from it which contains helpful functions to traversing the runs graph structure

func VisitLatestAttempt 

func VisitLatestAttempt(node *Node, fn func(*Node_Result))

VisitLatestAttempt calls the supplied function with the latest attempt result if any attempts have been made

Types

type Agent 

type Agent struct {
	Id                   string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Runtimes             []*Runtime `protobuf:"bytes,2,rep,name=runtimes,proto3" json:"runtimes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Agent) Descriptor 

func (*Agent) Descriptor() ([]byte, []int)

func (*Agent) GetId 

func (m *Agent) GetId() string

func (*Agent) GetRuntimes 

func (m *Agent) GetRuntimes() []*Runtime

func (*Agent) ProtoMessage 

func (*Agent) ProtoMessage()

func (*Agent) Reset 

func (m *Agent) Reset()

func (*Agent) String 

func (m *Agent) String() string

func (*Agent) XXX_DiscardUnknown 

func (m *Agent) XXX_DiscardUnknown()

func (*Agent) XXX_Marshal 

func (m *Agent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Agent) XXX_Merge 

func (m *Agent) XXX_Merge(src proto.Message)

func (*Agent) XXX_Size 

func (m *Agent) XXX_Size() int

func (*Agent) XXX_Unmarshal 

func (m *Agent) XXX_Unmarshal(b []byte) error

type Claim 

type Claim struct {
	Id                   string                    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata             map[string]*MetadataValue `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*Claim) Descriptor 

func (*Claim) Descriptor() ([]byte, []int)

func (*Claim) GetId 

func (m *Claim) GetId() string

func (*Claim) GetMetadata 

func (m *Claim) GetMetadata() map[string]*MetadataValue

func (*Claim) ProtoMessage 

func (*Claim) ProtoMessage()

func (*Claim) Reset 

func (m *Claim) Reset()

func (*Claim) String 

func (m *Claim) String() string

func (*Claim) XXX_DiscardUnknown 

func (m *Claim) XXX_DiscardUnknown()

func (*Claim) XXX_Marshal 

func (m *Claim) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Claim) XXX_Merge 

func (m *Claim) XXX_Merge(src proto.Message)

func (*Claim) XXX_Size 

func (m *Claim) XXX_Size() int

func (*Claim) XXX_Unmarshal 

func (m *Claim) XXX_Unmarshal(b []byte) error

type Edge 

type Edge struct {
	Source               string   `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination          string   `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Edge) Descriptor 

func (*Edge) Descriptor() ([]byte, []int)

func (*Edge) GetDestination 

func (m *Edge) GetDestination() string

func (*Edge) GetSource 

func (m *Edge) GetSource() string

func (*Edge) ProtoMessage 

func (*Edge) ProtoMessage()

func (*Edge) Reset 

func (m *Edge) Reset()

func (*Edge) String 

func (m *Edge) String() string

func (*Edge) XXX_DiscardUnknown 

func (m *Edge) XXX_DiscardUnknown()

func (*Edge) XXX_Marshal 

func (m *Edge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Edge) XXX_Merge 

func (m *Edge) XXX_Merge(src proto.Message)

func (*Edge) XXX_Size 

func (m *Edge) XXX_Size() int

func (*Edge) XXX_Unmarshal 

func (m *Edge) XXX_Unmarshal(b []byte) error

type Event 

type Event struct {
	Type                 Event_Type `protobuf:"varint,1,opt,name=type,proto3,enum=adagio.Event_Type" json:"type,omitempty"`
	RunID                string     `protobuf:"bytes,2,opt,name=runID,proto3" json:"runID,omitempty"`
	NodeSpec             *Node_Spec `protobuf:"bytes,3,opt,name=nodeSpec,proto3" json:"nodeSpec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Event) Descriptor 

func (*Event) Descriptor() ([]byte, []int)

func (*Event) GetNodeSpec 

func (m *Event) GetNodeSpec() *Node_Spec

func (*Event) GetRunID 

func (m *Event) GetRunID() string

func (*Event) GetType 

func (m *Event) GetType() Event_Type

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type Event_Type 

type Event_Type int32
const (
	Event_NODE_READY    Event_Type = 0
	Event_NODE_ORPHANED Event_Type = 1
)

func (Event_Type) EnumDescriptor 

func (Event_Type) EnumDescriptor() ([]byte, []int)

func (Event_Type) String 

func (x Event_Type) String() string

type GraphSpec 

type GraphSpec struct {
	Nodes                []*Node_Spec `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Edges                []*Edge      `protobuf:"bytes,2,rep,name=edges,proto3" json:"edges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GraphSpec) Descriptor 

func (*GraphSpec) Descriptor() ([]byte, []int)

func (*GraphSpec) GetEdges 

func (m *GraphSpec) GetEdges() []*Edge

func (*GraphSpec) GetNodes 

func (m *GraphSpec) GetNodes() []*Node_Spec

func (*GraphSpec) ProtoMessage 

func (*GraphSpec) ProtoMessage()

func (*GraphSpec) Reset 

func (m *GraphSpec) Reset()

func (*GraphSpec) String 

func (m *GraphSpec) String() string

func (*GraphSpec) XXX_DiscardUnknown 

func (m *GraphSpec) XXX_DiscardUnknown()

func (*GraphSpec) XXX_Marshal 

func (m *GraphSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GraphSpec) XXX_Merge 

func (m *GraphSpec) XXX_Merge(src proto.Message)

func (*GraphSpec) XXX_Size 

func (m *GraphSpec) XXX_Size() int

func (*GraphSpec) XXX_Unmarshal 

func (m *GraphSpec) XXX_Unmarshal(b []byte) error

type MetadataValue 

type MetadataValue struct {
	Values               []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MetadataValue) Descriptor 

func (*MetadataValue) Descriptor() ([]byte, []int)

func (*MetadataValue) GetValues 

func (m *MetadataValue) GetValues() []string

func (*MetadataValue) ProtoMessage 

func (*MetadataValue) ProtoMessage()

func (*MetadataValue) Reset 

func (m *MetadataValue) Reset()

func (*MetadataValue) String 

func (m *MetadataValue) String() string

func (*MetadataValue) XXX_DiscardUnknown 

func (m *MetadataValue) XXX_DiscardUnknown()

func (*MetadataValue) XXX_Marshal 

func (m *MetadataValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetadataValue) XXX_Merge 

func (m *MetadataValue) XXX_Merge(src proto.Message)

func (*MetadataValue) XXX_Size 

func (m *MetadataValue) XXX_Size() int

func (*MetadataValue) XXX_Unmarshal 

func (m *MetadataValue) XXX_Unmarshal(b []byte) error

type Node 

type Node struct {
	Spec                 *Node_Spec        `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Status               Node_Status       `protobuf:"varint,2,opt,name=status,proto3,enum=adagio.Node_Status" json:"status,omitempty"`
	Attempts             []*Node_Result    `protobuf:"bytes,3,rep,name=attempts,proto3" json:"attempts,omitempty"`
	StartedAt            string            `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	FinishedAt           string            `protobuf:"bytes,5,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	Inputs               map[string][]byte `` /* 153-byte string literal not displayed */
	Claim                *Claim            `protobuf:"bytes,7,opt,name=claim,proto3" json:"claim,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Node) Descriptor 

func (*Node) Descriptor() ([]byte, []int)

func (*Node) GetAttempts 

func (m *Node) GetAttempts() []*Node_Result

func (*Node) GetClaim 

func (m *Node) GetClaim() *Claim

func (*Node) GetFinishedAt 

func (m *Node) GetFinishedAt() string

func (*Node) GetInputs 

func (m *Node) GetInputs() map[string][]byte

func (*Node) GetSpec 

func (m *Node) GetSpec() *Node_Spec

func (*Node) GetStartedAt 

func (m *Node) GetStartedAt() string

func (*Node) GetStatus 

func (m *Node) GetStatus() Node_Status

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge 

func (m *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

func (m *Node) XXX_Unmarshal(b []byte) error

type Node_Result 

type Node_Result struct {
	Conclusion           Node_Result_Conclusion    `protobuf:"varint,1,opt,name=conclusion,proto3,enum=adagio.Node_Result_Conclusion" json:"conclusion,omitempty"`
	Metadata             map[string]*MetadataValue `` /* 157-byte string literal not displayed */
	Output               []byte                    `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*Node_Result) Descriptor 

func (*Node_Result) Descriptor() ([]byte, []int)

func (*Node_Result) GetConclusion 

func (m *Node_Result) GetConclusion() Node_Result_Conclusion

func (*Node_Result) GetMetadata 

func (m *Node_Result) GetMetadata() map[string]*MetadataValue

func (*Node_Result) GetOutput 

func (m *Node_Result) GetOutput() []byte

func (*Node_Result) ProtoMessage 

func (*Node_Result) ProtoMessage()

func (*Node_Result) Reset 

func (m *Node_Result) Reset()

func (*Node_Result) String 

func (m *Node_Result) String() string

func (*Node_Result) XXX_DiscardUnknown 

func (m *Node_Result) XXX_DiscardUnknown()

func (*Node_Result) XXX_Marshal 

func (m *Node_Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node_Result) XXX_Merge 

func (m *Node_Result) XXX_Merge(src proto.Message)

func (*Node_Result) XXX_Size 

func (m *Node_Result) XXX_Size() int

func (*Node_Result) XXX_Unmarshal 

func (m *Node_Result) XXX_Unmarshal(b []byte) error

type Node_Result_Conclusion 

type Node_Result_Conclusion int32
const (
	Node_Result_NONE    Node_Result_Conclusion = 0
	Node_Result_SUCCESS Node_Result_Conclusion = 1
	Node_Result_FAIL    Node_Result_Conclusion = 2
	Node_Result_ERROR   Node_Result_Conclusion = 3
)

func (Node_Result_Conclusion) EnumDescriptor 

func (Node_Result_Conclusion) EnumDescriptor() ([]byte, []int)

func (Node_Result_Conclusion) String 

func (x Node_Result_Conclusion) String() string

type Node_Spec 

type Node_Spec struct {
	Name                 string                      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Runtime              string                      `protobuf:"bytes,2,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Metadata             map[string]*MetadataValue   `` /* 157-byte string literal not displayed */
	Retry                map[string]*Node_Spec_Retry `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*Node_Spec) Descriptor 

func (*Node_Spec) Descriptor() ([]byte, []int)

func (*Node_Spec) GetMetadata 

func (m *Node_Spec) GetMetadata() map[string]*MetadataValue

func (*Node_Spec) GetName 

func (m *Node_Spec) GetName() string

func (*Node_Spec) GetRetry 

func (m *Node_Spec) GetRetry() map[string]*Node_Spec_Retry

func (*Node_Spec) GetRuntime 

func (m *Node_Spec) GetRuntime() string

func (*Node_Spec) ProtoMessage 

func (*Node_Spec) ProtoMessage()

func (*Node_Spec) Reset 

func (m *Node_Spec) Reset()

func (*Node_Spec) String 

func (m *Node_Spec) String() string

func (*Node_Spec) XXX_DiscardUnknown 

func (m *Node_Spec) XXX_DiscardUnknown()

func (*Node_Spec) XXX_Marshal 

func (m *Node_Spec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node_Spec) XXX_Merge 

func (m *Node_Spec) XXX_Merge(src proto.Message)

func (*Node_Spec) XXX_Size 

func (m *Node_Spec) XXX_Size() int

func (*Node_Spec) XXX_Unmarshal 

func (m *Node_Spec) XXX_Unmarshal(b []byte) error

type Node_Spec_Retry 

type Node_Spec_Retry struct {
	MaxAttempts          int32    `protobuf:"varint,1,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Node_Spec_Retry) Descriptor 

func (*Node_Spec_Retry) Descriptor() ([]byte, []int)

func (*Node_Spec_Retry) GetMaxAttempts 

func (m *Node_Spec_Retry) GetMaxAttempts() int32

func (*Node_Spec_Retry) ProtoMessage 

func (*Node_Spec_Retry) ProtoMessage()

func (*Node_Spec_Retry) Reset 

func (m *Node_Spec_Retry) Reset()

func (*Node_Spec_Retry) String 

func (m *Node_Spec_Retry) String() string

func (*Node_Spec_Retry) XXX_DiscardUnknown 

func (m *Node_Spec_Retry) XXX_DiscardUnknown()

func (*Node_Spec_Retry) XXX_Marshal 

func (m *Node_Spec_Retry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node_Spec_Retry) XXX_Merge 

func (m *Node_Spec_Retry) XXX_Merge(src proto.Message)

func (*Node_Spec_Retry) XXX_Size 

func (m *Node_Spec_Retry) XXX_Size() int

func (*Node_Spec_Retry) XXX_Unmarshal 

func (m *Node_Spec_Retry) XXX_Unmarshal(b []byte) error

type Node_Status 

type Node_Status int32
const (
	Node_NONE      Node_Status = 0
	Node_WAITING   Node_Status = 1
	Node_READY     Node_Status = 2
	Node_RUNNING   Node_Status = 3
	Node_COMPLETED Node_Status = 4
)

func (Node_Status) EnumDescriptor 

func (Node_Status) EnumDescriptor() ([]byte, []int)

func (Node_Status) String 

func (x Node_Status) String() string

type Result 

type Result struct {
	Conclusion           Result_Conclusion         `protobuf:"varint,1,opt,name=conclusion,proto3,enum=adagio.Result_Conclusion" json:"conclusion,omitempty"`
	Metadata             map[string]*MetadataValue `` /* 157-byte string literal not displayed */
	Output               []byte                    `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*Result) Descriptor 

func (*Result) Descriptor() ([]byte, []int)

func (*Result) GetConclusion 

func (m *Result) GetConclusion() Result_Conclusion

func (*Result) GetMetadata 

func (m *Result) GetMetadata() map[string]*MetadataValue

func (*Result) GetOutput 

func (m *Result) GetOutput() []byte

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) String 

func (m *Result) String() string

func (*Result) XXX_DiscardUnknown 

func (m *Result) XXX_DiscardUnknown()

func (*Result) XXX_Marshal 

func (m *Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Result) XXX_Merge 

func (m *Result) XXX_Merge(src proto.Message)

func (*Result) XXX_Size 

func (m *Result) XXX_Size() int

func (*Result) XXX_Unmarshal 

func (m *Result) XXX_Unmarshal(b []byte) error

type Result_Conclusion 

type Result_Conclusion int32
const (
	Result_NONE    Result_Conclusion = 0
	Result_SUCCESS Result_Conclusion = 1
	Result_FAIL    Result_Conclusion = 2
)

func (Result_Conclusion) EnumDescriptor 

func (Result_Conclusion) EnumDescriptor() ([]byte, []int)

func (Result_Conclusion) String 

func (x Result_Conclusion) String() string

type RetryCondition 

type RetryCondition string

RetryCondition is a key used in the node spec retry map 

const (
	// OnFail is the retry condition where a node results in a
	// failure
	OnFail RetryCondition = "fail"
	// OnError is the retry condition where a node results in a
	// system related error
	OnError RetryCondition = "error"
)

type Run 

type Run struct {
	Id                   string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt            string     `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Nodes                []*Node    `protobuf:"bytes,3,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Edges                []*Edge    `protobuf:"bytes,4,rep,name=edges,proto3" json:"edges,omitempty"`
	Status               Run_Status `protobuf:"varint,5,opt,name=status,proto3,enum=adagio.Run_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func NewRun 

func NewRun(spec *GraphSpec) (run *Run, err error)

NewRun converts a graph specification into a new run instance This is a convention and helper function for repository implementations to use to correctly adapt a new graph spec into a run. It validates that the graph has no cycles and initializes states, timestamps and IDs appropriately

func (*Run) Descriptor 

func (*Run) Descriptor() ([]byte, []int)

func (*Run) GetCreatedAt 

func (m *Run) GetCreatedAt() string

func (*Run) GetEdges 

func (m *Run) GetEdges() []*Edge

func (*Run) GetId 

func (m *Run) GetId() string

func (*Run) GetNodeByName 

func (run *Run) GetNodeByName(name string) (*Node, error)

GetNodeByName fetches a Node from the Run by name

func (*Run) GetNodes 

func (m *Run) GetNodes() []*Node

func (*Run) GetStatus 

func (m *Run) GetStatus() Run_Status

func (*Run) ProtoMessage 

func (*Run) ProtoMessage()

func (*Run) Reset 

func (m *Run) Reset()

func (*Run) String 

func (m *Run) String() string

func (*Run) XXX_DiscardUnknown 

func (m *Run) XXX_DiscardUnknown()

func (*Run) XXX_Marshal 

func (m *Run) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Run) XXX_Merge 

func (m *Run) XXX_Merge(src proto.Message)

func (*Run) XXX_Size 

func (m *Run) XXX_Size() int

func (*Run) XXX_Unmarshal 

func (m *Run) XXX_Unmarshal(b []byte) error

type Run_Status 

type Run_Status int32
const (
	Run_WAITING   Run_Status = 0
	Run_RUNNING   Run_Status = 1
	Run_COMPLETED Run_Status = 2
)

func (Run_Status) EnumDescriptor 

func (Run_Status) EnumDescriptor() ([]byte, []int)

func (Run_Status) String 

func (x Run_Status) String() string

type Runtime 

type Runtime struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Runtime) Descriptor 

func (*Runtime) Descriptor() ([]byte, []int)

func (*Runtime) GetName 

func (m *Runtime) GetName() string

func (*Runtime) ProtoMessage 

func (*Runtime) ProtoMessage()

func (*Runtime) Reset 

func (m *Runtime) Reset()

func (*Runtime) String 

func (m *Runtime) String() string

func (*Runtime) XXX_DiscardUnknown 

func (m *Runtime) XXX_DiscardUnknown()

func (*Runtime) XXX_Marshal 

func (m *Runtime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Runtime) XXX_Merge 

func (m *Runtime) XXX_Merge(src proto.Message)

func (*Runtime) XXX_Size 

func (m *Runtime) XXX_Size() int

func (*Runtime) XXX_Unmarshal 

func (m *Runtime) XXX_Unmarshal(b []byte) error

type Stats 

type Stats struct {
	RunCount             int64             `protobuf:"varint,1,opt,name=run_count,json=runCount,proto3" json:"run_count,omitempty"`
	NodeCounts           *Stats_NodeCounts `protobuf:"bytes,2,opt,name=node_counts,json=nodeCounts,proto3" json:"node_counts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Stats) Descriptor 

func (*Stats) Descriptor() ([]byte, []int)

func (*Stats) GetNodeCounts 

func (m *Stats) GetNodeCounts() *Stats_NodeCounts

func (*Stats) GetRunCount 

func (m *Stats) GetRunCount() int64

func (*Stats) ProtoMessage 

func (*Stats) ProtoMessage()

func (*Stats) Reset 

func (m *Stats) Reset()

func (*Stats) String 

func (m *Stats) String() string

func (*Stats) XXX_DiscardUnknown 

func (m *Stats) XXX_DiscardUnknown()

func (*Stats) XXX_Marshal 

func (m *Stats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Stats) XXX_Merge 

func (m *Stats) XXX_Merge(src proto.Message)

func (*Stats) XXX_Size 

func (m *Stats) XXX_Size() int

func (*Stats) XXX_Unmarshal 

func (m *Stats) XXX_Unmarshal(b []byte) error

type Stats_NodeCounts 

type Stats_NodeCounts struct {
	WaitingCount         int64    `protobuf:"varint,1,opt,name=waiting_count,json=waitingCount,proto3" json:"waiting_count,omitempty"`
	ReadyCount           int64    `protobuf:"varint,2,opt,name=ready_count,json=readyCount,proto3" json:"ready_count,omitempty"`
	RunningCount         int64    `protobuf:"varint,3,opt,name=running_count,json=runningCount,proto3" json:"running_count,omitempty"`
	CompletedCount       int64    `protobuf:"varint,4,opt,name=completed_count,json=completedCount,proto3" json:"completed_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Stats_NodeCounts) Descriptor 

func (*Stats_NodeCounts) Descriptor() ([]byte, []int)

func (*Stats_NodeCounts) GetCompletedCount 

func (m *Stats_NodeCounts) GetCompletedCount() int64

func (*Stats_NodeCounts) GetReadyCount 

func (m *Stats_NodeCounts) GetReadyCount() int64

func (*Stats_NodeCounts) GetRunningCount 

func (m *Stats_NodeCounts) GetRunningCount() int64

func (*Stats_NodeCounts) GetWaitingCount 

func (m *Stats_NodeCounts) GetWaitingCount() int64

func (*Stats_NodeCounts) ProtoMessage 

func (*Stats_NodeCounts) ProtoMessage()

func (*Stats_NodeCounts) Reset 

func (m *Stats_NodeCounts) Reset()

func (*Stats_NodeCounts) String 

func (m *Stats_NodeCounts) String() string

func (*Stats_NodeCounts) XXX_DiscardUnknown 

func (m *Stats_NodeCounts) XXX_DiscardUnknown()

func (*Stats_NodeCounts) XXX_Marshal 

func (m *Stats_NodeCounts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Stats_NodeCounts) XXX_Merge 

func (m *Stats_NodeCounts) XXX_Merge(src proto.Message)

func (*Stats_NodeCounts) XXX_Size 

func (m *Stats_NodeCounts) XXX_Size() int

func (*Stats_NodeCounts) XXX_Unmarshal 

func (m *Stats_NodeCounts) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.