workflows

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jul 7, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Copyright 2022 Evan Hazlett

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthWorkflows        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWorkflows          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWorkflows = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var WorkflowPriority_name = map[int32]string{
	0:  "NORMAL",
	1:  "LOW",
	2:  "URGENT",
	10: "UNKNOWN",
}
View Source 
var WorkflowPriority_value = map[string]int32{
	"NORMAL":  0,
	"LOW":     1,
	"URGENT":  2,
	"UNKNOWN": 10,
}
View Source 
var WorkflowStatus_name = map[int32]string{
	0: "PENDING",
	1: "ASSIGNED",
	2: "WAITING",
	3: "RUNNING",
	4: "ERROR",
	5: "COMPLETE",
}
View Source 
var WorkflowStatus_value = map[string]int32{
	"PENDING":  0,
	"ASSIGNED": 1,
	"WAITING":  2,
	"RUNNING":  3,
	"ERROR":    4,
	"COMPLETE": 5,
}

Functions

func RegisterWorkflowsServer 

func RegisterWorkflowsServer(s *grpc.Server, srv WorkflowsServer)

Types

type DeleteWorkflowRequest 

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

func (*DeleteWorkflowRequest) Descriptor 

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

func (*DeleteWorkflowRequest) GetID 

func (m *DeleteWorkflowRequest) GetID() string

func (*DeleteWorkflowRequest) Marshal 

func (m *DeleteWorkflowRequest) Marshal() (dAtA []byte, err error)

func (*DeleteWorkflowRequest) MarshalTo 

func (m *DeleteWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteWorkflowRequest) MarshalToSizedBuffer 

func (m *DeleteWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteWorkflowRequest) ProtoMessage 

func (*DeleteWorkflowRequest) ProtoMessage()

func (*DeleteWorkflowRequest) Reset 

func (m *DeleteWorkflowRequest) Reset()

func (*DeleteWorkflowRequest) Size 

func (m *DeleteWorkflowRequest) Size() (n int)

func (*DeleteWorkflowRequest) String 

func (m *DeleteWorkflowRequest) String() string

func (*DeleteWorkflowRequest) Unmarshal 

func (m *DeleteWorkflowRequest) Unmarshal(dAtA []byte) error

func (*DeleteWorkflowRequest) XXX_DiscardUnknown 

func (m *DeleteWorkflowRequest) XXX_DiscardUnknown()

func (*DeleteWorkflowRequest) XXX_Marshal 

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

func (*DeleteWorkflowRequest) XXX_Merge 

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

func (*DeleteWorkflowRequest) XXX_Size 

func (m *DeleteWorkflowRequest) XXX_Size() int

func (*DeleteWorkflowRequest) XXX_Unmarshal 

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

type GetWorkflowInputFileRequest 

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

func (*GetWorkflowInputFileRequest) Descriptor 

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

func (*GetWorkflowInputFileRequest) GetStoragePath 

func (m *GetWorkflowInputFileRequest) GetStoragePath() string

func (*GetWorkflowInputFileRequest) Marshal 

func (m *GetWorkflowInputFileRequest) Marshal() (dAtA []byte, err error)

func (*GetWorkflowInputFileRequest) MarshalTo 

func (m *GetWorkflowInputFileRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetWorkflowInputFileRequest) MarshalToSizedBuffer 

func (m *GetWorkflowInputFileRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWorkflowInputFileRequest) ProtoMessage 

func (*GetWorkflowInputFileRequest) ProtoMessage()

func (*GetWorkflowInputFileRequest) Reset 

func (m *GetWorkflowInputFileRequest) Reset()

func (*GetWorkflowInputFileRequest) Size 

func (m *GetWorkflowInputFileRequest) Size() (n int)

func (*GetWorkflowInputFileRequest) String 

func (m *GetWorkflowInputFileRequest) String() string

func (*GetWorkflowInputFileRequest) Unmarshal 

func (m *GetWorkflowInputFileRequest) Unmarshal(dAtA []byte) error

func (*GetWorkflowInputFileRequest) XXX_DiscardUnknown 

func (m *GetWorkflowInputFileRequest) XXX_DiscardUnknown()

func (*GetWorkflowInputFileRequest) XXX_Marshal 

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

func (*GetWorkflowInputFileRequest) XXX_Merge 

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

func (*GetWorkflowInputFileRequest) XXX_Size 

func (m *GetWorkflowInputFileRequest) XXX_Size() int

func (*GetWorkflowInputFileRequest) XXX_Unmarshal 

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

type GetWorkflowRequest 

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

func (*GetWorkflowRequest) Descriptor 

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

func (*GetWorkflowRequest) GetID 

func (m *GetWorkflowRequest) GetID() string

func (*GetWorkflowRequest) Marshal 

func (m *GetWorkflowRequest) Marshal() (dAtA []byte, err error)

func (*GetWorkflowRequest) MarshalTo 

func (m *GetWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetWorkflowRequest) MarshalToSizedBuffer 

func (m *GetWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWorkflowRequest) ProtoMessage 

func (*GetWorkflowRequest) ProtoMessage()

func (*GetWorkflowRequest) Reset 

func (m *GetWorkflowRequest) Reset()

func (*GetWorkflowRequest) Size 

func (m *GetWorkflowRequest) Size() (n int)

func (*GetWorkflowRequest) String 

func (m *GetWorkflowRequest) String() string

func (*GetWorkflowRequest) Unmarshal 

func (m *GetWorkflowRequest) Unmarshal(dAtA []byte) error

func (*GetWorkflowRequest) XXX_DiscardUnknown 

func (m *GetWorkflowRequest) XXX_DiscardUnknown()

func (*GetWorkflowRequest) XXX_Marshal 

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

func (*GetWorkflowRequest) XXX_Merge 

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

func (*GetWorkflowRequest) XXX_Size 

func (m *GetWorkflowRequest) XXX_Size() int

func (*GetWorkflowRequest) XXX_Unmarshal 

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

type GetWorkflowResponse 

type GetWorkflowResponse struct {
	Workflow             *Workflow `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetWorkflowResponse) Descriptor 

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

func (*GetWorkflowResponse) GetWorkflow 

func (m *GetWorkflowResponse) GetWorkflow() *Workflow

func (*GetWorkflowResponse) Marshal 

func (m *GetWorkflowResponse) Marshal() (dAtA []byte, err error)

func (*GetWorkflowResponse) MarshalTo 

func (m *GetWorkflowResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetWorkflowResponse) MarshalToSizedBuffer 

func (m *GetWorkflowResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWorkflowResponse) ProtoMessage 

func (*GetWorkflowResponse) ProtoMessage()

func (*GetWorkflowResponse) Reset 

func (m *GetWorkflowResponse) Reset()

func (*GetWorkflowResponse) Size 

func (m *GetWorkflowResponse) Size() (n int)

func (*GetWorkflowResponse) String 

func (m *GetWorkflowResponse) String() string

func (*GetWorkflowResponse) Unmarshal 

func (m *GetWorkflowResponse) Unmarshal(dAtA []byte) error

func (*GetWorkflowResponse) XXX_DiscardUnknown 

func (m *GetWorkflowResponse) XXX_DiscardUnknown()

func (*GetWorkflowResponse) XXX_Marshal 

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

func (*GetWorkflowResponse) XXX_Merge 

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

func (*GetWorkflowResponse) XXX_Size 

func (m *GetWorkflowResponse) XXX_Size() int

func (*GetWorkflowResponse) XXX_Unmarshal 

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

type ListWorkflowInputsRequest 

type ListWorkflowInputsRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListWorkflowInputsRequest) Descriptor 

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

func (*ListWorkflowInputsRequest) GetID 

func (m *ListWorkflowInputsRequest) GetID() string

func (*ListWorkflowInputsRequest) GetNamespace 

func (m *ListWorkflowInputsRequest) GetNamespace() string

func (*ListWorkflowInputsRequest) Marshal 

func (m *ListWorkflowInputsRequest) Marshal() (dAtA []byte, err error)

func (*ListWorkflowInputsRequest) MarshalTo 

func (m *ListWorkflowInputsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListWorkflowInputsRequest) MarshalToSizedBuffer 

func (m *ListWorkflowInputsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListWorkflowInputsRequest) ProtoMessage 

func (*ListWorkflowInputsRequest) ProtoMessage()

func (*ListWorkflowInputsRequest) Reset 

func (m *ListWorkflowInputsRequest) Reset()

func (*ListWorkflowInputsRequest) Size 

func (m *ListWorkflowInputsRequest) Size() (n int)

func (*ListWorkflowInputsRequest) String 

func (m *ListWorkflowInputsRequest) String() string

func (*ListWorkflowInputsRequest) Unmarshal 

func (m *ListWorkflowInputsRequest) Unmarshal(dAtA []byte) error

func (*ListWorkflowInputsRequest) XXX_DiscardUnknown 

func (m *ListWorkflowInputsRequest) XXX_DiscardUnknown()

func (*ListWorkflowInputsRequest) XXX_Marshal 

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

func (*ListWorkflowInputsRequest) XXX_Merge 

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

func (*ListWorkflowInputsRequest) XXX_Size 

func (m *ListWorkflowInputsRequest) XXX_Size() int

func (*ListWorkflowInputsRequest) XXX_Unmarshal 

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

type ListWorkflowInputsResponse 

type ListWorkflowInputsResponse struct {
	Files                []*WorkflowInputFile `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ListWorkflowInputsResponse) Descriptor 

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

func (*ListWorkflowInputsResponse) GetFiles 

func (m *ListWorkflowInputsResponse) GetFiles() []*WorkflowInputFile

func (*ListWorkflowInputsResponse) Marshal 

func (m *ListWorkflowInputsResponse) Marshal() (dAtA []byte, err error)

func (*ListWorkflowInputsResponse) MarshalTo 

func (m *ListWorkflowInputsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListWorkflowInputsResponse) MarshalToSizedBuffer 

func (m *ListWorkflowInputsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListWorkflowInputsResponse) ProtoMessage 

func (*ListWorkflowInputsResponse) ProtoMessage()

func (*ListWorkflowInputsResponse) Reset 

func (m *ListWorkflowInputsResponse) Reset()

func (*ListWorkflowInputsResponse) Size 

func (m *ListWorkflowInputsResponse) Size() (n int)

func (*ListWorkflowInputsResponse) String 

func (m *ListWorkflowInputsResponse) String() string

func (*ListWorkflowInputsResponse) Unmarshal 

func (m *ListWorkflowInputsResponse) Unmarshal(dAtA []byte) error

func (*ListWorkflowInputsResponse) XXX_DiscardUnknown 

func (m *ListWorkflowInputsResponse) XXX_DiscardUnknown()

func (*ListWorkflowInputsResponse) XXX_Marshal 

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

func (*ListWorkflowInputsResponse) XXX_Merge 

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

func (*ListWorkflowInputsResponse) XXX_Size 

