models

package
v0.0.0-...-6943f8c Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

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

func (*GetGraphStateResponseStageRepresentation) Validate 

func (m *GetGraphStateResponseStageRepresentation) Validate(formats strfmt.Registry) error

Validate validates this get graph state response stage representation

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

func (*ModelAddCompletedValueStageRequest) Validate 

func (m *ModelAddCompletedValueStageRequest) Validate(formats strfmt.Registry) error

Validate validates this model add completed value stage request

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

func (*ModelAddDelayStageRequest) Validate 

func (m *ModelAddDelayStageRequest) Validate(formats strfmt.Registry) error

Validate validates this model add delay stage request

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

func (*ModelAddInvokeFunctionStageRequest) Validate 

func (m *ModelAddInvokeFunctionStageRequest) Validate(formats strfmt.Registry) error

Validate validates this model add invoke function stage request

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

func (*ModelAddStageRequest) Validate 

func (m *ModelAddStageRequest) Validate(formats strfmt.Registry) error

Validate validates this model add stage request

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

func (*ModelAddStageResponse) Validate 

func (m *ModelAddStageResponse) Validate(formats strfmt.Registry) error

Validate validates this model add stage response

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

func (*ModelAwaitStageResultResponse) Validate 

func (m *ModelAwaitStageResultResponse) Validate(formats strfmt.Registry) error

Validate validates this model await stage result response

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

func (*ModelBlobDatum) Validate 

func (m *ModelBlobDatum) Validate(formats strfmt.Registry) error

Validate validates this model blob datum

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

func (*ModelCompleteStageExternallyRequest) Validate 

func (m *ModelCompleteStageExternallyRequest) Validate(formats strfmt.Registry) error

Validate validates this model complete stage externally request

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

func (*ModelCompleteStageExternallyResponse) Validate 

func (m *ModelCompleteStageExternallyResponse) Validate(formats strfmt.Registry) error

Validate validates this model complete stage externally response

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

func (ModelCompletionOperation) Validate 

func (m ModelCompletionOperation) Validate(formats strfmt.Registry) error

Validate validates this model completion operation

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

func (*ModelCompletionResult) Validate 

func (m *ModelCompletionResult) Validate(formats strfmt.Registry) error

Validate validates this model completion result

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

func (*ModelCreateGraphRequest) Validate 

func (m *ModelCreateGraphRequest) Validate(formats strfmt.Registry) error

Validate validates this model create graph request

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

func (*ModelCreateGraphResponse) Validate 

func (m *ModelCreateGraphResponse) Validate(formats strfmt.Registry) error

Validate validates this model create graph response

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

func (*ModelDatum) Validate 

func (m *ModelDatum) Validate(formats strfmt.Registry) error

Validate validates this model datum

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

func (*ModelDelayScheduledEvent) Validate 

func (m *ModelDelayScheduledEvent) Validate(formats strfmt.Registry) error

Validate validates this model delay scheduled event

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

func (*ModelErrorDatum) Validate 

func (m *ModelErrorDatum) Validate(formats strfmt.Registry) error

Validate validates this model error datum

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

func (ModelErrorDatumType) Validate 

func (m ModelErrorDatumType) Validate(formats strfmt.Registry) error

Validate validates this model error datum type

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

func (*ModelFaasInvocationCompletedEvent) Validate 

func (m *ModelFaasInvocationCompletedEvent) Validate(formats strfmt.Registry) error

Validate validates this model faas invocation completed event

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

func (*ModelFaasInvocationStartedEvent) Validate 

func (m *ModelFaasInvocationStartedEvent) Validate(formats strfmt.Registry) error

Validate validates this model faas invocation started event

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

func (*ModelGetGraphStateResponse) Validate 

func (m *ModelGetGraphStateResponse) Validate(formats strfmt.Registry) error

Validate validates this model get graph state response

type ModelGetGraphStateResponseStages 

type ModelGetGraphStateResponseStages map[string]GetGraphStateResponseStageRepresentation

ModelGetGraphStateResponseStages model get graph state response stages swagger:model modelGetGraphStateResponseStages

