model

package
v0.0.0-...-83edfdb Latest Latest
Warning

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

 Go to latest Published: May 17, 2021 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Overview

Package model is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var CompletionOperation_name = map[int32]string{
	0:  "unknown_operation",
	1:  "acceptEither",
	2:  "applyToEither",
	3:  "thenAcceptBoth",
	4:  "thenApply",
	5:  "thenRun",
	6:  "thenAccept",
	7:  "thenCompose",
	8:  "thenCombine",
	9:  "whenComplete",
	10: "handle",
	11: "supply",
	12: "invokeFunction",
	13: "completedValue",
	14: "delay",
	15: "allOf",
	16: "anyOf",
	17: "externalCompletion",
	18: "exceptionally",
	19: "terminationHook",
	20: "exceptionallyCompose",
}
View Source 
var CompletionOperation_value = map[string]int32{
	"unknown_operation":    0,
	"acceptEither":         1,
	"applyToEither":        2,
	"thenAcceptBoth":       3,
	"thenApply":            4,
	"thenRun":              5,
	"thenAccept":           6,
	"thenCompose":          7,
	"thenCombine":          8,
	"whenComplete":         9,
	"handle":               10,
	"supply":               11,
	"invokeFunction":       12,
	"completedValue":       13,
	"delay":                14,
	"allOf":                15,
	"anyOf":                16,
	"externalCompletion":   17,
	"exceptionally":        18,
	"terminationHook":      19,
	"exceptionallyCompose": 20,
}
View Source 
var ErrorDatumType_name = map[int32]string{
	0: "unknown_error",
	1: "stage_timeout",
	2: "stage_failed",
	3: "function_timeout",
	4: "function_invoke_failed",
	5: "stage_lost",
	6: "invalid_stage_response",
}
View Source 
var ErrorDatumType_value = map[string]int32{
	"unknown_error":          0,
	"stage_timeout":          1,
	"stage_failed":           2,
	"function_timeout":       3,
	"function_invoke_failed": 4,
	"stage_lost":             5,
	"invalid_stage_response": 6,
}
View Source 
var HTTPMethod_name = map[int32]string{
	0: "unknown_method",
	1: "get",
	2: "head",
	3: "post",
	4: "put",
	5: "delete",
	7: "options",
	6: "patch",
}
View Source 
var HTTPMethod_value = map[string]int32{
	"unknown_method": 0,
	"get":            1,
	"head":           2,
	"post":           3,
	"put":            4,
	"delete":         5,
	"options":        7,
	"patch":          6,
}
View Source 
var ListGraphsFilter_name = map[int32]string{
	0: "unknown",
	1: "all",
	2: "running",
	3: "completed",
}
View Source 
var ListGraphsFilter_value = map[string]int32{
	"unknown":   0,
	"all":       1,
	"running":   2,
	"completed": 3,
}
View Source 
var StatusDatumType_name = map[int32]string{
	0: "unknown_state",
	1: "succeeded",
	2: "failed",
	3: "cancelled",
	4: "killed",
}
View Source 
var StatusDatumType_value = map[string]int32{
	"unknown_state": 0,
	"succeeded":     1,
	"failed":        2,
	"cancelled":     3,
	"killed":        4,
}

Functions

func Asset 

func Asset(name string) ([]byte, error)

Asset loads and returns the asset for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetDigest 

func AssetDigest(name string) ([sha256.Size]byte, error)

AssetDigest returns the digest of the file with the given name. It returns an error if the asset could not be found or the digest could not be loaded.

func AssetDir 

func AssetDir(name string) ([]string, error)

AssetDir returns the file names below a certain directory embedded in the file by go-bindata. For example if you run go-bindata on data/... and data contains the following hierarchy: 

data/
  foo.txt
  img/
    a.png
    b.png

then AssetDir("data") would return []string{"foo.txt", "img"}, AssetDir("data/img") would return []string{"a.png", "b.png"}, AssetDir("foo.txt") and AssetDir("notexist") would return an error, and AssetDir("") will return []string{"data"}.

func AssetInfo 

func AssetInfo(name string) (os.FileInfo, error)

AssetInfo loads and returns the asset info for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetNames 

func AssetNames() []string

AssetNames returns the names of the assets.

func AssetString 

func AssetString(name string) (string, error)

AssetString returns the asset contents as a string (instead of a []byte).

func Digests 

func Digests() (map[string][sha256.Size]byte, error)

Digests returns a map of all known files and their checksums.

func MustAsset 

func MustAsset(name string) []byte

MustAsset is like Asset but panics when Asset would return an error. It simplifies safe initialization of global variables.

func MustAssetString 

func MustAssetString(name string) string

MustAssetString is like AssetString but panics when Asset would return an error. It simplifies safe initialization of global variables.

func NewAwaitStageError 

func NewAwaitStageError(flowID string, stageID string) error

NewAwaitStageError : Error (including a timeout) awaiting a stage

func NewGraphAlreadyExistsError 

func NewGraphAlreadyExistsError(flowID string) error

NewGraphAlreadyExistsError : can't create the same graph twice

func NewGraphCompletedError 

func NewGraphCompletedError(flowID string) error

NewGraphCompletedError : indicates an invalid operation on an already completed (or terminating) graph

func NewGraphCreationError 

func NewGraphCreationError(flowID string) error

NewGraphCreationError : failed to create graph, no graph exists afterwards

func NewGraphNotFoundError 

func NewGraphNotFoundError(flowID string) error

NewGraphNotFoundError : anywhere a graph is not found

func NewInvalidDatumError 

func NewInvalidDatumError(flowID string) error

NewInvalidDatumError : request contains an invalid datum

func NewInvalidDelayError 

func NewInvalidDelayError(flowID string, delayMs int64) error

NewInvalidDelayError - something wasn't right with your delay

func NewInvalidOperationError 

func NewInvalidOperationError(flowID string) error

NewInvalidOperationError : bad operation in request

func NewInvalidStageDependenciesError 

func NewInvalidStageDependenciesError(flowID string) error

NewInvalidStageDependenciesError : bad stage deps in request

func NewNeedsClosureError 

func NewNeedsClosureError(flowID string) error

NewNeedsClosureError :stage needs a closure

func NewShouldNotHaveClosureError 

func NewShouldNotHaveClosureError(flowID string) error

NewShouldNotHaveClosureError :stage has a closure when it shouldn't

func NewStageNotFoundError 

func NewStageNotFoundError(flowID string, stageID string) error

NewStageNotFoundError : anywhere a stage on an existing graph was not found

func NewTooManyStagesError 

func NewTooManyStagesError(flowID string) error

NewTooManyStagesError : too many stages in your graph

func NewTooManyTerminationHooksError 

func NewTooManyTerminationHooksError(flowID string) error

NewTooManyTerminationHooksError : too many termination hooks on your graph

func RegisterFlowServiceHandler 

func RegisterFlowServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterFlowServiceHandler registers the http handlers for service FlowService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterFlowServiceHandlerClient 

func RegisterFlowServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FlowServiceClient) error

RegisterFlowServiceHandlerClient registers the http handlers for service FlowService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "FlowServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "FlowServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "FlowServiceClient" to call the correct interceptors.

func RegisterFlowServiceHandlerFromEndpoint 

func RegisterFlowServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterFlowServiceHandlerFromEndpoint is same as RegisterFlowServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterFlowServiceServer 

func RegisterFlowServiceServer(s *grpc.Server, srv FlowServiceServer)

func RestoreAsset 

func RestoreAsset(dir, name string) error

RestoreAsset restores an asset under the given directory.

func RestoreAssets 

func RestoreAssets(dir, name string) error

RestoreAssets restores an asset under the given directory recursively.

Types

type AddCompletedValueStageRequest 