func (m *ListWorkflowInputsResponse) XXX_Size() int

func (*ListWorkflowInputsResponse) XXX_Unmarshal 

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

type ListWorkflowProcessorsRequest 

type ListWorkflowProcessorsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListWorkflowProcessorsRequest) Descriptor 

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

func (*ListWorkflowProcessorsRequest) Marshal 

func (m *ListWorkflowProcessorsRequest) Marshal() (dAtA []byte, err error)

func (*ListWorkflowProcessorsRequest) MarshalTo 

func (m *ListWorkflowProcessorsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListWorkflowProcessorsRequest) MarshalToSizedBuffer 

func (m *ListWorkflowProcessorsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListWorkflowProcessorsRequest) ProtoMessage 

func (*ListWorkflowProcessorsRequest) ProtoMessage()

func (*ListWorkflowProcessorsRequest) Reset 

func (m *ListWorkflowProcessorsRequest) Reset()

func (*ListWorkflowProcessorsRequest) Size 

func (m *ListWorkflowProcessorsRequest) Size() (n int)

func (*ListWorkflowProcessorsRequest) String 

func (m *ListWorkflowProcessorsRequest) String() string

func (*ListWorkflowProcessorsRequest) Unmarshal 

func (m *ListWorkflowProcessorsRequest) Unmarshal(dAtA []byte) error

func (*ListWorkflowProcessorsRequest) XXX_DiscardUnknown 

func (m *ListWorkflowProcessorsRequest) XXX_DiscardUnknown()

func (*ListWorkflowProcessorsRequest) XXX_Marshal 

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

func (*ListWorkflowProcessorsRequest) XXX_Merge 

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

func (*ListWorkflowProcessorsRequest) XXX_Size 

func (m *ListWorkflowProcessorsRequest) XXX_Size() int

func (*ListWorkflowProcessorsRequest) XXX_Unmarshal 

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

type ListWorkflowProcessorsResponse 

type ListWorkflowProcessorsResponse struct {
	Processors           []*ProcessorInfo `protobuf:"bytes,1,rep,name=processors,proto3" json:"processors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ListWorkflowProcessorsResponse) Descriptor 

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

func (*ListWorkflowProcessorsResponse) GetProcessors 

func (m *ListWorkflowProcessorsResponse) GetProcessors() []*ProcessorInfo

func (*ListWorkflowProcessorsResponse) Marshal 

func (m *ListWorkflowProcessorsResponse) Marshal() (dAtA []byte, err error)

func (*ListWorkflowProcessorsResponse) MarshalTo 

func (m *ListWorkflowProcessorsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListWorkflowProcessorsResponse) MarshalToSizedBuffer 

func (m *ListWorkflowProcessorsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListWorkflowProcessorsResponse) ProtoMessage 

func (*ListWorkflowProcessorsResponse) ProtoMessage()

func (*ListWorkflowProcessorsResponse) Reset 

func (m *ListWorkflowProcessorsResponse) Reset()

func (*ListWorkflowProcessorsResponse) Size 

func (m *ListWorkflowProcessorsResponse) Size() (n int)

func (*ListWorkflowProcessorsResponse) String 

func (m *ListWorkflowProcessorsResponse) String() string

func (*ListWorkflowProcessorsResponse) Unmarshal 

func (m *ListWorkflowProcessorsResponse) Unmarshal(dAtA []byte) error

func (*ListWorkflowProcessorsResponse) XXX_DiscardUnknown 

func (m *ListWorkflowProcessorsResponse) XXX_DiscardUnknown()

func (*ListWorkflowProcessorsResponse) XXX_Marshal 

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

func (*ListWorkflowProcessorsResponse) XXX_Merge 

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

func (*ListWorkflowProcessorsResponse) XXX_Size 

func (m *ListWorkflowProcessorsResponse) XXX_Size() int

func (*ListWorkflowProcessorsResponse) XXX_Unmarshal 

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

type ListWorkflowsRequest 

type ListWorkflowsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListWorkflowsRequest) Descriptor 

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

func (*ListWorkflowsRequest) Marshal 

func (m *ListWorkflowsRequest) Marshal() (dAtA []byte, err error)

func (*ListWorkflowsRequest) MarshalTo 

func (m *ListWorkflowsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListWorkflowsRequest) MarshalToSizedBuffer 

func (m *ListWorkflowsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListWorkflowsRequest) ProtoMessage 

func (*ListWorkflowsRequest) ProtoMessage()

func (*ListWorkflowsRequest) Reset 

func (m *ListWorkflowsRequest) Reset()

func (*ListWorkflowsRequest) Size 

func (m *ListWorkflowsRequest) Size() (n int)

func (*ListWorkflowsRequest) String 

func (m *ListWorkflowsRequest) String() string

func (*ListWorkflowsRequest) Unmarshal 

func (m *ListWorkflowsRequest) Unmarshal(dAtA []byte) error

func (*ListWorkflowsRequest) XXX_DiscardUnknown 

func (m *ListWorkflowsRequest) XXX_DiscardUnknown()

func (*ListWorkflowsRequest) XXX_Marshal 

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

func (*ListWorkflowsRequest) XXX_Merge 

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

func (*ListWorkflowsRequest) XXX_Size 

func (m *ListWorkflowsRequest) XXX_Size() int

func (*ListWorkflowsRequest) XXX_Unmarshal 

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

type ListWorkflowsResponse 

type ListWorkflowsResponse struct {
	Workflows            []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ListWorkflowsResponse) Descriptor 

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

func (*ListWorkflowsResponse) GetWorkflows 

func (m *ListWorkflowsResponse) GetWorkflows() []*Workflow

func (*ListWorkflowsResponse) Marshal 

func (m *ListWorkflowsResponse) Marshal() (dAtA []byte, err error)

func (*ListWorkflowsResponse) MarshalTo 

func (m *ListWorkflowsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListWorkflowsResponse) MarshalToSizedBuffer 

func (m *ListWorkflowsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListWorkflowsResponse) ProtoMessage 

func (*ListWorkflowsResponse) ProtoMessage()

func (*ListWorkflowsResponse) Reset 

func (m *ListWorkflowsResponse) Reset()

func (*ListWorkflowsResponse) Size 

func (m *ListWorkflowsResponse) Size() (n int)

func (*ListWorkflowsResponse) String 

func (m *ListWorkflowsResponse) String() string

func (*ListWorkflowsResponse) Unmarshal 

func (m *ListWorkflowsResponse) Unmarshal(dAtA []byte) error

func (*ListWorkflowsResponse) XXX_DiscardUnknown 

func (m *ListWorkflowsResponse) XXX_DiscardUnknown()

func (*ListWorkflowsResponse) XXX_Marshal 

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

func (*ListWorkflowsResponse) XXX_Merge 

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

func (*ListWorkflowsResponse) XXX_Size 

func (m *ListWorkflowsResponse) XXX_Size() int

func (*ListWorkflowsResponse) XXX_Unmarshal 

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

type ProcessorInfo 

type ProcessorInfo struct {
	ID                   string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type                 string          `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	MaxWorkflows         uint64          `protobuf:"varint,3,opt,name=max_workflows,json=maxWorkflows,proto3" json:"max_workflows,omitempty"`
	StartedAt            time.Time       `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3,stdtime" json:"started_at"`
	CPUs                 uint32          `protobuf:"varint,5,opt,name=cpus,proto3" json:"cpus,omitempty"`
	MemoryTotal          int64           `protobuf:"varint,6,opt,name=memory_total,json=memoryTotal,proto3" json:"memory_total,omitempty"`
	MemoryAvailable      int64           `protobuf:"varint,7,opt,name=memory_available,json=memoryAvailable,proto3" json:"memory_available,omitempty"`
	GPUs                 []string        `protobuf:"bytes,8,rep,name=gpus,proto3" json:"gpus,omitempty"`
	Load1                float64         `protobuf:"fixed64,9,opt,name=load1,proto3" json:"load1,omitempty"`
	Load5                float64         `protobuf:"fixed64,10,opt,name=load5,proto3" json:"load5,omitempty"`
	Load15               float64         `protobuf:"fixed64,11,opt,name=load15,proto3" json:"load15,omitempty"`
	Scope                *ProcessorScope `protobuf:"bytes,12,opt,name=scope,proto3" json:"scope,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ProcessorInfo) Descriptor 

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

func (*ProcessorInfo) GetCPUs 

func (m *ProcessorInfo) GetCPUs() uint32

func (*ProcessorInfo) GetGPUs 

func (m *ProcessorInfo) GetGPUs() []string

func (*ProcessorInfo) GetID 

func (m *ProcessorInfo) GetID() string

func (*ProcessorInfo) GetLoad1 

func (m *ProcessorInfo) GetLoad1() float64

func (*ProcessorInfo) GetLoad5 

func (m *ProcessorInfo) GetLoad5() float64

func (*ProcessorInfo) GetLoad15 

func (m *ProcessorInfo) GetLoad15() float64

func (*ProcessorInfo) GetMaxWorkflows 

func (m *ProcessorInfo) GetMaxWorkflows() uint64

func (*ProcessorInfo) GetMemoryAvailable 

func (m *ProcessorInfo) GetMemoryAvailable() int64

func (*ProcessorInfo) GetMemoryTotal 

func (m *ProcessorInfo) GetMemoryTotal() int64

func (*ProcessorInfo) GetScope 

func (m *ProcessorInfo) GetScope() *ProcessorScope

func (*ProcessorInfo) GetStartedAt 

func (m *ProcessorInfo) GetStartedAt() time.Time

func (*ProcessorInfo) GetType 

func (m *ProcessorInfo) GetType() string

func (*ProcessorInfo) Marshal 

func (m *ProcessorInfo) Marshal() (dAtA []byte, err error)

func (*ProcessorInfo) MarshalTo 

func (m *ProcessorInfo) MarshalTo(dAtA []byte) (int, error)

func (*ProcessorInfo) MarshalToSizedBuffer 

func (m *ProcessorInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProcessorInfo) ProtoMessage 

func (*ProcessorInfo) ProtoMessage()

func (*ProcessorInfo) Reset 

func (m *ProcessorInfo) Reset()

func (*ProcessorInfo) Size 

func (m *ProcessorInfo) Size() (n int)

func (*ProcessorInfo) String 

func (m *ProcessorInfo) String() string

func (*ProcessorInfo) Unmarshal 

func (m *ProcessorInfo) Unmarshal(dAtA []byte) error

func (*ProcessorInfo) XXX_DiscardUnknown 

func (m *ProcessorInfo) XXX_DiscardUnknown()

func (*ProcessorInfo) XXX_Marshal 

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

func (*ProcessorInfo) XXX_Merge 

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

func (*ProcessorInfo) XXX_Size 

func (m *ProcessorInfo) XXX_Size() int

func (*ProcessorInfo) XXX_Unmarshal 

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

type ProcessorScope 

type ProcessorScope struct {
	// Types that are valid to be assigned to Scope:
	//	*ProcessorScope_Global
	//	*ProcessorScope_Namespace
	Scope                isProcessorScope_Scope `protobuf_oneof:"scope"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ProcessorScope) Descriptor 

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

