workflows

package
v0.3.1 Latest Latest
Warning

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

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

Documentation

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 GetWorkflowOutputArtifactRequest added in v0.1.1 

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

func (*GetWorkflowOutputArtifactRequest) Descriptor added in v0.1.1 

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

func (*GetWorkflowOutputArtifactRequest) GetID added in v0.1.1 

func (m *GetWorkflowOutputArtifactRequest) GetID() string

func (*GetWorkflowOutputArtifactRequest) GetName added in v0.1.1 

func (m *GetWorkflowOutputArtifactRequest) GetName() string

func (*GetWorkflowOutputArtifactRequest) Marshal added in v0.1.1 

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

func (*GetWorkflowOutputArtifactRequest) MarshalTo added in v0.1.1 

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

func (*GetWorkflowOutputArtifactRequest) MarshalToSizedBuffer added in v0.1.1 

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

func (*GetWorkflowOutputArtifactRequest) ProtoMessage added in v0.1.1 

func (*GetWorkflowOutputArtifactRequest) ProtoMessage()

func (*GetWorkflowOutputArtifactRequest) Reset added in v0.1.1 

func (m *GetWorkflowOutputArtifactRequest) Reset()

func (*GetWorkflowOutputArtifactRequest) Size added in v0.1.1 

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

func (*GetWorkflowOutputArtifactRequest) String added in v0.1.1 

func (m *GetWorkflowOutputArtifactRequest) String() string

func (*GetWorkflowOutputArtifactRequest) Unmarshal added in v0.1.1 

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

func (*GetWorkflowOutputArtifactRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *GetWorkflowOutputArtifactRequest) XXX_DiscardUnknown()

func (*GetWorkflowOutputArtifactRequest) XXX_Marshal added in v0.1.1 

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

func (*GetWorkflowOutputArtifactRequest) XXX_Merge added in v0.1.1 

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

func (*GetWorkflowOutputArtifactRequest) XXX_Size added in v0.1.1 

func (m *GetWorkflowOutputArtifactRequest) XXX_Size() int

func (*GetWorkflowOutputArtifactRequest) XXX_Unmarshal added in v0.1.1 

func (m *GetWorkflowOutputArtifactRequest) 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 {
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListWorkflowsRequest) Descriptor 

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

func (*ListWorkflowsRequest) GetLabels added in v0.3.1 

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

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) GetLoad15 

func (m *ProcessorInfo) GetLoad15() float64

func (*ProcessorInfo) GetLoad5 

func (m *ProcessorInfo) GetLoad5() 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 RequeueWorkflowRequest added in v0.2.0 

type RequeueWorkflowRequest 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 (*RequeueWorkflowRequest) Descriptor added in v0.2.0 

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

func (*RequeueWorkflowRequest) GetID added in v0.2.0 

func (m *RequeueWorkflowRequest) GetID() string

func (*RequeueWorkflowRequest) Marshal added in v0.2.0 

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

func (*RequeueWorkflowRequest) MarshalTo added in v0.2.0 

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

func (*RequeueWorkflowRequest) MarshalToSizedBuffer added in v0.2.0 

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

func (*RequeueWorkflowRequest) ProtoMessage added in v0.2.0 

func (*RequeueWorkflowRequest) ProtoMessage()

func (*RequeueWorkflowRequest) Reset added in v0.2.0 

func (m *RequeueWorkflowRequest) Reset()

func (*RequeueWorkflowRequest) Size added in v0.2.0 

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

func (*RequeueWorkflowRequest) String added in v0.2.0 

func (m *RequeueWorkflowRequest) String() string

func (*RequeueWorkflowRequest) Unmarshal added in v0.2.0 

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

func (*RequeueWorkflowRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *RequeueWorkflowRequest) XXX_DiscardUnknown()

func (*RequeueWorkflowRequest) XXX_Marshal added in v0.2.0 

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

func (*RequeueWorkflowRequest) XXX_Merge added in v0.2.0 

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

func (*RequeueWorkflowRequest) XXX_Size added in v0.2.0 

func (m *RequeueWorkflowRequest) XXX_Size() int

