types

type ByQueueTime struct{ WorkflowInvocations }

type ConsentMessage struct {
	ID     string         `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"`
	Status *ConsentStatus `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"`
}

type ConsentStatus struct {
	Status ConsentStatus_Status `protobuf:"varint,1,opt,name=status,enum=fission.workflows.types.ConsentStatus_Status" json:"status,omitempty"`
}

type ConsentStatus_Status int32

type DataFlowSpec struct {
	// Indicates if consent should be verified before tasks are invoked at each
	// stage of the workflow
	ConsentCheck bool   `protobuf:"varint,1,opt,name=consentCheck" json:"consentCheck,omitempty"`
	Provenance   bool   `protobuf:"varint,2,opt,name=provenance" json:"provenance,omitempty"`
	Predecessor  string `protobuf:"bytes,3,opt,name=predecessor" json:"predecessor,omitempty"`
}

type DependencyConfig struct {
	// Dependencies for this task to execute
	Requires map[string]*TaskDependencyParameters `` /* 136-byte string literal not displayed */
	// Number of dependencies to wait for
	Await int32 `protobuf:"varint,2,opt,name=await" json:"await,omitempty"`
}

type Error struct {
	Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
}

type FnRef struct {
	// Runtime is the Function Runtime environment (fnenv) that was used to resolve the function.
	Runtime string `protobuf:"bytes,2,opt,name=runtime" json:"runtime,omitempty"`
	// Namespace is the namespace of the fission function.
	Namespace string `protobuf:"bytes,3,opt,name=namespace" json:"namespace,omitempty"`
	// ID is the runtime-specific identifier of the function.
	ID string `protobuf:"bytes,4,opt,name=ID" json:"ID,omitempty"`
	// the zone in which the the function execution is taking place
	Zone Zone `protobuf:"varint,5,opt,name=zone,enum=fission.workflows.types.Zone" json:"zone,omitempty"`
}

type Inputs map[string]*typedvalues.TypedValue

type NamedTypedValue struct {
	typedvalues.TypedValue
	// contains filtered or unexported fields
}

type ObjectMetadata struct {
	// ID is the unique identifier, generated by the workflow engine
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	// Name is an optional human-readable name of the object.
	Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// Created at contains the timestamp of when this object was created.
	// Typically the updatedAt field can be found in the status of the object.
	CreatedAt *google_protobuf.Timestamp `protobuf:"bytes,3,opt,name=createdAt" json:"createdAt,omitempty"`
	// Generation is a sequence identifier used and updated by the system to record the number of events or
	// changes applied to the object.
	Generation int64 `protobuf:"varint,4,opt,name=generation" json:"generation,omitempty"`
}

type ProvenanceMetadata struct {
	OpType ProvenanceMetadata_OpType `protobuf:"varint,4,opt,name=opType,enum=fission.workflows.types.ProvenanceMetadata_OpType" json:"opType,omitempty"`
	// additional meta
	Meta string `protobuf:"bytes,5,opt,name=meta" json:"meta,omitempty"`
}

type ProvenanceMetadata_OpType int32

type Requires map[string]*TaskDependencyParameters

type Task struct {
	Metadata *ObjectMetadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	Spec     *TaskSpec       `protobuf:"bytes,2,opt,name=spec" json:"spec,omitempty"`
	Status   *TaskStatus     `protobuf:"bytes,3,opt,name=status" json:"status,omitempty"`
}

type TaskDataflowSpec struct {
	ZoneLock  Zone `protobuf:"varint,1,opt,name=zoneLock,enum=fission.workflows.types.Zone" json:"zoneLock,omitempty"`
	ZoneHint  Zone `protobuf:"varint,2,opt,name=zoneHint,enum=fission.workflows.types.Zone" json:"zoneHint,omitempty"`
	MultiZone bool `protobuf:"varint,3,opt,name=multiZone" json:"multiZone,omitempty"`
}