func (*ProcessorScope) GetGlobal 

func (m *ProcessorScope) GetGlobal() bool

func (*ProcessorScope) GetNamespace 

func (m *ProcessorScope) GetNamespace() string

func (*ProcessorScope) GetScope 

func (m *ProcessorScope) GetScope() isProcessorScope_Scope

func (*ProcessorScope) Marshal 

func (m *ProcessorScope) Marshal() (dAtA []byte, err error)

func (*ProcessorScope) MarshalTo 

func (m *ProcessorScope) MarshalTo(dAtA []byte) (int, error)

func (*ProcessorScope) MarshalToSizedBuffer 

func (m *ProcessorScope) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProcessorScope) ProtoMessage 

func (*ProcessorScope) ProtoMessage()

func (*ProcessorScope) Reset 

func (m *ProcessorScope) Reset()

func (*ProcessorScope) Size 

func (m *ProcessorScope) Size() (n int)

func (*ProcessorScope) String 

func (m *ProcessorScope) String() string

func (*ProcessorScope) Unmarshal 

func (m *ProcessorScope) Unmarshal(dAtA []byte) error

func (*ProcessorScope) XXX_DiscardUnknown 

func (m *ProcessorScope) XXX_DiscardUnknown()

func (*ProcessorScope) XXX_Marshal 

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

func (*ProcessorScope) XXX_Merge 

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

func (*ProcessorScope) XXX_OneofWrappers 

func (*ProcessorScope) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ProcessorScope) XXX_Size 

func (m *ProcessorScope) XXX_Size() int

func (*ProcessorScope) XXX_Unmarshal 

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

type ProcessorScope_Global 

type ProcessorScope_Global struct {
	Global bool `protobuf:"varint,1,opt,name=global,proto3,oneof" json:"global,omitempty"`
}

func (*ProcessorScope_Global) MarshalTo 

func (m *ProcessorScope_Global) MarshalTo(dAtA []byte) (int, error)

func (*ProcessorScope_Global) MarshalToSizedBuffer 

func (m *ProcessorScope_Global) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProcessorScope_Global) Size 

func (m *ProcessorScope_Global) Size() (n int)

type ProcessorScope_Namespace 

type ProcessorScope_Namespace struct {
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
}

func (*ProcessorScope_Namespace) MarshalTo 

func (m *ProcessorScope_Namespace) MarshalTo(dAtA []byte) (int, error)

func (*ProcessorScope_Namespace) MarshalToSizedBuffer 

func (m *ProcessorScope_Namespace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProcessorScope_Namespace) Size 

func (m *ProcessorScope_Namespace) Size() (n int)

type QueueWorkflowRequest 

type QueueWorkflowRequest struct {
	// Types that are valid to be assigned to Data:
	//	*QueueWorkflowRequest_Request
	//	*QueueWorkflowRequest_ChunkData
	Data                 isQueueWorkflowRequest_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*QueueWorkflowRequest) Descriptor 

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

func (*QueueWorkflowRequest) GetChunkData 

func (m *QueueWorkflowRequest) GetChunkData() []byte

func (*QueueWorkflowRequest) GetData 

func (m *QueueWorkflowRequest) GetData() isQueueWorkflowRequest_Data

func (*QueueWorkflowRequest) GetRequest 

func (m *QueueWorkflowRequest) GetRequest() *WorkflowRequest

func (*QueueWorkflowRequest) Marshal 

func (m *QueueWorkflowRequest) Marshal() (dAtA []byte, err error)

func (*QueueWorkflowRequest) MarshalTo 

func (m *QueueWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueueWorkflowRequest) MarshalToSizedBuffer 

func (m *QueueWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueueWorkflowRequest) ProtoMessage 

func (*QueueWorkflowRequest) ProtoMessage()

func (*QueueWorkflowRequest) Reset 

func (m *QueueWorkflowRequest) Reset()

func (*QueueWorkflowRequest) Size 

func (m *QueueWorkflowRequest) Size() (n int)

func (*QueueWorkflowRequest) String 

func (m *QueueWorkflowRequest) String() string

func (*QueueWorkflowRequest) Unmarshal 

func (m *QueueWorkflowRequest) Unmarshal(dAtA []byte) error

func (*QueueWorkflowRequest) XXX_DiscardUnknown 

func (m *QueueWorkflowRequest) XXX_DiscardUnknown()

func (*QueueWorkflowRequest) XXX_Marshal 

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

func (*QueueWorkflowRequest) XXX_Merge 

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

func (*QueueWorkflowRequest) XXX_OneofWrappers 

func (*QueueWorkflowRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*QueueWorkflowRequest) XXX_Size 

func (m *QueueWorkflowRequest) XXX_Size() int

func (*QueueWorkflowRequest) XXX_Unmarshal 

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

type QueueWorkflowRequest_ChunkData 

type QueueWorkflowRequest_ChunkData struct {
	ChunkData []byte `protobuf:"bytes,2,opt,name=chunk_data,json=chunkData,proto3,oneof" json:"chunk_data,omitempty"`
}

func (*QueueWorkflowRequest_ChunkData) MarshalTo 

func (m *QueueWorkflowRequest_ChunkData) MarshalTo(dAtA []byte) (int, error)

func (*QueueWorkflowRequest_ChunkData) MarshalToSizedBuffer 

func (m *QueueWorkflowRequest_ChunkData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueueWorkflowRequest_ChunkData) Size 

func (m *QueueWorkflowRequest_ChunkData) Size() (n int)

type QueueWorkflowRequest_Request 

type QueueWorkflowRequest_Request struct {
	Request *WorkflowRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof" json:"request,omitempty"`
}

func (*QueueWorkflowRequest_Request) MarshalTo 

func (m *QueueWorkflowRequest_Request) MarshalTo(dAtA []byte) (int, error)

func (*QueueWorkflowRequest_Request) MarshalToSizedBuffer 

func (m *QueueWorkflowRequest_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueueWorkflowRequest_Request) Size 

func (m *QueueWorkflowRequest_Request) Size() (n int)

type QueueWorkflowResponse 

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

func (*QueueWorkflowResponse) Descriptor 

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

func (*QueueWorkflowResponse) GetID 

func (m *QueueWorkflowResponse) GetID() string

func (*QueueWorkflowResponse) Marshal 

func (m *QueueWorkflowResponse) Marshal() (dAtA []byte, err error)

func (*QueueWorkflowResponse) MarshalTo 

func (m *QueueWorkflowResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueueWorkflowResponse) MarshalToSizedBuffer 

func (m *QueueWorkflowResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueueWorkflowResponse) ProtoMessage 

func (*QueueWorkflowResponse) ProtoMessage()

func (*QueueWorkflowResponse) Reset 

func (m *QueueWorkflowResponse) Reset()

func (*QueueWorkflowResponse) Size 

func (m *QueueWorkflowResponse) Size() (n int)

func (*QueueWorkflowResponse) String 

func (m *QueueWorkflowResponse) String() string

func (*QueueWorkflowResponse) Unmarshal 

func (m *QueueWorkflowResponse) Unmarshal(dAtA []byte) error

func (*QueueWorkflowResponse) XXX_DiscardUnknown 

func (m *QueueWorkflowResponse) XXX_DiscardUnknown()

func (*QueueWorkflowResponse) XXX_Marshal 

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

func (*QueueWorkflowResponse) XXX_Merge 

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

func (*QueueWorkflowResponse) XXX_Size 

func (m *QueueWorkflowResponse) XXX_Size() int

func (*QueueWorkflowResponse) XXX_Unmarshal 

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

type SubscribeWorkflowEventsRequest 

type SubscribeWorkflowEventsRequest struct {
	// Types that are valid to be assigned to Request:
	//	*SubscribeWorkflowEventsRequest_Info
	//	*SubscribeWorkflowEventsRequest_Output
	//	*SubscribeWorkflowEventsRequest_Ack
	Request              isSubscribeWorkflowEventsRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
	XXX_unrecognized     []byte                                   `json:"-"`
	XXX_sizecache        int32                                    `json:"-"`
}

func (*SubscribeWorkflowEventsRequest) Descriptor 

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

func (*SubscribeWorkflowEventsRequest) GetAck 

func (m *SubscribeWorkflowEventsRequest) GetAck() *WorkflowAck

func (*SubscribeWorkflowEventsRequest) GetInfo 

func (m *SubscribeWorkflowEventsRequest) GetInfo() *ProcessorInfo

func (*SubscribeWorkflowEventsRequest) GetOutput 

func (m *SubscribeWorkflowEventsRequest) GetOutput() *WorkflowOutput

func (*SubscribeWorkflowEventsRequest) GetRequest 

func (m *SubscribeWorkflowEventsRequest) GetRequest() isSubscribeWorkflowEventsRequest_Request

func (*SubscribeWorkflowEventsRequest) Marshal 

func (m *SubscribeWorkflowEventsRequest) Marshal() (dAtA []byte, err error)

func (*SubscribeWorkflowEventsRequest) MarshalTo 

func (m *SubscribeWorkflowEventsRequest) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeWorkflowEventsRequest) MarshalToSizedBuffer 

func (m *SubscribeWorkflowEventsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeWorkflowEventsRequest) ProtoMessage 

func (*SubscribeWorkflowEventsRequest) ProtoMessage()

func (*SubscribeWorkflowEventsRequest) Reset 

func (m *SubscribeWorkflowEventsRequest) Reset()

func (*SubscribeWorkflowEventsRequest) Size 

func (m *SubscribeWorkflowEventsRequest) Size() (n int)

func (*SubscribeWorkflowEventsRequest) String 

func (m *SubscribeWorkflowEventsRequest) String() string

func (*SubscribeWorkflowEventsRequest) Unmarshal 

func (m *SubscribeWorkflowEventsRequest) Unmarshal(dAtA []byte) error

func (*SubscribeWorkflowEventsRequest) XXX_DiscardUnknown 

func (m *SubscribeWorkflowEventsRequest) XXX_DiscardUnknown()

func (*SubscribeWorkflowEventsRequest) XXX_Marshal 

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

func (*SubscribeWorkflowEventsRequest) XXX_Merge 

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

func (*SubscribeWorkflowEventsRequest) XXX_OneofWrappers 

func (*SubscribeWorkflowEventsRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SubscribeWorkflowEventsRequest) XXX_Size 

func (m *SubscribeWorkflowEventsRequest) XXX_Size() int

func (*SubscribeWorkflowEventsRequest) XXX_Unmarshal 

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

type SubscribeWorkflowEventsRequest_Ack 

type SubscribeWorkflowEventsRequest_Ack struct {
	Ack *WorkflowAck `protobuf:"bytes,3,opt,name=ack,proto3,oneof" json:"ack,omitempty"`
}