func (*RequeueWorkflowRequest) XXX_Unmarshal added in v0.2.0 

func (m *RequeueWorkflowRequest) 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
	//	*SubscribeWorkflowEventsRequest_Complete
	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) GetComplete added in v0.2.0 

func (m *SubscribeWorkflowEventsRequest) GetComplete() *WorkflowComplete

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_Complete added in v0.2.0 

type SubscribeWorkflowEventsRequest_Complete struct {
	Complete *WorkflowComplete `protobuf:"bytes,4,opt,name=complete,proto3,oneof" json:"complete,omitempty"`
}

func (*SubscribeWorkflowEventsRequest_Complete) MarshalTo added in v0.2.0 

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

func (*SubscribeWorkflowEventsRequest_Complete) MarshalToSizedBuffer added in v0.2.0 

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

func (*SubscribeWorkflowEventsRequest_Complete) Size added in v0.2.0 

func (m *SubscribeWorkflowEventsRequest_Complete) 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) GetWorkflowOutputArtifact added in v0.1.1 

func (*UnimplementedWorkflowsServer) GetWorkflowOutputArtifact(req *GetWorkflowOutputArtifactRequest, srv Workflows_GetWorkflowOutputArtifactServer) 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) RequeueWorkflow added in v0.2.0 

func (*UnimplementedWorkflowsServer) RequeueWorkflow(ctx context.Context, req *RequeueWorkflowRequest) (*types.Empty, error)

func (*UnimplementedWorkflowsServer) SubscribeWorkflowEvents 

func (*UnimplementedWorkflowsServer) SubscribeWorkflowEvents(srv Workflows_SubscribeWorkflowEventsServer) 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 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) Scan added in v0.2.0 

func (w *Workflow) Scan(value interface{}) error

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) Value added in v0.2.0 