type AddCompletedValueStageRequest struct {
	FlowId               string            `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	Value                *CompletionResult `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	CodeLocation         string            `protobuf:"bytes,3,opt,name=code_location,json=codeLocation,proto3" json:"code_location,omitempty"`
	CallerId             string            `protobuf:"bytes,4,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

AddCompletedValueStageRequest creates a new stage with a specific value

func (*AddCompletedValueStageRequest) Descriptor 

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

func (*AddCompletedValueStageRequest) GetCallerId 

func (m *AddCompletedValueStageRequest) GetCallerId() string

func (*AddCompletedValueStageRequest) GetCodeLocation 

func (m *AddCompletedValueStageRequest) GetCodeLocation() string

func (*AddCompletedValueStageRequest) GetDependencyCount 

func (m *AddCompletedValueStageRequest) GetDependencyCount() int

GetDependencyCount for AddStageCommand.GetDependencyCount

func (*AddCompletedValueStageRequest) GetFlowId 

func (m *AddCompletedValueStageRequest) GetFlowId() string

func (*AddCompletedValueStageRequest) GetOperation 

func (m *AddCompletedValueStageRequest) GetOperation() CompletionOperation

GetOperation for AddStageCommand.GetOperation

func (*AddCompletedValueStageRequest) GetValue 

func (m *AddCompletedValueStageRequest) GetValue() *CompletionResult

func (*AddCompletedValueStageRequest) HasClosure 

func (m *AddCompletedValueStageRequest) HasClosure() bool

HasClosure implements AddStageCommand

func (*AddCompletedValueStageRequest) ProtoMessage 

func (*AddCompletedValueStageRequest) ProtoMessage()

func (*AddCompletedValueStageRequest) Reset 

func (m *AddCompletedValueStageRequest) Reset()

func (*AddCompletedValueStageRequest) String 

func (m *AddCompletedValueStageRequest) String() string

func (*AddCompletedValueStageRequest) Validate 

func (this *AddCompletedValueStageRequest) Validate() error

func (*AddCompletedValueStageRequest) XXX_DiscardUnknown 

func (m *AddCompletedValueStageRequest) XXX_DiscardUnknown()

func (*AddCompletedValueStageRequest) XXX_Marshal 

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

func (*AddCompletedValueStageRequest) XXX_Merge 

func (dst *AddCompletedValueStageRequest) XXX_Merge(src proto.Message)

func (*AddCompletedValueStageRequest) XXX_Size 

func (m *AddCompletedValueStageRequest) XXX_Size() int

func (*AddCompletedValueStageRequest) XXX_Unmarshal 

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

type AddDelayStageRequest 

type AddDelayStageRequest struct {
	FlowId               string   `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	DelayMs              int64    `protobuf:"varint,2,opt,name=delay_ms,json=delayMs,proto3" json:"delay_ms,omitempty"`
	CodeLocation         string   `protobuf:"bytes,3,opt,name=code_location,json=codeLocation,proto3" json:"code_location,omitempty"`
	CallerId             string   `protobuf:"bytes,4,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AddDelayStageRequest creates a delay stage

func (*AddDelayStageRequest) Descriptor 

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

func (*AddDelayStageRequest) GetCallerId 

func (m *AddDelayStageRequest) GetCallerId() string

func (*AddDelayStageRequest) GetCodeLocation 

func (m *AddDelayStageRequest) GetCodeLocation() string

func (*AddDelayStageRequest) GetDelayMs 

func (m *AddDelayStageRequest) GetDelayMs() int64

func (*AddDelayStageRequest) GetDependencyCount 

func (m *AddDelayStageRequest) GetDependencyCount() int

GetDependencyCount for AddStageCommand.GetDependencyCount

func (*AddDelayStageRequest) GetFlowId 

func (m *AddDelayStageRequest) GetFlowId() string

func (*AddDelayStageRequest) GetOperation 

func (m *AddDelayStageRequest) GetOperation() CompletionOperation

GetOperation for AddStageCommand.GetOperation

func (*AddDelayStageRequest) HasClosure 

func (m *AddDelayStageRequest) HasClosure() bool

HasClosure implements AddStageCommand

func (*AddDelayStageRequest) ProtoMessage 

func (*AddDelayStageRequest) ProtoMessage()

func (*AddDelayStageRequest) Reset 

func (m *AddDelayStageRequest) Reset()

func (*AddDelayStageRequest) String 

func (m *AddDelayStageRequest) String() string

func (*AddDelayStageRequest) Validate 

func (this *AddDelayStageRequest) Validate() error

func (*AddDelayStageRequest) XXX_DiscardUnknown 

func (m *AddDelayStageRequest) XXX_DiscardUnknown()

func (*AddDelayStageRequest) XXX_Marshal 

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

func (*AddDelayStageRequest) XXX_Merge 

func (dst *AddDelayStageRequest) XXX_Merge(src proto.Message)

func (*AddDelayStageRequest) XXX_Size 

func (m *AddDelayStageRequest) XXX_Size() int

func (*AddDelayStageRequest) XXX_Unmarshal 

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

type AddInvokeFunctionStageRequest 

type AddInvokeFunctionStageRequest struct {
	FlowId               string        `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	FunctionId           string        `protobuf:"bytes,2,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	Arg                  *HTTPReqDatum `protobuf:"bytes,3,opt,name=arg,proto3" json:"arg,omitempty"`
	CodeLocation         string        `protobuf:"bytes,4,opt,name=code_location,json=codeLocation,proto3" json:"code_location,omitempty"`
	CallerId             string        `protobuf:"bytes,5,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

AddInvokeFunctionStageRequest adds a function invocation

func (*AddInvokeFunctionStageRequest) Descriptor 

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

func (*AddInvokeFunctionStageRequest) GetArg 

func (m *AddInvokeFunctionStageRequest) GetArg() *HTTPReqDatum

func (*AddInvokeFunctionStageRequest) GetCallerId 

func (m *AddInvokeFunctionStageRequest) GetCallerId() string

func (*AddInvokeFunctionStageRequest) GetCodeLocation 

func (m *AddInvokeFunctionStageRequest) GetCodeLocation() string

func (*AddInvokeFunctionStageRequest) GetDependencyCount 

func (m *AddInvokeFunctionStageRequest) GetDependencyCount() int

GetDependencyCount for AddStageCommand.GetDependencyCount

func (*AddInvokeFunctionStageRequest) GetFlowId 

func (m *AddInvokeFunctionStageRequest) GetFlowId() string

func (*AddInvokeFunctionStageRequest) GetFunctionId 

func (m *AddInvokeFunctionStageRequest) GetFunctionId() string

func (*AddInvokeFunctionStageRequest) GetOperation 

func (m *AddInvokeFunctionStageRequest) GetOperation() CompletionOperation

GetOperation for AddStageCommand.GetOperation

func (*AddInvokeFunctionStageRequest) HasClosure 

func (m *AddInvokeFunctionStageRequest) HasClosure() bool

HasClosure implements AddStageCommand

func (*AddInvokeFunctionStageRequest) ProtoMessage 

func (*AddInvokeFunctionStageRequest) ProtoMessage()

func (*AddInvokeFunctionStageRequest) Reset 

func (m *AddInvokeFunctionStageRequest) Reset()

func (*AddInvokeFunctionStageRequest) String 

func (m *AddInvokeFunctionStageRequest) String() string

func (*AddInvokeFunctionStageRequest) Validate 

func (this *AddInvokeFunctionStageRequest) Validate() error

func (*AddInvokeFunctionStageRequest) XXX_DiscardUnknown 

func (m *AddInvokeFunctionStageRequest) XXX_DiscardUnknown()

func (*AddInvokeFunctionStageRequest) XXX_Marshal 

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

func (*AddInvokeFunctionStageRequest) XXX_Merge 

func (dst *AddInvokeFunctionStageRequest) XXX_Merge(src proto.Message)

func (*AddInvokeFunctionStageRequest) XXX_Size 

func (m *AddInvokeFunctionStageRequest) XXX_Size() int

func (*AddInvokeFunctionStageRequest) XXX_Unmarshal 

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

type AddStageCommand 

type AddStageCommand interface {
	GetFlowId() string
	GetOperation() CompletionOperation
	GetDependencyCount() int
	GetCodeLocation() string
	GetCallerId() string
	HasClosure() bool
}

AddStageCommand is any command that creates a stage and Warrants an AddStageResponse

type AddStageRequest 

type AddStageRequest struct {
	FlowId               string              `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	Operation            CompletionOperation `protobuf:"varint,2,opt,name=operation,proto3,enum=model.CompletionOperation" json:"operation,omitempty"`
	Closure              *BlobDatum          `protobuf:"bytes,3,opt,name=closure,proto3" json:"closure,omitempty"`
	Deps                 []string            `protobuf:"bytes,4,rep,name=deps,proto3" json:"deps,omitempty"`
	CodeLocation         string              `protobuf:"bytes,5,opt,name=code_location,json=codeLocation,proto3" json:"code_location,omitempty"`
	CallerId             string              `protobuf:"bytes,6,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

AddStageRequest adds a new stage with dependenencies to the graph

func (*AddStageRequest) Descriptor 

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

func (*AddStageRequest) GetCallerId 

func (m *AddStageRequest) GetCallerId() string

func (*AddStageRequest) GetClosure 

func (m *AddStageRequest) GetClosure() *BlobDatum

func (*AddStageRequest) GetCodeLocation 

func (m *AddStageRequest) GetCodeLocation() string

func (*AddStageRequest) GetDependencyCount 

func (m *AddStageRequest) GetDependencyCount() int

GetDependencyCount for AddStageCommand.GetDependencyCount

func (*AddStageRequest) GetDeps 

func (m *AddStageRequest) GetDeps() []string

func (*AddStageRequest) GetFlowId 

func (m *AddStageRequest) GetFlowId() string

func (*AddStageRequest) GetOperation 

func (m *AddStageRequest) GetOperation() CompletionOperation

func (*AddStageRequest) HasClosure 

func (m *AddStageRequest) HasClosure() bool

HasClosure implements AddStageCommand

func (*AddStageRequest) ProtoMessage 

func (*AddStageRequest) ProtoMessage()

func (*AddStageRequest) Reset 

func (m *AddStageRequest) Reset()

func (*AddStageRequest) String 

func (m *AddStageRequest) String() string

func (*AddStageRequest) Validate 

func (this *AddStageRequest) Validate() error

func (*AddStageRequest) XXX_DiscardUnknown 

func (m *AddStageRequest) XXX_DiscardUnknown()

func (*AddStageRequest) XXX_Marshal 

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

func (*AddStageRequest) XXX_Merge 

func (dst *AddStageRequest) XXX_Merge(src proto.Message)

func (*AddStageRequest) XXX_Size 

func (m *AddStageRequest) XXX_Size() int

func (*AddStageRequest) XXX_Unmarshal 

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

type AddStageResponse 

type AddStageResponse struct {
	FlowId               string   `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	StageId              string   `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AddStageResponse returns the stage ID of the created stage

func (*AddStageResponse) Descriptor 

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

func (*AddStageResponse) GetFlowId 

func (m *AddStageResponse) GetFlowId() string

func (*AddStageResponse) GetStageId 

func (m *AddStageResponse) GetStageId() string

func (*AddStageResponse) ProtoMessage 

func (*AddStageResponse) ProtoMessage()

func (*AddStageResponse) Reset 

func (m *AddStageResponse) Reset()

func (*AddStageResponse) String 

func (m *AddStageResponse) String() string

func (*AddStageResponse) Validate 

func (this *AddStageResponse) Validate() error

func (*AddStageResponse) XXX_DiscardUnknown 

func (m *AddStageResponse) XXX_DiscardUnknown()

func (*AddStageResponse) XXX_Marshal 

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

func (*AddStageResponse) XXX_Merge 

func (dst *AddStageResponse) XXX_Merge(src proto.Message)

func (*AddStageResponse) XXX_Size 

func (m *AddStageResponse) XXX_Size() int

func (*AddStageResponse) XXX_Unmarshal 

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

type AwaitStageResultRequest 

type AwaitStageResultRequest struct {
	FlowId               string   `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	StageId              string   `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	TimeoutMs            int32    `protobuf:"varint,3,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeout_ms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AwaitStageResultRequest) Descriptor 

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

func (*AwaitStageResultRequest) GetFlowId 

func (m *AwaitStageResultRequest) GetFlowId() string

func (*AwaitStageResultRequest) GetStageId 

func (m *AwaitStageResultRequest) GetStageId() string

func (*AwaitStageResultRequest) GetTimeoutMs 

func (m *AwaitStageResultRequest) GetTimeoutMs() int32

func (*AwaitStageResultRequest) ProtoMessage 

func (*AwaitStageResultRequest) ProtoMessage()

func (*AwaitStageResultRequest) Reset 

func (m *AwaitStageResultRequest) Reset()

func (*AwaitStageResultRequest) String 

func (m *AwaitStageResultRequest) String() string

func (*AwaitStageResultRequest) Validate 

func (this *AwaitStageResultRequest) Validate() error

func (*AwaitStageResultRequest) XXX_DiscardUnknown 

func (m *AwaitStageResultRequest) XXX_DiscardUnknown()

func (*AwaitStageResultRequest) XXX_Marshal 

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

func (*AwaitStageResultRequest) XXX_Merge 

func (dst *AwaitStageResultRequest) XXX_Merge(src proto.Message)

func (*AwaitStageResultRequest) XXX_Size 

func (m *AwaitStageResultRequest) XXX_Size() int

func (*AwaitStageResultRequest) XXX_Unmarshal 

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

type AwaitStageResultResponse 

type AwaitStageResultResponse struct {
	FlowId               string            `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	StageId              string            `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	Result               *CompletionResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AwaitStageResultResponse) Descriptor 

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

func (*AwaitStageResultResponse) GetFlowId 

func (m *AwaitStageResultResponse) GetFlowId() string

func (*AwaitStageResultResponse) GetResult 

func (m *AwaitStageResultResponse) GetResult() *CompletionResult

func (*AwaitStageResultResponse) GetStageId 

func (m *AwaitStageResultResponse) GetStageId() string

func (*AwaitStageResultResponse) ProtoMessage 

func (*AwaitStageResultResponse) ProtoMessage()

func (*AwaitStageResultResponse) Reset 

func (m *AwaitStageResultResponse) Reset()

func (*AwaitStageResultResponse) String 

func (m *AwaitStageResultResponse) String() string

func (*AwaitStageResultResponse) Validate 

func (this *AwaitStageResultResponse) Validate() error

func (*AwaitStageResultResponse) XXX_DiscardUnknown 

func (m *AwaitStageResultResponse) XXX_DiscardUnknown()

func (*AwaitStageResultResponse) XXX_Marshal 

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

func (*AwaitStageResultResponse) XXX_Merge 

func (dst *AwaitStageResultResponse) XXX_Merge(src proto.Message)

func (*AwaitStageResultResponse) XXX_Size 

func (m *AwaitStageResultResponse) XXX_Size() int

func (*AwaitStageResultResponse) XXX_Unmarshal 

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

type BlobDatum 

type BlobDatum struct {
	BlobId               string   `protobuf:"bytes,1,opt,name=blob_id,json=blobId,proto3" json:"blob_id,omitempty"`
	ContentType          string   `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	Length               int64    `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

BlobDatum holds a reference to a blob the associated blob store

func BlobDatumFromBlobStoreBlob 

func BlobDatumFromBlobStoreBlob(b *blobs.Blob) *BlobDatum

BlobDatumFromBlobStoreBlob creates a model blob from a blobstore result

func NewBlob 

func NewBlob(id string, length int64, contentType string) *BlobDatum

NewBlob creates a new blob body element

func (*BlobDatum) Descriptor 

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

func (*BlobDatum) GetBlobId 

func (m *BlobDatum) GetBlobId() string

func (*BlobDatum) GetContentType 

func (m *BlobDatum) GetContentType() string

func (*BlobDatum) GetLength 

func (m *BlobDatum) GetLength() int64

func (*BlobDatum) ProtoMessage 

func (*BlobDatum) ProtoMessage()

func (*BlobDatum) Reset 

func (m *BlobDatum) Reset()

func (*BlobDatum) String 

func (m *BlobDatum) String() string

func (*BlobDatum) Validate 

func (this *BlobDatum) Validate() error

func (*BlobDatum) XXX_DiscardUnknown 

func (m *BlobDatum) XXX_DiscardUnknown()

func (*BlobDatum) XXX_Marshal 

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

func (*BlobDatum) XXX_Merge 

func (dst *BlobDatum) XXX_Merge(src proto.Message)

func (*BlobDatum) XXX_Size 

func (m *BlobDatum) XXX_Size() int

func (*BlobDatum) XXX_Unmarshal 

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

type Command 

type Command interface {
	GraphMessage
}

Command is the base interface for all user-facing graph requests

type CommitGraphRequest 

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

func (*CommitGraphRequest) Descriptor 

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

func (*CommitGraphRequest) GetFlowId 

func (m *CommitGraphRequest) GetFlowId() string

func (*CommitGraphRequest) ProtoMessage 

func (*CommitGraphRequest) ProtoMessage()

func (*CommitGraphRequest) Reset 

func (m *CommitGraphRequest) Reset()

func (*CommitGraphRequest) String 

func (m *CommitGraphRequest) String() string

func (*CommitGraphRequest) Validate 

func (this *CommitGraphRequest) Validate() error

func (*CommitGraphRequest) XXX_DiscardUnknown 

func (m *CommitGraphRequest) XXX_DiscardUnknown()

func (*CommitGraphRequest) XXX_Marshal 

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

func (*CommitGraphRequest) XXX_Merge 

func (dst *CommitGraphRequest) XXX_Merge(src proto.Message)

func (*CommitGraphRequest) XXX_Size 

func (m *CommitGraphRequest) XXX_Size() int

func (*CommitGraphRequest) XXX_Unmarshal 

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

type CompleteDelayStageRequest 

type CompleteDelayStageRequest struct {
	FlowId               string            `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	StageId              string            `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	Result               *CompletionResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CompleteDelayStageRequest) Descriptor 

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

func (*CompleteDelayStageRequest) GetFlowId 

func (m *CompleteDelayStageRequest) GetFlowId() string

func (*CompleteDelayStageRequest) GetResult 

func (m *CompleteDelayStageRequest) GetResult() *CompletionResult

func (*CompleteDelayStageRequest) GetStageId 

func (m *CompleteDelayStageRequest) GetStageId() string

func (*CompleteDelayStageRequest) ProtoMessage 

func (*CompleteDelayStageRequest) ProtoMessage()

func (*CompleteDelayStageRequest) Reset 

func (m *CompleteDelayStageRequest) Reset()

func (*CompleteDelayStageRequest) String 

func (m *CompleteDelayStageRequest) String() string

func (*CompleteDelayStageRequest) Validate 

func (this *CompleteDelayStageRequest) Validate() error

func (*CompleteDelayStageRequest) XXX_DiscardUnknown 

func (m *CompleteDelayStageRequest) XXX_DiscardUnknown()

func (*CompleteDelayStageRequest) XXX_Marshal 

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

func (*CompleteDelayStageRequest) XXX_Merge 

func (dst *CompleteDelayStageRequest) XXX_Merge(src proto.Message)

func (*CompleteDelayStageRequest) XXX_Size 

func (m *CompleteDelayStageRequest) XXX_Size() int

func (*CompleteDelayStageRequest) XXX_Unmarshal 

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

type CompleteStageExternallyRequest 

type CompleteStageExternallyRequest struct {
	FlowId               string            `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	StageId              string            `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	Value                *CompletionResult `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	CodeLocation         string            `protobuf:"bytes,4,opt,name=code_location,json=codeLocation,proto3" json:"code_location,omitempty"`
	CallerId             string            `protobuf:"bytes,5,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

CompleteStageExternallyRequest marks an existing stage as complete with a specific value

func (*CompleteStageExternallyRequest) Descriptor 

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

func (*CompleteStageExternallyRequest) GetCallerId 

func (m *CompleteStageExternallyRequest) GetCallerId() string

func (*CompleteStageExternallyRequest) GetCodeLocation 

func (m *CompleteStageExternallyRequest) GetCodeLocation() string

func (*CompleteStageExternallyRequest) GetFlowId 

func (m *CompleteStageExternallyRequest) GetFlowId() string

func (*CompleteStageExternallyRequest) GetStageId 

func (m *CompleteStageExternallyRequest) GetStageId() string

func (*CompleteStageExternallyRequest) GetValue 

func (m *CompleteStageExternallyRequest) GetValue() *CompletionResult

func (*CompleteStageExternallyRequest) ProtoMessage 

func (*CompleteStageExternallyRequest) ProtoMessage()

func (*CompleteStageExternallyRequest) Reset 

func (m *CompleteStageExternallyRequest) Reset()

func (*CompleteStageExternallyRequest) String 

func (m *CompleteStageExternallyRequest) String() string

func (*CompleteStageExternallyRequest) Validate 

func (this *CompleteStageExternallyRequest) Validate() error

func (*CompleteStageExternallyRequest) XXX_DiscardUnknown 

func (m *CompleteStageExternallyRequest) XXX_DiscardUnknown()

func (*CompleteStageExternallyRequest) XXX_Marshal 

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

func (*CompleteStageExternallyRequest) XXX_Merge 

func (dst *CompleteStageExternallyRequest) XXX_Merge(src proto.Message)

func (*CompleteStageExternallyRequest) XXX_Size 

func (m *CompleteStageExternallyRequest) XXX_Size() int

func (*CompleteStageExternallyRequest) XXX_Unmarshal 

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

type CompleteStageExternallyResponse 

type CompleteStageExternallyResponse struct {
	FlowId               string   `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	StageId              string   `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	Successful           bool     `protobuf:"varint,3,opt,name=successful,proto3" json:"successful,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CompleteStageExternallyResponse) Descriptor 

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

func (*CompleteStageExternallyResponse) GetFlowId 

func (m *CompleteStageExternallyResponse) GetFlowId() string

func (*CompleteStageExternallyResponse) GetStageId 

func (m *CompleteStageExternallyResponse) GetStageId() string

func (*CompleteStageExternallyResponse) GetSuccessful 

func (m *CompleteStageExternallyResponse) GetSuccessful() bool

func (*CompleteStageExternallyResponse) ProtoMessage 

func (*CompleteStageExternallyResponse) ProtoMessage()

func (*CompleteStageExternallyResponse) Reset 

func (m *CompleteStageExternallyResponse) Reset()

func (*CompleteStageExternallyResponse) String 

func (m *CompleteStageExternallyResponse) String() string

func (*CompleteStageExternallyResponse) Validate 

func (this *CompleteStageExternallyResponse) Validate() error

func (*CompleteStageExternallyResponse) XXX_DiscardUnknown 

func (m *CompleteStageExternallyResponse) XXX_DiscardUnknown()

func (*CompleteStageExternallyResponse) XXX_Marshal 

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

func (*CompleteStageExternallyResponse) XXX_Merge 

func (dst *CompleteStageExternallyResponse) XXX_Merge(src proto.Message)

func (*CompleteStageExternallyResponse) XXX_Size 

func (m *CompleteStageExternallyResponse) XXX_Size() int

func (*CompleteStageExternallyResponse) XXX_Unmarshal 

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

type CompletionOperation 

type CompletionOperation int32

CompletionOperation describes the type and behaviour of a stage of the graph 

const (
	CompletionOperation_unknown_operation    CompletionOperation = 0
	CompletionOperation_acceptEither         CompletionOperation = 1
	CompletionOperation_applyToEither        CompletionOperation = 2
	CompletionOperation_thenAcceptBoth       CompletionOperation = 3
	CompletionOperation_thenApply            CompletionOperation = 4
	CompletionOperation_thenRun              CompletionOperation = 5
	CompletionOperation_thenAccept           CompletionOperation = 6
	CompletionOperation_thenCompose          CompletionOperation = 7
	CompletionOperation_thenCombine          CompletionOperation = 8
	CompletionOperation_whenComplete         CompletionOperation = 9
	CompletionOperation_handle               CompletionOperation = 10
	CompletionOperation_supply               CompletionOperation = 11
	CompletionOperation_invokeFunction       CompletionOperation = 12
	CompletionOperation_completedValue       CompletionOperation = 13
	CompletionOperation_delay                CompletionOperation = 14
	CompletionOperation_allOf                CompletionOperation = 15
	CompletionOperation_anyOf                CompletionOperation = 16
	CompletionOperation_externalCompletion   CompletionOperation = 17
	CompletionOperation_exceptionally        CompletionOperation = 18
	CompletionOperation_terminationHook      CompletionOperation = 19
	CompletionOperation_exceptionallyCompose CompletionOperation = 20
)

func (CompletionOperation) EnumDescriptor 

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

func (CompletionOperation) String 

func (x CompletionOperation) String() string

type CompletionResult 

type CompletionResult struct {
	Successful           bool     `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"`
	Datum                *Datum   `protobuf:"bytes,2,opt,name=datum,proto3" json:"datum,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CompletinonResult holds a value Datum and a result status (successful/failed)

func NewEmptyResult 

func NewEmptyResult() *CompletionResult

NewEmptyResult creates a successful result with an empty datum attached

func NewFailedResult 

func NewFailedResult(datum *Datum) *CompletionResult

NewFailedResult creates a failed result from a given datum

func NewInternalErrorResult 

func NewInternalErrorResult(code ErrorDatumType, message string) *CompletionResult

NewInternalErrorResult is a shortcut to create an error result with a given message

func NewSuccessfulResult 

func NewSuccessfulResult(datum *Datum) *CompletionResult

NewSuccessfulResult creates a successful result from a given datum

func (*CompletionResult) Descriptor 

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

func (*CompletionResult) GetDatum 

func (m *CompletionResult) GetDatum() *Datum

func (*CompletionResult) GetSuccessful 

func (m *CompletionResult) GetSuccessful() bool

func (*CompletionResult) ProtoMessage 

func (*CompletionResult) ProtoMessage()

func (*CompletionResult) Reset 

func (m *CompletionResult) Reset()

func (*CompletionResult) String 

func (m *CompletionResult) String() string

func (*CompletionResult) Validate 

func (this *CompletionResult) Validate() error

func (*CompletionResult) XXX_DiscardUnknown 

func (m *CompletionResult) XXX_DiscardUnknown()

func (*CompletionResult) XXX_Marshal 

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

func (*CompletionResult) XXX_Merge 

func (dst *CompletionResult) XXX_Merge(src proto.Message)

func (*CompletionResult) XXX_Size 

func (m *CompletionResult) XXX_Size() int

func (*CompletionResult) XXX_Unmarshal 

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

type CreateGraphRequest 

type CreateGraphRequest struct {
	FunctionId           string   `protobuf:"bytes,1,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	FlowId               string   `protobuf:"bytes,2,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateGraphRequest) Descriptor 

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

func (*CreateGraphRequest) GetFlowId 

func (m *CreateGraphRequest) GetFlowId() string

func (*CreateGraphRequest) GetFunctionId 

func (m *CreateGraphRequest) GetFunctionId() string

func (*CreateGraphRequest) ProtoMessage 

func (*CreateGraphRequest) ProtoMessage()

func (*CreateGraphRequest) Reset 

func (m *CreateGraphRequest) Reset()

func (*CreateGraphRequest) String 

func (m *CreateGraphRequest) String() string

func (*CreateGraphRequest) Validate 

func (this *CreateGraphRequest) Validate() error

func (*CreateGraphRequest) XXX_DiscardUnknown 

func (m *CreateGraphRequest) XXX_DiscardUnknown()

func (*CreateGraphRequest) XXX_Marshal 

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

func (*CreateGraphRequest) XXX_Merge 

func (dst *CreateGraphRequest) XXX_Merge(src proto.Message)

func (*CreateGraphRequest) XXX_Size 

func (m *CreateGraphRequest) XXX_Size() int

func (*CreateGraphRequest) XXX_Unmarshal 

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

type CreateGraphResponse 

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

func (*CreateGraphResponse) Descriptor 

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

func (*CreateGraphResponse) GetFlowId 

func (m *CreateGraphResponse) GetFlowId() string

func (*CreateGraphResponse) ProtoMessage 

func (*CreateGraphResponse) ProtoMessage()

func (*CreateGraphResponse) Reset 

func (m *CreateGraphResponse) Reset()

func (*CreateGraphResponse) String 

func (m *CreateGraphResponse) String() string

func (*CreateGraphResponse) Validate 

func (this *CreateGraphResponse) Validate() error

func (*CreateGraphResponse) XXX_DiscardUnknown 

func (m *CreateGraphResponse) XXX_DiscardUnknown()

func (*CreateGraphResponse) XXX_Marshal 

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

func (*CreateGraphResponse) XXX_Merge 

func (dst *CreateGraphResponse) XXX_Merge(src proto.Message)

func (*CreateGraphResponse) XXX_Size 

func (m *CreateGraphResponse) XXX_Size() int

func (*CreateGraphResponse) XXX_Unmarshal 

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

type Datum 

type Datum struct {
	// Types that are valid to be assigned to Val:
	//	*Datum_Empty
	//	*Datum_Blob
	//	*Datum_Error
	//	*Datum_StageRef
	//	*Datum_HttpReq
	//	*Datum_HttpResp
	//	*Datum_Status
	Val                  isDatum_Val `protobuf_oneof:"val"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Datum encapusulates all possible values that may be associated with a stage in the flow graph

func NewBlobDatum 

func NewBlobDatum(body *BlobDatum) *Datum

NewBlobDatum creates a new blob datum

func NewEmptyDatum 

func NewEmptyDatum() *Datum

NewEmptyDatum creates a new empty datum

func NewHTTPReqDatum 

func NewHTTPReqDatum(httpreq *HTTPReqDatum) *Datum

NewHTTPReqDatum creates a datum from a HttpReq

func NewStageRefDatum 

func NewStageRefDatum(stageID string) *Datum

NewStageRefDatum creates a stage ref datum to a specific stage in the current graph

func NewStateDatum 

func NewStateDatum(statusType StatusDatumType) *Datum

NewStateDatum creates a graph state datum

func (*Datum) Descriptor 

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

func (*Datum) GetBlob 

func (m *Datum) GetBlob() *BlobDatum

func (*Datum) GetEmpty 

func (m *Datum) GetEmpty() *EmptyDatum

func (*Datum) GetError 

func (m *Datum) GetError() *ErrorDatum

func (*Datum) GetHttpReq 

func (m *Datum) GetHttpReq() *HTTPReqDatum

func (*Datum) GetHttpResp 

func (m *Datum) GetHttpResp() *HTTPRespDatum

func (*Datum) GetStageRef 

func (m *Datum) GetStageRef() *StageRefDatum

func (*Datum) GetStatus 

func (m *Datum) GetStatus() *StatusDatum

func (*Datum) GetVal 

func (m *Datum) GetVal() isDatum_Val

func (*Datum) HasValidValue 

func (d *Datum) HasValidValue() bool

HasValidValue is Quick mixin to overcome issues with oneof - this checks if at least one of the oneof values is set

func (*Datum) ProtoMessage 

func (*Datum) ProtoMessage()

func (*Datum) Reset 

func (m *Datum) Reset()

func (*Datum) String 

func (m *Datum) String() string

func (*Datum) Validate 

func (this *Datum) Validate() error

func (*Datum) XXX_DiscardUnknown 

func (m *Datum) XXX_DiscardUnknown()

func (*Datum) XXX_Marshal 

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

func (*Datum) XXX_Merge 

func (dst *Datum) XXX_Merge(src proto.Message)

func (*Datum) XXX_OneofFuncs 

func (*Datum) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Datum) XXX_Size 

func (m *Datum) XXX_Size() int

func (*Datum) XXX_Unmarshal 

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

type Datum_Blob 

type Datum_Blob struct {
	Blob *BlobDatum `protobuf:"bytes,2,opt,name=blob,proto3,oneof"`
}

type Datum_Empty 

type Datum_Empty struct {
	Empty *EmptyDatum `protobuf:"bytes,1,opt,name=empty,proto3,oneof"`
}

type Datum_Error 

type Datum_Error struct {
	Error *ErrorDatum `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}

type Datum_HttpReq 

type Datum_HttpReq struct {
	HttpReq *HTTPReqDatum `protobuf:"bytes,5,opt,name=http_req,json=httpReq,proto3,oneof"`
}

type Datum_HttpResp 

type Datum_HttpResp struct {
	HttpResp *HTTPRespDatum `protobuf:"bytes,6,opt,name=http_resp,json=httpResp,proto3,oneof"`
}

type Datum_StageRef 

type Datum_StageRef struct {
	StageRef *StageRefDatum `protobuf:"bytes,4,opt,name=stage_ref,json=stageRef,proto3,oneof"`
}

type Datum_Status 

type Datum_Status struct {
	Status *StatusDatum `protobuf:"bytes,7,opt,name=status,proto3,oneof"`
}

type DeactivateGraphRequest 

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

func (*DeactivateGraphRequest) Descriptor 

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

func (*DeactivateGraphRequest) GetFlowId 

func (m *DeactivateGraphRequest) GetFlowId() string

func (*DeactivateGraphRequest) ProtoMessage 

func (*DeactivateGraphRequest) ProtoMessage()

func (*DeactivateGraphRequest) Reset 

func (m *DeactivateGraphRequest) Reset()

func (*DeactivateGraphRequest) String 

func (m *DeactivateGraphRequest) String() string

func (*DeactivateGraphRequest) Validate 

func (this *DeactivateGraphRequest) Validate() error

func (*DeactivateGraphRequest) XXX_DiscardUnknown 

func (m *DeactivateGraphRequest) XXX_DiscardUnknown()

func (*DeactivateGraphRequest) XXX_Marshal 

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

func (*DeactivateGraphRequest) XXX_Merge 

func (dst *DeactivateGraphRequest) XXX_Merge(src proto.Message)

func (*DeactivateGraphRequest) XXX_Size 

func (m *DeactivateGraphRequest) XXX_Size() int

func (*DeactivateGraphRequest) XXX_Unmarshal 

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

type DelayScheduledEvent 

type DelayScheduledEvent struct {
	StageId              string               `protobuf:"bytes,1,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	TimeMs               int64                `protobuf:"varint,2,opt,name=time_ms,json=timeMs,proto3" json:"time_ms,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=ts,proto3" json:"ts,omitempty"`
	FlowId               string               `protobuf:"bytes,4,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A delay has started - this marks the relative start of an event when a delay node is recovered

func (*DelayScheduledEvent) Descriptor 

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

func (*DelayScheduledEvent) GetFlowId 

func (m *DelayScheduledEvent) GetFlowId() string

func (*DelayScheduledEvent) GetStageId 

func (m *DelayScheduledEvent) GetStageId() string

func (*DelayScheduledEvent) GetTimeMs 

func (m *DelayScheduledEvent) GetTimeMs() int64

func (*DelayScheduledEvent) GetTs 

func (m *DelayScheduledEvent) GetTs() *timestamp.Timestamp

func (*DelayScheduledEvent) ProtoMessage 

func (*DelayScheduledEvent) ProtoMessage()

func (*DelayScheduledEvent) Reset 

func (m *DelayScheduledEvent) Reset()

func (*DelayScheduledEvent) String 

func (m *DelayScheduledEvent) String() string

func (*DelayScheduledEvent) ToGraphStreamEvent 

func (m *DelayScheduledEvent) ToGraphStreamEvent(index int) *GraphStreamEvent

ToGraphStreamEvent implements StreamableGraphEvent

func (*DelayScheduledEvent) Validate 

func (this *DelayScheduledEvent) Validate() error

func (*DelayScheduledEvent) XXX_DiscardUnknown 

func (m *DelayScheduledEvent) XXX_DiscardUnknown()

func (*DelayScheduledEvent) XXX_Marshal 

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

func (*DelayScheduledEvent) XXX_Merge 

func (dst *DelayScheduledEvent) XXX_Merge(src proto.Message)

func (*DelayScheduledEvent) XXX_Size 

func (m *DelayScheduledEvent) XXX_Size() int

func (*DelayScheduledEvent) XXX_Unmarshal 

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

type EmptyDatum 

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

EmptyDatum represents a null or empty value

func (*EmptyDatum) Descriptor 

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

func (*EmptyDatum) ProtoMessage 

func (*EmptyDatum) ProtoMessage()

func (*EmptyDatum) Reset 

func (m *EmptyDatum) Reset()

func (*EmptyDatum) String 

func (m *EmptyDatum) String() string

func (*EmptyDatum) Validate 

func (this *EmptyDatum) Validate() error

func (*EmptyDatum) XXX_DiscardUnknown 

func (m *EmptyDatum) XXX_DiscardUnknown()

func (*EmptyDatum) XXX_Marshal 

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

func (*EmptyDatum) XXX_Merge 

func (dst *EmptyDatum) XXX_Merge(src proto.Message)

func (*EmptyDatum) XXX_Size 

func (m *EmptyDatum) XXX_Size() int

func (*EmptyDatum) XXX_Unmarshal 

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

type ErrorDatum 

type ErrorDatum struct {
	Type                 ErrorDatumType `protobuf:"varint,1,opt,name=type,proto3,enum=model.ErrorDatumType" json:"type,omitempty"`
	Message              string         `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

ErrorDatum represents an error that has occured within a flow graph, the type indicates the cause of the error and the message is informational

func (*ErrorDatum) Descriptor 

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

func (*ErrorDatum) GetMessage 

func (m *ErrorDatum) GetMessage() string

func (*ErrorDatum) GetType 

func (m *ErrorDatum) GetType() ErrorDatumType

func (*ErrorDatum) ProtoMessage 

func (*ErrorDatum) ProtoMessage()

func (*ErrorDatum) Reset 

func (m *ErrorDatum) Reset()

func (*ErrorDatum) String 

func (m *ErrorDatum) String() string

func (*ErrorDatum) Validate 

func (this *ErrorDatum) Validate() error

func (*ErrorDatum) XXX_DiscardUnknown 

func (m *ErrorDatum) XXX_DiscardUnknown()

func (*ErrorDatum) XXX_Marshal 

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

func (*ErrorDatum) XXX_Merge 

func (dst *ErrorDatum) XXX_Merge(src proto.Message)

func (*ErrorDatum) XXX_Size 

func (m *ErrorDatum) XXX_Size() int

func (*ErrorDatum) XXX_Unmarshal 

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

type ErrorDatumType 

type ErrorDatumType int32

ErrorDatumType defines an internal error code generated within a flow 

const (
	ErrorDatumType_unknown_error          ErrorDatumType = 0
	ErrorDatumType_stage_timeout          ErrorDatumType = 1
	ErrorDatumType_stage_failed           ErrorDatumType = 2
	ErrorDatumType_function_timeout       ErrorDatumType = 3
	ErrorDatumType_function_invoke_failed ErrorDatumType = 4
	ErrorDatumType_stage_lost             ErrorDatumType = 5
	ErrorDatumType_invalid_stage_response ErrorDatumType = 6
)

func (ErrorDatumType) EnumDescriptor 

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

func (ErrorDatumType) String 

func (x ErrorDatumType) String() string

type Event 

type Event interface {
	proto.Message
	GetTs() *timestamp.Timestamp
}

Event is the base interface for all things that may be persisted to the Journal

type FaasInvocationCompletedEvent 

type FaasInvocationCompletedEvent struct {
	StageId              string               `protobuf:"bytes,1,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	Result               *CompletionResult    `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=ts,proto3" json:"ts,omitempty"`
	CallId               string               `protobuf:"bytes,4,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	FlowId               string               `protobuf:"bytes,5,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A call to the FaaS completed

func (*FaasInvocationCompletedEvent) Descriptor 

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

func (*FaasInvocationCompletedEvent) GetCallId 

func (m *FaasInvocationCompletedEvent) GetCallId() string

func (*FaasInvocationCompletedEvent) GetFlowId 

func (m *FaasInvocationCompletedEvent) GetFlowId() string

func (*FaasInvocationCompletedEvent) GetResult 

func (m *FaasInvocationCompletedEvent) GetResult() *CompletionResult

func (*FaasInvocationCompletedEvent) GetStageId 

func (m *FaasInvocationCompletedEvent) GetStageId() string

func (*FaasInvocationCompletedEvent) GetTs 

func (m *FaasInvocationCompletedEvent) GetTs() *timestamp.Timestamp

func (*FaasInvocationCompletedEvent) ProtoMessage 

func (*FaasInvocationCompletedEvent) ProtoMessage()

func (*FaasInvocationCompletedEvent) Reset 

func (m *FaasInvocationCompletedEvent) Reset()

func (*FaasInvocationCompletedEvent) String 

func (m *FaasInvocationCompletedEvent) String() string

func (*FaasInvocationCompletedEvent) ToGraphStreamEvent 

func (m *FaasInvocationCompletedEvent) ToGraphStreamEvent(index int) *GraphStreamEvent

ToGraphStreamEvent implements StreamableGraphEvent

func (*FaasInvocationCompletedEvent) Validate 

func (this *FaasInvocationCompletedEvent) Validate() error

func (*FaasInvocationCompletedEvent) XXX_DiscardUnknown 

func (m *FaasInvocationCompletedEvent) XXX_DiscardUnknown()

func (*FaasInvocationCompletedEvent) XXX_Marshal 

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

func (*FaasInvocationCompletedEvent) XXX_Merge 

func (dst *FaasInvocationCompletedEvent) XXX_Merge(src proto.Message)

func (*FaasInvocationCompletedEvent) XXX_Size 

func (m *FaasInvocationCompletedEvent) XXX_Size() int

func (*FaasInvocationCompletedEvent) XXX_Unmarshal 

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

type FaasInvocationResponse 

type FaasInvocationResponse struct {
	FlowId               string            `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	StageId              string            `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	FunctionId           string            `protobuf:"bytes,3,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	Result               *CompletionResult `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	CallId               string            `protobuf:"bytes,5,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*FaasInvocationResponse) Descriptor 

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

func (*FaasInvocationResponse) GetCallId 

func (m *FaasInvocationResponse) GetCallId() string

func (*FaasInvocationResponse) GetFlowId 

func (m *FaasInvocationResponse) GetFlowId() string

func (*FaasInvocationResponse) GetFunctionId 

func (m *FaasInvocationResponse) GetFunctionId() string

func (*FaasInvocationResponse) GetResult 

func (m *FaasInvocationResponse) GetResult() *CompletionResult

func (*FaasInvocationResponse) GetStageId 

func (m *FaasInvocationResponse) GetStageId() string

func (*FaasInvocationResponse) ProtoMessage 

func (*FaasInvocationResponse) ProtoMessage()

func (*FaasInvocationResponse) Reset 

func (m *FaasInvocationResponse) Reset()

func (*FaasInvocationResponse) String 

func (m *FaasInvocationResponse) String() string

func (*FaasInvocationResponse) Validate 

func (this *FaasInvocationResponse) Validate() error

func (*FaasInvocationResponse) XXX_DiscardUnknown 

func (m *FaasInvocationResponse) XXX_DiscardUnknown()

func (*FaasInvocationResponse) XXX_Marshal 

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

func (*FaasInvocationResponse) XXX_Merge 

func (dst *FaasInvocationResponse) XXX_Merge(src proto.Message)

func (*FaasInvocationResponse) XXX_Size 

func (m *FaasInvocationResponse) XXX_Size() int

func (*FaasInvocationResponse) XXX_Unmarshal 

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

type FaasInvocationStartedEvent 

type FaasInvocationStartedEvent struct {
	StageId              string               `protobuf:"bytes,1,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,2,opt,name=ts,proto3" json:"ts,omitempty"`
	FunctionId           string               `protobuf:"bytes,3,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	FlowId               string               `protobuf:"bytes,4,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A call to the FaaS has started

func (*FaasInvocationStartedEvent) Descriptor 

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

func (*FaasInvocationStartedEvent) GetFlowId 

func (m *FaasInvocationStartedEvent) GetFlowId() string

func (*FaasInvocationStartedEvent) GetFunctionId 

func (m *FaasInvocationStartedEvent) GetFunctionId() string

func (*FaasInvocationStartedEvent) GetStageId 

func (m *FaasInvocationStartedEvent) GetStageId() string

func (*FaasInvocationStartedEvent) GetTs 

func (m *FaasInvocationStartedEvent) GetTs() *timestamp.Timestamp

func (*FaasInvocationStartedEvent) ProtoMessage 

func (*FaasInvocationStartedEvent) ProtoMessage()

func (*FaasInvocationStartedEvent) Reset 

func (m *FaasInvocationStartedEvent) Reset()

func (*FaasInvocationStartedEvent) String 

func (m *FaasInvocationStartedEvent) String() string

func (*FaasInvocationStartedEvent) ToGraphStreamEvent 

func (m *FaasInvocationStartedEvent) ToGraphStreamEvent(index int) *GraphStreamEvent

ToGraphStreamEvent implements StreamableGraphEvent

func (*FaasInvocationStartedEvent) Validate 

func (this *FaasInvocationStartedEvent) Validate() error

func (*FaasInvocationStartedEvent) XXX_DiscardUnknown 

func (m *FaasInvocationStartedEvent) XXX_DiscardUnknown()

func (*FaasInvocationStartedEvent) XXX_Marshal 

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

func (*FaasInvocationStartedEvent) XXX_Merge 

func (dst *FaasInvocationStartedEvent) XXX_Merge(src proto.Message)

func (*FaasInvocationStartedEvent) XXX_Size 

func (m *FaasInvocationStartedEvent) XXX_Size() int

func (*FaasInvocationStartedEvent) XXX_Unmarshal 

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

type FlowServiceClient 

type FlowServiceClient interface {
	CreateGraph(ctx context.Context, in *CreateGraphRequest, opts ...grpc.CallOption) (*CreateGraphResponse, error)
	AddStage(ctx context.Context, in *AddStageRequest, opts ...grpc.CallOption) (*AddStageResponse, error)
	AddValueStage(ctx context.Context, in *AddCompletedValueStageRequest, opts ...grpc.CallOption) (*AddStageResponse, error)
	AddInvokeFunction(ctx context.Context, in *AddInvokeFunctionStageRequest, opts ...grpc.CallOption) (*AddStageResponse, error)
	AddDelay(ctx context.Context, in *AddDelayStageRequest, opts ...grpc.CallOption) (*AddStageResponse, error)
	AwaitStageResult(ctx context.Context, in *AwaitStageResultRequest, opts ...grpc.CallOption) (*AwaitStageResultResponse, error)
	CompleteStageExternally(ctx context.Context, in *CompleteStageExternallyRequest, opts ...grpc.CallOption) (*CompleteStageExternallyResponse, error)
	Commit(ctx context.Context, in *CommitGraphRequest, opts ...grpc.CallOption) (*GraphRequestProcessedResponse, error)
	GetGraphState(ctx context.Context, in *GetGraphStateRequest, opts ...grpc.CallOption) (*GetGraphStateResponse, error)
	StreamLifecycle(ctx context.Context, in *StreamLifecycleRequest, opts ...grpc.CallOption) (FlowService_StreamLifecycleClient, error)
	StreamEvents(ctx context.Context, in *StreamGraphRequest, opts ...grpc.CallOption) (FlowService_StreamEventsClient, error)
}

FlowServiceClient is the client API for FlowService service.

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

func NewFlowServiceClient 

func NewFlowServiceClient(cc *grpc.ClientConn) FlowServiceClient

type FlowServiceServer 

type FlowServiceServer interface {
	CreateGraph(context.Context, *CreateGraphRequest) (*CreateGraphResponse, error)
	AddStage(context.Context, *AddStageRequest) (*AddStageResponse, error)
	AddValueStage(context.Context, *AddCompletedValueStageRequest) (*AddStageResponse, error)
	AddInvokeFunction(context.Context, *AddInvokeFunctionStageRequest) (*AddStageResponse, error)
	AddDelay(context.Context, *AddDelayStageRequest) (*AddStageResponse, error)
	AwaitStageResult(context.Context, *AwaitStageResultRequest) (*AwaitStageResultResponse, error)
	CompleteStageExternally(context.Context, *CompleteStageExternallyRequest) (*CompleteStageExternallyResponse, error)
	Commit(context.Context, *CommitGraphRequest) (*GraphRequestProcessedResponse, error)
	GetGraphState(context.Context, *GetGraphStateRequest) (*GetGraphStateResponse, error)
	StreamLifecycle(*StreamLifecycleRequest, FlowService_StreamLifecycleServer) error
	StreamEvents(*StreamGraphRequest, FlowService_StreamEventsServer) error
}

FlowServiceServer is the server API for FlowService service.

type FlowService_StreamEventsClient 

type FlowService_StreamEventsClient interface {
	Recv() (*GraphStreamEvent, error)
	grpc.ClientStream
}

type FlowService_StreamEventsServer 

type FlowService_StreamEventsServer interface {
	Send(*GraphStreamEvent) error
	grpc.ServerStream
}

type FlowService_StreamLifecycleClient 

type FlowService_StreamLifecycleClient interface {
	Recv() (*GraphLifecycleEvent, error)
	grpc.ClientStream
}

type FlowService_StreamLifecycleServer 

type FlowService_StreamLifecycleServer interface {
	Send(*GraphLifecycleEvent) error
	grpc.ServerStream
}

type GetGraphStateRequest 

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

func (*GetGraphStateRequest) Descriptor 

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

func (*GetGraphStateRequest) GetFlowId 

func (m *GetGraphStateRequest) GetFlowId() string

func (*GetGraphStateRequest) ProtoMessage 

func (*GetGraphStateRequest) ProtoMessage()

func (*GetGraphStateRequest) Reset 

func (m *GetGraphStateRequest) Reset()

func (*GetGraphStateRequest) String 

func (m *GetGraphStateRequest) String() string

func (*GetGraphStateRequest) Validate 

func (this *GetGraphStateRequest) Validate() error

func (*GetGraphStateRequest) XXX_DiscardUnknown 

func (m *GetGraphStateRequest) XXX_DiscardUnknown()

func (*GetGraphStateRequest) XXX_Marshal 

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

func (*GetGraphStateRequest) XXX_Merge 

func (dst *GetGraphStateRequest) XXX_Merge(src proto.Message)

func (*GetGraphStateRequest) XXX_Size 

func (m *GetGraphStateRequest) XXX_Size() int

func (*GetGraphStateRequest) XXX_Unmarshal 

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

type GetGraphStateResponse 

type GetGraphStateResponse struct {
	Stages               map[string]*GetGraphStateResponse_StageRepresentation `` /* 153-byte string literal not displayed */
	FunctionId           string                                                `protobuf:"bytes,2,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	FlowId               string                                                `protobuf:"bytes,3,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                              `json:"-"`
	XXX_unrecognized     []byte                                                `json:"-"`
	XXX_sizecache        int32                                                 `json:"-"`
}

func (*GetGraphStateResponse) Descriptor 

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

func (*GetGraphStateResponse) GetFlowId 

func (m *GetGraphStateResponse) GetFlowId() string

func (*GetGraphStateResponse) GetFunctionId 

func (m *GetGraphStateResponse) GetFunctionId() string

func (*GetGraphStateResponse) GetStages 

func (m *GetGraphStateResponse) GetStages() map[string]*GetGraphStateResponse_StageRepresentation

func (*GetGraphStateResponse) ProtoMessage 

func (*GetGraphStateResponse) ProtoMessage()

func (*GetGraphStateResponse) Reset 

func (m *GetGraphStateResponse) Reset()

func (*GetGraphStateResponse) String 

func (m *GetGraphStateResponse) String() string

func (*GetGraphStateResponse) Validate 

func (this *GetGraphStateResponse) Validate() error

func (*GetGraphStateResponse) XXX_DiscardUnknown 

func (m *GetGraphStateResponse) XXX_DiscardUnknown()

func (*GetGraphStateResponse) XXX_Marshal 

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

func (*GetGraphStateResponse) XXX_Merge 

func (dst *GetGraphStateResponse) XXX_Merge(src proto.Message)

func (*GetGraphStateResponse) XXX_Size 

func (m *GetGraphStateResponse) XXX_Size() int

func (*GetGraphStateResponse) XXX_Unmarshal 

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

type GetGraphStateResponse_StageRepresentation 

type GetGraphStateResponse_StageRepresentation struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Status               string   `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Dependencies         []string `protobuf:"bytes,3,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetGraphStateResponse_StageRepresentation) Descriptor 

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

func (*GetGraphStateResponse_StageRepresentation) GetDependencies 

func (m *GetGraphStateResponse_StageRepresentation) GetDependencies() []string

func (*GetGraphStateResponse_StageRepresentation) GetStatus 

func (m *GetGraphStateResponse_StageRepresentation) GetStatus() string

func (*GetGraphStateResponse_StageRepresentation) GetType 

func (m *GetGraphStateResponse_StageRepresentation) GetType() string

func (*GetGraphStateResponse_StageRepresentation) ProtoMessage 

func (*GetGraphStateResponse_StageRepresentation) ProtoMessage()

func (*GetGraphStateResponse_StageRepresentation) Reset 

func (m *GetGraphStateResponse_StageRepresentation) Reset()

func (*GetGraphStateResponse_StageRepresentation) String 

func (m *GetGraphStateResponse_StageRepresentation) String() string

func (*GetGraphStateResponse_StageRepresentation) Validate 

func (this *GetGraphStateResponse_StageRepresentation) Validate() error

func (*GetGraphStateResponse_StageRepresentation) XXX_DiscardUnknown 

func (m *GetGraphStateResponse_StageRepresentation) XXX_DiscardUnknown()

func (*GetGraphStateResponse_StageRepresentation) XXX_Marshal 

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

func (*GetGraphStateResponse_StageRepresentation) XXX_Merge 

func (dst *GetGraphStateResponse_StageRepresentation) XXX_Merge(src proto.Message)

func (*GetGraphStateResponse_StageRepresentation) XXX_Size 

func (m *GetGraphStateResponse_StageRepresentation) XXX_Size() int

func (*GetGraphStateResponse_StageRepresentation) XXX_Unmarshal 

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

type GraphCommittedEvent 

type GraphCommittedEvent struct {
	FlowId               string               `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,2,opt,name=ts,proto3" json:"ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

The graph is committed - this typically indicates that the function that created the flow has completed once this event has been posted the graph will finish when all active or pending nodes have completed.

func (*GraphCommittedEvent) Descriptor 

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

func (*GraphCommittedEvent) GetFlowId 

func (m *GraphCommittedEvent) GetFlowId() string

func (*GraphCommittedEvent) GetTs 

func (m *GraphCommittedEvent) GetTs() *timestamp.Timestamp

func (*GraphCommittedEvent) ProtoMessage 

func (*GraphCommittedEvent) ProtoMessage()

func (*GraphCommittedEvent) Reset 

func (m *GraphCommittedEvent) Reset()

func (*GraphCommittedEvent) String 

func (m *GraphCommittedEvent) String() string

func (*GraphCommittedEvent) ToGraphStreamEvent 

func (m *GraphCommittedEvent) ToGraphStreamEvent(index int) *GraphStreamEvent

ToGraphStreamEvent implements StreamableGraphEvent

func (*GraphCommittedEvent) Validate 

func (this *GraphCommittedEvent) Validate() error

func (*GraphCommittedEvent) XXX_DiscardUnknown 

func (m *GraphCommittedEvent) XXX_DiscardUnknown()

func (*GraphCommittedEvent) XXX_Marshal 

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

func (*GraphCommittedEvent) XXX_Merge 

func (dst *GraphCommittedEvent) XXX_Merge(src proto.Message)

func (*GraphCommittedEvent) XXX_Size 

func (m *GraphCommittedEvent) XXX_Size() int

func (*GraphCommittedEvent) XXX_Unmarshal 

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

type GraphCompletedEvent 

type GraphCompletedEvent struct {
	FlowId               string               `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	FunctionId           string               `protobuf:"bytes,2,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=ts,proto3" json:"ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Graph is complete and will no longer change

func (*GraphCompletedEvent) Descriptor 

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

func (*GraphCompletedEvent) GetFlowId 

func (m *GraphCompletedEvent) GetFlowId() string

func (*GraphCompletedEvent) GetFunctionId 

func (m *GraphCompletedEvent) GetFunctionId() string

func (*GraphCompletedEvent) GetTs 

func (m *GraphCompletedEvent) GetTs() *timestamp.Timestamp

func (*GraphCompletedEvent) GraphLifecycleEvent 

func (m *GraphCompletedEvent) GraphLifecycleEvent(index int) *GraphLifecycleEvent

GraphLifecycleEvent implements GraphLifecycleEventSource

func (*GraphCompletedEvent) ProtoMessage 

func (*GraphCompletedEvent) ProtoMessage()

func (*GraphCompletedEvent) Reset 

func (m *GraphCompletedEvent) Reset()

func (*GraphCompletedEvent) String 

func (m *GraphCompletedEvent) String() string

func (*GraphCompletedEvent) ToGraphStreamEvent 

func (m *GraphCompletedEvent) ToGraphStreamEvent(index int) *GraphStreamEvent

ToGraphStreamEvent implements StreamableGraphEvent

func (*GraphCompletedEvent) Validate 

func (this *GraphCompletedEvent) Validate() error

func (*GraphCompletedEvent) XXX_DiscardUnknown 

func (m *GraphCompletedEvent) XXX_DiscardUnknown()

func (*GraphCompletedEvent) XXX_Marshal 

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

func (*GraphCompletedEvent) XXX_Merge 

func (dst *GraphCompletedEvent) XXX_Merge(src proto.Message)

func (*GraphCompletedEvent) XXX_Size 

func (m *GraphCompletedEvent) XXX_Size() int

func (*GraphCompletedEvent) XXX_Unmarshal 

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

type GraphCreatedEvent 

type GraphCreatedEvent struct {
	FlowId               string               `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	FunctionId           string               `protobuf:"bytes,2,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=ts,proto3" json:"ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Graph created

func (*GraphCreatedEvent) Descriptor 

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

func (*GraphCreatedEvent) GetFlowId 

func (m *GraphCreatedEvent) GetFlowId() string

func (*GraphCreatedEvent) GetFunctionId 

func (m *GraphCreatedEvent) GetFunctionId() string

func (*GraphCreatedEvent) GetTs 

func (m *GraphCreatedEvent) GetTs() *timestamp.Timestamp

func (*GraphCreatedEvent) GraphLifecycleEvent 

func (m *GraphCreatedEvent) GraphLifecycleEvent(index int) *GraphLifecycleEvent

GraphLifecycleEvent implements GraphLifecycleEventSource

func (*GraphCreatedEvent) ProtoMessage 

func (*GraphCreatedEvent) ProtoMessage()

func (*GraphCreatedEvent) Reset 

func (m *GraphCreatedEvent) Reset()

func (*GraphCreatedEvent) String 

func (m *GraphCreatedEvent) String() string

func (*GraphCreatedEvent) ToGraphStreamEvent 

func (m *GraphCreatedEvent) ToGraphStreamEvent(index int) *GraphStreamEvent

ToGraphStreamEvent implements StreamableGraphEvent

func (*GraphCreatedEvent) Validate 

func (this *GraphCreatedEvent) Validate() error

func (*GraphCreatedEvent) XXX_DiscardUnknown 

func (m *GraphCreatedEvent) XXX_DiscardUnknown()

func (*GraphCreatedEvent) XXX_Marshal 

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

func (*GraphCreatedEvent) XXX_Merge 

func (dst *GraphCreatedEvent) XXX_Merge(src proto.Message)

func (*GraphCreatedEvent) XXX_Size 

func (m *GraphCreatedEvent) XXX_Size() int

func (*GraphCreatedEvent) XXX_Unmarshal 

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

type GraphLifecycleEvent 

type GraphLifecycleEvent struct {
	Seq    uint64 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	FlowId string `protobuf:"bytes,2,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	// Types that are valid to be assigned to Val:
	//	*GraphLifecycleEvent_GraphCreated
	//	*GraphLifecycleEvent_GraphCompleted
	Val                  isGraphLifecycleEvent_Val `protobuf_oneof:"val"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*GraphLifecycleEvent) Descriptor 

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

func (*GraphLifecycleEvent) GetFlowId 

func (m *GraphLifecycleEvent) GetFlowId() string

func (*GraphLifecycleEvent) GetGraphCompleted 

func (m *GraphLifecycleEvent) GetGraphCompleted() *GraphCompletedEvent

func (*GraphLifecycleEvent) GetGraphCreated 

func (m *GraphLifecycleEvent) GetGraphCreated() *GraphCreatedEvent

func (*GraphLifecycleEvent) GetSeq 

func (m *GraphLifecycleEvent) GetSeq() uint64

func (*GraphLifecycleEvent) GetVal 

func (m *GraphLifecycleEvent) GetVal() isGraphLifecycleEvent_Val

func (*GraphLifecycleEvent) ProtoMessage 

func (*GraphLifecycleEvent) ProtoMessage()

func (*GraphLifecycleEvent) Reset 

func (m *GraphLifecycleEvent) Reset()

func (*GraphLifecycleEvent) String 

func (m *GraphLifecycleEvent) String() string

func (*GraphLifecycleEvent) Validate 

func (this *GraphLifecycleEvent) Validate() error

func (*GraphLifecycleEvent) XXX_DiscardUnknown 

func (m *GraphLifecycleEvent) XXX_DiscardUnknown()

func (*GraphLifecycleEvent) XXX_Marshal 

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

func (*GraphLifecycleEvent) XXX_Merge 

func (dst *GraphLifecycleEvent) XXX_Merge(src proto.Message)

func (*GraphLifecycleEvent) XXX_OneofFuncs 

func (*GraphLifecycleEvent) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*GraphLifecycleEvent) XXX_Size 

func (m *GraphLifecycleEvent) XXX_Size() int

func (*GraphLifecycleEvent) XXX_Unmarshal 

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

type GraphLifecycleEventSource 

type GraphLifecycleEventSource interface {
	// GraphLifecycleEvent constructs a graph lifecycle event from this event type with a specified index
	GraphLifecycleEvent(index int) *GraphLifecycleEvent
}

GraphLifecycleEventSource describes an event that can be mapped to graph lifecycle event

type GraphLifecycleEvent_GraphCompleted 

type GraphLifecycleEvent_GraphCompleted struct {
	GraphCompleted *GraphCompletedEvent `protobuf:"bytes,12,opt,name=graph_completed,json=graphCompleted,proto3,oneof"`
}

type GraphLifecycleEvent_GraphCreated 

type GraphLifecycleEvent_GraphCreated struct {
	GraphCreated *GraphCreatedEvent `protobuf:"bytes,10,opt,name=graph_created,json=graphCreated,proto3,oneof"`
}

type GraphMessage 

type GraphMessage interface {
	proto.Message
	GetFlowId() string
}

GraphMessage is any message that belongs exclusively to a graph

type GraphRequestProcessedResponse 

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

func (*GraphRequestProcessedResponse) Descriptor 

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

func (*GraphRequestProcessedResponse) GetFlowId 

func (m *GraphRequestProcessedResponse) GetFlowId() string

func (*GraphRequestProcessedResponse) ProtoMessage 

func (*GraphRequestProcessedResponse) ProtoMessage()

func (*GraphRequestProcessedResponse) Reset 

func (m *GraphRequestProcessedResponse) Reset()

func (*GraphRequestProcessedResponse) String 

func (m *GraphRequestProcessedResponse) String() string

func (*GraphRequestProcessedResponse) Validate 

func (this *GraphRequestProcessedResponse) Validate() error

func (*GraphRequestProcessedResponse) XXX_DiscardUnknown 

func (m *GraphRequestProcessedResponse) XXX_DiscardUnknown()

func (*GraphRequestProcessedResponse) XXX_Marshal 

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

func (*GraphRequestProcessedResponse) XXX_Merge 

func (dst *GraphRequestProcessedResponse) XXX_Merge(src proto.Message)

func (*GraphRequestProcessedResponse) XXX_Size 

func (m *GraphRequestProcessedResponse) XXX_Size() int

func (*GraphRequestProcessedResponse) XXX_Unmarshal 

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

type GraphStreamEvent 

type GraphStreamEvent struct {
	Seq    uint64               `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	FlowId string               `protobuf:"bytes,2,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	SentTs *timestamp.Timestamp `protobuf:"bytes,3,opt,name=sent_ts,json=sentTs,proto3" json:"sent_ts,omitempty"`
	// Types that are valid to be assigned to Val:
	//	*GraphStreamEvent_GraphCreated
	//	*GraphStreamEvent_GraphTerminating
	//	*GraphStreamEvent_GraphCompleted
	//	*GraphStreamEvent_DelayScheduled
	//	*GraphStreamEvent_StageAdded
	//	*GraphStreamEvent_StageCompleted
	//	*GraphStreamEvent_StageComposed
	//	*GraphStreamEvent_FaasInvocationStarted
	//	*GraphStreamEvent_FaasInvocationCompleted
	//	*GraphStreamEvent_GraphCommitted
	Val                  isGraphStreamEvent_Val `protobuf_oneof:"val"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*GraphStreamEvent) Descriptor 

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

func (*GraphStreamEvent) GetDelayScheduled 

func (m *GraphStreamEvent) GetDelayScheduled() *DelayScheduledEvent

func (*GraphStreamEvent) GetFaasInvocationCompleted 

func (m *GraphStreamEvent) GetFaasInvocationCompleted() *FaasInvocationCompletedEvent

func (*GraphStreamEvent) GetFaasInvocationStarted 

func (m *GraphStreamEvent) GetFaasInvocationStarted() *FaasInvocationStartedEvent

func (*GraphStreamEvent) GetFlowId 

func (m *GraphStreamEvent) GetFlowId() string

func (*GraphStreamEvent) GetGraphCommitted 

func (m *GraphStreamEvent) GetGraphCommitted() *GraphCommittedEvent

func (*GraphStreamEvent) GetGraphCompleted 

func (m *GraphStreamEvent) GetGraphCompleted() *GraphCompletedEvent

func (*GraphStreamEvent) GetGraphCreated 

func (m *GraphStreamEvent) GetGraphCreated() *GraphCreatedEvent

func (*GraphStreamEvent) GetGraphTerminating 

func (m *GraphStreamEvent) GetGraphTerminating() *GraphTerminatingEvent

func (*GraphStreamEvent) GetSentTs 

func (m *GraphStreamEvent) GetSentTs() *timestamp.Timestamp

func (*GraphStreamEvent) GetSeq 

func (m *GraphStreamEvent) GetSeq() uint64

func (*GraphStreamEvent) GetStageAdded 

func (m *GraphStreamEvent) GetStageAdded() *StageAddedEvent

func (*GraphStreamEvent) GetStageCompleted 

func (m *GraphStreamEvent) GetStageCompleted() *StageCompletedEvent

func (*GraphStreamEvent) GetStageComposed 

func (m *GraphStreamEvent) GetStageComposed() *StageComposedEvent

func (*GraphStreamEvent) GetVal 

func (m *GraphStreamEvent) GetVal() isGraphStreamEvent_Val

func (*GraphStreamEvent) ProtoMessage 

func (*GraphStreamEvent) ProtoMessage()

func (*GraphStreamEvent) Reset 

func (m *GraphStreamEvent) Reset()

func (*GraphStreamEvent) String 

func (m *GraphStreamEvent) String() string

func (*GraphStreamEvent) Validate 

func (this *GraphStreamEvent) Validate() error

func (*GraphStreamEvent) XXX_DiscardUnknown 

func (m *GraphStreamEvent) XXX_DiscardUnknown()

func (*GraphStreamEvent) XXX_Marshal 

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

func (*GraphStreamEvent) XXX_Merge 

func (dst *GraphStreamEvent) XXX_Merge(src proto.Message)

func (*GraphStreamEvent) XXX_OneofFuncs 

func (*GraphStreamEvent) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*GraphStreamEvent) XXX_Size 

func (m *GraphStreamEvent) XXX_Size() int

func (*GraphStreamEvent) XXX_Unmarshal 

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

type GraphStreamEvent_DelayScheduled 

type GraphStreamEvent_DelayScheduled struct {
	DelayScheduled *DelayScheduledEvent `protobuf:"bytes,13,opt,name=delay_scheduled,json=delayScheduled,proto3,oneof"`
}

type GraphStreamEvent_FaasInvocationCompleted 

type GraphStreamEvent_FaasInvocationCompleted struct {
	FaasInvocationCompleted *FaasInvocationCompletedEvent `protobuf:"bytes,18,opt,name=faas_invocation_completed,json=faasInvocationCompleted,proto3,oneof"`
}

type GraphStreamEvent_FaasInvocationStarted 

type GraphStreamEvent_FaasInvocationStarted struct {
	FaasInvocationStarted *FaasInvocationStartedEvent `protobuf:"bytes,17,opt,name=faas_invocation_started,json=faasInvocationStarted,proto3,oneof"`
}

type GraphStreamEvent_GraphCommitted 

type GraphStreamEvent_GraphCommitted struct {
	GraphCommitted *GraphCommittedEvent `protobuf:"bytes,19,opt,name=graph_committed,json=graphCommitted,proto3,oneof"`
}

type GraphStreamEvent_GraphCompleted 

type GraphStreamEvent_GraphCompleted struct {
	GraphCompleted *GraphCompletedEvent `protobuf:"bytes,12,opt,name=graph_completed,json=graphCompleted,proto3,oneof"`
}

type GraphStreamEvent_GraphCreated 

type GraphStreamEvent_GraphCreated struct {
	GraphCreated *GraphCreatedEvent `protobuf:"bytes,10,opt,name=graph_created,json=graphCreated,proto3,oneof"`
}

type GraphStreamEvent_GraphTerminating 

type GraphStreamEvent_GraphTerminating struct {
	GraphTerminating *GraphTerminatingEvent `protobuf:"bytes,11,opt,name=graph_terminating,json=graphTerminating,proto3,oneof"`
}

type GraphStreamEvent_StageAdded 

type GraphStreamEvent_StageAdded struct {
	StageAdded *StageAddedEvent `protobuf:"bytes,14,opt,name=stage_added,json=stageAdded,proto3,oneof"`
}

type GraphStreamEvent_StageCompleted 

type GraphStreamEvent_StageCompleted struct {
	StageCompleted *StageCompletedEvent `protobuf:"bytes,15,opt,name=stage_completed,json=stageCompleted,proto3,oneof"`
}

type GraphStreamEvent_StageComposed 

type GraphStreamEvent_StageComposed struct {
	StageComposed *StageComposedEvent `protobuf:"bytes,16,opt,name=stage_composed,json=stageComposed,proto3,oneof"`
}

type GraphTerminatingEvent 

type GraphTerminatingEvent struct {
	FlowId               string               `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	FunctionId           string               `protobuf:"bytes,2,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	Status               StatusDatumType      `protobuf:"varint,3,opt,name=status,proto3,enum=model.StatusDatumType" json:"status,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,4,opt,name=ts,proto3" json:"ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Graph termination has started - no more changes can be made to this graph this will be fillowed by a completion event when any termination hooks have run

func (*GraphTerminatingEvent) Descriptor 

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

func (*GraphTerminatingEvent) GetFlowId 

func (m *GraphTerminatingEvent) GetFlowId() string

func (*GraphTerminatingEvent) GetFunctionId 

func (m *GraphTerminatingEvent) GetFunctionId() string

func (*GraphTerminatingEvent) GetStatus 

func (m *GraphTerminatingEvent) GetStatus() StatusDatumType

func (*GraphTerminatingEvent) GetTs 

func (m *GraphTerminatingEvent) GetTs() *timestamp.Timestamp

func (*GraphTerminatingEvent) ProtoMessage 

func (*GraphTerminatingEvent) ProtoMessage()

func (*GraphTerminatingEvent) Reset 

func (m *GraphTerminatingEvent) Reset()

func (*GraphTerminatingEvent) String 

func (m *GraphTerminatingEvent) String() string

func (*GraphTerminatingEvent) ToGraphStreamEvent 

func (m *GraphTerminatingEvent) ToGraphStreamEvent(index int) *GraphStreamEvent

ToGraphStreamEvent implements StreamableGraphEvent

func (*GraphTerminatingEvent) Validate 

func (this *GraphTerminatingEvent) Validate() error

func (*GraphTerminatingEvent) XXX_DiscardUnknown 

func (m *GraphTerminatingEvent) XXX_DiscardUnknown()

func (*GraphTerminatingEvent) XXX_Marshal 

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

func (*GraphTerminatingEvent) XXX_Merge 

func (dst *GraphTerminatingEvent) XXX_Merge(src proto.Message)

func (*GraphTerminatingEvent) XXX_Size 

func (m *GraphTerminatingEvent) XXX_Size() int

func (*GraphTerminatingEvent) XXX_Unmarshal 

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

type HTTPHeader 

type HTTPHeader struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

HTTPHeader wraps a single header key/value

func (*HTTPHeader) Descriptor 

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

func (*HTTPHeader) GetKey 

func (m *HTTPHeader) GetKey() string

func (*HTTPHeader) GetValue 

func (m *HTTPHeader) GetValue() string

func (*HTTPHeader) ProtoMessage 

func (*HTTPHeader) ProtoMessage()

func (*HTTPHeader) Reset 

func (m *HTTPHeader) Reset()

func (*HTTPHeader) String 

func (m *HTTPHeader) String() string

func (*HTTPHeader) Validate 

func (this *HTTPHeader) Validate() error

func (*HTTPHeader) XXX_DiscardUnknown 

func (m *HTTPHeader) XXX_DiscardUnknown()

func (*HTTPHeader) XXX_Marshal 

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

func (*HTTPHeader) XXX_Merge 

func (dst *HTTPHeader) XXX_Merge(src proto.Message)

func (*HTTPHeader) XXX_Size 

func (m *HTTPHeader) XXX_Size() int

func (*HTTPHeader) XXX_Unmarshal 

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

type HTTPMethod 

type HTTPMethod int32

HTTPMethod defines a specific HTTP method 

const (
	HTTPMethod_unknown_method HTTPMethod = 0
	HTTPMethod_get            HTTPMethod = 1
	HTTPMethod_head           HTTPMethod = 2
	HTTPMethod_post           HTTPMethod = 3
	HTTPMethod_put            HTTPMethod = 4
	HTTPMethod_delete         HTTPMethod = 5
	HTTPMethod_options        HTTPMethod = 7
	HTTPMethod_patch          HTTPMethod = 6
)

func (HTTPMethod) EnumDescriptor 

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

func (HTTPMethod) String 

func (x HTTPMethod) String() string

type HTTPReqDatum 

type HTTPReqDatum struct {
	Body                 *BlobDatum    `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Headers              []*HTTPHeader `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	Method               HTTPMethod    `protobuf:"varint,4,opt,name=method,proto3,enum=model.HTTPMethod" json:"method,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

HTTPReqDatum describes an outgoing or incoming HTTP Request, it wraps the headers, method and optional body

func (*HTTPReqDatum) Descriptor 

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

func (*HTTPReqDatum) GetBody 

func (m *HTTPReqDatum) GetBody() *BlobDatum

func (*HTTPReqDatum) GetHeader 

func (m *HTTPReqDatum) GetHeader(key string) string

GetHeader returns the first header with the corresponding key in the HttpReqDatum, or an empty string if not found

func (*HTTPReqDatum) GetHeaderValues 

func (m *HTTPReqDatum) GetHeaderValues(key string) []string

GetHeaderValues returns a list of values of the headers with the corresponding key in HttpReqDatum

func (*HTTPReqDatum) GetHeaders 

func (m *HTTPReqDatum) GetHeaders() []*HTTPHeader

func (*HTTPReqDatum) GetMethod 

func (m *HTTPReqDatum) GetMethod() HTTPMethod

func (*HTTPReqDatum) ProtoMessage 

func (*HTTPReqDatum) ProtoMessage()

func (*HTTPReqDatum) Reset 

func (m *HTTPReqDatum) Reset()

func (*HTTPReqDatum) String 

func (m *HTTPReqDatum) String() string

func (*HTTPReqDatum) Validate 

func (this *HTTPReqDatum) Validate() error

func (*HTTPReqDatum) XXX_DiscardUnknown 

func (m *HTTPReqDatum) XXX_DiscardUnknown()

func (*HTTPReqDatum) XXX_Marshal 

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

func (*HTTPReqDatum) XXX_Merge 

func (dst *HTTPReqDatum) XXX_Merge(src proto.Message)

func (*HTTPReqDatum) XXX_Size 

func (m *HTTPReqDatum) XXX_Size() int

func (*HTTPReqDatum) XXX_Unmarshal 

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

type HTTPRespDatum 

type HTTPRespDatum struct {
	Body                 *BlobDatum    `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Headers              []*HTTPHeader `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	StatusCode           int32         `protobuf:"varint,4,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

HTTPRespDatum wraps an outgoing or incoming HTTP REQUEST, it wraps the headers, status code and optinoal body

func (*HTTPRespDatum) Descriptor 

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

func (*HTTPRespDatum) GetBody 

func (m *HTTPRespDatum) GetBody() *BlobDatum

func (*HTTPRespDatum) GetHeader 

func (m *HTTPRespDatum) GetHeader(key string) string

GetHeader returns the first header with the corresponding key in the HttpRespDatum, or an empty string if not found

func (*HTTPRespDatum) GetHeaderValues 

func (m *HTTPRespDatum) GetHeaderValues(key string) []string

GetHeaderValues returns a list of values of the headers with the corresponding key in HttpRespDatum

func (*HTTPRespDatum) GetHeaders 

func (m *HTTPRespDatum) GetHeaders() []*HTTPHeader

func (*HTTPRespDatum) GetStatusCode 

func (m *HTTPRespDatum) GetStatusCode() int32

func (*HTTPRespDatum) ProtoMessage 

func (*HTTPRespDatum) ProtoMessage()

func (*HTTPRespDatum) Reset 

func (m *HTTPRespDatum) Reset()

func (*HTTPRespDatum) String 

func (m *HTTPRespDatum) String() string

func (*HTTPRespDatum) Validate 

func (this *HTTPRespDatum) Validate() error

func (*HTTPRespDatum) XXX_DiscardUnknown 

func (m *HTTPRespDatum) XXX_DiscardUnknown()

func (*HTTPRespDatum) XXX_Marshal 

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

func (*HTTPRespDatum) XXX_Merge 

func (dst *HTTPRespDatum) XXX_Merge(src proto.Message)

func (*HTTPRespDatum) XXX_Size 

func (m *HTTPRespDatum) XXX_Size() int

func (*HTTPRespDatum) XXX_Unmarshal 

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

type InvokeFunctionRequest 

type InvokeFunctionRequest struct {
	FlowId               string        `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	StageId              string        `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	FunctionId           string        `protobuf:"bytes,3,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	Arg                  *HTTPReqDatum `protobuf:"bytes,4,opt,name=arg,proto3" json:"arg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Invoke commands

func (*InvokeFunctionRequest) Descriptor 

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

func (*InvokeFunctionRequest) GetArg 

func (m *InvokeFunctionRequest) GetArg() *HTTPReqDatum

func (*InvokeFunctionRequest) GetFlowId 

func (m *InvokeFunctionRequest) GetFlowId() string

func (*InvokeFunctionRequest) GetFunctionId 

func (m *InvokeFunctionRequest) GetFunctionId() string

func (*InvokeFunctionRequest) GetStageId 

func (m *InvokeFunctionRequest) GetStageId() string

func (*InvokeFunctionRequest) ProtoMessage 

func (*InvokeFunctionRequest) ProtoMessage()

func (*InvokeFunctionRequest) Reset 

func (m *InvokeFunctionRequest) Reset()

func (*InvokeFunctionRequest) String 

func (m *InvokeFunctionRequest) String() string

func (*InvokeFunctionRequest) Validate 

func (this *InvokeFunctionRequest) Validate() error

func (*InvokeFunctionRequest) XXX_DiscardUnknown 

func (m *InvokeFunctionRequest) XXX_DiscardUnknown()

func (*InvokeFunctionRequest) XXX_Marshal 

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

func (*InvokeFunctionRequest) XXX_Merge 

func (dst *InvokeFunctionRequest) XXX_Merge(src proto.Message)

func (*InvokeFunctionRequest) XXX_Size 

func (m *InvokeFunctionRequest) XXX_Size() int

func (*InvokeFunctionRequest) XXX_Unmarshal 

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

type InvokeStageRequest 

type InvokeStageRequest struct {
	FlowId               string              `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	StageId              string              `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	FunctionId           string              `protobuf:"bytes,3,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	Args                 []*CompletionResult `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	Closure              *BlobDatum          `protobuf:"bytes,6,opt,name=closure,proto3" json:"closure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*InvokeStageRequest) Descriptor 

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

func (*InvokeStageRequest) GetArgs 

func (m *InvokeStageRequest) GetArgs() []*CompletionResult

func (*InvokeStageRequest) GetClosure 

func (m *InvokeStageRequest) GetClosure() *BlobDatum

func (*InvokeStageRequest) GetFlowId 

func (m *InvokeStageRequest) GetFlowId() string

func (*InvokeStageRequest) GetFunctionId 

func (m *InvokeStageRequest) GetFunctionId() string

func (*InvokeStageRequest) GetStageId 

func (m *InvokeStageRequest) GetStageId() string

func (*InvokeStageRequest) ProtoMessage 

func (*InvokeStageRequest) ProtoMessage()

func (*InvokeStageRequest) Reset 

func (m *InvokeStageRequest) Reset()

func (*InvokeStageRequest) String 

func (m *InvokeStageRequest) String() string

func (*InvokeStageRequest) Validate 

func (this *InvokeStageRequest) Validate() error

func (*InvokeStageRequest) XXX_DiscardUnknown 

func (m *InvokeStageRequest) XXX_DiscardUnknown()

func (*InvokeStageRequest) XXX_Marshal 

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

func (*InvokeStageRequest) XXX_Merge 

func (dst *InvokeStageRequest) XXX_Merge(src proto.Message)

func (*InvokeStageRequest) XXX_Size 

func (m *InvokeStageRequest) XXX_Size() int

func (*InvokeStageRequest) XXX_Unmarshal 

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

type ListGraphResponse 

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

func (*ListGraphResponse) Descriptor 

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

func (*ListGraphResponse) GetFlowId 

func (m *ListGraphResponse) GetFlowId() string

func (*ListGraphResponse) ProtoMessage 

func (*ListGraphResponse) ProtoMessage()

func (*ListGraphResponse) Reset 

func (m *ListGraphResponse) Reset()

func (*ListGraphResponse) String 

func (m *ListGraphResponse) String() string

func (*ListGraphResponse) Validate 

func (this *ListGraphResponse) Validate() error

func (*ListGraphResponse) XXX_DiscardUnknown 

func (m *ListGraphResponse) XXX_DiscardUnknown()

func (*ListGraphResponse) XXX_Marshal 

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

func (*ListGraphResponse) XXX_Merge 

func (dst *ListGraphResponse) XXX_Merge(src proto.Message)

func (*ListGraphResponse) XXX_Size 

func (m *ListGraphResponse) XXX_Size() int

func (*ListGraphResponse) XXX_Unmarshal 

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

type ListGraphsFilter 

type ListGraphsFilter int32
const (
	ListGraphsFilter_unknown   ListGraphsFilter = 0
	ListGraphsFilter_all       ListGraphsFilter = 1
	ListGraphsFilter_running   ListGraphsFilter = 2
	ListGraphsFilter_completed ListGraphsFilter = 3
)

func (ListGraphsFilter) EnumDescriptor 

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

func (ListGraphsFilter) String 

func (x ListGraphsFilter) String() string

type ListGraphsRequest 

type ListGraphsRequest struct {
	Filter               ListGraphsFilter `protobuf:"varint,1,opt,name=filter,proto3,enum=model.ListGraphsFilter" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ListGraphsRequest) Descriptor 

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

func (*ListGraphsRequest) GetFilter 

func (m *ListGraphsRequest) GetFilter() ListGraphsFilter

func (*ListGraphsRequest) ProtoMessage 

func (*ListGraphsRequest) ProtoMessage()

func (*ListGraphsRequest) Reset 

func (m *ListGraphsRequest) Reset()

func (*ListGraphsRequest) String 

func (m *ListGraphsRequest) String() string

func (*ListGraphsRequest) Validate 

func (this *ListGraphsRequest) Validate() error

func (*ListGraphsRequest) XXX_DiscardUnknown 

func (m *ListGraphsRequest) XXX_DiscardUnknown()

func (*ListGraphsRequest) XXX_Marshal 

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

func (*ListGraphsRequest) XXX_Merge 

func (dst *ListGraphsRequest) XXX_Merge(src proto.Message)

func (*ListGraphsRequest) XXX_Size 

func (m *ListGraphsRequest) XXX_Size() int

func (*ListGraphsRequest) XXX_Unmarshal 

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

type ListGraphsResponse 

type ListGraphsResponse struct {
	Graphs               []*ListGraphResponse `protobuf:"bytes,1,rep,name=graphs,proto3" json:"graphs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ListGraphsResponse) Descriptor 

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

func (*ListGraphsResponse) GetGraphs 

func (m *ListGraphsResponse) GetGraphs() []*ListGraphResponse

func (*ListGraphsResponse) ProtoMessage 

func (*ListGraphsResponse) ProtoMessage()

func (*ListGraphsResponse) Reset 

func (m *ListGraphsResponse) Reset()

func (*ListGraphsResponse) String 

func (m *ListGraphsResponse) String() string

func (*ListGraphsResponse) Validate 

func (this *ListGraphsResponse) Validate() error

func (*ListGraphsResponse) XXX_DiscardUnknown 

func (m *ListGraphsResponse) XXX_DiscardUnknown()

func (*ListGraphsResponse) XXX_Marshal 

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

func (*ListGraphsResponse) XXX_Merge 

func (dst *ListGraphsResponse) XXX_Merge(src proto.Message)

func (*ListGraphsResponse) XXX_Size 

func (m *ListGraphsResponse) XXX_Size() int

func (*ListGraphsResponse) XXX_Unmarshal 

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

type RuntimeInvokeStageRequest 

type RuntimeInvokeStageRequest struct {
	FlowId               string              `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	StageId              string              `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	Args                 []*CompletionResult `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	Closure              *BlobDatum          `protobuf:"bytes,4,opt,name=closure,proto3" json:"closure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Request Wrapper,

func (*RuntimeInvokeStageRequest) Descriptor 

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

func (*RuntimeInvokeStageRequest) GetArgs 

func (m *RuntimeInvokeStageRequest) GetArgs() []*CompletionResult

func (*RuntimeInvokeStageRequest) GetClosure 

func (m *RuntimeInvokeStageRequest) GetClosure() *BlobDatum

func (*RuntimeInvokeStageRequest) GetFlowId 

func (m *RuntimeInvokeStageRequest) GetFlowId() string

func (*RuntimeInvokeStageRequest) GetStageId 

func (m *RuntimeInvokeStageRequest) GetStageId() string

func (*RuntimeInvokeStageRequest) ProtoMessage 

func (*RuntimeInvokeStageRequest) ProtoMessage()

func (*RuntimeInvokeStageRequest) Reset 

func (m *RuntimeInvokeStageRequest) Reset()

func (*RuntimeInvokeStageRequest) String 

func (m *RuntimeInvokeStageRequest) String() string

func (*RuntimeInvokeStageRequest) Validate 

func (this *RuntimeInvokeStageRequest) Validate() error

func (*RuntimeInvokeStageRequest) XXX_DiscardUnknown 

func (m *RuntimeInvokeStageRequest) XXX_DiscardUnknown()

func (*RuntimeInvokeStageRequest) XXX_Marshal 

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

func (*RuntimeInvokeStageRequest) XXX_Merge 

func (dst *RuntimeInvokeStageRequest) XXX_Merge(src proto.Message)

func (*RuntimeInvokeStageRequest) XXX_Size 

func (m *RuntimeInvokeStageRequest) XXX_Size() int

func (*RuntimeInvokeStageRequest) XXX_Unmarshal 

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

type RuntimeInvokeStageResponse 

type RuntimeInvokeStageResponse struct {
	Result               *CompletionResult `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Result wrapper - intentionally deep to allow extra fields at top level

func (*RuntimeInvokeStageResponse) Descriptor 

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

func (*RuntimeInvokeStageResponse) GetResult 

func (m *RuntimeInvokeStageResponse) GetResult() *CompletionResult

func (*RuntimeInvokeStageResponse) ProtoMessage 

func (*RuntimeInvokeStageResponse) ProtoMessage()

func (*RuntimeInvokeStageResponse) Reset 

func (m *RuntimeInvokeStageResponse) Reset()

func (*RuntimeInvokeStageResponse) String 

func (m *RuntimeInvokeStageResponse) String() string

func (*RuntimeInvokeStageResponse) Validate 

func (this *RuntimeInvokeStageResponse) Validate() error

func (*RuntimeInvokeStageResponse) XXX_DiscardUnknown 

func (m *RuntimeInvokeStageResponse) XXX_DiscardUnknown()

func (*RuntimeInvokeStageResponse) XXX_Marshal 

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

func (*RuntimeInvokeStageResponse) XXX_Merge 

func (dst *RuntimeInvokeStageResponse) XXX_Merge(src proto.Message)

func (*RuntimeInvokeStageResponse) XXX_Size 

func (m *RuntimeInvokeStageResponse) XXX_Size() int

func (*RuntimeInvokeStageResponse) XXX_Unmarshal 

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

type StageAddedEvent 

type StageAddedEvent struct {
	StageId              string               `protobuf:"bytes,1,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	Op                   CompletionOperation  `protobuf:"varint,2,opt,name=op,proto3,enum=model.CompletionOperation" json:"op,omitempty"`
	Closure              *BlobDatum           `protobuf:"bytes,3,opt,name=closure,proto3" json:"closure,omitempty"`
	Dependencies         []string             `protobuf:"bytes,4,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,5,opt,name=ts,proto3" json:"ts,omitempty"`
	CodeLocation         string               `protobuf:"bytes,6,opt,name=code_location,json=codeLocation,proto3" json:"code_location,omitempty"`
	CallerId             string               `protobuf:"bytes,7,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	FlowId               string               `protobuf:"bytes,8,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A stage was added to the graph

func (*StageAddedEvent) Descriptor 

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

func (*StageAddedEvent) GetCallerId 

func (m *StageAddedEvent) GetCallerId() string

func (*StageAddedEvent) GetClosure 

func (m *StageAddedEvent) GetClosure() *BlobDatum

func (*StageAddedEvent) GetCodeLocation 

func (m *StageAddedEvent) GetCodeLocation() string

func (*StageAddedEvent) GetDependencies 

func (m *StageAddedEvent) GetDependencies() []string

func (*StageAddedEvent) GetFlowId 

func (m *StageAddedEvent) GetFlowId() string

func (*StageAddedEvent) GetOp 

func (m *StageAddedEvent) GetOp() CompletionOperation

func (*StageAddedEvent) GetStageId 

func (m *StageAddedEvent) GetStageId() string

func (*StageAddedEvent) GetTs 

func (m *StageAddedEvent) GetTs() *timestamp.Timestamp

func (*StageAddedEvent) ProtoMessage 

func (*StageAddedEvent) ProtoMessage()

func (*StageAddedEvent) Reset 

func (m *StageAddedEvent) Reset()

func (*StageAddedEvent) String 

func (m *StageAddedEvent) String() string

func (*StageAddedEvent) ToGraphStreamEvent 

func (m *StageAddedEvent) ToGraphStreamEvent(index int) *GraphStreamEvent

ToGraphStreamEvent implements StreamableGraphEvent

func (*StageAddedEvent) Validate 

func (this *StageAddedEvent) Validate() error

func (*StageAddedEvent) XXX_DiscardUnknown 

func (m *StageAddedEvent) XXX_DiscardUnknown()

func (*StageAddedEvent) XXX_Marshal 

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

func (*StageAddedEvent) XXX_Merge 

func (dst *StageAddedEvent) XXX_Merge(src proto.Message)

func (*StageAddedEvent) XXX_Size 

func (m *StageAddedEvent) XXX_Size() int

func (*StageAddedEvent) XXX_Unmarshal 

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

type StageCompletedEvent 

type StageCompletedEvent struct {
	StageId              string               `protobuf:"bytes,1,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	Result               *CompletionResult    `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=ts,proto3" json:"ts,omitempty"`
	FlowId               string               `protobuf:"bytes,4,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A stage completed - downstream stages may be triggered

func (*StageCompletedEvent) Descriptor 

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

func (*StageCompletedEvent) GetFlowId 

func (m *StageCompletedEvent) GetFlowId() string

func (*StageCompletedEvent) GetResult 

func (m *StageCompletedEvent) GetResult() *CompletionResult

func (*StageCompletedEvent) GetStageId 

func (m *StageCompletedEvent) GetStageId() string

func (*StageCompletedEvent) GetTs 

func (m *StageCompletedEvent) GetTs() *timestamp.Timestamp

func (*StageCompletedEvent) ProtoMessage 

func (*StageCompletedEvent) ProtoMessage()

func (*StageCompletedEvent) Reset 

func (m *StageCompletedEvent) Reset()

func (*StageCompletedEvent) String 

func (m *StageCompletedEvent) String() string

func (*StageCompletedEvent) ToGraphStreamEvent 

func (m *StageCompletedEvent) ToGraphStreamEvent(index int) *GraphStreamEvent

ToGraphStreamEvent implements StreamableGraphEvent

func (*StageCompletedEvent) Validate 

func (this *StageCompletedEvent) Validate() error

func (*StageCompletedEvent) XXX_DiscardUnknown 

func (m *StageCompletedEvent) XXX_DiscardUnknown()

func (*StageCompletedEvent) XXX_Marshal 

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

func (*StageCompletedEvent) XXX_Merge 

func (dst *StageCompletedEvent) XXX_Merge(src proto.Message)

func (*StageCompletedEvent) XXX_Size 

func (m *StageCompletedEvent) XXX_Size() int

func (*StageCompletedEvent) XXX_Unmarshal 

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

type StageComposedEvent 

type StageComposedEvent struct {
	StageId              string               `protobuf:"bytes,1,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	ComposedStageId      string               `protobuf:"bytes,2,opt,name=composed_stage_id,json=composedStageId,proto3" json:"composed_stage_id,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=ts,proto3" json:"ts,omitempty"`
	FlowId               string               `protobuf:"bytes,4,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A stage was composed into stage_id - stage_id will compelete with the saem result as composed_stage_id

func (*StageComposedEvent) Descriptor 

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

func (*StageComposedEvent) GetComposedStageId 

func (m *StageComposedEvent) GetComposedStageId() string

func (*StageComposedEvent) GetFlowId 

func (m *StageComposedEvent) GetFlowId() string

func (*StageComposedEvent) GetStageId 

func (m *StageComposedEvent) GetStageId() string

func (*StageComposedEvent) GetTs 

func (m *StageComposedEvent) GetTs() *timestamp.Timestamp

func (*StageComposedEvent) ProtoMessage 

func (*StageComposedEvent) ProtoMessage()

func (*StageComposedEvent) Reset 

func (m *StageComposedEvent) Reset()

func (*StageComposedEvent) String 

func (m *StageComposedEvent) String() string

func (*StageComposedEvent) ToGraphStreamEvent 

func (m *StageComposedEvent) ToGraphStreamEvent(index int) *GraphStreamEvent

ToGraphStreamEvent implements StreamableGraphEvent

func (*StageComposedEvent) Validate 

func (this *StageComposedEvent) Validate() error

func (*StageComposedEvent) XXX_DiscardUnknown 

func (m *StageComposedEvent) XXX_DiscardUnknown()

func (*StageComposedEvent) XXX_Marshal 

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

func (*StageComposedEvent) XXX_Merge 

func (dst *StageComposedEvent) XXX_Merge(src proto.Message)

func (*StageComposedEvent) XXX_Size 

func (m *StageComposedEvent) XXX_Size() int

func (*StageComposedEvent) XXX_Unmarshal 

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

type StageMessage 

type StageMessage interface {
	proto.Message
	GetFlowId() string
	GetStageId() string
}

StageMessage is any message that belongs exclusively a stage (and hence a graph) This is intentionally distinct from GraphMessage!

type StageRefDatum 

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

StageRefDatum represents a reference to another stage in the graph

func (*StageRefDatum) Descriptor 

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

func (*StageRefDatum) GetStageId 

func (m *StageRefDatum) GetStageId() string

func (*StageRefDatum) ProtoMessage 

func (*StageRefDatum) ProtoMessage()

func (*StageRefDatum) Reset 

func (m *StageRefDatum) Reset()

func (*StageRefDatum) String 

func (m *StageRefDatum) String() string

func (*StageRefDatum) Validate 

func (this *StageRefDatum) Validate() error

func (*StageRefDatum) XXX_DiscardUnknown 

func (m *StageRefDatum) XXX_DiscardUnknown()

func (*StageRefDatum) XXX_Marshal 

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

func (*StageRefDatum) XXX_Merge 

func (dst *StageRefDatum) XXX_Merge(src proto.Message)

func (*StageRefDatum) XXX_Size 

func (m *StageRefDatum) XXX_Size() int

func (*StageRefDatum) XXX_Unmarshal 

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

type StatusDatum 

type StatusDatum struct {
	Type                 StatusDatumType `protobuf:"varint,1,opt,name=type,proto3,enum=model.StatusDatumType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

StateDatum wraps a description of the state of the graph in a datum

func (*StatusDatum) Descriptor 

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

func (*StatusDatum) GetType 

func (m *StatusDatum) GetType() StatusDatumType

func (*StatusDatum) ProtoMessage 

func (*StatusDatum) ProtoMessage()

func (*StatusDatum) Reset 

func (m *StatusDatum) Reset()

func (*StatusDatum) String 

func (m *StatusDatum) String() string

func (*StatusDatum) Validate 

func (this *StatusDatum) Validate() error

func (*StatusDatum) XXX_DiscardUnknown 

func (m *StatusDatum) XXX_DiscardUnknown()

func (*StatusDatum) XXX_Marshal 

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

func (*StatusDatum) XXX_Merge 

func (dst *StatusDatum) XXX_Merge(src proto.Message)

func (*StatusDatum) XXX_Size 

func (m *StatusDatum) XXX_Size() int

func (*StatusDatum) XXX_Unmarshal 

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

type StatusDatumType 

type StatusDatumType int32

StateDatumType describes the state of a stage or graph 

const (
	StatusDatumType_unknown_state StatusDatumType = 0
	StatusDatumType_succeeded     StatusDatumType = 1
	StatusDatumType_failed        StatusDatumType = 2
	StatusDatumType_cancelled     StatusDatumType = 3
	StatusDatumType_killed        StatusDatumType = 4
)

func (StatusDatumType) EnumDescriptor 

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

func (StatusDatumType) String 

func (x StatusDatumType) String() string

type StreamGraphRequest 

type StreamGraphRequest struct {
	FlowId               string   `protobuf:"bytes,2,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	FromSeq              uint64   `protobuf:"varint,3,opt,name=from_seq,json=fromSeq,proto3" json:"from_seq,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamGraphRequest) Descriptor 

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

func (*StreamGraphRequest) GetFlowId 

func (m *StreamGraphRequest) GetFlowId() string

func (*StreamGraphRequest) GetFromSeq 

func (m *StreamGraphRequest) GetFromSeq() uint64

func (*StreamGraphRequest) ProtoMessage 

func (*StreamGraphRequest) ProtoMessage()

func (*StreamGraphRequest) Reset 

func (m *StreamGraphRequest) Reset()

func (*StreamGraphRequest) String 

func (m *StreamGraphRequest) String() string

func (*StreamGraphRequest) Validate 

func (this *StreamGraphRequest) Validate() error

func (*StreamGraphRequest) XXX_DiscardUnknown 

func (m *StreamGraphRequest) XXX_DiscardUnknown()

func (*StreamGraphRequest) XXX_Marshal 

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

func (*StreamGraphRequest) XXX_Merge 

func (dst *StreamGraphRequest) XXX_Merge(src proto.Message)

func (*StreamGraphRequest) XXX_Size 

func (m *StreamGraphRequest) XXX_Size() int

func (*StreamGraphRequest) XXX_Unmarshal 

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

type StreamLifecycleRequest 

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

func (*StreamLifecycleRequest) Descriptor 

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

func (*StreamLifecycleRequest) ProtoMessage 

func (*StreamLifecycleRequest) ProtoMessage()

func (*StreamLifecycleRequest) Reset 

func (m *StreamLifecycleRequest) Reset()

func (*StreamLifecycleRequest) String 

func (m *StreamLifecycleRequest) String() string

func (*StreamLifecycleRequest) Validate 

func (this *StreamLifecycleRequest) Validate() error

func (*StreamLifecycleRequest) XXX_DiscardUnknown 

func (m *StreamLifecycleRequest) XXX_DiscardUnknown()

func (*StreamLifecycleRequest) XXX_Marshal 

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

func (*StreamLifecycleRequest) XXX_Merge 

func (dst *StreamLifecycleRequest) XXX_Merge(src proto.Message)

func (*StreamLifecycleRequest) XXX_Size 

func (m *StreamLifecycleRequest) XXX_Size() int

func (*StreamLifecycleRequest) XXX_Unmarshal 

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

type StreamableGraphEvent 

type StreamableGraphEvent interface {
	// ToGraphStreamEvent constructs a GraphStreamEvent from the current event type
	ToGraphStreamEvent(index int) *GraphStreamEvent
}

StreamableGraphEvent describes an event that can be mapped to a graph event

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.