func (*SubscribeWorkflowEventsRequest_Ack) MarshalTo 

func (m *SubscribeWorkflowEventsRequest_Ack) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeWorkflowEventsRequest_Ack) MarshalToSizedBuffer 

func (m *SubscribeWorkflowEventsRequest_Ack) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeWorkflowEventsRequest_Ack) Size 

func (m *SubscribeWorkflowEventsRequest_Ack) Size() (n int)

type SubscribeWorkflowEventsRequest_Info 

type SubscribeWorkflowEventsRequest_Info struct {
	Info *ProcessorInfo `protobuf:"bytes,1,opt,name=info,proto3,oneof" json:"info,omitempty"`
}

func (*SubscribeWorkflowEventsRequest_Info) MarshalTo 

func (m *SubscribeWorkflowEventsRequest_Info) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeWorkflowEventsRequest_Info) MarshalToSizedBuffer 

func (m *SubscribeWorkflowEventsRequest_Info) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeWorkflowEventsRequest_Info) Size 

func (m *SubscribeWorkflowEventsRequest_Info) Size() (n int)

type SubscribeWorkflowEventsRequest_Output 

type SubscribeWorkflowEventsRequest_Output struct {
	Output *WorkflowOutput `protobuf:"bytes,2,opt,name=output,proto3,oneof" json:"output,omitempty"`
}

func (*SubscribeWorkflowEventsRequest_Output) MarshalTo 

func (m *SubscribeWorkflowEventsRequest_Output) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeWorkflowEventsRequest_Output) MarshalToSizedBuffer 

func (m *SubscribeWorkflowEventsRequest_Output) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeWorkflowEventsRequest_Output) Size 

func (m *SubscribeWorkflowEventsRequest_Output) Size() (n int)

type UnimplementedWorkflowsServer 

type UnimplementedWorkflowsServer struct {
}

UnimplementedWorkflowsServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowsServer) DeleteWorkflow 

func (*UnimplementedWorkflowsServer) DeleteWorkflow(ctx context.Context, req *DeleteWorkflowRequest) (*types.Empty, error)

func (*UnimplementedWorkflowsServer) GetWorkflow 

func (*UnimplementedWorkflowsServer) GetWorkflow(ctx context.Context, req *GetWorkflowRequest) (*GetWorkflowResponse, error)

func (*UnimplementedWorkflowsServer) GetWorkflowInputFile 

func (*UnimplementedWorkflowsServer) GetWorkflowInputFile(req *GetWorkflowInputFileRequest, srv Workflows_GetWorkflowInputFileServer) error

func (*UnimplementedWorkflowsServer) ListWorkflowInputs 

func (*UnimplementedWorkflowsServer) ListWorkflowInputs(ctx context.Context, req *ListWorkflowInputsRequest) (*ListWorkflowInputsResponse, error)

func (*UnimplementedWorkflowsServer) ListWorkflowProcessors 

func (*UnimplementedWorkflowsServer) ListWorkflowProcessors(ctx context.Context, req *ListWorkflowProcessorsRequest) (*ListWorkflowProcessorsResponse, error)

func (*UnimplementedWorkflowsServer) ListWorkflows 

func (*UnimplementedWorkflowsServer) ListWorkflows(ctx context.Context, req *ListWorkflowsRequest) (*ListWorkflowsResponse, error)

func (*UnimplementedWorkflowsServer) QueueWorkflow 

func (*UnimplementedWorkflowsServer) QueueWorkflow(srv Workflows_QueueWorkflowServer) error

func (*UnimplementedWorkflowsServer) SubscribeWorkflowEvents 

func (*UnimplementedWorkflowsServer) SubscribeWorkflowEvents(srv Workflows_SubscribeWorkflowEventsServer) error

func (*UnimplementedWorkflowsServer) UpdateWorkflowOutput 

func (*UnimplementedWorkflowsServer) UpdateWorkflowOutput(ctx context.Context, req *UpdateWorkflowOutputRequest) (*types.Empty, error)

func (*UnimplementedWorkflowsServer) UpdateWorkflowStatus 

func (*UnimplementedWorkflowsServer) UpdateWorkflowStatus(ctx context.Context, req *UpdateWorkflowStatusRequest) (*types.Empty, error)

func (*UnimplementedWorkflowsServer) UploadWorkflowArtifact 

func (*UnimplementedWorkflowsServer) UploadWorkflowArtifact(srv Workflows_UploadWorkflowArtifactServer) error

type UpdateWorkflowOutputRequest 