func (ModelGetGraphStateResponseStages) Validate 

func (m ModelGetGraphStateResponseStages) Validate(formats strfmt.Registry) error

Validate validates this model get graph state response stages

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

func (*ModelGraphCommittedEvent) Validate 

func (m *ModelGraphCommittedEvent) Validate(formats strfmt.Registry) error

Validate validates this model graph committed event

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

func (*ModelGraphCompletedEvent) Validate 

func (m *ModelGraphCompletedEvent) Validate(formats strfmt.Registry) error

Validate validates this model graph completed event

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

func (*ModelGraphCreatedEvent) Validate 

func (m *ModelGraphCreatedEvent) Validate(formats strfmt.Registry) error

Validate validates this model graph created event

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

func (*ModelGraphEvent) Validate 

func (m *ModelGraphEvent) Validate(formats strfmt.Registry) error

Validate validates this model graph event

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

func (*ModelGraphLifecycleEvent) Validate 

func (m *ModelGraphLifecycleEvent) Validate(formats strfmt.Registry) error

Validate validates this model graph lifecycle event

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

func (*ModelGraphRequestProcessedResponse) Validate 

func (m *ModelGraphRequestProcessedResponse) Validate(formats strfmt.Registry) error

Validate validates this model graph request processed response

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

func (*ModelGraphTerminatingEvent) Validate 

func (m *ModelGraphTerminatingEvent) Validate(formats strfmt.Registry) error

Validate validates this model graph terminating event

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

func (*ModelHTTPHeader) Validate 

func (m *ModelHTTPHeader) Validate(formats strfmt.Registry) error

Validate validates this model HTTP header

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

func (ModelHTTPMethod) Validate 

func (m ModelHTTPMethod) Validate(formats strfmt.Registry) error

Validate validates this model HTTP method

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

func (*ModelHTTPReqDatum) Validate 

func (m *ModelHTTPReqDatum) Validate(formats strfmt.Registry) error

Validate validates this model HTTP req datum

type ModelHTTPReqDatumHeaders 

type ModelHTTPReqDatumHeaders []*ModelHTTPHeader

ModelHTTPReqDatumHeaders model Http req datum headers swagger:model modelHttpReqDatumHeaders

func (ModelHTTPReqDatumHeaders) Validate 

func (m ModelHTTPReqDatumHeaders) Validate(formats strfmt.Registry) error

Validate validates this model Http req datum headers

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

func (*ModelHTTPRespDatum) Validate 

func (m *ModelHTTPRespDatum) Validate(formats strfmt.Registry) error

Validate validates this model HTTP resp datum

type ModelHTTPRespDatumHeaders 

type ModelHTTPRespDatumHeaders []*ModelHTTPHeader

ModelHTTPRespDatumHeaders model Http resp datum headers swagger:model modelHttpRespDatumHeaders

func (ModelHTTPRespDatumHeaders) Validate 

func (m ModelHTTPRespDatumHeaders) Validate(formats strfmt.Registry) error

Validate validates this model Http resp datum headers

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

func (*ModelStageAddedEvent) Validate 

func (m *ModelStageAddedEvent) Validate(formats strfmt.Registry) error

Validate validates this model stage added event

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

func (*ModelStageCompletedEvent) Validate 

func (m *ModelStageCompletedEvent) Validate(formats strfmt.Registry) error

Validate validates this model stage completed event

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

func (*ModelStageComposedEvent) Validate 

func (m *ModelStageComposedEvent) Validate(formats strfmt.Registry) error

Validate validates this model stage composed event

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

func (*ModelStageRefDatum) Validate 

func (m *ModelStageRefDatum) Validate(formats strfmt.Registry) error

Validate validates this model stage ref datum

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

func (*ModelStatusDatum) Validate 

func (m *ModelStatusDatum) Validate(formats strfmt.Registry) error

Validate validates this model status datum

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

func (ModelStatusDatumType) Validate 

func (m ModelStatusDatumType) Validate(formats strfmt.Registry) error

Validate validates this model status datum type

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.