type TaskDependencyParameters struct {
	Type  TaskDependencyParameters_DependencyType `protobuf:"varint,1,opt,name=type,enum=fission.workflows.types.TaskDependencyParameters_DependencyType" json:"type,omitempty"`
	Alias string                                  `protobuf:"bytes,2,opt,name=alias" json:"alias,omitempty"`
}

type TaskDependencyParameters_DependencyType int32

type TaskInvocation struct {
	Metadata *ObjectMetadata       `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	Spec     *TaskInvocationSpec   `protobuf:"bytes,2,opt,name=spec" json:"spec,omitempty"`
	Status   *TaskInvocationStatus `protobuf:"bytes,3,opt,name=status" json:"status,omitempty"`
}

type TaskInvocationSpec struct {
	// Id of the task to be invoked (no ambiguity at this point)
	FnRef *FnRef `protobuf:"bytes,1,opt,name=fnRef" json:"fnRef,omitempty"`
	// TaskId is the id of the task within the workflow
	//
	// Deprecated: use task.metadata.id instead to reference the workflow.
	TaskId string `protobuf:"bytes,2,opt,name=taskId" json:"taskId,omitempty"`
	// Inputs contain all inputs to the task invocation
	Inputs map[string]*fission_workflows_types.TypedValue `` /* 132-byte string literal not displayed */
	// InvocationID contains a reference to the workflow invocation of this task.
	InvocationId string `protobuf:"bytes,4,opt,name=invocationId" json:"invocationId,omitempty"`
	// Task contains a snapshot of the task that needs to be run.
	Task *Task `protobuf:"bytes,5,opt,name=task" json:"task,omitempty"`
	// Deadline is the timestamp before which the task invocation needs to be completed.
	//
	// The field is a hard deadline; any invocation exceeding the deadline specified here will be canceled.
	// Each task has a deadline. If no deadline is specified the task invocation inherits the deadline of the
	// invocation.
	Deadline *google_protobuf.Timestamp `protobuf:"bytes,6,opt,name=Deadline" json:"Deadline,omitempty"`
}

type TaskInvocationStatus struct {
	Status        TaskInvocationStatus_Status         `protobuf:"varint,1,opt,name=status,enum=fission.workflows.types.TaskInvocationStatus_Status" json:"status,omitempty"`
	UpdatedAt     *google_protobuf.Timestamp          `protobuf:"bytes,2,opt,name=updatedAt" json:"updatedAt,omitempty"`
	Output        *fission_workflows_types.TypedValue `protobuf:"bytes,3,opt,name=output" json:"output,omitempty"`
	Error         *Error                              `protobuf:"bytes,4,opt,name=error" json:"error,omitempty"`
	OutputHeaders *fission_workflows_types.TypedValue `protobuf:"bytes,5,opt,name=outputHeaders" json:"outputHeaders,omitempty"`
}

type TaskInvocationStatus_Status int32

type TaskSpec struct {
	// FunctionRef contains an identifier for the function.
	//
	// This possibly ambiguous reference will be resolved to a unambiguous function reference during the workflow
	// parsing. The result of this is found in the TaskStatus.FnRef.
	FunctionRef string                                         `protobuf:"bytes,1,opt,name=functionRef" json:"functionRef,omitempty"`
	Inputs      map[string]*fission_workflows_types.TypedValue `` /* 132-byte string literal not displayed */
	// Dependencies for this task to execute.
	Requires map[string]*TaskDependencyParameters `` /* 136-byte string literal not displayed */
	// Await signals the number of dependencies to wait for before this task can be started.
	Await int32 `protobuf:"varint,4,opt,name=await" json:"await,omitempty"`
	// Output transforms or overrides the output of the executed function.
	Output *fission_workflows_types.TypedValue `protobuf:"bytes,5,opt,name=output" json:"output,omitempty"`
	// OutputHeaders transforms or overrides the output headers of the executed function.
	OutputHeaders *fission_workflows_types.TypedValue `protobuf:"bytes,6,opt,name=outputHeaders" json:"outputHeaders,omitempty"`
	// Timeout specifies the the maximum runtime duration when executing this task.
	//
	// It overrides the deadline specified by the workflow invocation, but cannot exceed it. If set, this field will be
	// used in the task invocation spec to compute the deadline.
	Timeout         *google_protobuf1.Duration `protobuf:"bytes,7,opt,name=timeout" json:"timeout,omitempty"`
	ExecConstraints *TaskDataflowSpec          `protobuf:"bytes,8,opt,name=execConstraints" json:"execConstraints,omitempty"`
	ProvenanceMeta  *ProvenanceMetadata        `protobuf:"bytes,9,opt,name=provenanceMeta" json:"provenanceMeta,omitempty"`
}

type TaskStatus struct {
	Status    TaskStatus_Status          `protobuf:"varint,1,opt,name=status,enum=fission.workflows.types.TaskStatus_Status" json:"status,omitempty"`
	UpdatedAt *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=updatedAt" json:"updatedAt,omitempty"`
	// The main fnRef for executing the task. Keeping this field in order to
	// preserve backward compatibility when dataflow extension is disabled
	FnRef *FnRef `protobuf:"bytes,3,opt,name=fnRef" json:"fnRef,omitempty"`
	Error *Error `protobuf:"bytes,4,opt,name=error" json:"error,omitempty"`
	// Alternative FnRefs that the task can be executed from if the main FnRef
	// is deemed to busy or zoneHints suggest the better alternative for execution
	// map<function-zone, FnRef>
	AltFnRefs map[string]*FnRef `` /* 138-byte string literal not displayed */
	// Record the original function identified in the task spec run field.
	BaseFnName string `protobuf:"bytes,6,opt,name=baseFnName" json:"baseFnName,omitempty"`
}