type UpdateWorkflowOutputRequest struct {
	WorkflowOutput       *WorkflowOutput `protobuf:"bytes,1,opt,name=workflow_output,json=workflowOutput,proto3" json:"workflow_output,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*UpdateWorkflowOutputRequest) Descriptor 

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

func (*UpdateWorkflowOutputRequest) GetWorkflowOutput 

func (m *UpdateWorkflowOutputRequest) GetWorkflowOutput() *WorkflowOutput

func (*UpdateWorkflowOutputRequest) Marshal 

func (m *UpdateWorkflowOutputRequest) Marshal() (dAtA []byte, err error)

func (*UpdateWorkflowOutputRequest) MarshalTo 

func (m *UpdateWorkflowOutputRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateWorkflowOutputRequest) MarshalToSizedBuffer 

func (m *UpdateWorkflowOutputRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateWorkflowOutputRequest) ProtoMessage 

func (*UpdateWorkflowOutputRequest) ProtoMessage()

func (*UpdateWorkflowOutputRequest) Reset 

func (m *UpdateWorkflowOutputRequest) Reset()

func (*UpdateWorkflowOutputRequest) Size 

func (m *UpdateWorkflowOutputRequest) Size() (n int)

func (*UpdateWorkflowOutputRequest) String 

func (m *UpdateWorkflowOutputRequest) String() string

func (*UpdateWorkflowOutputRequest) Unmarshal 

func (m *UpdateWorkflowOutputRequest) Unmarshal(dAtA []byte) error

func (*UpdateWorkflowOutputRequest) XXX_DiscardUnknown 

func (m *UpdateWorkflowOutputRequest) XXX_DiscardUnknown()

func (*UpdateWorkflowOutputRequest) XXX_Marshal 

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

func (*UpdateWorkflowOutputRequest) XXX_Merge 

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

func (*UpdateWorkflowOutputRequest) XXX_Size 

func (m *UpdateWorkflowOutputRequest) XXX_Size() int

func (*UpdateWorkflowOutputRequest) XXX_Unmarshal 

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

type UpdateWorkflowStatusRequest 

type UpdateWorkflowStatusRequest struct {
	ID                   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status               WorkflowStatus `protobuf:"varint,2,opt,name=status,proto3,enum=flow.services.workflows.v1.WorkflowStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*UpdateWorkflowStatusRequest) Descriptor 

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

func (*UpdateWorkflowStatusRequest) GetID 

func (m *UpdateWorkflowStatusRequest) GetID() string

func (*UpdateWorkflowStatusRequest) GetStatus 

func (m *UpdateWorkflowStatusRequest) GetStatus() WorkflowStatus

func (*UpdateWorkflowStatusRequest) Marshal 

func (m *UpdateWorkflowStatusRequest) Marshal() (dAtA []byte, err error)

func (*UpdateWorkflowStatusRequest) MarshalTo 

func (m *UpdateWorkflowStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateWorkflowStatusRequest) MarshalToSizedBuffer 

func (m *UpdateWorkflowStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateWorkflowStatusRequest) ProtoMessage 

func (*UpdateWorkflowStatusRequest) ProtoMessage()

func (*UpdateWorkflowStatusRequest) Reset 

func (m *UpdateWorkflowStatusRequest) Reset()

func (*UpdateWorkflowStatusRequest) Size 

func (m *UpdateWorkflowStatusRequest) Size() (n int)

func (*UpdateWorkflowStatusRequest) String 

func (m *UpdateWorkflowStatusRequest) String() string

func (*UpdateWorkflowStatusRequest) Unmarshal 

func (m *UpdateWorkflowStatusRequest) Unmarshal(dAtA []byte) error

func (*UpdateWorkflowStatusRequest) XXX_DiscardUnknown 

func (m *UpdateWorkflowStatusRequest) XXX_DiscardUnknown()

func (*UpdateWorkflowStatusRequest) XXX_Marshal 

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

func (*UpdateWorkflowStatusRequest) XXX_Merge 

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

func (*UpdateWorkflowStatusRequest) XXX_Size 

func (m *UpdateWorkflowStatusRequest) XXX_Size() int

func (*UpdateWorkflowStatusRequest) XXX_Unmarshal 

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

type UploadWorkflowArtifactRequest 

type UploadWorkflowArtifactRequest struct {
	// Types that are valid to be assigned to Data:
	//	*UploadWorkflowArtifactRequest_Artifact
	//	*UploadWorkflowArtifactRequest_ChunkData
	Data                 isUploadWorkflowArtifactRequest_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

func (*UploadWorkflowArtifactRequest) Descriptor 

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

func (*UploadWorkflowArtifactRequest) GetArtifact 

func (m *UploadWorkflowArtifactRequest) GetArtifact() *WorkflowOutputArtifactUpload

func (*UploadWorkflowArtifactRequest) GetChunkData 

func (m *UploadWorkflowArtifactRequest) GetChunkData() []byte

func (*UploadWorkflowArtifactRequest) GetData 

func (m *UploadWorkflowArtifactRequest) GetData() isUploadWorkflowArtifactRequest_Data

func (*UploadWorkflowArtifactRequest) Marshal 

func (m *UploadWorkflowArtifactRequest) Marshal() (dAtA []byte, err error)

func (*UploadWorkflowArtifactRequest) MarshalTo 

func (m *UploadWorkflowArtifactRequest) MarshalTo(dAtA []byte) (int, error)

func (*UploadWorkflowArtifactRequest) MarshalToSizedBuffer 

func (m *UploadWorkflowArtifactRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UploadWorkflowArtifactRequest) ProtoMessage 

func (*UploadWorkflowArtifactRequest) ProtoMessage()

func (*UploadWorkflowArtifactRequest) Reset 

func (m *UploadWorkflowArtifactRequest) Reset()

func (*UploadWorkflowArtifactRequest) Size 

func (m *UploadWorkflowArtifactRequest) Size() (n int)

func (*UploadWorkflowArtifactRequest) String 

func (m *UploadWorkflowArtifactRequest) String() string

func (*UploadWorkflowArtifactRequest) Unmarshal 

func (m *UploadWorkflowArtifactRequest) Unmarshal(dAtA []byte) error

func (*UploadWorkflowArtifactRequest) XXX_DiscardUnknown 

func (m *UploadWorkflowArtifactRequest) XXX_DiscardUnknown()

func (*UploadWorkflowArtifactRequest) XXX_Marshal 

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

func (*UploadWorkflowArtifactRequest) XXX_Merge 

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

func (*UploadWorkflowArtifactRequest) XXX_OneofWrappers 

func (*UploadWorkflowArtifactRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*UploadWorkflowArtifactRequest) XXX_Size 

func (m *UploadWorkflowArtifactRequest) XXX_Size() int

func (*UploadWorkflowArtifactRequest) XXX_Unmarshal 

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

type UploadWorkflowArtifactRequest_Artifact 

type UploadWorkflowArtifactRequest_Artifact struct {
	Artifact *WorkflowOutputArtifactUpload `protobuf:"bytes,1,opt,name=artifact,proto3,oneof" json:"artifact,omitempty"`
}

func (*UploadWorkflowArtifactRequest_Artifact) MarshalTo 

func (m *UploadWorkflowArtifactRequest_Artifact) MarshalTo(dAtA []byte) (int, error)

func (*UploadWorkflowArtifactRequest_Artifact) MarshalToSizedBuffer 

func (m *UploadWorkflowArtifactRequest_Artifact) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UploadWorkflowArtifactRequest_Artifact) Size 

func (m *UploadWorkflowArtifactRequest_Artifact) Size() (n int)

type UploadWorkflowArtifactRequest_ChunkData 

type UploadWorkflowArtifactRequest_ChunkData struct {
	ChunkData []byte `protobuf:"bytes,2,opt,name=chunk_data,json=chunkData,proto3,oneof" json:"chunk_data,omitempty"`
}

func (*UploadWorkflowArtifactRequest_ChunkData) MarshalTo 

func (m *UploadWorkflowArtifactRequest_ChunkData) MarshalTo(dAtA []byte) (int, error)

func (*UploadWorkflowArtifactRequest_ChunkData) MarshalToSizedBuffer 

func (m *UploadWorkflowArtifactRequest_ChunkData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UploadWorkflowArtifactRequest_ChunkData) Size 

func (m *UploadWorkflowArtifactRequest_ChunkData) Size() (n int)

type UploadWorkflowArtifactResponse 

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

func (*UploadWorkflowArtifactResponse) Descriptor 

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

func (*UploadWorkflowArtifactResponse) GetStoragePath 

func (m *UploadWorkflowArtifactResponse) GetStoragePath() string

func (*UploadWorkflowArtifactResponse) Marshal 

func (m *UploadWorkflowArtifactResponse) Marshal() (dAtA []byte, err error)

func (*UploadWorkflowArtifactResponse) MarshalTo 

func (m *UploadWorkflowArtifactResponse) MarshalTo(dAtA []byte) (int, error)

func (*UploadWorkflowArtifactResponse) MarshalToSizedBuffer 

func (m *UploadWorkflowArtifactResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UploadWorkflowArtifactResponse) ProtoMessage 

func (*UploadWorkflowArtifactResponse) ProtoMessage()

func (*UploadWorkflowArtifactResponse) Reset 

func (m *UploadWorkflowArtifactResponse) Reset()

func (*UploadWorkflowArtifactResponse) Size 

func (m *UploadWorkflowArtifactResponse) Size() (n int)

func (*UploadWorkflowArtifactResponse) String 

func (m *UploadWorkflowArtifactResponse) String() string

func (*UploadWorkflowArtifactResponse) Unmarshal 

func (m *UploadWorkflowArtifactResponse) Unmarshal(dAtA []byte) error

func (*UploadWorkflowArtifactResponse) XXX_DiscardUnknown 

func (m *UploadWorkflowArtifactResponse) XXX_DiscardUnknown()

func (*UploadWorkflowArtifactResponse) XXX_Marshal 

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

func (*UploadWorkflowArtifactResponse) XXX_Merge 

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

func (*UploadWorkflowArtifactResponse) XXX_Size 

func (m *UploadWorkflowArtifactResponse) XXX_Size() int

func (*UploadWorkflowArtifactResponse) XXX_Unmarshal 

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

type Workflow 

type Workflow struct {
	ID         string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type       string            `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Name       string            `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Namespace  string            `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	Status     WorkflowStatus    `protobuf:"varint,7,opt,name=status,proto3,enum=flow.services.workflows.v1.WorkflowStatus" json:"status,omitempty"`
	Output     *WorkflowOutput   `protobuf:"bytes,8,opt,name=output,proto3" json:"output,omitempty"`
	CreatedAt  time.Time         `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3,stdtime" json:"created_at"`
	UpdatedAt  time.Time         `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3,stdtime" json:"updated_at"`
	Priority   WorkflowPriority  `protobuf:"varint,11,opt,name=priority,proto3,enum=flow.services.workflows.v1.WorkflowPriority" json:"priority,omitempty"`
	Labels     map[string]string `` /* 154-byte string literal not displayed */
	// Types that are valid to be assigned to Input:
	//	*Workflow_Workflows
	//	*Workflow_File
	Input                isWorkflow_Input `protobuf_oneof:"input"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Workflow) Descriptor 

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

func (*Workflow) GetCreatedAt 

func (m *Workflow) GetCreatedAt() time.Time

func (*Workflow) GetFile 

func (m *Workflow) GetFile() *WorkflowInputFile

func (*Workflow) GetID 

func (m *Workflow) GetID() string

func (*Workflow) GetInput 

func (m *Workflow) GetInput() isWorkflow_Input

func (*Workflow) GetLabels 

func (m *Workflow) GetLabels() map[string]string

func (*Workflow) GetName 

func (m *Workflow) GetName() string

func (*Workflow) GetNamespace 

func (m *Workflow) GetNamespace() string

func (*Workflow) GetOutput 

func (m *Workflow) GetOutput() *WorkflowOutput

func (*Workflow) GetParameters 

func (m *Workflow) GetParameters() map[string]string

func (*Workflow) GetPriority 

func (m *Workflow) GetPriority() WorkflowPriority

func (*Workflow) GetStatus 

func (m *Workflow) GetStatus() WorkflowStatus

func (*Workflow) GetType 

func (m *Workflow) GetType() string

func (*Workflow) GetUpdatedAt 

func (m *Workflow) GetUpdatedAt() time.Time

func (*Workflow) GetWorkflows 

func (m *Workflow) GetWorkflows() *WorkflowInputWorkflows

func (*Workflow) Marshal 

func (m *Workflow) Marshal() (dAtA []byte, err error)

func (*Workflow) MarshalTo 

func (m *Workflow) MarshalTo(dAtA []byte) (int, error)

func (*Workflow) MarshalToSizedBuffer 

func (m *Workflow) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) Reset 

func (m *Workflow) Reset()

func (*Workflow) Size 

func (m *Workflow) Size() (n int)

func (*Workflow) String 

func (m *Workflow) String() string

func (*Workflow) Unmarshal 

func (m *Workflow) Unmarshal(dAtA []byte) error

func (*Workflow) XXX_DiscardUnknown 

func (m *Workflow) XXX_DiscardUnknown()

func (*Workflow) XXX_Marshal 

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

func (*Workflow) XXX_Merge 

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

func (*Workflow) XXX_OneofWrappers 

func (*Workflow) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Workflow) XXX_Size 

func (m *Workflow) XXX_Size() int

func (*Workflow) XXX_Unmarshal 

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

type WorkflowAck 

type WorkflowAck struct {
	ID                   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Namespace            string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Status               WorkflowStatus `protobuf:"varint,3,opt,name=status,proto3,enum=flow.services.workflows.v1.WorkflowStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*WorkflowAck) Descriptor 

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

func (*WorkflowAck) GetID 

func (m *WorkflowAck) GetID() string

func (*WorkflowAck) GetNamespace 

func (m *WorkflowAck) GetNamespace() string

func (*WorkflowAck) GetStatus 

func (m *WorkflowAck) GetStatus() WorkflowStatus

func (*WorkflowAck) Marshal 

func (m *WorkflowAck) Marshal() (dAtA []byte, err error)

func (*WorkflowAck) MarshalTo 

func (m *WorkflowAck) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowAck) MarshalToSizedBuffer 

func (m *WorkflowAck) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowAck) ProtoMessage 

func (*WorkflowAck) ProtoMessage()

func (*WorkflowAck) Reset 

func (m *WorkflowAck) Reset()

func (*WorkflowAck) Size 

func (m *WorkflowAck) Size() (n int)

func (*WorkflowAck) String 

func (m *WorkflowAck) String() string

func (*WorkflowAck) Unmarshal 

func (m *WorkflowAck) Unmarshal(dAtA []byte) error

func (*WorkflowAck) XXX_DiscardUnknown 

func (m *WorkflowAck) XXX_DiscardUnknown()

func (*WorkflowAck) XXX_Marshal 

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

func (*WorkflowAck) XXX_Merge 

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

func (*WorkflowAck) XXX_Size 

func (m *WorkflowAck) XXX_Size() int

func (*WorkflowAck) XXX_Unmarshal 

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

type WorkflowCloseEvent 

type WorkflowCloseEvent struct {
	Error                *WorkflowError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*WorkflowCloseEvent) Descriptor 

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

func (*WorkflowCloseEvent) GetError 

func (m *WorkflowCloseEvent) GetError() *WorkflowError

func (*WorkflowCloseEvent) Marshal 

func (m *WorkflowCloseEvent) Marshal() (dAtA []byte, err error)

func (*WorkflowCloseEvent) MarshalTo 

func (m *WorkflowCloseEvent) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowCloseEvent) MarshalToSizedBuffer 

func (m *WorkflowCloseEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowCloseEvent) ProtoMessage 

func (*WorkflowCloseEvent) ProtoMessage()

func (*WorkflowCloseEvent) Reset 

func (m *WorkflowCloseEvent) Reset()

func (*WorkflowCloseEvent) Size 

func (m *WorkflowCloseEvent) Size() (n int)

func (*WorkflowCloseEvent) String 

func (m *WorkflowCloseEvent) String() string

func (*WorkflowCloseEvent) Unmarshal 

func (m *WorkflowCloseEvent) Unmarshal(dAtA []byte) error

func (*WorkflowCloseEvent) XXX_DiscardUnknown 

func (m *WorkflowCloseEvent) XXX_DiscardUnknown()

func (*WorkflowCloseEvent) XXX_Marshal 

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

func (*WorkflowCloseEvent) XXX_Merge 

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

func (*WorkflowCloseEvent) XXX_Size 

func (m *WorkflowCloseEvent) XXX_Size() int

func (*WorkflowCloseEvent) XXX_Unmarshal 

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

type WorkflowError 

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

func (*WorkflowError) Descriptor 

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

func (*WorkflowError) GetError 

func (m *WorkflowError) GetError() string

func (*WorkflowError) Marshal 

func (m *WorkflowError) Marshal() (dAtA []byte, err error)

func (*WorkflowError) MarshalTo 

func (m *WorkflowError) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowError) MarshalToSizedBuffer 

func (m *WorkflowError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowError) ProtoMessage 

