events

package
v0.0.0-...-0f8ae5d Latest Latest
Warning

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

 Go to latest Published: Dec 31, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Code generated by hack/codegen-events.py. DO NOT EDIT.

Package events is a generated protocol buffer package.

It is generated from these files: 

pkg/api/events/events.proto

It has these top-level messages: 

WorkflowCreated
WorkflowDeleted
WorkflowParsed
WorkflowParsingFailed
InvocationCreated
InvocationScheduled
InvocationCompleted
InvocationCanceled
InvocationTaskAdded
InvocationFailed
InvocationEvictable
TaskStarted
TaskSucceeded
TaskSkipped
TaskFailed

Index

Constants

This section is empty.

Variables

View Source 
var InvocationTerminalEvents = []string{
	EventInvocationCompleted,
	EventInvocationCanceled,
	EventInvocationFailed,
}
View Source 
var WorkflowTerminalEvents = []string{
	EventWorkflowDeleted,
}

Functions

This section is empty.

Types

type Event 

type Event interface {
	proto.Message
	Type() EventType
}

type EventType 

type EventType = string
const (
	EventWorkflowCreated       EventType = "WorkflowCreated"
	EventWorkflowDeleted       EventType = "WorkflowDeleted"
	EventWorkflowParsed        EventType = "WorkflowParsed"
	EventWorkflowParsingFailed EventType = "WorkflowParsingFailed"
	EventInvocationCreated     EventType = "InvocationCreated"
	EventInvocationScheduled   EventType = "InvocationScheduled"
	EventInvocationCompleted   EventType = "InvocationCompleted"
	EventInvocationCanceled    EventType = "InvocationCanceled"
	EventInvocationTaskAdded   EventType = "InvocationTaskAdded"
	EventInvocationFailed      EventType = "InvocationFailed"
	EventInvocationEvictable   EventType = "InvocationEvictable"
	EventTaskStarted           EventType = "TaskStarted"
	EventTaskSucceeded         EventType = "TaskSucceeded"
	EventTaskSkipped           EventType = "TaskSkipped"
	EventTaskFailed            EventType = "TaskFailed"
)

type InvocationCanceled 

type InvocationCanceled struct {
	Error *fission_workflows_types1.Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*InvocationCanceled) Descriptor 

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

func (*InvocationCanceled) GetError 

func (m *InvocationCanceled) GetError() *fission_workflows_types1.Error

func (*InvocationCanceled) ProtoMessage 

func (*InvocationCanceled) ProtoMessage()

func (*InvocationCanceled) Reset 

func (m *InvocationCanceled) Reset()

func (*InvocationCanceled) String 

func (m *InvocationCanceled) String() string

func (*InvocationCanceled) Type 

func (m *InvocationCanceled) Type() EventType

type InvocationCompleted 

type InvocationCompleted struct {
	Output        *fission_workflows_types.TypedValue `protobuf:"bytes,1,opt,name=output" json:"output,omitempty"`
	OutputHeaders *fission_workflows_types.TypedValue `protobuf:"bytes,2,opt,name=OutputHeaders" json:"OutputHeaders,omitempty"`
}

func (*InvocationCompleted) Descriptor 

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

func (*InvocationCompleted) GetOutput 

func (m *InvocationCompleted) GetOutput() *fission_workflows_types.TypedValue

func (*InvocationCompleted) GetOutputHeaders 

func (m *InvocationCompleted) GetOutputHeaders() *fission_workflows_types.TypedValue

func (*InvocationCompleted) ProtoMessage 

func (*InvocationCompleted) ProtoMessage()

func (*InvocationCompleted) Reset 

func (m *InvocationCompleted) Reset()

func (*InvocationCompleted) String 

func (m *InvocationCompleted) String() string

func (*InvocationCompleted) Type 

func (m *InvocationCompleted) Type() EventType

type InvocationCreated 

type InvocationCreated struct {
	Spec *fission_workflows_types1.WorkflowInvocationSpec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"`
}

func (*InvocationCreated) Descriptor 

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

func (*InvocationCreated) GetSpec 