type TaskStatus_Status int32

type Tasks map[string]*TaskSpec

type TypedValueList struct {
	Value []*fission_workflows_types.TypedValue `protobuf:"bytes,1,rep,name=Value" json:"Value,omitempty"`
}

type TypedValueMap struct {
	Value map[string]*fission_workflows_types.TypedValue `` /* 130-byte string literal not displayed */
}

type Workflow struct {
	Metadata *ObjectMetadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	Spec     *WorkflowSpec   `protobuf:"bytes,2,opt,name=spec" json:"spec,omitempty"`
	Status   *WorkflowStatus `protobuf:"bytes,3,opt,name=status" json:"status,omitempty"`
}

type WorkflowInvocation struct {
	Metadata *ObjectMetadata           `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	Spec     *WorkflowInvocationSpec   `protobuf:"bytes,2,opt,name=spec" json:"spec,omitempty"`
	Status   *WorkflowInvocationStatus `protobuf:"bytes,3,opt,name=status" json:"status,omitempty"`
}

type WorkflowInvocationSpec struct {
	// WorkflowId contains a reference to the workflow that needs to be executed.
	//
	// Deprecated: use workflow.metadata.id instead to reference the workflow.
	WorkflowId string                                         `protobuf:"bytes,1,opt,name=workflowId" json:"workflowId,omitempty"`
	Inputs     map[string]*fission_workflows_types.TypedValue `` /* 132-byte string literal not displayed */
	// ParentId contains the id of the encapsulating workflow invocation.
	//
	// This used within the workflow engine; for user-provided workflow invocations the parentId is ignored.
	ParentId string `protobuf:"bytes,3,opt,name=parentId" json:"parentId,omitempty"`
	// Workflow contains the workflow that should be invoked.
	//
	// The workflow here is a snapshot; it should be considered immutable after added to the spec.
	Workflow *Workflow `protobuf:"bytes,4,opt,name=workflow" json:"workflow,omitempty"`
	// Deadline is the timestamp before which the workflow invocation needs to be completed.
	//
	// The field is a hard deadline; any invocation exceeding the deadline specified here will be canceled.
	// Each invocation has a deadline. If no deadline is provided Fission Workflows uses a default deadline (typically
	// 10 minutes).
	Deadline *google_protobuf.Timestamp `protobuf:"bytes,5,opt,name=Deadline" json:"Deadline,omitempty"`
	// The value to look up in the consent store (extracted from x-consent)
	// header. If the dataflow spec calls for a consent check this field is
	// required to proceed with an invocation
	ConsentId string `protobuf:"bytes,6,opt,name=consentId" json:"consentId,omitempty"`
	// Optional map of taskId's to Zones, allowing us to take into account which
	// zone a task should be executed in at RUN-TIME rather then creation time
	// if a given task identifier is not present it is ignored
	TaskHints map[string]Zone `` /* 173-byte string literal not displayed */
}

type WorkflowInvocationStatus struct {
	Status    WorkflowInvocationStatus_Status     `protobuf:"varint,1,opt,name=status,enum=fission.workflows.types.WorkflowInvocationStatus_Status" json:"status,omitempty"`
	UpdatedAt *google_protobuf.Timestamp          `protobuf:"bytes,2,opt,name=updatedAt" json:"updatedAt,omitempty"`
	Tasks     map[string]*TaskInvocation          `` /* 130-byte string literal not displayed */
	Output    *fission_workflows_types.TypedValue `protobuf:"bytes,4,opt,name=output" json:"output,omitempty"`
	// In case the task ID also exists in the workflow spec, the dynamic task will be
	// used as an overlay over the static task.
	DynamicTasks  map[string]*Task                    `` /* 144-byte string literal not displayed */
	Error         *Error                              `protobuf:"bytes,6,opt,name=error" json:"error,omitempty"`
	OutputHeaders *fission_workflows_types.TypedValue `protobuf:"bytes,7,opt,name=outputHeaders" json:"outputHeaders,omitempty"`
}

type WorkflowInvocationStatus_Status int32

type WorkflowInvocations []*WorkflowInvocation

type WorkflowSpec struct {
	// apiVersion describes what version is of the workflow definition.
	// By default the workflow engine will assume the latest version to be used.
	ApiVersion string `protobuf:"bytes,1,opt,name=apiVersion" json:"apiVersion,omitempty"`
	// Tasks contains the specs of the tasks, with the key being the task id.
	//
	// Note: Dependency graph is build into the tasks.
	Tasks map[string]*TaskSpec `` /* 130-byte string literal not displayed */
	// From which task should the workflow return the output? Future: multiple? Implicit?
	OutputTask  string `protobuf:"bytes,3,opt,name=outputTask" json:"outputTask,omitempty"`
	Description string `protobuf:"bytes,4,opt,name=description" json:"description,omitempty"`
	// The UID that the workflow should have. Only use this in case you want to force a specific UID.
	ForceId string `protobuf:"bytes,5,opt,name=forceId" json:"forceId,omitempty"`
	// Name is solely for human-readablity
	Name string `protobuf:"bytes,6,opt,name=name" json:"name,omitempty"`
	// Internal indicates whether is a workflow should be visible to a human (default) or not.
	Internal bool `protobuf:"varint,7,opt,name=internal" json:"internal,omitempty"`
	// Added with DataFlow privacy extension, specifies weather for the given
	// tasks data privacy measures should be taken. Such as verifying consent and
	// generating provenance data or region locking the execution of workflow
	Dataflow *DataFlowSpec `protobuf:"bytes,8,opt,name=dataflow" json:"dataflow,omitempty"`
}

type WorkflowStatus struct {
	Status    WorkflowStatus_Status      `protobuf:"varint,1,opt,name=status,enum=fission.workflows.types.WorkflowStatus_Status" json:"status,omitempty"`
	UpdatedAt *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=updatedAt" json:"updatedAt,omitempty"`
	// Tasks contains the status of the tasks, with the key being the task id.
	Tasks map[string]*Task `` /* 130-byte string literal not displayed */
	Error *Error           `protobuf:"bytes,4,opt,name=error" json:"error,omitempty"`
}

type WorkflowStatus_Status int32

type Zone int32