func (w *Workflow) Value() (driver.Value, 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 WorkflowComplete added in v0.2.0 

type WorkflowComplete 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"`
	NodeID               string         `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*WorkflowComplete) Descriptor added in v0.2.0 

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

func (*WorkflowComplete) GetID added in v0.2.0 

func (m *WorkflowComplete) GetID() string

func (*WorkflowComplete) GetNamespace added in v0.2.0 

func (m *WorkflowComplete) GetNamespace() string

func (*WorkflowComplete) GetNodeID added in v0.2.0 

func (m *WorkflowComplete) GetNodeID() string

func (*WorkflowComplete) GetStatus added in v0.2.0 

func (m *WorkflowComplete) GetStatus() WorkflowStatus

func (*WorkflowComplete) Marshal added in v0.2.0 

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

func (*WorkflowComplete) MarshalTo added in v0.2.0 

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

func (*WorkflowComplete) MarshalToSizedBuffer added in v0.2.0 

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

func (*WorkflowComplete) ProtoMessage added in v0.2.0 

func (*WorkflowComplete) ProtoMessage()

func (*WorkflowComplete) Reset added in v0.2.0 

func (m *WorkflowComplete) Reset()

func (*WorkflowComplete) Size added in v0.2.0 

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

func (*WorkflowComplete) String added in v0.2.0 

func (m *WorkflowComplete) String() string

func (*WorkflowComplete) Unmarshal added in v0.2.0 

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

func (*WorkflowComplete) XXX_DiscardUnknown added in v0.2.0 

func (m *WorkflowComplete) XXX_DiscardUnknown()

func (*WorkflowComplete) XXX_Marshal added in v0.2.0 

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

func (*WorkflowComplete) XXX_Merge added in v0.2.0 

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

func (*WorkflowComplete) XXX_Size added in v0.2.0 

func (m *WorkflowComplete) XXX_Size() int

func (*WorkflowComplete) XXX_Unmarshal added in v0.2.0 

func (m *WorkflowComplete) 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 WorkflowOutputArtifactContents added in v0.1.1 

type WorkflowOutputArtifactContents struct {
	// Types that are valid to be assigned to Data:
	//	*WorkflowOutputArtifactContents_Artifact
	//	*WorkflowOutputArtifactContents_ChunkData
	Data                 isWorkflowOutputArtifactContents_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*WorkflowOutputArtifactContents) Descriptor added in v0.1.1 

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

func (*WorkflowOutputArtifactContents) GetArtifact added in v0.1.1 

func (m *WorkflowOutputArtifactContents) GetArtifact() *WorkflowOutputArtifact

func (*WorkflowOutputArtifactContents) GetChunkData added in v0.1.1 

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

func (*WorkflowOutputArtifactContents) GetData added in v0.1.1 

func (m *WorkflowOutputArtifactContents) GetData() isWorkflowOutputArtifactContents_Data

func (*WorkflowOutputArtifactContents) Marshal added in v0.1.1 

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

func (*WorkflowOutputArtifactContents) MarshalTo added in v0.1.1 

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

func (*WorkflowOutputArtifactContents) MarshalToSizedBuffer added in v0.1.1 

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

func (*WorkflowOutputArtifactContents) ProtoMessage added in v0.1.1 

func (*WorkflowOutputArtifactContents) ProtoMessage()

func (*WorkflowOutputArtifactContents) Reset added in v0.1.1 

func (m *WorkflowOutputArtifactContents) Reset()

func (*WorkflowOutputArtifactContents) Size added in v0.1.1 

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

func (*WorkflowOutputArtifactContents) String added in v0.1.1 

func (m *WorkflowOutputArtifactContents) String() string

func (*WorkflowOutputArtifactContents) Unmarshal added in v0.1.1 

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

func (*WorkflowOutputArtifactContents) XXX_DiscardUnknown added in v0.1.1 

func (m *WorkflowOutputArtifactContents) XXX_DiscardUnknown()

func (*WorkflowOutputArtifactContents) XXX_Marshal added in v0.1.1 

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

func (*WorkflowOutputArtifactContents) XXX_Merge added in v0.1.1 

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

func (*WorkflowOutputArtifactContents) XXX_OneofWrappers added in v0.1.1 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*WorkflowOutputArtifactContents) XXX_Size added in v0.1.1 

func (m *WorkflowOutputArtifactContents) XXX_Size() int

func (*WorkflowOutputArtifactContents) XXX_Unmarshal added in v0.1.1 

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

type WorkflowOutputArtifactContents_Artifact added in v0.1.1 

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

func (*WorkflowOutputArtifactContents_Artifact) MarshalTo added in v0.1.1 

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

func (*WorkflowOutputArtifactContents_Artifact) MarshalToSizedBuffer added in v0.1.1 

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

func (*WorkflowOutputArtifactContents_Artifact) Size added in v0.1.1 

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

type WorkflowOutputArtifactContents_ChunkData added in v0.1.1 

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

func (*WorkflowOutputArtifactContents_ChunkData) MarshalTo added in v0.1.1 

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

func (*WorkflowOutputArtifactContents_ChunkData) MarshalToSizedBuffer added in v0.1.1 

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

func (*WorkflowOutputArtifactContents_ChunkData) Size added in v0.1.1 

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

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)
	RequeueWorkflow(ctx context.Context, in *RequeueWorkflowRequest, opts ...grpc.CallOption) (*types.Empty, 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)
	GetWorkflowOutputArtifact(ctx context.Context, in *GetWorkflowOutputArtifactRequest, opts ...grpc.CallOption) (Workflows_GetWorkflowOutputArtifactClient, 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)
	RequeueWorkflow(context.Context, *RequeueWorkflowRequest) (*types.Empty, 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)
	GetWorkflowOutputArtifact(*GetWorkflowOutputArtifactRequest, Workflows_GetWorkflowOutputArtifactServer) 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_GetWorkflowOutputArtifactClient added in v0.1.1 

type Workflows_GetWorkflowOutputArtifactClient interface {
	Recv() (*WorkflowOutputArtifactContents, error)
	grpc.ClientStream
}

type Workflows_GetWorkflowOutputArtifactServer added in v0.1.1 

type Workflows_GetWorkflowOutputArtifactServer interface {
	Send(*WorkflowOutputArtifactContents) 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.