func (m *InvocationCreated) GetSpec() *fission_workflows_types1.WorkflowInvocationSpec

func (*InvocationCreated) ProtoMessage 

func (*InvocationCreated) ProtoMessage()

func (*InvocationCreated) Reset 

func (m *InvocationCreated) Reset()

func (*InvocationCreated) String 

func (m *InvocationCreated) String() string

func (*InvocationCreated) Type 

func (m *InvocationCreated) Type() EventType

type InvocationEvictable 

type InvocationEvictable struct {
}

func (*InvocationEvictable) Descriptor 

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

func (*InvocationEvictable) ProtoMessage 

func (*InvocationEvictable) ProtoMessage()

func (*InvocationEvictable) Reset 

func (m *InvocationEvictable) Reset()

func (*InvocationEvictable) String 

func (m *InvocationEvictable) String() string

func (*InvocationEvictable) Type 

func (m *InvocationEvictable) Type() EventType

type InvocationFailed 

type InvocationFailed struct {
	Error *fission_workflows_types1.Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*InvocationFailed) Descriptor 

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

func (*InvocationFailed) GetError 

func (m *InvocationFailed) GetError() *fission_workflows_types1.Error

func (*InvocationFailed) ProtoMessage 

func (*InvocationFailed) ProtoMessage()

func (*InvocationFailed) Reset 

func (m *InvocationFailed) Reset()

func (*InvocationFailed) String 

func (m *InvocationFailed) String() string

func (*InvocationFailed) Type 

func (m *InvocationFailed) Type() EventType

type InvocationScheduled 

type InvocationScheduled struct {
	Spec *fission_workflows_types1.WorkflowInvocationSpec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"`
}

func (*InvocationScheduled) Descriptor 

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

func (*InvocationScheduled) GetSpec 

func (m *InvocationScheduled) GetSpec() *fission_workflows_types1.WorkflowInvocationSpec

func (*InvocationScheduled) ProtoMessage 

func (*InvocationScheduled) ProtoMessage()

func (*InvocationScheduled) Reset 

func (m *InvocationScheduled) Reset()

func (*InvocationScheduled) String 

func (m *InvocationScheduled) String() string

func (*InvocationScheduled) Type 

func (m *InvocationScheduled) Type() EventType

type InvocationTaskAdded 

type InvocationTaskAdded struct {
	Task *fission_workflows_types1.Task `protobuf:"bytes,1,opt,name=task" json:"task,omitempty"`
}

func (*InvocationTaskAdded) Descriptor 

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

func (*InvocationTaskAdded) GetTask 

func (m *InvocationTaskAdded) GetTask() *fission_workflows_types1.Task

func (*InvocationTaskAdded) ProtoMessage 

func (*InvocationTaskAdded) ProtoMessage()

func (*InvocationTaskAdded) Reset 

func (m *InvocationTaskAdded) Reset()

func (*InvocationTaskAdded) String 

func (m *InvocationTaskAdded) String() string

func (*InvocationTaskAdded) Type 

func (m *InvocationTaskAdded) Type() EventType

type TaskFailed 

type TaskFailed struct {
	Error *fission_workflows_types1.Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*TaskFailed) Descriptor 

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

func (*TaskFailed) GetError 

func (m *TaskFailed) GetError() *fission_workflows_types1.Error

func (*TaskFailed) ProtoMessage 

func (*TaskFailed) ProtoMessage()

func (*TaskFailed) Reset 

func (m *TaskFailed) Reset()

func (*TaskFailed) String 

func (m *TaskFailed) String() string

func (*TaskFailed) Type 

func (m *TaskFailed) Type() EventType

type TaskSkipped 

type TaskSkipped struct {
}

func (*TaskSkipped) Descriptor 

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

func (*TaskSkipped) ProtoMessage 

func (*TaskSkipped) ProtoMessage()

func (*TaskSkipped) Reset 

func (m *TaskSkipped) Reset()

func (*TaskSkipped) String 

func (m *TaskSkipped) String() string

func (*TaskSkipped) Type 

func (m *TaskSkipped) Type() EventType