func (*WorkflowError) ProtoMessage()

func (*WorkflowError) Reset 

func (m *WorkflowError) Reset()

func (*WorkflowError) Size 

func (m *WorkflowError) Size() (n int)

func (*WorkflowError) String 

func (m *WorkflowError) String() string

func (*WorkflowError) Unmarshal 

func (m *WorkflowError) Unmarshal(dAtA []byte) error

func (*WorkflowError) XXX_DiscardUnknown 

func (m *WorkflowError) XXX_DiscardUnknown()

func (*WorkflowError) XXX_Marshal 

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

func (*WorkflowError) XXX_Merge 

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

func (*WorkflowError) XXX_Size 

func (m *WorkflowError) XXX_Size() int

func (*WorkflowError) XXX_Unmarshal 

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

type WorkflowEvent 

type WorkflowEvent struct {
	// Types that are valid to be assigned to Event:
	//	*WorkflowEvent_Workflow
	//	*WorkflowEvent_Close
	Event                isWorkflowEvent_Event `protobuf_oneof:"event"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*WorkflowEvent) Descriptor 

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

func (*WorkflowEvent) GetClose 

func (m *WorkflowEvent) GetClose() *WorkflowCloseEvent

func (*WorkflowEvent) GetEvent 

func (m *WorkflowEvent) GetEvent() isWorkflowEvent_Event

func (*WorkflowEvent) GetWorkflow 

func (m *WorkflowEvent) GetWorkflow() *Workflow

func (*WorkflowEvent) Marshal 

func (m *WorkflowEvent) Marshal() (dAtA []byte, err error)

func (*WorkflowEvent) MarshalTo 

func (m *WorkflowEvent) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowEvent) MarshalToSizedBuffer 

func (m *WorkflowEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowEvent) ProtoMessage 

func (*WorkflowEvent) ProtoMessage()

func (*WorkflowEvent) Reset 

func (m *WorkflowEvent) Reset()

func (*WorkflowEvent) Size 

func (m *WorkflowEvent) Size() (n int)

func (*WorkflowEvent) String 

func (m *WorkflowEvent) String() string

func (*WorkflowEvent) Unmarshal 

func (m *WorkflowEvent) Unmarshal(dAtA []byte) error

func (*WorkflowEvent) XXX_DiscardUnknown 

func (m *WorkflowEvent) XXX_DiscardUnknown()

func (*WorkflowEvent) XXX_Marshal 

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

func (*WorkflowEvent) XXX_Merge 

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

func (*WorkflowEvent) XXX_OneofWrappers 

func (*WorkflowEvent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*WorkflowEvent) XXX_Size 

func (m *WorkflowEvent) XXX_Size() int

func (*WorkflowEvent) XXX_Unmarshal 

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

type WorkflowEvent_Close 

type WorkflowEvent_Close struct {
	Close *WorkflowCloseEvent `protobuf:"bytes,2,opt,name=close,proto3,oneof" json:"close,omitempty"`
}

func (*WorkflowEvent_Close) MarshalTo 

func (m *WorkflowEvent_Close) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowEvent_Close) MarshalToSizedBuffer 

func (m *WorkflowEvent_Close) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowEvent_Close) Size 

func (m *WorkflowEvent_Close) Size() (n int)

type WorkflowEvent_Workflow 

type WorkflowEvent_Workflow struct {
	Workflow *Workflow `protobuf:"bytes,1,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"`
}

func (*WorkflowEvent_Workflow) MarshalTo 

func (m *WorkflowEvent_Workflow) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowEvent_Workflow) MarshalToSizedBuffer 

func (m *WorkflowEvent_Workflow) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowEvent_Workflow) Size 

func (m *WorkflowEvent_Workflow) Size() (n int)

type WorkflowInputFile 

type WorkflowInputFile struct {
	Filename             string   `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	ContentType          string   `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	StoragePath          string   `protobuf:"bytes,3,opt,name=storage_path,json=storagePath,proto3" json:"storage_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowInputFile) Descriptor 

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

func (*WorkflowInputFile) GetContentType 

func (m *WorkflowInputFile) GetContentType() string

func (*WorkflowInputFile) GetFilename 

func (m *WorkflowInputFile) GetFilename() string

func (*WorkflowInputFile) GetStoragePath 

func (m *WorkflowInputFile) GetStoragePath() string

func (*WorkflowInputFile) Marshal 

func (m *WorkflowInputFile) Marshal() (dAtA []byte, err error)

func (*WorkflowInputFile) MarshalTo 

func (m *WorkflowInputFile) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowInputFile) MarshalToSizedBuffer 

func (m *WorkflowInputFile) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowInputFile) ProtoMessage 

func (*WorkflowInputFile) ProtoMessage()

func (*WorkflowInputFile) Reset 

func (m *WorkflowInputFile) Reset()

func (*WorkflowInputFile) Size 

func (m *WorkflowInputFile) Size() (n int)

func (*WorkflowInputFile) String 

func (m *WorkflowInputFile) String() string

func (*WorkflowInputFile) Unmarshal 

func (m *WorkflowInputFile) Unmarshal(dAtA []byte) error

func (*WorkflowInputFile) XXX_DiscardUnknown 

func (m *WorkflowInputFile) XXX_DiscardUnknown()

func (*WorkflowInputFile) XXX_Marshal 

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

func (*WorkflowInputFile) XXX_Merge 

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

func (*WorkflowInputFile) XXX_Size 

func (m *WorkflowInputFile) XXX_Size() int

func (*WorkflowInputFile) XXX_Unmarshal 

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

type WorkflowInputFileContents 

type WorkflowInputFileContents struct {
	ChunkData            []byte   `protobuf:"bytes,1,opt,name=chunk_data,json=chunkData,proto3" json:"chunk_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowInputFileContents) Descriptor 

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

func (*WorkflowInputFileContents) GetChunkData 

func (m *WorkflowInputFileContents) GetChunkData() []byte

func (*WorkflowInputFileContents) Marshal 

func (m *WorkflowInputFileContents) Marshal() (dAtA []byte, err error)

func (*WorkflowInputFileContents) MarshalTo 

func (m *WorkflowInputFileContents) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowInputFileContents) MarshalToSizedBuffer 

func (m *WorkflowInputFileContents) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowInputFileContents) ProtoMessage 

func (*WorkflowInputFileContents) ProtoMessage()

func (*WorkflowInputFileContents) Reset 

func (m *WorkflowInputFileContents) Reset()

func (*WorkflowInputFileContents) Size 

func (m *WorkflowInputFileContents) Size() (n int)

func (*WorkflowInputFileContents) String 

func (m *WorkflowInputFileContents) String() string

func (*WorkflowInputFileContents) Unmarshal 

func (m *WorkflowInputFileContents) Unmarshal(dAtA []byte) error

func (*WorkflowInputFileContents) XXX_DiscardUnknown 

func (m *WorkflowInputFileContents) XXX_DiscardUnknown()

func (*WorkflowInputFileContents) XXX_Marshal 

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

func (*WorkflowInputFileContents) XXX_Merge 

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

func (*WorkflowInputFileContents) XXX_Size 

func (m *WorkflowInputFileContents) XXX_Size() int

func (*WorkflowInputFileContents) XXX_Unmarshal 

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

type WorkflowInputWorkflow 

type WorkflowInputWorkflow struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowInputWorkflow) Descriptor 

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

func (*WorkflowInputWorkflow) GetID 

func (m *WorkflowInputWorkflow) GetID() string

func (*WorkflowInputWorkflow) GetNamespace 

func (m *WorkflowInputWorkflow) GetNamespace() string

func (*WorkflowInputWorkflow) Marshal 

func (m *WorkflowInputWorkflow) Marshal() (dAtA []byte, err error)

func (*WorkflowInputWorkflow) MarshalTo 

func (m *WorkflowInputWorkflow) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowInputWorkflow) MarshalToSizedBuffer 

func (m *WorkflowInputWorkflow) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowInputWorkflow) ProtoMessage 

func (*WorkflowInputWorkflow) ProtoMessage()

func (*WorkflowInputWorkflow) Reset 

func (m *WorkflowInputWorkflow) Reset()

func (*WorkflowInputWorkflow) Size 

func (m *WorkflowInputWorkflow) Size() (n int)

func (*WorkflowInputWorkflow) String 

func (m *WorkflowInputWorkflow) String() string

func (*WorkflowInputWorkflow) Unmarshal 

func (m *WorkflowInputWorkflow) Unmarshal(dAtA []byte) error

func (*WorkflowInputWorkflow) XXX_DiscardUnknown 

func (m *WorkflowInputWorkflow) XXX_DiscardUnknown()

func (*WorkflowInputWorkflow) XXX_Marshal 

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

func (*WorkflowInputWorkflow) XXX_Merge 

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

func (*WorkflowInputWorkflow) XXX_Size 

func (m *WorkflowInputWorkflow) XXX_Size() int

func (*WorkflowInputWorkflow) XXX_Unmarshal 

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

type WorkflowInputWorkflows 

type WorkflowInputWorkflows struct {
	WorkflowInputs       []*WorkflowInputWorkflow `protobuf:"bytes,1,rep,name=workflow_inputs,json=workflowInputs,proto3" json:"workflow_inputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*WorkflowInputWorkflows) Descriptor 

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

func (*WorkflowInputWorkflows) GetWorkflowInputs 

func (m *WorkflowInputWorkflows) GetWorkflowInputs() []*WorkflowInputWorkflow

func (*WorkflowInputWorkflows) Marshal 

func (m *WorkflowInputWorkflows) Marshal() (dAtA []byte, err error)

func (*WorkflowInputWorkflows) MarshalTo 

func (m *WorkflowInputWorkflows) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowInputWorkflows) MarshalToSizedBuffer 

func (m *WorkflowInputWorkflows) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowInputWorkflows) ProtoMessage 

func (*WorkflowInputWorkflows) ProtoMessage()

func (*WorkflowInputWorkflows) Reset 

func (m *WorkflowInputWorkflows) Reset()

func (*WorkflowInputWorkflows) Size 

func (m *WorkflowInputWorkflows) Size() (n int)

func (*WorkflowInputWorkflows) String 

func (m *WorkflowInputWorkflows) String() string

func (*WorkflowInputWorkflows) Unmarshal 

func (m *WorkflowInputWorkflows) Unmarshal(dAtA []byte) error

func (*WorkflowInputWorkflows) XXX_DiscardUnknown 

func (m *WorkflowInputWorkflows) XXX_DiscardUnknown()

func (*WorkflowInputWorkflows) XXX_Marshal 

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

func (*WorkflowInputWorkflows) XXX_Merge 

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

func (*WorkflowInputWorkflows) XXX_Size 

func (m *WorkflowInputWorkflows) XXX_Size() int

func (*WorkflowInputWorkflows) XXX_Unmarshal 

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

type WorkflowOutput 

