Documentation ¶
Index ¶
- type GetGraphStateResponseStageRepresentation
- type ModelAddCompletedValueStageRequest
- type ModelAddDelayStageRequest
- type ModelAddInvokeFunctionStageRequest
- type ModelAddStageRequest
- type ModelAddStageResponse
- type ModelAwaitStageResultResponse
- type ModelBlobDatum
- type ModelCompleteStageExternallyRequest
- type ModelCompleteStageExternallyResponse
- type ModelCompletionOperation
- type ModelCompletionResult
- type ModelCreateGraphRequest
- type ModelCreateGraphResponse
- type ModelDatum
- type ModelDelayScheduledEvent
- type ModelEmptyDatum
- type ModelErrorDatum
- type ModelErrorDatumType
- type ModelFaasInvocationCompletedEvent
- type ModelFaasInvocationStartedEvent
- type ModelGetGraphStateResponse
- type ModelGetGraphStateResponseStages
- type ModelGraphCommittedEvent
- type ModelGraphCompletedEvent
- type ModelGraphCreatedEvent
- type ModelGraphEvent
- type ModelGraphLifecycleEvent
- type ModelGraphRequestProcessedResponse
- type ModelGraphTerminatingEvent
- type ModelHTTPHeader
- type ModelHTTPMethod
- type ModelHTTPReqDatum
- type ModelHTTPReqDatumHeaders
- type ModelHTTPRespDatum
- type ModelHTTPRespDatumHeaders
- type ModelStageAddedEvent
- type ModelStageCompletedEvent
- type ModelStageComposedEvent
- type ModelStageRefDatum
- type ModelStatusDatum
- type ModelStatusDatumType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GetGraphStateResponseStageRepresentation ¶
type GetGraphStateResponseStageRepresentation struct { // dependencies Dependencies []string `json:"dependencies"` // status Status string `json:"status,omitempty"` // type Type string `json:"type,omitempty"` }
GetGraphStateResponseStageRepresentation get graph state response stage representation swagger:model GetGraphStateResponseStageRepresentation
func (*GetGraphStateResponseStageRepresentation) MarshalBinary ¶
func (m *GetGraphStateResponseStageRepresentation) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*GetGraphStateResponseStageRepresentation) UnmarshalBinary ¶
func (m *GetGraphStateResponseStageRepresentation) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelAddCompletedValueStageRequest ¶
type ModelAddCompletedValueStageRequest struct { // caller id CallerID string `json:"caller_id,omitempty"` // code location CodeLocation string `json:"code_location,omitempty"` // flow id FlowID string `json:"flow_id,omitempty"` // value Value *ModelCompletionResult `json:"value,omitempty"` }
ModelAddCompletedValueStageRequest AddCompletedValueStageRequest creates a new stage with a specific value swagger:model modelAddCompletedValueStageRequest
func (*ModelAddCompletedValueStageRequest) MarshalBinary ¶
func (m *ModelAddCompletedValueStageRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelAddCompletedValueStageRequest) UnmarshalBinary ¶
func (m *ModelAddCompletedValueStageRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelAddDelayStageRequest ¶
type ModelAddDelayStageRequest struct { // caller id CallerID string `json:"caller_id,omitempty"` // code location CodeLocation string `json:"code_location,omitempty"` // delay ms DelayMs int64 `json:"delay_ms,omitempty"` // flow id FlowID string `json:"flow_id,omitempty"` }
ModelAddDelayStageRequest AddDelayStageRequest creates a delay stage swagger:model modelAddDelayStageRequest
func (*ModelAddDelayStageRequest) MarshalBinary ¶
func (m *ModelAddDelayStageRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelAddDelayStageRequest) UnmarshalBinary ¶
func (m *ModelAddDelayStageRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelAddInvokeFunctionStageRequest ¶
type ModelAddInvokeFunctionStageRequest struct { // arg Arg *ModelHTTPReqDatum `json:"arg,omitempty"` // caller id CallerID string `json:"caller_id,omitempty"` // code location CodeLocation string `json:"code_location,omitempty"` // flow id FlowID string `json:"flow_id,omitempty"` // function id FunctionID string `json:"function_id,omitempty"` }
ModelAddInvokeFunctionStageRequest AddInvokeFunctionStageRequest adds a function invocation swagger:model modelAddInvokeFunctionStageRequest
func (*ModelAddInvokeFunctionStageRequest) MarshalBinary ¶
func (m *ModelAddInvokeFunctionStageRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelAddInvokeFunctionStageRequest) UnmarshalBinary ¶
func (m *ModelAddInvokeFunctionStageRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelAddStageRequest ¶
type ModelAddStageRequest struct { // caller id CallerID string `json:"caller_id,omitempty"` // closure Closure *ModelBlobDatum `json:"closure,omitempty"` // code location CodeLocation string `json:"code_location,omitempty"` // deps Deps []string `json:"deps"` // flow id FlowID string `json:"flow_id,omitempty"` // operation Operation ModelCompletionOperation `json:"operation,omitempty"` }
ModelAddStageRequest AddStageRequest adds a new stage with dependenencies to the graph swagger:model modelAddStageRequest
func (*ModelAddStageRequest) MarshalBinary ¶
func (m *ModelAddStageRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelAddStageRequest) UnmarshalBinary ¶
func (m *ModelAddStageRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelAddStageResponse ¶
type ModelAddStageResponse struct { // flow id FlowID string `json:"flow_id,omitempty"` // stage id StageID string `json:"stage_id,omitempty"` }
ModelAddStageResponse AddStageResponse returns the stage ID of the created stage swagger:model modelAddStageResponse
func (*ModelAddStageResponse) MarshalBinary ¶
func (m *ModelAddStageResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelAddStageResponse) UnmarshalBinary ¶
func (m *ModelAddStageResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelAwaitStageResultResponse ¶
type ModelAwaitStageResultResponse struct { // flow id FlowID string `json:"flow_id,omitempty"` // result Result *ModelCompletionResult `json:"result,omitempty"` // stage id StageID string `json:"stage_id,omitempty"` }
ModelAwaitStageResultResponse model await stage result response swagger:model modelAwaitStageResultResponse
func (*ModelAwaitStageResultResponse) MarshalBinary ¶
func (m *ModelAwaitStageResultResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelAwaitStageResultResponse) UnmarshalBinary ¶
func (m *ModelAwaitStageResultResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelBlobDatum ¶
type ModelBlobDatum struct { // blob id BlobID string `json:"blob_id,omitempty"` // content type ContentType string `json:"content_type,omitempty"` // length Length int64 `json:"length,omitempty,string"` }
ModelBlobDatum BlobDatum holds a reference to a blob the associated blob store swagger:model modelBlobDatum
func (*ModelBlobDatum) MarshalBinary ¶
func (m *ModelBlobDatum) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelBlobDatum) UnmarshalBinary ¶
func (m *ModelBlobDatum) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelCompleteStageExternallyRequest ¶
type ModelCompleteStageExternallyRequest struct { // caller id CallerID string `json:"caller_id,omitempty"` // code location CodeLocation string `json:"code_location,omitempty"` // flow id FlowID string `json:"flow_id,omitempty"` // stage id StageID string `json:"stage_id,omitempty"` // value Value *ModelCompletionResult `json:"value,omitempty"` }
ModelCompleteStageExternallyRequest CompleteStageExternallyRequest marks an existing stage as complete with a specific value swagger:model modelCompleteStageExternallyRequest
func (*ModelCompleteStageExternallyRequest) MarshalBinary ¶
func (m *ModelCompleteStageExternallyRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelCompleteStageExternallyRequest) UnmarshalBinary ¶
func (m *ModelCompleteStageExternallyRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelCompleteStageExternallyResponse ¶
type ModelCompleteStageExternallyResponse struct { // flow id FlowID string `json:"flow_id,omitempty"` // stage id StageID string `json:"stage_id,omitempty"` // successful Successful bool `json:"successful,omitempty"` }
ModelCompleteStageExternallyResponse model complete stage externally response swagger:model modelCompleteStageExternallyResponse
func (*ModelCompleteStageExternallyResponse) MarshalBinary ¶
func (m *ModelCompleteStageExternallyResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelCompleteStageExternallyResponse) UnmarshalBinary ¶
func (m *ModelCompleteStageExternallyResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelCompletionOperation ¶
type ModelCompletionOperation string
ModelCompletionOperation CompletionOperation describes the type and behaviour of a stage of the graph swagger:model modelCompletionOperation
const ( // ModelCompletionOperationUnknownOperation captures enum value "unknown_operation" ModelCompletionOperationUnknownOperation ModelCompletionOperation = "unknown_operation" // ModelCompletionOperationAcceptEither captures enum value "acceptEither" ModelCompletionOperationAcceptEither ModelCompletionOperation = "acceptEither" // ModelCompletionOperationApplyToEither captures enum value "applyToEither" ModelCompletionOperationApplyToEither ModelCompletionOperation = "applyToEither" // ModelCompletionOperationThenAcceptBoth captures enum value "thenAcceptBoth" ModelCompletionOperationThenAcceptBoth ModelCompletionOperation = "thenAcceptBoth" // ModelCompletionOperationThenApply captures enum value "thenApply" ModelCompletionOperationThenApply ModelCompletionOperation = "thenApply" // ModelCompletionOperationThenRun captures enum value "thenRun" ModelCompletionOperationThenRun ModelCompletionOperation = "thenRun" // ModelCompletionOperationThenAccept captures enum value "thenAccept" ModelCompletionOperationThenAccept ModelCompletionOperation = "thenAccept" // ModelCompletionOperationThenCompose captures enum value "thenCompose" ModelCompletionOperationThenCompose ModelCompletionOperation = "thenCompose" // ModelCompletionOperationThenCombine captures enum value "thenCombine" ModelCompletionOperationThenCombine ModelCompletionOperation = "thenCombine" // ModelCompletionOperationWhenComplete captures enum value "whenComplete" ModelCompletionOperationWhenComplete ModelCompletionOperation = "whenComplete" // ModelCompletionOperationHandle captures enum value "handle" ModelCompletionOperationHandle ModelCompletionOperation = "handle" // ModelCompletionOperationSupply captures enum value "supply" ModelCompletionOperationSupply ModelCompletionOperation = "supply" // ModelCompletionOperationInvokeFunction captures enum value "invokeFunction" ModelCompletionOperationInvokeFunction ModelCompletionOperation = "invokeFunction" // ModelCompletionOperationCompletedValue captures enum value "completedValue" ModelCompletionOperationCompletedValue ModelCompletionOperation = "completedValue" // ModelCompletionOperationDelay captures enum value "delay" ModelCompletionOperationDelay ModelCompletionOperation = "delay" // ModelCompletionOperationAllOf captures enum value "allOf" ModelCompletionOperationAllOf ModelCompletionOperation = "allOf" // ModelCompletionOperationAnyOf captures enum value "anyOf" ModelCompletionOperationAnyOf ModelCompletionOperation = "anyOf" // ModelCompletionOperationExternalCompletion captures enum value "externalCompletion" ModelCompletionOperationExternalCompletion ModelCompletionOperation = "externalCompletion" // ModelCompletionOperationExceptionally captures enum value "exceptionally" ModelCompletionOperationExceptionally ModelCompletionOperation = "exceptionally" // ModelCompletionOperationTerminationHook captures enum value "terminationHook" ModelCompletionOperationTerminationHook ModelCompletionOperation = "terminationHook" // ModelCompletionOperationExceptionallyCompose captures enum value "exceptionallyCompose" ModelCompletionOperationExceptionallyCompose ModelCompletionOperation = "exceptionallyCompose" )
type ModelCompletionResult ¶
type ModelCompletionResult struct { // datum Datum *ModelDatum `json:"datum,omitempty"` // successful Successful bool `json:"successful,omitempty"` }
ModelCompletionResult CompletinonResult holds a value Datum and a result status (successful/failed) swagger:model modelCompletionResult
func (*ModelCompletionResult) MarshalBinary ¶
func (m *ModelCompletionResult) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelCompletionResult) UnmarshalBinary ¶
func (m *ModelCompletionResult) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelCreateGraphRequest ¶
type ModelCreateGraphRequest struct { // flow id FlowID string `json:"flow_id,omitempty"` // function id FunctionID string `json:"function_id,omitempty"` }
ModelCreateGraphRequest model create graph request swagger:model modelCreateGraphRequest
func (*ModelCreateGraphRequest) MarshalBinary ¶
func (m *ModelCreateGraphRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelCreateGraphRequest) UnmarshalBinary ¶
func (m *ModelCreateGraphRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelCreateGraphResponse ¶
type ModelCreateGraphResponse struct { // flow id FlowID string `json:"flow_id,omitempty"` }
ModelCreateGraphResponse model create graph response swagger:model modelCreateGraphResponse
func (*ModelCreateGraphResponse) MarshalBinary ¶
func (m *ModelCreateGraphResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelCreateGraphResponse) UnmarshalBinary ¶
func (m *ModelCreateGraphResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelDatum ¶
type ModelDatum struct { // blob Blob *ModelBlobDatum `json:"blob,omitempty"` // empty Empty ModelEmptyDatum `json:"empty,omitempty"` // error Error *ModelErrorDatum `json:"error,omitempty"` // http req HTTPReq *ModelHTTPReqDatum `json:"http_req,omitempty"` // http resp HTTPResp *ModelHTTPRespDatum `json:"http_resp,omitempty"` // stage ref StageRef *ModelStageRefDatum `json:"stage_ref,omitempty"` // status Status *ModelStatusDatum `json:"status,omitempty"` }
ModelDatum Datum encapusulates all possible values that may be associated with a stage in the flow graph swagger:model modelDatum
func (*ModelDatum) InnerDatum ¶
func (d *ModelDatum) InnerDatum() interface{}
func (*ModelDatum) MarshalBinary ¶
func (m *ModelDatum) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelDatum) UnmarshalBinary ¶
func (m *ModelDatum) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelDelayScheduledEvent ¶
type ModelDelayScheduledEvent struct { // flow id FlowID string `json:"flow_id,omitempty"` // stage id StageID string `json:"stage_id,omitempty"` // time ms TimeMs int64 `json:"time_ms,omitempty"` // ts Ts strfmt.DateTime `json:"ts,omitempty"` }
ModelDelayScheduledEvent A delay has started - this marks the relative start of an event when a delay node is recovered swagger:model modelDelayScheduledEvent
func (*ModelDelayScheduledEvent) MarshalBinary ¶
func (m *ModelDelayScheduledEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelDelayScheduledEvent) UnmarshalBinary ¶
func (m *ModelDelayScheduledEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelEmptyDatum ¶
type ModelEmptyDatum interface{}
ModelEmptyDatum EmptyDatum represents a null or empty value swagger:model modelEmptyDatum
type ModelErrorDatum ¶
type ModelErrorDatum struct { // message Message string `json:"message,omitempty"` // type Type ModelErrorDatumType `json:"type,omitempty"` }
ModelErrorDatum ErrorDatum represents an error that has occured within a flow graph, the type indicates the cause of the error and the message is informational swagger:model modelErrorDatum
func (*ModelErrorDatum) MarshalBinary ¶
func (m *ModelErrorDatum) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelErrorDatum) UnmarshalBinary ¶
func (m *ModelErrorDatum) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelErrorDatumType ¶
type ModelErrorDatumType string
ModelErrorDatumType ErrorDatumType defines an internal error code generated within a flow swagger:model modelErrorDatumType
const ( // ModelErrorDatumTypeUnknownError captures enum value "unknown_error" ModelErrorDatumTypeUnknownError ModelErrorDatumType = "unknown_error" // ModelErrorDatumTypeStageTimeout captures enum value "stage_timeout" ModelErrorDatumTypeStageTimeout ModelErrorDatumType = "stage_timeout" // ModelErrorDatumTypeStageFailed captures enum value "stage_failed" ModelErrorDatumTypeStageFailed ModelErrorDatumType = "stage_failed" // ModelErrorDatumTypeFunctionTimeout captures enum value "function_timeout" ModelErrorDatumTypeFunctionTimeout ModelErrorDatumType = "function_timeout" // ModelErrorDatumTypeFunctionInvokeFailed captures enum value "function_invoke_failed" ModelErrorDatumTypeFunctionInvokeFailed ModelErrorDatumType = "function_invoke_failed" // ModelErrorDatumTypeStageLost captures enum value "stage_lost" ModelErrorDatumTypeStageLost ModelErrorDatumType = "stage_lost" // ModelErrorDatumTypeInvalidStageResponse captures enum value "invalid_stage_response" ModelErrorDatumTypeInvalidStageResponse ModelErrorDatumType = "invalid_stage_response" )
type ModelFaasInvocationCompletedEvent ¶
type ModelFaasInvocationCompletedEvent struct { // call id CallID string `json:"call_id,omitempty"` // flow id FlowID string `json:"flow_id,omitempty"` // result Result *ModelCompletionResult `json:"result,omitempty"` // stage id StageID string `json:"stage_id,omitempty"` // ts Ts strfmt.DateTime `json:"ts,omitempty"` }
ModelFaasInvocationCompletedEvent A call to the FaaS completed swagger:model modelFaasInvocationCompletedEvent
func (*ModelFaasInvocationCompletedEvent) MarshalBinary ¶
func (m *ModelFaasInvocationCompletedEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelFaasInvocationCompletedEvent) UnmarshalBinary ¶
func (m *ModelFaasInvocationCompletedEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelFaasInvocationStartedEvent ¶
type ModelFaasInvocationStartedEvent struct { // flow id FlowID string `json:"flow_id,omitempty"` // function id FunctionID string `json:"function_id,omitempty"` // stage id StageID string `json:"stage_id,omitempty"` // ts Ts strfmt.DateTime `json:"ts,omitempty"` }
ModelFaasInvocationStartedEvent A call to the FaaS has started swagger:model modelFaasInvocationStartedEvent
func (*ModelFaasInvocationStartedEvent) MarshalBinary ¶
func (m *ModelFaasInvocationStartedEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelFaasInvocationStartedEvent) UnmarshalBinary ¶
func (m *ModelFaasInvocationStartedEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelGetGraphStateResponse ¶
type ModelGetGraphStateResponse struct { // flow id FlowID string `json:"flow_id,omitempty"` // function id FunctionID string `json:"function_id,omitempty"` // stages Stages ModelGetGraphStateResponseStages `json:"stages,omitempty"` }
ModelGetGraphStateResponse model get graph state response swagger:model modelGetGraphStateResponse
func (*ModelGetGraphStateResponse) MarshalBinary ¶
func (m *ModelGetGraphStateResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelGetGraphStateResponse) UnmarshalBinary ¶
func (m *ModelGetGraphStateResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelGetGraphStateResponseStages ¶
type ModelGetGraphStateResponseStages map[string]GetGraphStateResponseStageRepresentation
ModelGetGraphStateResponseStages model get graph state response stages swagger:model modelGetGraphStateResponseStages
type ModelGraphCommittedEvent ¶
type ModelGraphCommittedEvent struct { // flow id FlowID string `json:"flow_id,omitempty"` // ts Ts strfmt.DateTime `json:"ts,omitempty"` }
ModelGraphCommittedEvent 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. swagger:model modelGraphCommittedEvent
func (*ModelGraphCommittedEvent) MarshalBinary ¶
func (m *ModelGraphCommittedEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelGraphCommittedEvent) UnmarshalBinary ¶
func (m *ModelGraphCommittedEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelGraphCompletedEvent ¶
type ModelGraphCompletedEvent struct { // flow id FlowID string `json:"flow_id,omitempty"` // function id FunctionID string `json:"function_id,omitempty"` // ts Ts strfmt.DateTime `json:"ts,omitempty"` }
ModelGraphCompletedEvent Graph is complete and will no longer change swagger:model modelGraphCompletedEvent
func (*ModelGraphCompletedEvent) MarshalBinary ¶
func (m *ModelGraphCompletedEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelGraphCompletedEvent) UnmarshalBinary ¶
func (m *ModelGraphCompletedEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelGraphCreatedEvent ¶
type ModelGraphCreatedEvent struct { // flow id FlowID string `json:"flow_id,omitempty"` // function id FunctionID string `json:"function_id,omitempty"` // ts Ts strfmt.DateTime `json:"ts,omitempty"` }
ModelGraphCreatedEvent Graph created swagger:model modelGraphCreatedEvent
func (*ModelGraphCreatedEvent) MarshalBinary ¶
func (m *ModelGraphCreatedEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelGraphCreatedEvent) UnmarshalBinary ¶
func (m *ModelGraphCreatedEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelGraphEvent ¶
type ModelGraphEvent struct { // delay scheduled DelayScheduled *ModelDelayScheduledEvent `json:"delay_scheduled,omitempty"` // faas invocation completed FaasInvocationCompleted *ModelFaasInvocationCompletedEvent `json:"faas_invocation_completed,omitempty"` // faas invocation started FaasInvocationStarted *ModelFaasInvocationStartedEvent `json:"faas_invocation_started,omitempty"` // flow id FlowID string `json:"flow_id,omitempty"` // graph committed GraphCommitted *ModelGraphCommittedEvent `json:"graph_committed,omitempty"` // graph completed GraphCompleted *ModelGraphCompletedEvent `json:"graph_completed,omitempty"` // graph created GraphCreated *ModelGraphCreatedEvent `json:"graph_created,omitempty"` // graph terminating GraphTerminating *ModelGraphTerminatingEvent `json:"graph_terminating,omitempty"` // sent ts SentTs strfmt.DateTime `json:"sent_ts,omitempty"` // seq Seq uint64 `json:"seq,omitempty"` // stage added StageAdded *ModelStageAddedEvent `json:"stage_added,omitempty"` // stage completed StageCompleted *ModelStageCompletedEvent `json:"stage_completed,omitempty"` // stage composed StageComposed *ModelStageComposedEvent `json:"stage_composed,omitempty"` }
ModelGraphEvent model graph event swagger:model modelGraphEvent
func (*ModelGraphEvent) MarshalBinary ¶
func (m *ModelGraphEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelGraphEvent) UnmarshalBinary ¶
func (m *ModelGraphEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelGraphLifecycleEvent ¶
type ModelGraphLifecycleEvent struct { // flow id FlowID string `json:"flow_id,omitempty"` // graph completed GraphCompleted *ModelGraphCompletedEvent `json:"graph_completed,omitempty"` // graph created GraphCreated *ModelGraphCreatedEvent `json:"graph_created,omitempty"` // seq Seq uint64 `json:"seq,omitempty"` }
ModelGraphLifecycleEvent model graph lifecycle event swagger:model modelGraphLifecycleEvent
func (*ModelGraphLifecycleEvent) MarshalBinary ¶
func (m *ModelGraphLifecycleEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelGraphLifecycleEvent) UnmarshalBinary ¶
func (m *ModelGraphLifecycleEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelGraphRequestProcessedResponse ¶
type ModelGraphRequestProcessedResponse struct { // flow id FlowID string `json:"flow_id,omitempty"` }
ModelGraphRequestProcessedResponse model graph request processed response swagger:model modelGraphRequestProcessedResponse
func (*ModelGraphRequestProcessedResponse) MarshalBinary ¶
func (m *ModelGraphRequestProcessedResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelGraphRequestProcessedResponse) UnmarshalBinary ¶
func (m *ModelGraphRequestProcessedResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelGraphTerminatingEvent ¶
type ModelGraphTerminatingEvent struct { // flow id FlowID string `json:"flow_id,omitempty"` // function id FunctionID string `json:"function_id,omitempty"` // status Status ModelStatusDatumType `json:"status,omitempty"` // ts Ts strfmt.DateTime `json:"ts,omitempty"` }
ModelGraphTerminatingEvent 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 swagger:model modelGraphTerminatingEvent
func (*ModelGraphTerminatingEvent) MarshalBinary ¶
func (m *ModelGraphTerminatingEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelGraphTerminatingEvent) UnmarshalBinary ¶
func (m *ModelGraphTerminatingEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelHTTPHeader ¶
type ModelHTTPHeader struct { // key Key string `json:"key,omitempty"` // value Value string `json:"value,omitempty"` }
ModelHTTPHeader HTTPHeader wraps a single header key/value swagger:model modelHTTPHeader
func (*ModelHTTPHeader) MarshalBinary ¶
func (m *ModelHTTPHeader) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelHTTPHeader) UnmarshalBinary ¶
func (m *ModelHTTPHeader) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelHTTPMethod ¶
type ModelHTTPMethod string
ModelHTTPMethod HTTPMethod defines a specific HTTP method swagger:model modelHTTPMethod
const ( // ModelHTTPMethodUnknownMethod captures enum value "unknown_method" ModelHTTPMethodUnknownMethod ModelHTTPMethod = "unknown_method" // ModelHTTPMethodGet captures enum value "get" ModelHTTPMethodGet ModelHTTPMethod = "get" // ModelHTTPMethodHead captures enum value "head" ModelHTTPMethodHead ModelHTTPMethod = "head" // ModelHTTPMethodPost captures enum value "post" ModelHTTPMethodPost ModelHTTPMethod = "post" // ModelHTTPMethodPut captures enum value "put" ModelHTTPMethodPut ModelHTTPMethod = "put" // ModelHTTPMethodDelete captures enum value "delete" ModelHTTPMethodDelete ModelHTTPMethod = "delete" // ModelHTTPMethodOptions captures enum value "options" ModelHTTPMethodOptions ModelHTTPMethod = "options" // ModelHTTPMethodPatch captures enum value "patch" ModelHTTPMethodPatch ModelHTTPMethod = "patch" )
type ModelHTTPReqDatum ¶
type ModelHTTPReqDatum struct { // body Body *ModelBlobDatum `json:"body,omitempty"` // headers Headers ModelHTTPReqDatumHeaders `json:"headers"` // method Method ModelHTTPMethod `json:"method,omitempty"` }
ModelHTTPReqDatum HTTPReqDatum describes an outgoing or incoming HTTP Request, it wraps the headers, method and optional body swagger:model modelHTTPReqDatum
func (*ModelHTTPReqDatum) MarshalBinary ¶
func (m *ModelHTTPReqDatum) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelHTTPReqDatum) UnmarshalBinary ¶
func (m *ModelHTTPReqDatum) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelHTTPReqDatumHeaders ¶
type ModelHTTPReqDatumHeaders []*ModelHTTPHeader
ModelHTTPReqDatumHeaders model Http req datum headers swagger:model modelHttpReqDatumHeaders
type ModelHTTPRespDatum ¶
type ModelHTTPRespDatum struct { // body Body *ModelBlobDatum `json:"body,omitempty"` // headers Headers ModelHTTPRespDatumHeaders `json:"headers"` // status code StatusCode int32 `json:"status_code,omitempty"` }
ModelHTTPRespDatum HTTPRespDatum wraps an outgoing or incoming HTTP REQUEST, it wraps the headers, status code and optinoal body swagger:model modelHTTPRespDatum
func (*ModelHTTPRespDatum) MarshalBinary ¶
func (m *ModelHTTPRespDatum) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelHTTPRespDatum) UnmarshalBinary ¶
func (m *ModelHTTPRespDatum) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelHTTPRespDatumHeaders ¶
type ModelHTTPRespDatumHeaders []*ModelHTTPHeader
ModelHTTPRespDatumHeaders model Http resp datum headers swagger:model modelHttpRespDatumHeaders
type ModelStageAddedEvent ¶
type ModelStageAddedEvent struct { // caller id CallerID string `json:"caller_id,omitempty"` // closure Closure *ModelBlobDatum `json:"closure,omitempty"` // code location CodeLocation string `json:"code_location,omitempty"` // dependencies Dependencies []string `json:"dependencies"` // flow id FlowID string `json:"flow_id,omitempty"` // op Op ModelCompletionOperation `json:"op,omitempty"` // stage id StageID string `json:"stage_id,omitempty"` // ts Ts strfmt.DateTime `json:"ts,omitempty"` }
ModelStageAddedEvent A stage was added to the graph swagger:model modelStageAddedEvent
func (*ModelStageAddedEvent) MarshalBinary ¶
func (m *ModelStageAddedEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelStageAddedEvent) UnmarshalBinary ¶
func (m *ModelStageAddedEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelStageCompletedEvent ¶
type ModelStageCompletedEvent struct { // flow id FlowID string `json:"flow_id,omitempty"` // result Result *ModelCompletionResult `json:"result,omitempty"` // stage id StageID string `json:"stage_id,omitempty"` // ts Ts strfmt.DateTime `json:"ts,omitempty"` }
ModelStageCompletedEvent A stage completed - downstream stages may be triggered swagger:model modelStageCompletedEvent
func (*ModelStageCompletedEvent) MarshalBinary ¶
func (m *ModelStageCompletedEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelStageCompletedEvent) UnmarshalBinary ¶
func (m *ModelStageCompletedEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelStageComposedEvent ¶
type ModelStageComposedEvent struct { // composed stage id ComposedStageID string `json:"composed_stage_id,omitempty"` // flow id FlowID string `json:"flow_id,omitempty"` // stage id StageID string `json:"stage_id,omitempty"` // ts Ts strfmt.DateTime `json:"ts,omitempty"` }
ModelStageComposedEvent A stage was composed into stage_id - stage_id will compelete with the saem result as composed_stage_id swagger:model modelStageComposedEvent
func (*ModelStageComposedEvent) MarshalBinary ¶
func (m *ModelStageComposedEvent) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelStageComposedEvent) UnmarshalBinary ¶
func (m *ModelStageComposedEvent) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelStageRefDatum ¶
type ModelStageRefDatum struct { // stage id StageID string `json:"stage_id,omitempty"` }
ModelStageRefDatum StageRefDatum represents a reference to another stage in the graph swagger:model modelStageRefDatum
func (*ModelStageRefDatum) MarshalBinary ¶
func (m *ModelStageRefDatum) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelStageRefDatum) UnmarshalBinary ¶
func (m *ModelStageRefDatum) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelStatusDatum ¶
type ModelStatusDatum struct { // type Type ModelStatusDatumType `json:"type,omitempty"` }
ModelStatusDatum StateDatum wraps a description of the state of the graph in a datum swagger:model modelStatusDatum
func (*ModelStatusDatum) MarshalBinary ¶
func (m *ModelStatusDatum) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ModelStatusDatum) UnmarshalBinary ¶
func (m *ModelStatusDatum) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ModelStatusDatumType ¶
type ModelStatusDatumType string
ModelStatusDatumType StateDatumType describes the state of a stage or graph swagger:model modelStatusDatumType
const ( // ModelStatusDatumTypeUnknownState captures enum value "unknown_state" ModelStatusDatumTypeUnknownState ModelStatusDatumType = "unknown_state" // ModelStatusDatumTypeSucceeded captures enum value "succeeded" ModelStatusDatumTypeSucceeded ModelStatusDatumType = "succeeded" // ModelStatusDatumTypeFailed captures enum value "failed" ModelStatusDatumTypeFailed ModelStatusDatumType = "failed" // ModelStatusDatumTypeCancelled captures enum value "cancelled" ModelStatusDatumTypeCancelled ModelStatusDatumType = "cancelled" // ModelStatusDatumTypeKilled captures enum value "killed" ModelStatusDatumTypeKilled ModelStatusDatumType = "killed" )
Source Files ¶
- get_graph_state_response_stage_representation.go
- mixins.go
- model_add_completed_value_stage_request.go
- model_add_delay_stage_request.go
- model_add_invoke_function_stage_request.go
- model_add_stage_request.go
- model_add_stage_response.go
- model_await_stage_result_response.go
- model_blob_datum.go
- model_complete_stage_externally_request.go
- model_complete_stage_externally_response.go
- model_completion_operation.go
- model_completion_result.go
- model_create_graph_request.go
- model_create_graph_response.go
- model_datum.go
- model_delay_scheduled_event.go
- model_empty_datum.go
- model_error_datum.go
- model_error_datum_type.go
- model_faas_invocation_completed_event.go
- model_faas_invocation_started_event.go
- model_get_graph_state_response.go
- model_get_graph_state_response_stages.go
- model_graph_committed_event.go
- model_graph_completed_event.go
- model_graph_created_event.go
- model_graph_event.go
- model_graph_lifecycle_event.go
- model_graph_request_processed_response.go
- model_graph_terminating_event.go
- model_http_header.go
- model_http_method.go
- model_http_req_datum.go
- model_http_req_datum_headers.go
- model_http_resp_datum.go
- model_http_resp_datum_headers.go
- model_stage_added_event.go
- model_stage_completed_event.go
- model_stage_composed_event.go
- model_stage_ref_datum.go
- model_status_datum.go
- model_status_datum_type.go