type TaskStarted 

type TaskStarted struct {
	Spec *fission_workflows_types1.TaskInvocationSpec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"`
}

Task

TODO why do we need task, and not just task spec.

func (*TaskStarted) Descriptor 

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

func (*TaskStarted) GetSpec 

func (m *TaskStarted) GetSpec() *fission_workflows_types1.TaskInvocationSpec

func (*TaskStarted) ProtoMessage 

func (*TaskStarted) ProtoMessage()

func (*TaskStarted) Reset 

func (m *TaskStarted) Reset()

func (*TaskStarted) String 

func (m *TaskStarted) String() string

func (*TaskStarted) Type 

func (m *TaskStarted) Type() EventType

type TaskSucceeded 

type TaskSucceeded struct {
	Result *fission_workflows_types1.TaskInvocationStatus `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

func (*TaskSucceeded) Descriptor 

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

func (*TaskSucceeded) GetResult 

func (m *TaskSucceeded) GetResult() *fission_workflows_types1.TaskInvocationStatus

func (*TaskSucceeded) ProtoMessage 

func (*TaskSucceeded) ProtoMessage()

func (*TaskSucceeded) Reset 

func (m *TaskSucceeded) Reset()

func (*TaskSucceeded) String 

func (m *TaskSucceeded) String() string

func (*TaskSucceeded) Type 

func (m *TaskSucceeded) Type() EventType

type WorkflowCreated 

type WorkflowCreated struct {
	Spec *fission_workflows_types1.WorkflowSpec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"`
}

func (*WorkflowCreated) Descriptor 

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

func (*WorkflowCreated) GetSpec 

func (m *WorkflowCreated) GetSpec() *fission_workflows_types1.WorkflowSpec

func (*WorkflowCreated) ProtoMessage 

func (*WorkflowCreated) ProtoMessage()

func (*WorkflowCreated) Reset 

func (m *WorkflowCreated) Reset()

func (*WorkflowCreated) String 

func (m *WorkflowCreated) String() string

func (*WorkflowCreated) Type 

func (m *WorkflowCreated) Type() EventType

type WorkflowDeleted 

type WorkflowDeleted struct {
}

func (*WorkflowDeleted) Descriptor 

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

func (*WorkflowDeleted) ProtoMessage 

func (*WorkflowDeleted) ProtoMessage()

func (*WorkflowDeleted) Reset 

func (m *WorkflowDeleted) Reset()

func (*WorkflowDeleted) String 

func (m *WorkflowDeleted) String() string

func (*WorkflowDeleted) Type 

func (m *WorkflowDeleted) Type() EventType

type WorkflowParsed 

type WorkflowParsed struct {
	Tasks map[string]*fission_workflows_types1.TaskStatus `` /* 130-byte string literal not displayed */
}

func (*WorkflowParsed) Descriptor 

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

func (*WorkflowParsed) GetTasks 

func (m *WorkflowParsed) GetTasks() map[string]*fission_workflows_types1.TaskStatus

func (*WorkflowParsed) ProtoMessage 

func (*WorkflowParsed) ProtoMessage()

func (*WorkflowParsed) Reset 

func (m *WorkflowParsed) Reset()

func (*WorkflowParsed) String 

func (m *WorkflowParsed) String() string

func (*WorkflowParsed) Type 

func (m *WorkflowParsed) Type() EventType

type WorkflowParsingFailed 

type WorkflowParsingFailed struct {
	Error *fission_workflows_types1.Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*WorkflowParsingFailed) Descriptor 

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

func (*WorkflowParsingFailed) GetError 

func (m *WorkflowParsingFailed) GetError() *fission_workflows_types1.Error

func (*WorkflowParsingFailed) ProtoMessage 

func (*WorkflowParsingFailed) ProtoMessage()

func (*WorkflowParsingFailed) Reset 

func (m *WorkflowParsingFailed) Reset()

func (*WorkflowParsingFailed) String 

func (m *WorkflowParsingFailed) String() string

func (*WorkflowParsingFailed) Type 

func (m *WorkflowParsingFailed) Type() EventType

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.