flow_service

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: 11 Imported by: 0

Documentation

Index

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

func (*CommitOK) Error 

func (o *CommitOK) Error() string

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

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.