Documentation ¶
Index ¶
- type AddDelayOK
- type AddDelayParams
- func (o *AddDelayParams) SetBody(body *models.ModelAddDelayStageRequest)
- func (o *AddDelayParams) SetContext(ctx context.Context)
- func (o *AddDelayParams) SetFlowID(flowID string)
- func (o *AddDelayParams) SetHTTPClient(client *http.Client)
- func (o *AddDelayParams) SetTimeout(timeout time.Duration)
- func (o *AddDelayParams) WithBody(body *models.ModelAddDelayStageRequest) *AddDelayParams
- func (o *AddDelayParams) WithContext(ctx context.Context) *AddDelayParams
- func (o *AddDelayParams) WithFlowID(flowID string) *AddDelayParams
- func (o *AddDelayParams) WithHTTPClient(client *http.Client) *AddDelayParams
- func (o *AddDelayParams) WithTimeout(timeout time.Duration) *AddDelayParams
- func (o *AddDelayParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type AddDelayReader
- type AddInvokeFunctionOK
- type AddInvokeFunctionParams
- func NewAddInvokeFunctionParams() *AddInvokeFunctionParams
- func NewAddInvokeFunctionParamsWithContext(ctx context.Context) *AddInvokeFunctionParams
- func NewAddInvokeFunctionParamsWithHTTPClient(client *http.Client) *AddInvokeFunctionParams
- func NewAddInvokeFunctionParamsWithTimeout(timeout time.Duration) *AddInvokeFunctionParams
- func (o *AddInvokeFunctionParams) SetBody(body *models.ModelAddInvokeFunctionStageRequest)
- func (o *AddInvokeFunctionParams) SetContext(ctx context.Context)
- func (o *AddInvokeFunctionParams) SetFlowID(flowID string)
- func (o *AddInvokeFunctionParams) SetHTTPClient(client *http.Client)
- func (o *AddInvokeFunctionParams) SetTimeout(timeout time.Duration)
- func (o *AddInvokeFunctionParams) WithBody(body *models.ModelAddInvokeFunctionStageRequest) *AddInvokeFunctionParams
- func (o *AddInvokeFunctionParams) WithContext(ctx context.Context) *AddInvokeFunctionParams
- func (o *AddInvokeFunctionParams) WithFlowID(flowID string) *AddInvokeFunctionParams
- func (o *AddInvokeFunctionParams) WithHTTPClient(client *http.Client) *AddInvokeFunctionParams
- func (o *AddInvokeFunctionParams) WithTimeout(timeout time.Duration) *AddInvokeFunctionParams
- func (o *AddInvokeFunctionParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type AddInvokeFunctionReader
- type AddStageOK
- type AddStageParams
- func (o *AddStageParams) SetBody(body *models.ModelAddStageRequest)
- func (o *AddStageParams) SetContext(ctx context.Context)
- func (o *AddStageParams) SetFlowID(flowID string)
- func (o *AddStageParams) SetHTTPClient(client *http.Client)
- func (o *AddStageParams) SetTimeout(timeout time.Duration)
- func (o *AddStageParams) WithBody(body *models.ModelAddStageRequest) *AddStageParams
- func (o *AddStageParams) WithContext(ctx context.Context) *AddStageParams
- func (o *AddStageParams) WithFlowID(flowID string) *AddStageParams
- func (o *AddStageParams) WithHTTPClient(client *http.Client) *AddStageParams
- func (o *AddStageParams) WithTimeout(timeout time.Duration) *AddStageParams
- func (o *AddStageParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type AddStageReader
- type AddValueStageOK
- type AddValueStageParams
- func (o *AddValueStageParams) SetBody(body *models.ModelAddCompletedValueStageRequest)
- func (o *AddValueStageParams) SetContext(ctx context.Context)
- func (o *AddValueStageParams) SetFlowID(flowID string)
- func (o *AddValueStageParams) SetHTTPClient(client *http.Client)
- func (o *AddValueStageParams) SetTimeout(timeout time.Duration)
- func (o *AddValueStageParams) WithBody(body *models.ModelAddCompletedValueStageRequest) *AddValueStageParams
- func (o *AddValueStageParams) WithContext(ctx context.Context) *AddValueStageParams
- func (o *AddValueStageParams) WithFlowID(flowID string) *AddValueStageParams
- func (o *AddValueStageParams) WithHTTPClient(client *http.Client) *AddValueStageParams
- func (o *AddValueStageParams) WithTimeout(timeout time.Duration) *AddValueStageParams
- func (o *AddValueStageParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type AddValueStageReader
- type AwaitStageResultOK
- type AwaitStageResultParams
- func NewAwaitStageResultParams() *AwaitStageResultParams
- func NewAwaitStageResultParamsWithContext(ctx context.Context) *AwaitStageResultParams
- func NewAwaitStageResultParamsWithHTTPClient(client *http.Client) *AwaitStageResultParams
- func NewAwaitStageResultParamsWithTimeout(timeout time.Duration) *AwaitStageResultParams
- func (o *AwaitStageResultParams) SetContext(ctx context.Context)
- func (o *AwaitStageResultParams) SetFlowID(flowID string)
- func (o *AwaitStageResultParams) SetHTTPClient(client *http.Client)
- func (o *AwaitStageResultParams) SetStageID(stageID string)
- func (o *AwaitStageResultParams) SetTimeout(timeout time.Duration)
- func (o *AwaitStageResultParams) SetTimeoutMs(timeoutMs *int32)
- func (o *AwaitStageResultParams) WithContext(ctx context.Context) *AwaitStageResultParams
- func (o *AwaitStageResultParams) WithFlowID(flowID string) *AwaitStageResultParams
- func (o *AwaitStageResultParams) WithHTTPClient(client *http.Client) *AwaitStageResultParams
- func (o *AwaitStageResultParams) WithStageID(stageID string) *AwaitStageResultParams
- func (o *AwaitStageResultParams) WithTimeout(timeout time.Duration) *AwaitStageResultParams
- func (o *AwaitStageResultParams) WithTimeoutMs(timeoutMs *int32) *AwaitStageResultParams
- func (o *AwaitStageResultParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type AwaitStageResultReader
- type Client
- func (a *Client) AddDelay(params *AddDelayParams) (*AddDelayOK, error)
- func (a *Client) AddInvokeFunction(params *AddInvokeFunctionParams) (*AddInvokeFunctionOK, error)
- func (a *Client) AddStage(params *AddStageParams) (*AddStageOK, error)
- func (a *Client) AddValueStage(params *AddValueStageParams) (*AddValueStageOK, error)
- func (a *Client) AwaitStageResult(params *AwaitStageResultParams) (*AwaitStageResultOK, error)
- func (a *Client) Commit(params *CommitParams) (*CommitOK, error)
- func (a *Client) CompleteStageExternally(params *CompleteStageExternallyParams) (*CompleteStageExternallyOK, error)
- func (a *Client) CreateGraph(params *CreateGraphParams) (*CreateGraphOK, error)
- func (a *Client) GetGraphState(params *GetGraphStateParams) (*GetGraphStateOK, error)
- func (a *Client) SetTransport(transport runtime.ClientTransport)
- func (a *Client) StreamEvents(params *StreamEventsParams) (*StreamEventsOK, error)
- func (a *Client) StreamLifecycle(params *StreamLifecycleParams) (*StreamLifecycleOK, error)
- type CommitOK
- type CommitParams
- func (o *CommitParams) SetContext(ctx context.Context)
- func (o *CommitParams) SetFlowID(flowID string)
- func (o *CommitParams) SetHTTPClient(client *http.Client)
- func (o *CommitParams) SetTimeout(timeout time.Duration)
- func (o *CommitParams) WithContext(ctx context.Context) *CommitParams
- func (o *CommitParams) WithFlowID(flowID string) *CommitParams
- func (o *CommitParams) WithHTTPClient(client *http.Client) *CommitParams
- func (o *CommitParams) WithTimeout(timeout time.Duration) *CommitParams
- func (o *CommitParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type CommitReader
- type CompleteStageExternallyOK
- type CompleteStageExternallyParams
- func NewCompleteStageExternallyParams() *CompleteStageExternallyParams
- func NewCompleteStageExternallyParamsWithContext(ctx context.Context) *CompleteStageExternallyParams
- func NewCompleteStageExternallyParamsWithHTTPClient(client *http.Client) *CompleteStageExternallyParams
- func NewCompleteStageExternallyParamsWithTimeout(timeout time.Duration) *CompleteStageExternallyParams
- func (o *CompleteStageExternallyParams) SetBody(body *models.ModelCompleteStageExternallyRequest)
- func (o *CompleteStageExternallyParams) SetContext(ctx context.Context)
- func (o *CompleteStageExternallyParams) SetFlowID(flowID string)
- func (o *CompleteStageExternallyParams) SetHTTPClient(client *http.Client)
- func (o *CompleteStageExternallyParams) SetStageID(stageID string)
- func (o *CompleteStageExternallyParams) SetTimeout(timeout time.Duration)
- func (o *CompleteStageExternallyParams) WithBody(body *models.ModelCompleteStageExternallyRequest) *CompleteStageExternallyParams
- func (o *CompleteStageExternallyParams) WithContext(ctx context.Context) *CompleteStageExternallyParams
- func (o *CompleteStageExternallyParams) WithFlowID(flowID string) *CompleteStageExternallyParams
- func (o *CompleteStageExternallyParams) WithHTTPClient(client *http.Client) *CompleteStageExternallyParams
- func (o *CompleteStageExternallyParams) WithStageID(stageID string) *CompleteStageExternallyParams
- func (o *CompleteStageExternallyParams) WithTimeout(timeout time.Duration) *CompleteStageExternallyParams
- func (o *CompleteStageExternallyParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type CompleteStageExternallyReader
- type CreateGraphOK
- type CreateGraphParams
- func (o *CreateGraphParams) SetBody(body *models.ModelCreateGraphRequest)
- func (o *CreateGraphParams) SetContext(ctx context.Context)
- func (o *CreateGraphParams) SetHTTPClient(client *http.Client)
- func (o *CreateGraphParams) SetTimeout(timeout time.Duration)
- func (o *CreateGraphParams) WithBody(body *models.ModelCreateGraphRequest) *CreateGraphParams
- func (o *CreateGraphParams) WithContext(ctx context.Context) *CreateGraphParams
- func (o *CreateGraphParams) WithHTTPClient(client *http.Client) *CreateGraphParams
- func (o *CreateGraphParams) WithTimeout(timeout time.Duration) *CreateGraphParams
- func (o *CreateGraphParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type CreateGraphReader
- type GetGraphStateOK
- type GetGraphStateParams
- func (o *GetGraphStateParams) SetContext(ctx context.Context)
- func (o *GetGraphStateParams) SetFlowID(flowID string)
- func (o *GetGraphStateParams) SetHTTPClient(client *http.Client)
- func (o *GetGraphStateParams) SetTimeout(timeout time.Duration)
- func (o *GetGraphStateParams) WithContext(ctx context.Context) *GetGraphStateParams
- func (o *GetGraphStateParams) WithFlowID(flowID string) *GetGraphStateParams
- func (o *GetGraphStateParams) WithHTTPClient(client *http.Client) *GetGraphStateParams
- func (o *GetGraphStateParams) WithTimeout(timeout time.Duration) *GetGraphStateParams
- func (o *GetGraphStateParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type GetGraphStateReader
- type StreamEventsOK
- type StreamEventsParams
- func (o *StreamEventsParams) SetContext(ctx context.Context)
- func (o *StreamEventsParams) SetFlowID(flowID string)
- func (o *StreamEventsParams) SetFromSeq(fromSeq *uint64)
- func (o *StreamEventsParams) SetHTTPClient(client *http.Client)
- func (o *StreamEventsParams) SetTimeout(timeout time.Duration)
- func (o *StreamEventsParams) WithContext(ctx context.Context) *StreamEventsParams
- func (o *StreamEventsParams) WithFlowID(flowID string) *StreamEventsParams
- func (o *StreamEventsParams) WithFromSeq(fromSeq *uint64) *StreamEventsParams
- func (o *StreamEventsParams) WithHTTPClient(client *http.Client) *StreamEventsParams
- func (o *StreamEventsParams) WithTimeout(timeout time.Duration) *StreamEventsParams
- func (o *StreamEventsParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type StreamEventsReader
- type StreamLifecycleOK
- type StreamLifecycleParams
- func NewStreamLifecycleParams() *StreamLifecycleParams
- func NewStreamLifecycleParamsWithContext(ctx context.Context) *StreamLifecycleParams
- func NewStreamLifecycleParamsWithHTTPClient(client *http.Client) *StreamLifecycleParams
- func NewStreamLifecycleParamsWithTimeout(timeout time.Duration) *StreamLifecycleParams
- func (o *StreamLifecycleParams) SetContext(ctx context.Context)
- func (o *StreamLifecycleParams) SetHTTPClient(client *http.Client)
- func (o *StreamLifecycleParams) SetTimeout(timeout time.Duration)
- func (o *StreamLifecycleParams) WithContext(ctx context.Context) *StreamLifecycleParams
- func (o *StreamLifecycleParams) WithHTTPClient(client *http.Client) *StreamLifecycleParams
- func (o *StreamLifecycleParams) WithTimeout(timeout time.Duration) *StreamLifecycleParams
- func (o *StreamLifecycleParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type StreamLifecycleReader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddDelayOK ¶
type AddDelayOK struct {
Payload *models.ModelAddStageResponse
}
AddDelayOK handles this case with default header values.
AddDelayOK add delay o k
func NewAddDelayOK ¶
func NewAddDelayOK() *AddDelayOK
NewAddDelayOK creates a AddDelayOK with default headers values
func (*AddDelayOK) Error ¶
func (o *AddDelayOK) Error() string
type AddDelayParams ¶
type AddDelayParams struct { /*Body*/ Body *models.ModelAddDelayStageRequest /*FlowID*/ FlowID string Context context.Context HTTPClient *http.Client // contains filtered or unexported fields }
AddDelayParams contains all the parameters to send to the API endpoint for the add delay operation typically these are written to a http.Request
func NewAddDelayParams ¶
func NewAddDelayParams() *AddDelayParams
NewAddDelayParams creates a new AddDelayParams object with the default values initialized.
func NewAddDelayParamsWithContext ¶
func NewAddDelayParamsWithContext(ctx context.Context) *AddDelayParams
NewAddDelayParamsWithContext creates a new AddDelayParams object with the default values initialized, and the ability to set a context for a request
func NewAddDelayParamsWithHTTPClient ¶
func NewAddDelayParamsWithHTTPClient(client *http.Client) *AddDelayParams
NewAddDelayParamsWithHTTPClient creates a new AddDelayParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewAddDelayParamsWithTimeout ¶
func NewAddDelayParamsWithTimeout(timeout time.Duration) *AddDelayParams
NewAddDelayParamsWithTimeout creates a new AddDelayParams object with the default values initialized, and the ability to set a timeout on a request
func (*AddDelayParams) SetBody ¶
func (o *AddDelayParams) SetBody(body *models.ModelAddDelayStageRequest)
SetBody adds the body to the add delay params
func (*AddDelayParams) SetContext ¶
func (o *AddDelayParams) SetContext(ctx context.Context)
SetContext adds the context to the add delay params
func (*AddDelayParams) SetFlowID ¶
func (o *AddDelayParams) SetFlowID(flowID string)
SetFlowID adds the flowId to the add delay params
func (*AddDelayParams) SetHTTPClient ¶
func (o *AddDelayParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the add delay params
func (*AddDelayParams) SetTimeout ¶
func (o *AddDelayParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the add delay params
func (*AddDelayParams) WithBody ¶
func (o *AddDelayParams) WithBody(body *models.ModelAddDelayStageRequest) *AddDelayParams
WithBody adds the body to the add delay params
func (*AddDelayParams) WithContext ¶
func (o *AddDelayParams) WithContext(ctx context.Context) *AddDelayParams
WithContext adds the context to the add delay params
func (*AddDelayParams) WithFlowID ¶
func (o *AddDelayParams) WithFlowID(flowID string) *AddDelayParams
WithFlowID adds the flowID to the add delay params
func (*AddDelayParams) WithHTTPClient ¶
func (o *AddDelayParams) WithHTTPClient(client *http.Client) *AddDelayParams
WithHTTPClient adds the HTTPClient to the add delay params
func (*AddDelayParams) WithTimeout ¶
func (o *AddDelayParams) WithTimeout(timeout time.Duration) *AddDelayParams
WithTimeout adds the timeout to the add delay params
func (*AddDelayParams) WriteToRequest ¶
func (o *AddDelayParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type AddDelayReader ¶
type AddDelayReader struct {
// contains filtered or unexported fields
}
AddDelayReader is a Reader for the AddDelay structure.
func (*AddDelayReader) ReadResponse ¶
func (o *AddDelayReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type AddInvokeFunctionOK ¶
type AddInvokeFunctionOK struct {
Payload *models.ModelAddStageResponse
}
AddInvokeFunctionOK handles this case with default header values.
AddInvokeFunctionOK add invoke function o k
func NewAddInvokeFunctionOK ¶
func NewAddInvokeFunctionOK() *AddInvokeFunctionOK
NewAddInvokeFunctionOK creates a AddInvokeFunctionOK with default headers values
func (*AddInvokeFunctionOK) Error ¶
func (o *AddInvokeFunctionOK) Error() string
type AddInvokeFunctionParams ¶
type AddInvokeFunctionParams struct { /*Body*/ Body *models.ModelAddInvokeFunctionStageRequest /*FlowID*/ FlowID string Context context.Context HTTPClient *http.Client // contains filtered or unexported fields }
AddInvokeFunctionParams contains all the parameters to send to the API endpoint for the add invoke function operation typically these are written to a http.Request
func NewAddInvokeFunctionParams ¶
func NewAddInvokeFunctionParams() *AddInvokeFunctionParams
NewAddInvokeFunctionParams creates a new AddInvokeFunctionParams object with the default values initialized.
func NewAddInvokeFunctionParamsWithContext ¶
func NewAddInvokeFunctionParamsWithContext(ctx context.Context) *AddInvokeFunctionParams
NewAddInvokeFunctionParamsWithContext creates a new AddInvokeFunctionParams object with the default values initialized, and the ability to set a context for a request
func NewAddInvokeFunctionParamsWithHTTPClient ¶
func NewAddInvokeFunctionParamsWithHTTPClient(client *http.Client) *AddInvokeFunctionParams
NewAddInvokeFunctionParamsWithHTTPClient creates a new AddInvokeFunctionParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewAddInvokeFunctionParamsWithTimeout ¶
func NewAddInvokeFunctionParamsWithTimeout(timeout time.Duration) *AddInvokeFunctionParams
NewAddInvokeFunctionParamsWithTimeout creates a new AddInvokeFunctionParams object with the default values initialized, and the ability to set a timeout on a request
func (*AddInvokeFunctionParams) SetBody ¶
func (o *AddInvokeFunctionParams) SetBody(body *models.ModelAddInvokeFunctionStageRequest)
SetBody adds the body to the add invoke function params
func (*AddInvokeFunctionParams) SetContext ¶
func (o *AddInvokeFunctionParams) SetContext(ctx context.Context)
SetContext adds the context to the add invoke function params
func (*AddInvokeFunctionParams) SetFlowID ¶
func (o *AddInvokeFunctionParams) SetFlowID(flowID string)
SetFlowID adds the flowId to the add invoke function params
func (*AddInvokeFunctionParams) SetHTTPClient ¶
func (o *AddInvokeFunctionParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the add invoke function params
func (*AddInvokeFunctionParams) SetTimeout ¶
func (o *AddInvokeFunctionParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the add invoke function params
func (*AddInvokeFunctionParams) WithBody ¶
func (o *AddInvokeFunctionParams) WithBody(body *models.ModelAddInvokeFunctionStageRequest) *AddInvokeFunctionParams
WithBody adds the body to the add invoke function params
func (*AddInvokeFunctionParams) WithContext ¶
func (o *AddInvokeFunctionParams) WithContext(ctx context.Context) *AddInvokeFunctionParams
WithContext adds the context to the add invoke function params
func (*AddInvokeFunctionParams) WithFlowID ¶
func (o *AddInvokeFunctionParams) WithFlowID(flowID string) *AddInvokeFunctionParams
WithFlowID adds the flowID to the add invoke function params
func (*AddInvokeFunctionParams) WithHTTPClient ¶
func (o *AddInvokeFunctionParams) WithHTTPClient(client *http.Client) *AddInvokeFunctionParams
WithHTTPClient adds the HTTPClient to the add invoke function params
func (*AddInvokeFunctionParams) WithTimeout ¶
func (o *AddInvokeFunctionParams) WithTimeout(timeout time.Duration) *AddInvokeFunctionParams
WithTimeout adds the timeout to the add invoke function params
func (*AddInvokeFunctionParams) WriteToRequest ¶
func (o *AddInvokeFunctionParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type AddInvokeFunctionReader ¶
type AddInvokeFunctionReader struct {
// contains filtered or unexported fields
}
AddInvokeFunctionReader is a Reader for the AddInvokeFunction structure.
func (*AddInvokeFunctionReader) ReadResponse ¶
func (o *AddInvokeFunctionReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type AddStageOK ¶
type AddStageOK struct {
Payload *models.ModelAddStageResponse
}
AddStageOK handles this case with default header values.
AddStageOK add stage o k
func NewAddStageOK ¶
func NewAddStageOK() *AddStageOK
NewAddStageOK creates a AddStageOK with default headers values
func (*AddStageOK) Error ¶
func (o *AddStageOK) Error() string
type AddStageParams ¶
type AddStageParams struct { /*Body*/ Body *models.ModelAddStageRequest /*FlowID*/ FlowID string Context context.Context HTTPClient *http.Client // contains filtered or unexported fields }
AddStageParams contains all the parameters to send to the API endpoint for the add stage operation typically these are written to a http.Request
func NewAddStageParams ¶
func NewAddStageParams() *AddStageParams
NewAddStageParams creates a new AddStageParams object with the default values initialized.
func NewAddStageParamsWithContext ¶
func NewAddStageParamsWithContext(ctx context.Context) *AddStageParams
NewAddStageParamsWithContext creates a new AddStageParams object with the default values initialized, and the ability to set a context for a request
func NewAddStageParamsWithHTTPClient ¶
func NewAddStageParamsWithHTTPClient(client *http.Client) *AddStageParams
NewAddStageParamsWithHTTPClient creates a new AddStageParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewAddStageParamsWithTimeout ¶
func NewAddStageParamsWithTimeout(timeout time.Duration) *AddStageParams
NewAddStageParamsWithTimeout creates a new AddStageParams object with the default values initialized, and the ability to set a timeout on a request
func (*AddStageParams) SetBody ¶
func (o *AddStageParams) SetBody(body *models.ModelAddStageRequest)
SetBody adds the body to the add stage params
func (*AddStageParams) SetContext ¶
func (o *AddStageParams) SetContext(ctx context.Context)
SetContext adds the context to the add stage params
func (*AddStageParams) SetFlowID ¶
func (o *AddStageParams) SetFlowID(flowID string)
SetFlowID adds the flowId to the add stage params
func (*AddStageParams) SetHTTPClient ¶
func (o *AddStageParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the add stage params
func (*AddStageParams) SetTimeout ¶
func (o *AddStageParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the add stage params
func (*AddStageParams) WithBody ¶
func (o *AddStageParams) WithBody(body *models.ModelAddStageRequest) *AddStageParams
WithBody adds the body to the add stage params
func (*AddStageParams) WithContext ¶
func (o *AddStageParams) WithContext(ctx context.Context) *AddStageParams
WithContext adds the context to the add stage params
func (*AddStageParams) WithFlowID ¶
func (o *AddStageParams) WithFlowID(flowID string) *AddStageParams
WithFlowID adds the flowID to the add stage params
func (*AddStageParams) WithHTTPClient ¶
func (o *AddStageParams) WithHTTPClient(client *http.Client) *AddStageParams
WithHTTPClient adds the HTTPClient to the add stage params
func (*AddStageParams) WithTimeout ¶
func (o *AddStageParams) WithTimeout(timeout time.Duration) *AddStageParams
WithTimeout adds the timeout to the add stage params
func (*AddStageParams) WriteToRequest ¶
func (o *AddStageParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type AddStageReader ¶
type AddStageReader struct {
// contains filtered or unexported fields
}
AddStageReader is a Reader for the AddStage structure.
func (*AddStageReader) ReadResponse ¶
func (o *AddStageReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type AddValueStageOK ¶
type AddValueStageOK struct {
Payload *models.ModelAddStageResponse
}
AddValueStageOK handles this case with default header values.
AddValueStageOK add value stage o k
func NewAddValueStageOK ¶
func NewAddValueStageOK() *AddValueStageOK
NewAddValueStageOK creates a AddValueStageOK with default headers values
func (*AddValueStageOK) Error ¶
func (o *AddValueStageOK) Error() string
type AddValueStageParams ¶
type AddValueStageParams struct { /*Body*/ Body *models.ModelAddCompletedValueStageRequest /*FlowID*/ FlowID string Context context.Context HTTPClient *http.Client // contains filtered or unexported fields }
AddValueStageParams contains all the parameters to send to the API endpoint for the add value stage operation typically these are written to a http.Request
func NewAddValueStageParams ¶
func NewAddValueStageParams() *AddValueStageParams
NewAddValueStageParams creates a new AddValueStageParams object with the default values initialized.
func NewAddValueStageParamsWithContext ¶
func NewAddValueStageParamsWithContext(ctx context.Context) *AddValueStageParams
NewAddValueStageParamsWithContext creates a new AddValueStageParams object with the default values initialized, and the ability to set a context for a request
func NewAddValueStageParamsWithHTTPClient ¶
func NewAddValueStageParamsWithHTTPClient(client *http.Client) *AddValueStageParams
NewAddValueStageParamsWithHTTPClient creates a new AddValueStageParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewAddValueStageParamsWithTimeout ¶
func NewAddValueStageParamsWithTimeout(timeout time.Duration) *AddValueStageParams
NewAddValueStageParamsWithTimeout creates a new AddValueStageParams object with the default values initialized, and the ability to set a timeout on a request
func (*AddValueStageParams) SetBody ¶
func (o *AddValueStageParams) SetBody(body *models.ModelAddCompletedValueStageRequest)
SetBody adds the body to the add value stage params
func (*AddValueStageParams) SetContext ¶
func (o *AddValueStageParams) SetContext(ctx context.Context)
SetContext adds the context to the add value stage params
func (*AddValueStageParams) SetFlowID ¶
func (o *AddValueStageParams) SetFlowID(flowID string)
SetFlowID adds the flowId to the add value stage params
func (*AddValueStageParams) SetHTTPClient ¶
func (o *AddValueStageParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the add value stage params
func (*AddValueStageParams) SetTimeout ¶
func (o *AddValueStageParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the add value stage params
func (*AddValueStageParams) WithBody ¶
func (o *AddValueStageParams) WithBody(body *models.ModelAddCompletedValueStageRequest) *AddValueStageParams
WithBody adds the body to the add value stage params
func (*AddValueStageParams) WithContext ¶
func (o *AddValueStageParams) WithContext(ctx context.Context) *AddValueStageParams
WithContext adds the context to the add value stage params
func (*AddValueStageParams) WithFlowID ¶
func (o *AddValueStageParams) WithFlowID(flowID string) *AddValueStageParams
WithFlowID adds the flowID to the add value stage params
func (*AddValueStageParams) WithHTTPClient ¶
func (o *AddValueStageParams) WithHTTPClient(client *http.Client) *AddValueStageParams
WithHTTPClient adds the HTTPClient to the add value stage params
func (*AddValueStageParams) WithTimeout ¶
func (o *AddValueStageParams) WithTimeout(timeout time.Duration) *AddValueStageParams
WithTimeout adds the timeout to the add value stage params
func (*AddValueStageParams) WriteToRequest ¶
func (o *AddValueStageParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type AddValueStageReader ¶
type AddValueStageReader struct {
// contains filtered or unexported fields
}
AddValueStageReader is a Reader for the AddValueStage structure.
func (*AddValueStageReader) ReadResponse ¶
func (o *AddValueStageReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type AwaitStageResultOK ¶
type AwaitStageResultOK struct {
Payload *models.ModelAwaitStageResultResponse
}
AwaitStageResultOK handles this case with default header values.
AwaitStageResultOK await stage result o k
func NewAwaitStageResultOK ¶
func NewAwaitStageResultOK() *AwaitStageResultOK
NewAwaitStageResultOK creates a AwaitStageResultOK with default headers values
func (*AwaitStageResultOK) Error ¶
func (o *AwaitStageResultOK) Error() string
type AwaitStageResultParams ¶
type AwaitStageResultParams struct { /*FlowID*/ FlowID string /*StageID*/ StageID string /*TimeoutMs*/ TimeoutMs *int32 Context context.Context HTTPClient *http.Client // contains filtered or unexported fields }
AwaitStageResultParams contains all the parameters to send to the API endpoint for the await stage result operation typically these are written to a http.Request
func NewAwaitStageResultParams ¶
func NewAwaitStageResultParams() *AwaitStageResultParams
NewAwaitStageResultParams creates a new AwaitStageResultParams object with the default values initialized.
func NewAwaitStageResultParamsWithContext ¶
func NewAwaitStageResultParamsWithContext(ctx context.Context) *AwaitStageResultParams
NewAwaitStageResultParamsWithContext creates a new AwaitStageResultParams object with the default values initialized, and the ability to set a context for a request
func NewAwaitStageResultParamsWithHTTPClient ¶
func NewAwaitStageResultParamsWithHTTPClient(client *http.Client) *AwaitStageResultParams
NewAwaitStageResultParamsWithHTTPClient creates a new AwaitStageResultParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewAwaitStageResultParamsWithTimeout ¶
func NewAwaitStageResultParamsWithTimeout(timeout time.Duration) *AwaitStageResultParams
NewAwaitStageResultParamsWithTimeout creates a new AwaitStageResultParams object with the default values initialized, and the ability to set a timeout on a request
func (*AwaitStageResultParams) SetContext ¶
func (o *AwaitStageResultParams) SetContext(ctx context.Context)
SetContext adds the context to the await stage result params
func (*AwaitStageResultParams) SetFlowID ¶
func (o *AwaitStageResultParams) SetFlowID(flowID string)
SetFlowID adds the flowId to the await stage result params
func (*AwaitStageResultParams) SetHTTPClient ¶
func (o *AwaitStageResultParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the await stage result params
func (*AwaitStageResultParams) SetStageID ¶
func (o *AwaitStageResultParams) SetStageID(stageID string)
SetStageID adds the stageId to the await stage result params
func (*AwaitStageResultParams) SetTimeout ¶
func (o *AwaitStageResultParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the await stage result params
func (*AwaitStageResultParams) SetTimeoutMs ¶
func (o *AwaitStageResultParams) SetTimeoutMs(timeoutMs *int32)
SetTimeoutMs adds the timeoutMs to the await stage result params
func (*AwaitStageResultParams) WithContext ¶
func (o *AwaitStageResultParams) WithContext(ctx context.Context) *AwaitStageResultParams
WithContext adds the context to the await stage result params
func (*AwaitStageResultParams) WithFlowID ¶
func (o *AwaitStageResultParams) WithFlowID(flowID string) *AwaitStageResultParams
WithFlowID adds the flowID to the await stage result params
func (*AwaitStageResultParams) WithHTTPClient ¶
func (o *AwaitStageResultParams) WithHTTPClient(client *http.Client) *AwaitStageResultParams
WithHTTPClient adds the HTTPClient to the await stage result params
func (*AwaitStageResultParams) WithStageID ¶
func (o *AwaitStageResultParams) WithStageID(stageID string) *AwaitStageResultParams
WithStageID adds the stageID to the await stage result params
func (*AwaitStageResultParams) WithTimeout ¶
func (o *AwaitStageResultParams) WithTimeout(timeout time.Duration) *AwaitStageResultParams
WithTimeout adds the timeout to the await stage result params
func (*AwaitStageResultParams) WithTimeoutMs ¶
func (o *AwaitStageResultParams) WithTimeoutMs(timeoutMs *int32) *AwaitStageResultParams
WithTimeoutMs adds the timeoutMs to the await stage result params
func (*AwaitStageResultParams) WriteToRequest ¶
func (o *AwaitStageResultParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type AwaitStageResultReader ¶
type AwaitStageResultReader struct {
// contains filtered or unexported fields
}
AwaitStageResultReader is a Reader for the AwaitStageResult structure.
func (*AwaitStageResultReader) ReadResponse ¶
func (o *AwaitStageResultReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client for flow service API
func New ¶
func New(transport runtime.ClientTransport, formats strfmt.Registry) *Client
New creates a new flow service API client.
func (*Client) AddDelay ¶
func (a *Client) AddDelay(params *AddDelayParams) (*AddDelayOK, error)
AddDelay add delay API
func (*Client) AddInvokeFunction ¶
func (a *Client) AddInvokeFunction(params *AddInvokeFunctionParams) (*AddInvokeFunctionOK, error)
AddInvokeFunction add invoke function API
func (*Client) AddStage ¶
func (a *Client) AddStage(params *AddStageParams) (*AddStageOK, error)
AddStage add stage API
func (*Client) AddValueStage ¶
func (a *Client) AddValueStage(params *AddValueStageParams) (*AddValueStageOK, error)
AddValueStage add value stage API
func (*Client) AwaitStageResult ¶
func (a *Client) AwaitStageResult(params *AwaitStageResultParams) (*AwaitStageResultOK, error)
AwaitStageResult await stage result API
func (*Client) Commit ¶
func (a *Client) Commit(params *CommitParams) (*CommitOK, error)
Commit commit API
func (*Client) CompleteStageExternally ¶
func (a *Client) CompleteStageExternally(params *CompleteStageExternallyParams) (*CompleteStageExternallyOK, error)
CompleteStageExternally complete stage externally API
func (*Client) CreateGraph ¶
func (a *Client) CreateGraph(params *CreateGraphParams) (*CreateGraphOK, error)
CreateGraph create graph API
func (*Client) GetGraphState ¶
func (a *Client) GetGraphState(params *GetGraphStateParams) (*GetGraphStateOK, error)
GetGraphState get graph state API
func (*Client) SetTransport ¶
func (a *Client) SetTransport(transport runtime.ClientTransport)
SetTransport changes the transport on the client
func (*Client) StreamEvents ¶
func (a *Client) StreamEvents(params *StreamEventsParams) (*StreamEventsOK, error)
StreamEvents stream events API
func (*Client) StreamLifecycle ¶
func (a *Client) StreamLifecycle(params *StreamLifecycleParams) (*StreamLifecycleOK, error)
StreamLifecycle stream lifecycle API
type CommitOK ¶
type CommitOK struct {
Payload *models.ModelGraphRequestProcessedResponse
}
CommitOK handles this case with default header values.
CommitOK commit o k
func NewCommitOK ¶
func NewCommitOK() *CommitOK
NewCommitOK creates a CommitOK with default headers values
type CommitParams ¶
type CommitParams struct { /*FlowID*/ FlowID string Context context.Context HTTPClient *http.Client // contains filtered or unexported fields }
CommitParams contains all the parameters to send to the API endpoint for the commit operation typically these are written to a http.Request
func NewCommitParams ¶
func NewCommitParams() *CommitParams
NewCommitParams creates a new CommitParams object with the default values initialized.
func NewCommitParamsWithContext ¶
func NewCommitParamsWithContext(ctx context.Context) *CommitParams
NewCommitParamsWithContext creates a new CommitParams object with the default values initialized, and the ability to set a context for a request
func NewCommitParamsWithHTTPClient ¶
func NewCommitParamsWithHTTPClient(client *http.Client) *CommitParams
NewCommitParamsWithHTTPClient creates a new CommitParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewCommitParamsWithTimeout ¶
func NewCommitParamsWithTimeout(timeout time.Duration) *CommitParams
NewCommitParamsWithTimeout creates a new CommitParams object with the default values initialized, and the ability to set a timeout on a request
func (*CommitParams) SetContext ¶
func (o *CommitParams) SetContext(ctx context.Context)
SetContext adds the context to the commit params
func (*CommitParams) SetFlowID ¶
func (o *CommitParams) SetFlowID(flowID string)
SetFlowID adds the flowId to the commit params
func (*CommitParams) SetHTTPClient ¶
func (o *CommitParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the commit params
func (*CommitParams) SetTimeout ¶
func (o *CommitParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the commit params
func (*CommitParams) WithContext ¶
func (o *CommitParams) WithContext(ctx context.Context) *CommitParams
WithContext adds the context to the commit params
func (*CommitParams) WithFlowID ¶
func (o *CommitParams) WithFlowID(flowID string) *CommitParams
WithFlowID adds the flowID to the commit params
func (*CommitParams) WithHTTPClient ¶
func (o *CommitParams) WithHTTPClient(client *http.Client) *CommitParams
WithHTTPClient adds the HTTPClient to the commit params
func (*CommitParams) WithTimeout ¶
func (o *CommitParams) WithTimeout(timeout time.Duration) *CommitParams
WithTimeout adds the timeout to the commit params
func (*CommitParams) WriteToRequest ¶
func (o *CommitParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type CommitReader ¶
type CommitReader struct {
// contains filtered or unexported fields
}
CommitReader is a Reader for the Commit structure.
func (*CommitReader) ReadResponse ¶
func (o *CommitReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type CompleteStageExternallyOK ¶
type CompleteStageExternallyOK struct {
Payload *models.ModelCompleteStageExternallyResponse
}
CompleteStageExternallyOK handles this case with default header values.
CompleteStageExternallyOK complete stage externally o k
func NewCompleteStageExternallyOK ¶
func NewCompleteStageExternallyOK() *CompleteStageExternallyOK
NewCompleteStageExternallyOK creates a CompleteStageExternallyOK with default headers values
func (*CompleteStageExternallyOK) Error ¶
func (o *CompleteStageExternallyOK) Error() string
type CompleteStageExternallyParams ¶
type CompleteStageExternallyParams struct { /*Body*/ Body *models.ModelCompleteStageExternallyRequest /*FlowID*/ FlowID string /*StageID*/ StageID string Context context.Context HTTPClient *http.Client // contains filtered or unexported fields }
CompleteStageExternallyParams contains all the parameters to send to the API endpoint for the complete stage externally operation typically these are written to a http.Request
func NewCompleteStageExternallyParams ¶
func NewCompleteStageExternallyParams() *CompleteStageExternallyParams
NewCompleteStageExternallyParams creates a new CompleteStageExternallyParams object with the default values initialized.
func NewCompleteStageExternallyParamsWithContext ¶
func NewCompleteStageExternallyParamsWithContext(ctx context.Context) *CompleteStageExternallyParams
NewCompleteStageExternallyParamsWithContext creates a new CompleteStageExternallyParams object with the default values initialized, and the ability to set a context for a request
func NewCompleteStageExternallyParamsWithHTTPClient ¶
func NewCompleteStageExternallyParamsWithHTTPClient(client *http.Client) *CompleteStageExternallyParams
NewCompleteStageExternallyParamsWithHTTPClient creates a new CompleteStageExternallyParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewCompleteStageExternallyParamsWithTimeout ¶
func NewCompleteStageExternallyParamsWithTimeout(timeout time.Duration) *CompleteStageExternallyParams
NewCompleteStageExternallyParamsWithTimeout creates a new CompleteStageExternallyParams object with the default values initialized, and the ability to set a timeout on a request
func (*CompleteStageExternallyParams) SetBody ¶
func (o *CompleteStageExternallyParams) SetBody(body *models.ModelCompleteStageExternallyRequest)
SetBody adds the body to the complete stage externally params
func (*CompleteStageExternallyParams) SetContext ¶
func (o *CompleteStageExternallyParams) SetContext(ctx context.Context)
SetContext adds the context to the complete stage externally params
func (*CompleteStageExternallyParams) SetFlowID ¶
func (o *CompleteStageExternallyParams) SetFlowID(flowID string)
SetFlowID adds the flowId to the complete stage externally params
func (*CompleteStageExternallyParams) SetHTTPClient ¶
func (o *CompleteStageExternallyParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the complete stage externally params
func (*CompleteStageExternallyParams) SetStageID ¶
func (o *CompleteStageExternallyParams) SetStageID(stageID string)
SetStageID adds the stageId to the complete stage externally params
func (*CompleteStageExternallyParams) SetTimeout ¶
func (o *CompleteStageExternallyParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the complete stage externally params
func (*CompleteStageExternallyParams) WithBody ¶
func (o *CompleteStageExternallyParams) WithBody(body *models.ModelCompleteStageExternallyRequest) *CompleteStageExternallyParams
WithBody adds the body to the complete stage externally params
func (*CompleteStageExternallyParams) WithContext ¶
func (o *CompleteStageExternallyParams) WithContext(ctx context.Context) *CompleteStageExternallyParams
WithContext adds the context to the complete stage externally params
func (*CompleteStageExternallyParams) WithFlowID ¶
func (o *CompleteStageExternallyParams) WithFlowID(flowID string) *CompleteStageExternallyParams
WithFlowID adds the flowID to the complete stage externally params
func (*CompleteStageExternallyParams) WithHTTPClient ¶
func (o *CompleteStageExternallyParams) WithHTTPClient(client *http.Client) *CompleteStageExternallyParams
WithHTTPClient adds the HTTPClient to the complete stage externally params
func (*CompleteStageExternallyParams) WithStageID ¶
func (o *CompleteStageExternallyParams) WithStageID(stageID string) *CompleteStageExternallyParams
WithStageID adds the stageID to the complete stage externally params
func (*CompleteStageExternallyParams) WithTimeout ¶
func (o *CompleteStageExternallyParams) WithTimeout(timeout time.Duration) *CompleteStageExternallyParams
WithTimeout adds the timeout to the complete stage externally params
func (*CompleteStageExternallyParams) WriteToRequest ¶
func (o *CompleteStageExternallyParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type CompleteStageExternallyReader ¶
type CompleteStageExternallyReader struct {
// contains filtered or unexported fields
}
CompleteStageExternallyReader is a Reader for the CompleteStageExternally structure.
func (*CompleteStageExternallyReader) ReadResponse ¶
func (o *CompleteStageExternallyReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type CreateGraphOK ¶
type CreateGraphOK struct {
Payload *models.ModelCreateGraphResponse
}
CreateGraphOK handles this case with default header values.
CreateGraphOK create graph o k
func NewCreateGraphOK ¶
func NewCreateGraphOK() *CreateGraphOK
NewCreateGraphOK creates a CreateGraphOK with default headers values
func (*CreateGraphOK) Error ¶
func (o *CreateGraphOK) Error() string
type CreateGraphParams ¶
type CreateGraphParams struct { /*Body*/ Body *models.ModelCreateGraphRequest Context context.Context HTTPClient *http.Client // contains filtered or unexported fields }
CreateGraphParams contains all the parameters to send to the API endpoint for the create graph operation typically these are written to a http.Request
func NewCreateGraphParams ¶
func NewCreateGraphParams() *CreateGraphParams
NewCreateGraphParams creates a new CreateGraphParams object with the default values initialized.
func NewCreateGraphParamsWithContext ¶
func NewCreateGraphParamsWithContext(ctx context.Context) *CreateGraphParams
NewCreateGraphParamsWithContext creates a new CreateGraphParams object with the default values initialized, and the ability to set a context for a request
func NewCreateGraphParamsWithHTTPClient ¶
func NewCreateGraphParamsWithHTTPClient(client *http.Client) *CreateGraphParams
NewCreateGraphParamsWithHTTPClient creates a new CreateGraphParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewCreateGraphParamsWithTimeout ¶
func NewCreateGraphParamsWithTimeout(timeout time.Duration) *CreateGraphParams
NewCreateGraphParamsWithTimeout creates a new CreateGraphParams object with the default values initialized, and the ability to set a timeout on a request
func (*CreateGraphParams) SetBody ¶
func (o *CreateGraphParams) SetBody(body *models.ModelCreateGraphRequest)
SetBody adds the body to the create graph params
func (*CreateGraphParams) SetContext ¶
func (o *CreateGraphParams) SetContext(ctx context.Context)
SetContext adds the context to the create graph params
func (*CreateGraphParams) SetHTTPClient ¶
func (o *CreateGraphParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the create graph params
func (*CreateGraphParams) SetTimeout ¶
func (o *CreateGraphParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the create graph params
func (*CreateGraphParams) WithBody ¶
func (o *CreateGraphParams) WithBody(body *models.ModelCreateGraphRequest) *CreateGraphParams
WithBody adds the body to the create graph params
func (*CreateGraphParams) WithContext ¶
func (o *CreateGraphParams) WithContext(ctx context.Context) *CreateGraphParams
WithContext adds the context to the create graph params
func (*CreateGraphParams) WithHTTPClient ¶
func (o *CreateGraphParams) WithHTTPClient(client *http.Client) *CreateGraphParams
WithHTTPClient adds the HTTPClient to the create graph params
func (*CreateGraphParams) WithTimeout ¶
func (o *CreateGraphParams) WithTimeout(timeout time.Duration) *CreateGraphParams
WithTimeout adds the timeout to the create graph params
func (*CreateGraphParams) WriteToRequest ¶
func (o *CreateGraphParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type CreateGraphReader ¶
type CreateGraphReader struct {
// contains filtered or unexported fields
}
CreateGraphReader is a Reader for the CreateGraph structure.
func (*CreateGraphReader) ReadResponse ¶
func (o *CreateGraphReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type GetGraphStateOK ¶
type GetGraphStateOK struct {
Payload *models.ModelGetGraphStateResponse
}
GetGraphStateOK handles this case with default header values.
GetGraphStateOK get graph state o k
func NewGetGraphStateOK ¶
func NewGetGraphStateOK() *GetGraphStateOK
NewGetGraphStateOK creates a GetGraphStateOK with default headers values
func (*GetGraphStateOK) Error ¶
func (o *GetGraphStateOK) Error() string
type GetGraphStateParams ¶
type GetGraphStateParams struct { /*FlowID*/ FlowID string Context context.Context HTTPClient *http.Client // contains filtered or unexported fields }
GetGraphStateParams contains all the parameters to send to the API endpoint for the get graph state operation typically these are written to a http.Request
func NewGetGraphStateParams ¶
func NewGetGraphStateParams() *GetGraphStateParams
NewGetGraphStateParams creates a new GetGraphStateParams object with the default values initialized.
func NewGetGraphStateParamsWithContext ¶
func NewGetGraphStateParamsWithContext(ctx context.Context) *GetGraphStateParams
NewGetGraphStateParamsWithContext creates a new GetGraphStateParams object with the default values initialized, and the ability to set a context for a request
func NewGetGraphStateParamsWithHTTPClient ¶
func NewGetGraphStateParamsWithHTTPClient(client *http.Client) *GetGraphStateParams
NewGetGraphStateParamsWithHTTPClient creates a new GetGraphStateParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewGetGraphStateParamsWithTimeout ¶
func NewGetGraphStateParamsWithTimeout(timeout time.Duration) *GetGraphStateParams
NewGetGraphStateParamsWithTimeout creates a new GetGraphStateParams object with the default values initialized, and the ability to set a timeout on a request
func (*GetGraphStateParams) SetContext ¶
func (o *GetGraphStateParams) SetContext(ctx context.Context)
SetContext adds the context to the get graph state params
func (*GetGraphStateParams) SetFlowID ¶
func (o *GetGraphStateParams) SetFlowID(flowID string)
SetFlowID adds the flowId to the get graph state params
func (*GetGraphStateParams) SetHTTPClient ¶
func (o *GetGraphStateParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the get graph state params
func (*GetGraphStateParams) SetTimeout ¶
func (o *GetGraphStateParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the get graph state params
func (*GetGraphStateParams) WithContext ¶
func (o *GetGraphStateParams) WithContext(ctx context.Context) *GetGraphStateParams
WithContext adds the context to the get graph state params
func (*GetGraphStateParams) WithFlowID ¶
func (o *GetGraphStateParams) WithFlowID(flowID string) *GetGraphStateParams
WithFlowID adds the flowID to the get graph state params
func (*GetGraphStateParams) WithHTTPClient ¶
func (o *GetGraphStateParams) WithHTTPClient(client *http.Client) *GetGraphStateParams
WithHTTPClient adds the HTTPClient to the get graph state params
func (*GetGraphStateParams) WithTimeout ¶
func (o *GetGraphStateParams) WithTimeout(timeout time.Duration) *GetGraphStateParams
WithTimeout adds the timeout to the get graph state params
func (*GetGraphStateParams) WriteToRequest ¶
func (o *GetGraphStateParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type GetGraphStateReader ¶
type GetGraphStateReader struct {
// contains filtered or unexported fields
}
GetGraphStateReader is a Reader for the GetGraphState structure.
func (*GetGraphStateReader) ReadResponse ¶
func (o *GetGraphStateReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type StreamEventsOK ¶
type StreamEventsOK struct {
Payload *models.ModelGraphEvent
}
StreamEventsOK handles this case with default header values.
(streaming responses)
func NewStreamEventsOK ¶
func NewStreamEventsOK() *StreamEventsOK
NewStreamEventsOK creates a StreamEventsOK with default headers values
func (*StreamEventsOK) Error ¶
func (o *StreamEventsOK) Error() string
type StreamEventsParams ¶
type StreamEventsParams struct { /*FlowID*/ FlowID string /*FromSeq*/ FromSeq *uint64 Context context.Context HTTPClient *http.Client // contains filtered or unexported fields }
StreamEventsParams contains all the parameters to send to the API endpoint for the stream events operation typically these are written to a http.Request
func NewStreamEventsParams ¶
func NewStreamEventsParams() *StreamEventsParams
NewStreamEventsParams creates a new StreamEventsParams object with the default values initialized.
func NewStreamEventsParamsWithContext ¶
func NewStreamEventsParamsWithContext(ctx context.Context) *StreamEventsParams
NewStreamEventsParamsWithContext creates a new StreamEventsParams object with the default values initialized, and the ability to set a context for a request
func NewStreamEventsParamsWithHTTPClient ¶
func NewStreamEventsParamsWithHTTPClient(client *http.Client) *StreamEventsParams
NewStreamEventsParamsWithHTTPClient creates a new StreamEventsParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewStreamEventsParamsWithTimeout ¶
func NewStreamEventsParamsWithTimeout(timeout time.Duration) *StreamEventsParams
NewStreamEventsParamsWithTimeout creates a new StreamEventsParams object with the default values initialized, and the ability to set a timeout on a request
func (*StreamEventsParams) SetContext ¶
func (o *StreamEventsParams) SetContext(ctx context.Context)
SetContext adds the context to the stream events params
func (*StreamEventsParams) SetFlowID ¶
func (o *StreamEventsParams) SetFlowID(flowID string)
SetFlowID adds the flowId to the stream events params
func (*StreamEventsParams) SetFromSeq ¶
func (o *StreamEventsParams) SetFromSeq(fromSeq *uint64)
SetFromSeq adds the fromSeq to the stream events params
func (*StreamEventsParams) SetHTTPClient ¶
func (o *StreamEventsParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the stream events params
func (*StreamEventsParams) SetTimeout ¶
func (o *StreamEventsParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the stream events params
func (*StreamEventsParams) WithContext ¶
func (o *StreamEventsParams) WithContext(ctx context.Context) *StreamEventsParams
WithContext adds the context to the stream events params
func (*StreamEventsParams) WithFlowID ¶
func (o *StreamEventsParams) WithFlowID(flowID string) *StreamEventsParams
WithFlowID adds the flowID to the stream events params
func (*StreamEventsParams) WithFromSeq ¶
func (o *StreamEventsParams) WithFromSeq(fromSeq *uint64) *StreamEventsParams
WithFromSeq adds the fromSeq to the stream events params
func (*StreamEventsParams) WithHTTPClient ¶
func (o *StreamEventsParams) WithHTTPClient(client *http.Client) *StreamEventsParams
WithHTTPClient adds the HTTPClient to the stream events params
func (*StreamEventsParams) WithTimeout ¶
func (o *StreamEventsParams) WithTimeout(timeout time.Duration) *StreamEventsParams
WithTimeout adds the timeout to the stream events params
func (*StreamEventsParams) WriteToRequest ¶
func (o *StreamEventsParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type StreamEventsReader ¶
type StreamEventsReader struct {
// contains filtered or unexported fields
}
StreamEventsReader is a Reader for the StreamEvents structure.
func (*StreamEventsReader) ReadResponse ¶
func (o *StreamEventsReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type StreamLifecycleOK ¶
type StreamLifecycleOK struct {
Payload *models.ModelGraphLifecycleEvent
}
StreamLifecycleOK handles this case with default header values.
(streaming responses)
func NewStreamLifecycleOK ¶
func NewStreamLifecycleOK() *StreamLifecycleOK
NewStreamLifecycleOK creates a StreamLifecycleOK with default headers values
func (*StreamLifecycleOK) Error ¶
func (o *StreamLifecycleOK) Error() string
type StreamLifecycleParams ¶
type StreamLifecycleParams struct { Context context.Context HTTPClient *http.Client // contains filtered or unexported fields }
StreamLifecycleParams contains all the parameters to send to the API endpoint for the stream lifecycle operation typically these are written to a http.Request
func NewStreamLifecycleParams ¶
func NewStreamLifecycleParams() *StreamLifecycleParams
NewStreamLifecycleParams creates a new StreamLifecycleParams object with the default values initialized.
func NewStreamLifecycleParamsWithContext ¶
func NewStreamLifecycleParamsWithContext(ctx context.Context) *StreamLifecycleParams
NewStreamLifecycleParamsWithContext creates a new StreamLifecycleParams object with the default values initialized, and the ability to set a context for a request
func NewStreamLifecycleParamsWithHTTPClient ¶
func NewStreamLifecycleParamsWithHTTPClient(client *http.Client) *StreamLifecycleParams
NewStreamLifecycleParamsWithHTTPClient creates a new StreamLifecycleParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewStreamLifecycleParamsWithTimeout ¶
func NewStreamLifecycleParamsWithTimeout(timeout time.Duration) *StreamLifecycleParams
NewStreamLifecycleParamsWithTimeout creates a new StreamLifecycleParams object with the default values initialized, and the ability to set a timeout on a request
func (*StreamLifecycleParams) SetContext ¶
func (o *StreamLifecycleParams) SetContext(ctx context.Context)
SetContext adds the context to the stream lifecycle params
func (*StreamLifecycleParams) SetHTTPClient ¶
func (o *StreamLifecycleParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the stream lifecycle params
func (*StreamLifecycleParams) SetTimeout ¶
func (o *StreamLifecycleParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the stream lifecycle params
func (*StreamLifecycleParams) WithContext ¶
func (o *StreamLifecycleParams) WithContext(ctx context.Context) *StreamLifecycleParams
WithContext adds the context to the stream lifecycle params
func (*StreamLifecycleParams) WithHTTPClient ¶
func (o *StreamLifecycleParams) WithHTTPClient(client *http.Client) *StreamLifecycleParams
WithHTTPClient adds the HTTPClient to the stream lifecycle params
func (*StreamLifecycleParams) WithTimeout ¶
func (o *StreamLifecycleParams) WithTimeout(timeout time.Duration) *StreamLifecycleParams
WithTimeout adds the timeout to the stream lifecycle params
func (*StreamLifecycleParams) WriteToRequest ¶
func (o *StreamLifecycleParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type StreamLifecycleReader ¶
type StreamLifecycleReader struct {
// contains filtered or unexported fields
}
StreamLifecycleReader is a Reader for the StreamLifecycle structure.
func (*StreamLifecycleReader) ReadResponse ¶
func (o *StreamLifecycleReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
Source Files ¶
- add_delay_parameters.go
- add_delay_responses.go
- add_invoke_function_parameters.go
- add_invoke_function_responses.go
- add_stage_parameters.go
- add_stage_responses.go
- add_value_stage_parameters.go
- add_value_stage_responses.go
- await_stage_result_parameters.go
- await_stage_result_responses.go
- commit_parameters.go
- commit_responses.go
- complete_stage_externally_parameters.go
- complete_stage_externally_responses.go
- create_graph_parameters.go
- create_graph_responses.go
- flow_service_client.go
- get_graph_state_parameters.go
- get_graph_state_responses.go
- stream_events_parameters.go
- stream_events_responses.go
- stream_lifecycle_parameters.go
- stream_lifecycle_responses.go