type WorkflowOutput struct {
	ID                   string                    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Namespace            string                    `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Metadata             *WorkflowOutputMetadata   `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Log                  string                    `protobuf:"bytes,4,opt,name=log,proto3" json:"log,omitempty"`
	Info                 map[string]string         `` /* 149-byte string literal not displayed */
	Artifacts            []*WorkflowOutputArtifact `protobuf:"bytes,6,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	StartedAt            time.Time                 `protobuf:"bytes,7,opt,name=started_at,json=startedAt,proto3,stdtime" json:"started_at"`
	FinishedAt           time.Time                 `protobuf:"bytes,8,opt,name=finished_at,json=finishedAt,proto3,stdtime" json:"finished_at"`
	Duration             time.Duration             `protobuf:"bytes,9,opt,name=duration,proto3,stdduration" json:"duration"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*WorkflowOutput) Descriptor 

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

func (*WorkflowOutput) GetArtifacts 

func (m *WorkflowOutput) GetArtifacts() []*WorkflowOutputArtifact

func (*WorkflowOutput) GetDuration 

func (m *WorkflowOutput) GetDuration() time.Duration

func (*WorkflowOutput) GetFinishedAt 

func (m *WorkflowOutput) GetFinishedAt() time.Time

func (*WorkflowOutput) GetID 

func (m *WorkflowOutput) GetID() string

func (*WorkflowOutput) GetInfo 

func (m *WorkflowOutput) GetInfo() map[string]string

func (*WorkflowOutput) GetLog 

func (m *WorkflowOutput) GetLog() string

func (*WorkflowOutput) GetMetadata 

func (m *WorkflowOutput) GetMetadata() *WorkflowOutputMetadata

func (*WorkflowOutput) GetNamespace 

func (m *WorkflowOutput) GetNamespace() string

func (*WorkflowOutput) GetStartedAt 

func (m *WorkflowOutput) GetStartedAt() time.Time

func (*WorkflowOutput) Marshal 

func (m *WorkflowOutput) Marshal() (dAtA []byte, err error)

func (*WorkflowOutput) MarshalTo 

func (m *WorkflowOutput) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowOutput) MarshalToSizedBuffer 

func (m *WorkflowOutput) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowOutput) ProtoMessage 

func (*WorkflowOutput) ProtoMessage()

func (*WorkflowOutput) Reset 

func (m *WorkflowOutput) Reset()

func (*WorkflowOutput) Size 

func (m *WorkflowOutput) Size() (n int)

func (*WorkflowOutput) String 

func (m *WorkflowOutput) String() string

func (*WorkflowOutput) Unmarshal 

func (m *WorkflowOutput) Unmarshal(dAtA []byte) error

func (*WorkflowOutput) XXX_DiscardUnknown 

func (m *WorkflowOutput) XXX_DiscardUnknown()

func (*WorkflowOutput) XXX_Marshal 

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

func (*WorkflowOutput) XXX_Merge 

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

func (*WorkflowOutput) XXX_Size 

func (m *WorkflowOutput) XXX_Size() int

func (*WorkflowOutput) XXX_Unmarshal 

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

type WorkflowOutputArtifact 

type WorkflowOutputArtifact struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ContentType          string   `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	StoragePath          string   `protobuf:"bytes,3,opt,name=storage_path,json=storagePath,proto3" json:"storage_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowOutputArtifact) Descriptor 

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

func (*WorkflowOutputArtifact) GetContentType 

func (m *WorkflowOutputArtifact) GetContentType() string

func (*WorkflowOutputArtifact) GetName 

func (m *WorkflowOutputArtifact) GetName() string

func (*WorkflowOutputArtifact) GetStoragePath 

func (m *WorkflowOutputArtifact) GetStoragePath() string

func (*WorkflowOutputArtifact) Marshal 

func (m *WorkflowOutputArtifact) Marshal() (dAtA []byte, err error)

func (*WorkflowOutputArtifact) MarshalTo 

func (m *WorkflowOutputArtifact) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowOutputArtifact) MarshalToSizedBuffer 

func (m *WorkflowOutputArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowOutputArtifact) ProtoMessage 

func (*WorkflowOutputArtifact) ProtoMessage()

func (*WorkflowOutputArtifact) Reset 

func (m *WorkflowOutputArtifact) Reset()

func (*WorkflowOutputArtifact) Size 

func (m *WorkflowOutputArtifact) Size() (n int)

func (*WorkflowOutputArtifact) String 

func (m *WorkflowOutputArtifact) String() string

func (*WorkflowOutputArtifact) Unmarshal 

func (m *WorkflowOutputArtifact) Unmarshal(dAtA []byte) error

func (*WorkflowOutputArtifact) XXX_DiscardUnknown 

func (m *WorkflowOutputArtifact) XXX_DiscardUnknown()

func (*WorkflowOutputArtifact) XXX_Marshal 

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

func (*WorkflowOutputArtifact) XXX_Merge 

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

func (*WorkflowOutputArtifact) XXX_Size 

func (m *WorkflowOutputArtifact) XXX_Size() int

func (*WorkflowOutputArtifact) XXX_Unmarshal 

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

type WorkflowOutputArtifactUpload 

type WorkflowOutputArtifactUpload struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Filename             string   `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	ContentType          string   `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowOutputArtifactUpload) Descriptor 

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

func (*WorkflowOutputArtifactUpload) GetContentType 

func (m *WorkflowOutputArtifactUpload) GetContentType() string

func (*WorkflowOutputArtifactUpload) GetFilename 

func (m *WorkflowOutputArtifactUpload) GetFilename() string

func (*WorkflowOutputArtifactUpload) GetID 

func (m *WorkflowOutputArtifactUpload) GetID() string

func (*WorkflowOutputArtifactUpload) GetNamespace 

func (m *WorkflowOutputArtifactUpload) GetNamespace() string

func (*WorkflowOutputArtifactUpload) Marshal 

func (m *WorkflowOutputArtifactUpload) Marshal() (dAtA []byte, err error)

func (*WorkflowOutputArtifactUpload) MarshalTo 

func (m *WorkflowOutputArtifactUpload) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowOutputArtifactUpload) MarshalToSizedBuffer 

func (m *WorkflowOutputArtifactUpload) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowOutputArtifactUpload) ProtoMessage 

func (*WorkflowOutputArtifactUpload) ProtoMessage()

func (*WorkflowOutputArtifactUpload) Reset 

func (m *WorkflowOutputArtifactUpload) Reset()

func (*WorkflowOutputArtifactUpload) Size 

func (m *WorkflowOutputArtifactUpload) Size() (n int)

func (*WorkflowOutputArtifactUpload) String 

func (m *WorkflowOutputArtifactUpload) String() string

func (*WorkflowOutputArtifactUpload) Unmarshal 

func (m *WorkflowOutputArtifactUpload) Unmarshal(dAtA []byte) error

func (*WorkflowOutputArtifactUpload) XXX_DiscardUnknown 

func (m *WorkflowOutputArtifactUpload) XXX_DiscardUnknown()

func (*WorkflowOutputArtifactUpload) XXX_Marshal 

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

func (*WorkflowOutputArtifactUpload) XXX_Merge 

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

func (*WorkflowOutputArtifactUpload) XXX_Size 

func (m *WorkflowOutputArtifactUpload) XXX_Size() int

func (*WorkflowOutputArtifactUpload) XXX_Unmarshal 

func (m *WorkflowOutputArtifactUpload) XXX_Unmarshal(b []byte) error
type WorkflowOutputLink struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Target               string   `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowOutputLink) Descriptor 

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

func (*WorkflowOutputLink) GetName 

func (m *WorkflowOutputLink) GetName() string

func (*WorkflowOutputLink) GetTarget 

func (m *WorkflowOutputLink) GetTarget() string

func (*WorkflowOutputLink) Marshal 

func (m *WorkflowOutputLink) Marshal() (dAtA []byte, err error)

func (*WorkflowOutputLink) MarshalTo 

func (m *WorkflowOutputLink) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowOutputLink) MarshalToSizedBuffer 

func (m *WorkflowOutputLink) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowOutputLink) ProtoMessage 

func (*WorkflowOutputLink) ProtoMessage()

func (*WorkflowOutputLink) Reset 

func (m *WorkflowOutputLink) Reset()

func (*WorkflowOutputLink) Size 

func (m *WorkflowOutputLink) Size() (n int)

func (*WorkflowOutputLink) String 

func (m *WorkflowOutputLink) String() string

func (*WorkflowOutputLink) Unmarshal 

func (m *WorkflowOutputLink) Unmarshal(dAtA []byte) error

func (*WorkflowOutputLink) XXX_DiscardUnknown 

func (m *WorkflowOutputLink) XXX_DiscardUnknown()

func (*WorkflowOutputLink) XXX_Marshal 

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

func (*WorkflowOutputLink) XXX_Merge 

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

func (*WorkflowOutputLink) XXX_Size 

func (m *WorkflowOutputLink) XXX_Size() int

func (*WorkflowOutputLink) XXX_Unmarshal 

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

type WorkflowOutputMetadata 

type WorkflowOutputMetadata struct {
	Thumbnail            string                `protobuf:"bytes,1,opt,name=thumbnail,proto3" json:"thumbnail,omitempty"`
	Links                []*WorkflowOutputLink `protobuf:"bytes,2,rep,name=links,proto3" json:"links,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*WorkflowOutputMetadata) Descriptor 

func (*WorkflowOutputMetadata) Descriptor() ([]byte, []int)
func (m *WorkflowOutputMetadata) GetLinks() []*WorkflowOutputLink

func (*WorkflowOutputMetadata) GetThumbnail 

func (m *WorkflowOutputMetadata) GetThumbnail() string

func (*WorkflowOutputMetadata) Marshal 

func (m *WorkflowOutputMetadata) Marshal() (dAtA []byte, err error)

func (*WorkflowOutputMetadata) MarshalTo 

func (m *WorkflowOutputMetadata) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowOutputMetadata) MarshalToSizedBuffer 

func (m *WorkflowOutputMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowOutputMetadata) ProtoMessage 

func (*WorkflowOutputMetadata) ProtoMessage()

func (*WorkflowOutputMetadata) Reset 

func (m *WorkflowOutputMetadata) Reset()

func (*WorkflowOutputMetadata) Size 

func (m *WorkflowOutputMetadata) Size() (n int)

func (*WorkflowOutputMetadata) String 

func (m *WorkflowOutputMetadata) String() string

func (*WorkflowOutputMetadata) Unmarshal 

func (m *WorkflowOutputMetadata) Unmarshal(dAtA []byte) error

func (*WorkflowOutputMetadata) XXX_DiscardUnknown 

func (m *WorkflowOutputMetadata) XXX_DiscardUnknown()

func (*WorkflowOutputMetadata) XXX_Marshal 

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

func (*WorkflowOutputMetadata) XXX_Merge 

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

func (*WorkflowOutputMetadata) XXX_Size 

func (m *WorkflowOutputMetadata) XXX_Size() int

func (*WorkflowOutputMetadata) XXX_Unmarshal 

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

type WorkflowPriority 

type WorkflowPriority int32
const (
	WorkflowPriority_NORMAL  WorkflowPriority = 0
	WorkflowPriority_LOW     WorkflowPriority = 1
	WorkflowPriority_URGENT  WorkflowPriority = 2
	WorkflowPriority_UNKNOWN WorkflowPriority = 10
)

func (WorkflowPriority) EnumDescriptor 

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

func (WorkflowPriority) String 

func (x WorkflowPriority) String() string

type WorkflowRequest 

type WorkflowRequest struct {
	Type       string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Name       string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	Priority   WorkflowPriority  `protobuf:"varint,4,opt,name=priority,proto3,enum=flow.services.workflows.v1.WorkflowPriority" json:"priority,omitempty"`
	Labels     map[string]string `` /* 153-byte string literal not displayed */
	// Types that are valid to be assigned to Input:
	//	*WorkflowRequest_Workflows
	//	*WorkflowRequest_File
	Input                isWorkflowRequest_Input `protobuf_oneof:"input"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*WorkflowRequest) Descriptor 

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

func (*WorkflowRequest) GetFile 

func (m *WorkflowRequest) GetFile() *WorkflowInputFile

func (*WorkflowRequest) GetInput 

func (m *WorkflowRequest) GetInput() isWorkflowRequest_Input

func (*WorkflowRequest) GetLabels 

func (m *WorkflowRequest) GetLabels() map[string]string

func (*WorkflowRequest) GetName 

func (m *WorkflowRequest) GetName() string

func (*WorkflowRequest) GetParameters 

func (m *WorkflowRequest) GetParameters() map[string]string

func (*WorkflowRequest) GetPriority 

func (m *WorkflowRequest) GetPriority() WorkflowPriority

func (*WorkflowRequest) GetType 

func (m *WorkflowRequest) GetType() string

func (*WorkflowRequest) GetWorkflows 

func (m *WorkflowRequest) GetWorkflows() *WorkflowInputWorkflows

func (*WorkflowRequest) Marshal 

func (m *WorkflowRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowRequest) MarshalTo 

func (m *WorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowRequest) MarshalToSizedBuffer 

func (m *WorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowRequest) ProtoMessage 

func (*WorkflowRequest) ProtoMessage()

func (*WorkflowRequest) Reset 

func (m *WorkflowRequest) Reset()

func (*WorkflowRequest) Size 

func (m *WorkflowRequest) Size() (n int)

func (*WorkflowRequest) String 

func (m *WorkflowRequest) String() string

func (*WorkflowRequest) Unmarshal 

func (m *WorkflowRequest) Unmarshal(dAtA []byte) error

func (*WorkflowRequest) XXX_DiscardUnknown 

func (m *WorkflowRequest) XXX_DiscardUnknown()

func (*WorkflowRequest) XXX_Marshal 

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

func (*WorkflowRequest) XXX_Merge 

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

func (*WorkflowRequest) XXX_OneofWrappers 

func (*WorkflowRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*WorkflowRequest) XXX_Size 

func (m *WorkflowRequest) XXX_Size() int

func (*WorkflowRequest) XXX_Unmarshal 

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

type WorkflowRequest_File 

type WorkflowRequest_File struct {
	File *WorkflowInputFile `protobuf:"bytes,7,opt,name=file,proto3,oneof" json:"file,omitempty"`
}

func (*WorkflowRequest_File) MarshalTo 

func (m *WorkflowRequest_File) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowRequest_File) MarshalToSizedBuffer 

func (m *WorkflowRequest_File) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowRequest_File) Size 

func (m *WorkflowRequest_File) Size() (n int)

type WorkflowRequest_Workflows 

type WorkflowRequest_Workflows struct {
	Workflows *WorkflowInputWorkflows `protobuf:"bytes,6,opt,name=workflows,proto3,oneof" json:"workflows,omitempty"`
}

func (*WorkflowRequest_Workflows) MarshalTo 

func (m *WorkflowRequest_Workflows) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowRequest_Workflows) MarshalToSizedBuffer 

func (m *WorkflowRequest_Workflows) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowRequest_Workflows) Size 

func (m *WorkflowRequest_Workflows) Size() (n int)

type WorkflowStatus 

type WorkflowStatus int32
const (
	WorkflowStatus_PENDING  WorkflowStatus = 0
	WorkflowStatus_ASSIGNED WorkflowStatus = 1
	WorkflowStatus_WAITING  WorkflowStatus = 2
	WorkflowStatus_RUNNING  WorkflowStatus = 3
	WorkflowStatus_ERROR    WorkflowStatus = 4
	WorkflowStatus_COMPLETE WorkflowStatus = 5
)

func (WorkflowStatus) EnumDescriptor 

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

func (WorkflowStatus) String 

func (x WorkflowStatus) String() string

type Workflow_File 

type Workflow_File struct {
	File *WorkflowInputFile `protobuf:"bytes,14,opt,name=file,proto3,oneof" json:"file,omitempty"`
}

func (*Workflow_File) MarshalTo 

func (m *Workflow_File) MarshalTo(dAtA []byte) (int, error)

func (*Workflow_File) MarshalToSizedBuffer 

func (m *Workflow_File) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Workflow_File) Size 

func (m *Workflow_File) Size() (n int)

type Workflow_Workflows 

type Workflow_Workflows struct {
	Workflows *WorkflowInputWorkflows `protobuf:"bytes,13,opt,name=workflows,proto3,oneof" json:"workflows,omitempty"`
}

func (*Workflow_Workflows) MarshalTo 

func (m *Workflow_Workflows) MarshalTo(dAtA []byte) (int, error)

func (*Workflow_Workflows) MarshalToSizedBuffer 

func (m *Workflow_Workflows) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Workflow_Workflows) Size 

func (m *Workflow_Workflows) Size() (n int)

type WorkflowsClient 

type WorkflowsClient interface {
	QueueWorkflow(ctx context.Context, opts ...grpc.CallOption) (Workflows_QueueWorkflowClient, error)
	ListWorkflows(ctx context.Context, in *ListWorkflowsRequest, opts ...grpc.CallOption) (*ListWorkflowsResponse, error)
	GetWorkflow(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*GetWorkflowResponse, error)
	DeleteWorkflow(ctx context.Context, in *DeleteWorkflowRequest, opts ...grpc.CallOption) (*types.Empty, error)
	SubscribeWorkflowEvents(ctx context.Context, opts ...grpc.CallOption) (Workflows_SubscribeWorkflowEventsClient, error)
	ListWorkflowInputs(ctx context.Context, in *ListWorkflowInputsRequest, opts ...grpc.CallOption) (*ListWorkflowInputsResponse, error)
	GetWorkflowInputFile(ctx context.Context, in *GetWorkflowInputFileRequest, opts ...grpc.CallOption) (Workflows_GetWorkflowInputFileClient, error)
	UploadWorkflowArtifact(ctx context.Context, opts ...grpc.CallOption) (Workflows_UploadWorkflowArtifactClient, error)
	UpdateWorkflowStatus(ctx context.Context, in *UpdateWorkflowStatusRequest, opts ...grpc.CallOption) (*types.Empty, error)
	UpdateWorkflowOutput(ctx context.Context, in *UpdateWorkflowOutputRequest, opts ...grpc.CallOption) (*types.Empty, error)
	ListWorkflowProcessors(ctx context.Context, in *ListWorkflowProcessorsRequest, opts ...grpc.CallOption) (*ListWorkflowProcessorsResponse, error)
}

WorkflowsClient is the client API for Workflows service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWorkflowsClient 

func NewWorkflowsClient(cc *grpc.ClientConn) WorkflowsClient

type WorkflowsServer 

type WorkflowsServer interface {
	QueueWorkflow(Workflows_QueueWorkflowServer) error
	ListWorkflows(context.Context, *ListWorkflowsRequest) (*ListWorkflowsResponse, error)
	GetWorkflow(context.Context, *GetWorkflowRequest) (*GetWorkflowResponse, error)
	DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*types.Empty, error)
	SubscribeWorkflowEvents(Workflows_SubscribeWorkflowEventsServer) error
	ListWorkflowInputs(context.Context, *ListWorkflowInputsRequest) (*ListWorkflowInputsResponse, error)
	GetWorkflowInputFile(*GetWorkflowInputFileRequest, Workflows_GetWorkflowInputFileServer) error
	UploadWorkflowArtifact(Workflows_UploadWorkflowArtifactServer) error
	UpdateWorkflowStatus(context.Context, *UpdateWorkflowStatusRequest) (*types.Empty, error)
	UpdateWorkflowOutput(context.Context, *UpdateWorkflowOutputRequest) (*types.Empty, error)
	ListWorkflowProcessors(context.Context, *ListWorkflowProcessorsRequest) (*ListWorkflowProcessorsResponse, error)
}

WorkflowsServer is the server API for Workflows service.

type Workflows_GetWorkflowInputFileClient 

type Workflows_GetWorkflowInputFileClient interface {
	Recv() (*WorkflowInputFileContents, error)
	grpc.ClientStream
}

type Workflows_GetWorkflowInputFileServer 

type Workflows_GetWorkflowInputFileServer interface {
	Send(*WorkflowInputFileContents) error
	grpc.ServerStream
}

type Workflows_QueueWorkflowClient 

type Workflows_QueueWorkflowClient interface {
	Send(*QueueWorkflowRequest) error
	CloseAndRecv() (*QueueWorkflowResponse, error)
	grpc.ClientStream
}

type Workflows_QueueWorkflowServer 

type Workflows_QueueWorkflowServer interface {
	SendAndClose(*QueueWorkflowResponse) error
	Recv() (*QueueWorkflowRequest, error)
	grpc.ServerStream
}

type Workflows_SubscribeWorkflowEventsClient 

type Workflows_SubscribeWorkflowEventsClient interface {
	Send(*SubscribeWorkflowEventsRequest) error
	Recv() (*WorkflowEvent, error)
	grpc.ClientStream
}

type Workflows_SubscribeWorkflowEventsServer 

type Workflows_SubscribeWorkflowEventsServer interface {
	Send(*WorkflowEvent) error
	Recv() (*SubscribeWorkflowEventsRequest, error)
	grpc.ServerStream
}

type Workflows_UploadWorkflowArtifactClient 

type Workflows_UploadWorkflowArtifactClient interface {
	Send(*UploadWorkflowArtifactRequest) error
	CloseAndRecv() (*UploadWorkflowArtifactResponse, error)
	grpc.ClientStream
}

type Workflows_UploadWorkflowArtifactServer 

type Workflows_UploadWorkflowArtifactServer interface {
	SendAndClose(*UploadWorkflowArtifactResponse) error
	Recv() (*UploadWorkflowArtifactRequest, error)
	grpc.ServerStream
}

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.