operations

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Mar 15, 2017 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client struct {
	// contains filtered or unexported fields
}

Client for operations API

func New 

func New(transport runtime.ClientTransport, formats strfmt.Registry) *Client

New creates a new operations API client.

func (*Client) GetInstance 

func (a *Client) GetInstance(params *GetInstanceParams) (*GetInstanceOK, error)

GetInstance Get instance using cluster name and instance ARN

func (*Client) GetTask 

func (a *Client) GetTask(params *GetTaskParams) (*GetTaskOK, error)

GetTask Get task using cluster name and task ARN

func (*Client) ListInstances 

func (a *Client) ListInstances(params *ListInstancesParams) (*ListInstancesOK, error)

ListInstances Lists all instances, after applying filters if any

func (*Client) ListTasks 

func (a *Client) ListTasks(params *ListTasksParams) (*ListTasksOK, error)

ListTasks Lists all tasks, after applying filters if any

func (*Client) SetTransport 

func (a *Client) SetTransport(transport runtime.ClientTransport)

SetTransport changes the transport on the client

func (*Client) StreamInstances 

func (a *Client) StreamInstances(params *StreamInstancesParams, writer io.Writer) (*StreamInstancesOK, error)

StreamInstances Streams all instances

func (*Client) StreamTasks 

func (a *Client) StreamTasks(params *StreamTasksParams, writer io.Writer) (*StreamTasksOK, error)

StreamTasks Streams all tasks

type GetInstanceInternalServerError 

type GetInstanceInternalServerError struct {
	Payload string
}

GetInstanceInternalServerError handles this case with default header values.

Get instance using cluster name and instance ARN - unexpected error

func NewGetInstanceInternalServerError 

func NewGetInstanceInternalServerError() *GetInstanceInternalServerError

NewGetInstanceInternalServerError creates a GetInstanceInternalServerError with default headers values

func (*GetInstanceInternalServerError) Error 

func (o *GetInstanceInternalServerError) Error() string

type GetInstanceNotFound 

type GetInstanceNotFound struct {
	Payload string
}

GetInstanceNotFound handles this case with default header values.

Get instance using cluster name and instance ARN - instance not found

func NewGetInstanceNotFound 

func NewGetInstanceNotFound() *GetInstanceNotFound

NewGetInstanceNotFound creates a GetInstanceNotFound with default headers values

func (*GetInstanceNotFound) Error 

func (o *GetInstanceNotFound) Error() string

type GetInstanceOK 

type GetInstanceOK struct {
	Payload *models.ContainerInstance
}

GetInstanceOK handles this case with default header values.

Get instance using cluster name and instance ARN - success

func NewGetInstanceOK 

func NewGetInstanceOK() *GetInstanceOK

NewGetInstanceOK creates a GetInstanceOK with default headers values

func (*GetInstanceOK) Error 

func (o *GetInstanceOK) Error() string

type GetInstanceParams 

type GetInstanceParams struct {

	/*Arn
	  ARN of the instance to fetch

	*/
	Arn string
	/*Cluster
	  Cluster name of the instance to fetch

	*/
	Cluster string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetInstanceParams contains all the parameters to send to the API endpoint for the get instance operation typically these are written to a http.Request

func NewGetInstanceParams 

func NewGetInstanceParams() *GetInstanceParams

NewGetInstanceParams creates a new GetInstanceParams object with the default values initialized.

func NewGetInstanceParamsWithContext 

func NewGetInstanceParamsWithContext(ctx context.Context) *GetInstanceParams

NewGetInstanceParamsWithContext creates a new GetInstanceParams object with the default values initialized, and the ability to set a context for a request

func NewGetInstanceParamsWithHTTPClient 

func NewGetInstanceParamsWithHTTPClient(client *http.Client) *GetInstanceParams

NewGetInstanceParamsWithHTTPClient creates a new GetInstanceParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetInstanceParamsWithTimeout 

func NewGetInstanceParamsWithTimeout(timeout time.Duration) *GetInstanceParams

NewGetInstanceParamsWithTimeout creates a new GetInstanceParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetInstanceParams) SetArn 

func (o *GetInstanceParams) SetArn(arn string)

SetArn adds the arn to the get instance params

func (*GetInstanceParams) SetCluster 

func (o *GetInstanceParams) SetCluster(cluster string)

SetCluster adds the cluster to the get instance params

func (*GetInstanceParams) SetContext 

func (o *GetInstanceParams) SetContext(ctx context.Context)

SetContext adds the context to the get instance params

func (*GetInstanceParams) SetHTTPClient 

func (o *GetInstanceParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get instance params

func (*GetInstanceParams) SetTimeout 

func (o *GetInstanceParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get instance params

func (*GetInstanceParams) WithArn 

func (o *GetInstanceParams) WithArn(arn string) *GetInstanceParams

WithArn adds the arn to the get instance params

func (*GetInstanceParams) WithCluster 

func (o *GetInstanceParams) WithCluster(cluster string) *GetInstanceParams

WithCluster adds the cluster to the get instance params

func (*GetInstanceParams) WithContext 

func (o *GetInstanceParams) WithContext(ctx context.Context) *GetInstanceParams

WithContext adds the context to the get instance params

func (*GetInstanceParams) WithHTTPClient 

func (o *GetInstanceParams) WithHTTPClient(client *http.Client) *GetInstanceParams

WithHTTPClient adds the HTTPClient to the get instance params

func (*GetInstanceParams) WithTimeout 

func (o *GetInstanceParams) WithTimeout(timeout time.Duration) *GetInstanceParams

WithTimeout adds the timeout to the get instance params

func (*GetInstanceParams) WriteToRequest 

func (o *GetInstanceParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetInstanceReader 

type GetInstanceReader struct {
	// contains filtered or unexported fields
}

GetInstanceReader is a Reader for the GetInstance structure.

func (*GetInstanceReader) ReadResponse 

func (o *GetInstanceReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetTaskInternalServerError 

type GetTaskInternalServerError struct {
	Payload string
}

GetTaskInternalServerError handles this case with default header values.

Get task using cluster name and task ARN - unexpected error

func NewGetTaskInternalServerError 

func NewGetTaskInternalServerError() *GetTaskInternalServerError

NewGetTaskInternalServerError creates a GetTaskInternalServerError with default headers values

func (*GetTaskInternalServerError) Error 

func (o *GetTaskInternalServerError) Error() string

type GetTaskNotFound 

type GetTaskNotFound struct {
	Payload string
}

GetTaskNotFound handles this case with default header values.

Get task using cluster name and task ARN - task not found

func NewGetTaskNotFound 

func NewGetTaskNotFound() *GetTaskNotFound

NewGetTaskNotFound creates a GetTaskNotFound with default headers values

func (*GetTaskNotFound) Error 

func (o *GetTaskNotFound) Error() string

type GetTaskOK 

type GetTaskOK struct {
	Payload *models.Task
}

GetTaskOK handles this case with default header values.

Get task using cluster name and task ARN - success

func NewGetTaskOK 

func NewGetTaskOK() *GetTaskOK

NewGetTaskOK creates a GetTaskOK with default headers values

func (*GetTaskOK) Error 

func (o *GetTaskOK) Error() string

type GetTaskParams 

type GetTaskParams struct {

	/*Arn
	  ARN of the task to fetch

	*/
	Arn string
	/*Cluster
	  Cluster name of the task to fetch

	*/
	Cluster string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetTaskParams contains all the parameters to send to the API endpoint for the get task operation typically these are written to a http.Request

func NewGetTaskParams 

func NewGetTaskParams() *GetTaskParams

NewGetTaskParams creates a new GetTaskParams object with the default values initialized.

func NewGetTaskParamsWithContext 

func NewGetTaskParamsWithContext(ctx context.Context) *GetTaskParams

NewGetTaskParamsWithContext creates a new GetTaskParams object with the default values initialized, and the ability to set a context for a request

func NewGetTaskParamsWithHTTPClient 

func NewGetTaskParamsWithHTTPClient(client *http.Client) *GetTaskParams

NewGetTaskParamsWithHTTPClient creates a new GetTaskParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetTaskParamsWithTimeout 

func NewGetTaskParamsWithTimeout(timeout time.Duration) *GetTaskParams

NewGetTaskParamsWithTimeout creates a new GetTaskParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetTaskParams) SetArn 

func (o *GetTaskParams) SetArn(arn string)

SetArn adds the arn to the get task params

func (*GetTaskParams) SetCluster 

func (o *GetTaskParams) SetCluster(cluster string)

SetCluster adds the cluster to the get task params

func (*GetTaskParams) SetContext 

func (o *GetTaskParams) SetContext(ctx context.Context)

SetContext adds the context to the get task params

func (*GetTaskParams) SetHTTPClient 

func (o *GetTaskParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get task params

func (*GetTaskParams) SetTimeout 

func (o *GetTaskParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get task params

func (*GetTaskParams) WithArn 

func (o *GetTaskParams) WithArn(arn string) *GetTaskParams

WithArn adds the arn to the get task params

func (*GetTaskParams) WithCluster 

func (o *GetTaskParams) WithCluster(cluster string) *GetTaskParams

WithCluster adds the cluster to the get task params

func (*GetTaskParams) WithContext 

func (o *GetTaskParams) WithContext(ctx context.Context) *GetTaskParams

WithContext adds the context to the get task params

func (*GetTaskParams) WithHTTPClient 

func (o *GetTaskParams) WithHTTPClient(client *http.Client) *GetTaskParams

WithHTTPClient adds the HTTPClient to the get task params

func (*GetTaskParams) WithTimeout 

func (o *GetTaskParams) WithTimeout(timeout time.Duration) *GetTaskParams

WithTimeout adds the timeout to the get task params

func (*GetTaskParams) WriteToRequest 

func (o *GetTaskParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetTaskReader 

type GetTaskReader struct {
	// contains filtered or unexported fields
}

GetTaskReader is a Reader for the GetTask structure.

func (*GetTaskReader) ReadResponse 

func (o *GetTaskReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type ListInstancesBadRequest 

type ListInstancesBadRequest struct {
	Payload string
}

ListInstancesBadRequest handles this case with default header values.

List instances - bad input

func NewListInstancesBadRequest 

func NewListInstancesBadRequest() *ListInstancesBadRequest

NewListInstancesBadRequest creates a ListInstancesBadRequest with default headers values

func (*ListInstancesBadRequest) Error 

func (o *ListInstancesBadRequest) Error() string

type ListInstancesInternalServerError 

type ListInstancesInternalServerError struct {
	Payload string
}

ListInstancesInternalServerError handles this case with default header values.

List instances - unexpected error

func NewListInstancesInternalServerError 

func NewListInstancesInternalServerError() *ListInstancesInternalServerError

NewListInstancesInternalServerError creates a ListInstancesInternalServerError with default headers values

func (*ListInstancesInternalServerError) Error 

func (o *ListInstancesInternalServerError) Error() string

type ListInstancesOK 

type ListInstancesOK struct {
	Payload *models.ContainerInstances
}

ListInstancesOK handles this case with default header values.

List instances - success

func NewListInstancesOK 

func NewListInstancesOK() *ListInstancesOK

NewListInstancesOK creates a ListInstancesOK with default headers values

func (*ListInstancesOK) Error 

func (o *ListInstancesOK) Error() string

type ListInstancesParams 

type ListInstancesParams struct {

	/*Cluster
	  Cluster name or ARN to filter instances by

	*/
	Cluster *string
	/*Status
	  Status to filter instances by

	*/
	Status *string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

ListInstancesParams contains all the parameters to send to the API endpoint for the list instances operation typically these are written to a http.Request

func NewListInstancesParams 

func NewListInstancesParams() *ListInstancesParams

NewListInstancesParams creates a new ListInstancesParams object with the default values initialized.

func NewListInstancesParamsWithContext 

func NewListInstancesParamsWithContext(ctx context.Context) *ListInstancesParams

NewListInstancesParamsWithContext creates a new ListInstancesParams object with the default values initialized, and the ability to set a context for a request

func NewListInstancesParamsWithHTTPClient 

func NewListInstancesParamsWithHTTPClient(client *http.Client) *ListInstancesParams

NewListInstancesParamsWithHTTPClient creates a new ListInstancesParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewListInstancesParamsWithTimeout 

func NewListInstancesParamsWithTimeout(timeout time.Duration) *ListInstancesParams

NewListInstancesParamsWithTimeout creates a new ListInstancesParams object with the default values initialized, and the ability to set a timeout on a request

func (*ListInstancesParams) SetCluster 

func (o *ListInstancesParams) SetCluster(cluster *string)

SetCluster adds the cluster to the list instances params

func (*ListInstancesParams) SetContext 

func (o *ListInstancesParams) SetContext(ctx context.Context)

SetContext adds the context to the list instances params

func (*ListInstancesParams) SetHTTPClient 

func (o *ListInstancesParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the list instances params

func (*ListInstancesParams) SetStatus 

func (o *ListInstancesParams) SetStatus(status *string)

SetStatus adds the status to the list instances params

func (*ListInstancesParams) SetTimeout 

func (o *ListInstancesParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the list instances params

func (*ListInstancesParams) WithCluster 

func (o *ListInstancesParams) WithCluster(cluster *string) *ListInstancesParams

WithCluster adds the cluster to the list instances params

func (*ListInstancesParams) WithContext 

func (o *ListInstancesParams) WithContext(ctx context.Context) *ListInstancesParams

WithContext adds the context to the list instances params

func (*ListInstancesParams) WithHTTPClient 

func (o *ListInstancesParams) WithHTTPClient(client *http.Client) *ListInstancesParams

WithHTTPClient adds the HTTPClient to the list instances params

func (*ListInstancesParams) WithStatus 

func (o *ListInstancesParams) WithStatus(status *string) *ListInstancesParams

WithStatus adds the status to the list instances params

func (*ListInstancesParams) WithTimeout 

func (o *ListInstancesParams) WithTimeout(timeout time.Duration) *ListInstancesParams

WithTimeout adds the timeout to the list instances params

func (*ListInstancesParams) WriteToRequest 

func (o *ListInstancesParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type ListInstancesReader 

type ListInstancesReader struct {
	// contains filtered or unexported fields
}

ListInstancesReader is a Reader for the ListInstances structure.

func (*ListInstancesReader) ReadResponse 

func (o *ListInstancesReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type ListTasksBadRequest 

type ListTasksBadRequest struct {
	Payload string
}

ListTasksBadRequest handles this case with default header values.

List tasks - bad input

func NewListTasksBadRequest 

func NewListTasksBadRequest() *ListTasksBadRequest

NewListTasksBadRequest creates a ListTasksBadRequest with default headers values

func (*ListTasksBadRequest) Error 

func (o *ListTasksBadRequest) Error() string

type ListTasksInternalServerError 

type ListTasksInternalServerError struct {
	Payload string
}

ListTasksInternalServerError handles this case with default header values.

List tasks - unexpected error

func NewListTasksInternalServerError 

func NewListTasksInternalServerError() *ListTasksInternalServerError

NewListTasksInternalServerError creates a ListTasksInternalServerError with default headers values

func (*ListTasksInternalServerError) Error 

func (o *ListTasksInternalServerError) Error() string

type ListTasksOK 

type ListTasksOK struct {
	Payload *models.Tasks
}

ListTasksOK handles this case with default header values.

List tasks - success

func NewListTasksOK 

func NewListTasksOK() *ListTasksOK

NewListTasksOK creates a ListTasksOK with default headers values

func (*ListTasksOK) Error 

func (o *ListTasksOK) Error() string

type ListTasksParams 

type ListTasksParams struct {

	/*Cluster
	  Cluster name or ARN to filter tasks by

	*/
	Cluster *string
	/*StartedBy
	  StartedBy to filter tasks by

	*/
	StartedBy *string
	/*Status
	  Status to filter tasks by

	*/
	Status *string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

ListTasksParams contains all the parameters to send to the API endpoint for the list tasks operation typically these are written to a http.Request

func NewListTasksParams 

func NewListTasksParams() *ListTasksParams

NewListTasksParams creates a new ListTasksParams object with the default values initialized.

func NewListTasksParamsWithContext 

func NewListTasksParamsWithContext(ctx context.Context) *ListTasksParams

NewListTasksParamsWithContext creates a new ListTasksParams object with the default values initialized, and the ability to set a context for a request

func NewListTasksParamsWithHTTPClient 

func NewListTasksParamsWithHTTPClient(client *http.Client) *ListTasksParams

NewListTasksParamsWithHTTPClient creates a new ListTasksParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewListTasksParamsWithTimeout 

func NewListTasksParamsWithTimeout(timeout time.Duration) *ListTasksParams

NewListTasksParamsWithTimeout creates a new ListTasksParams object with the default values initialized, and the ability to set a timeout on a request

func (*ListTasksParams) SetCluster 

func (o *ListTasksParams) SetCluster(cluster *string)

SetCluster adds the cluster to the list tasks params

func (*ListTasksParams) SetContext 

func (o *ListTasksParams) SetContext(ctx context.Context)

SetContext adds the context to the list tasks params

func (*ListTasksParams) SetHTTPClient 

func (o *ListTasksParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the list tasks params

func (*ListTasksParams) SetStartedBy 

func (o *ListTasksParams) SetStartedBy(startedBy *string)

SetStartedBy adds the startedBy to the list tasks params

func (*ListTasksParams) SetStatus 

func (o *ListTasksParams) SetStatus(status *string)

SetStatus adds the status to the list tasks params

func (*ListTasksParams) SetTimeout 

func (o *ListTasksParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the list tasks params

func (*ListTasksParams) WithCluster 

func (o *ListTasksParams) WithCluster(cluster *string) *ListTasksParams

WithCluster adds the cluster to the list tasks params

func (*ListTasksParams) WithContext 

func (o *ListTasksParams) WithContext(ctx context.Context) *ListTasksParams

WithContext adds the context to the list tasks params

func (*ListTasksParams) WithHTTPClient 

func (o *ListTasksParams) WithHTTPClient(client *http.Client) *ListTasksParams

WithHTTPClient adds the HTTPClient to the list tasks params

func (*ListTasksParams) WithStartedBy 

func (o *ListTasksParams) WithStartedBy(startedBy *string) *ListTasksParams

WithStartedBy adds the startedBy to the list tasks params

func (*ListTasksParams) WithStatus 

func (o *ListTasksParams) WithStatus(status *string) *ListTasksParams

WithStatus adds the status to the list tasks params

func (*ListTasksParams) WithTimeout 

func (o *ListTasksParams) WithTimeout(timeout time.Duration) *ListTasksParams

WithTimeout adds the timeout to the list tasks params

func (*ListTasksParams) WriteToRequest 

func (o *ListTasksParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type ListTasksReader 

type ListTasksReader struct {
	// contains filtered or unexported fields
}

ListTasksReader is a Reader for the ListTasks structure.

func (*ListTasksReader) ReadResponse 

func (o *ListTasksReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type StreamInstancesInternalServerError 

type StreamInstancesInternalServerError struct {
	Payload string
}

StreamInstancesInternalServerError handles this case with default header values.

Stream instances - unexpected error

func NewStreamInstancesInternalServerError 

func NewStreamInstancesInternalServerError() *StreamInstancesInternalServerError

NewStreamInstancesInternalServerError creates a StreamInstancesInternalServerError with default headers values

func (*StreamInstancesInternalServerError) Error 

func (o *StreamInstancesInternalServerError) Error() string

type StreamInstancesOK 

type StreamInstancesOK struct {
	Payload io.Writer
}

StreamInstancesOK handles this case with default header values.

Stream instances - success

func NewStreamInstancesOK 

func NewStreamInstancesOK(writer io.Writer) *StreamInstancesOK

NewStreamInstancesOK creates a StreamInstancesOK with default headers values

func (*StreamInstancesOK) Error 

func (o *StreamInstancesOK) Error() string

type StreamInstancesParams 

type StreamInstancesParams struct {

	/*EntityVersion
	  Entity version to start streaming from

	*/
	EntityVersion *string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

StreamInstancesParams contains all the parameters to send to the API endpoint for the stream instances operation typically these are written to a http.Request

func NewStreamInstancesParams 

func NewStreamInstancesParams() *StreamInstancesParams

NewStreamInstancesParams creates a new StreamInstancesParams object with the default values initialized.

func NewStreamInstancesParamsWithContext 

func NewStreamInstancesParamsWithContext(ctx context.Context) *StreamInstancesParams

NewStreamInstancesParamsWithContext creates a new StreamInstancesParams object with the default values initialized, and the ability to set a context for a request

func NewStreamInstancesParamsWithHTTPClient 

func NewStreamInstancesParamsWithHTTPClient(client *http.Client) *StreamInstancesParams

NewStreamInstancesParamsWithHTTPClient creates a new StreamInstancesParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewStreamInstancesParamsWithTimeout 

func NewStreamInstancesParamsWithTimeout(timeout time.Duration) *StreamInstancesParams

NewStreamInstancesParamsWithTimeout creates a new StreamInstancesParams object with the default values initialized, and the ability to set a timeout on a request

func (*StreamInstancesParams) SetContext 

func (o *StreamInstancesParams) SetContext(ctx context.Context)

SetContext adds the context to the stream instances params

func (*StreamInstancesParams) SetEntityVersion 

func (o *StreamInstancesParams) SetEntityVersion(entityVersion *string)

SetEntityVersion adds the entityVersion to the stream instances params

func (*StreamInstancesParams) SetHTTPClient 

func (o *StreamInstancesParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the stream instances params

func (*StreamInstancesParams) SetTimeout 

func (o *StreamInstancesParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the stream instances params

func (*StreamInstancesParams) WithContext 

func (o *StreamInstancesParams) WithContext(ctx context.Context) *StreamInstancesParams

WithContext adds the context to the stream instances params

func (*StreamInstancesParams) WithEntityVersion 

func (o *StreamInstancesParams) WithEntityVersion(entityVersion *string) *StreamInstancesParams

WithEntityVersion adds the entityVersion to the stream instances params

func (*StreamInstancesParams) WithHTTPClient 

func (o *StreamInstancesParams) WithHTTPClient(client *http.Client) *StreamInstancesParams

WithHTTPClient adds the HTTPClient to the stream instances params

func (*StreamInstancesParams) WithTimeout 

func (o *StreamInstancesParams) WithTimeout(timeout time.Duration) *StreamInstancesParams

WithTimeout adds the timeout to the stream instances params

func (*StreamInstancesParams) WriteToRequest 

func (o *StreamInstancesParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type StreamInstancesReader 

type StreamInstancesReader struct {
	// contains filtered or unexported fields
}

StreamInstancesReader is a Reader for the StreamInstances structure.

func (*StreamInstancesReader) ReadResponse 

func (o *StreamInstancesReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type StreamTasksInternalServerError 

type StreamTasksInternalServerError struct {
	Payload string
}

StreamTasksInternalServerError handles this case with default header values.

Stream tasks - unexpected error

func NewStreamTasksInternalServerError 

func NewStreamTasksInternalServerError() *StreamTasksInternalServerError

NewStreamTasksInternalServerError creates a StreamTasksInternalServerError with default headers values

func (*StreamTasksInternalServerError) Error 

func (o *StreamTasksInternalServerError) Error() string

type StreamTasksOK 

type StreamTasksOK struct {
	Payload io.Writer
}

StreamTasksOK handles this case with default header values.

Stream tasks - success

func NewStreamTasksOK 

func NewStreamTasksOK(writer io.Writer) *StreamTasksOK

NewStreamTasksOK creates a StreamTasksOK with default headers values

func (*StreamTasksOK) Error 

func (o *StreamTasksOK) Error() string

type StreamTasksParams 

type StreamTasksParams struct {

	/*EntityVersion
	  Entity version to start streaming from

	*/
	EntityVersion *string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

StreamTasksParams contains all the parameters to send to the API endpoint for the stream tasks operation typically these are written to a http.Request

func NewStreamTasksParams 

func NewStreamTasksParams() *StreamTasksParams

NewStreamTasksParams creates a new StreamTasksParams object with the default values initialized.

func NewStreamTasksParamsWithContext 

func NewStreamTasksParamsWithContext(ctx context.Context) *StreamTasksParams

NewStreamTasksParamsWithContext creates a new StreamTasksParams object with the default values initialized, and the ability to set a context for a request

func NewStreamTasksParamsWithHTTPClient 

func NewStreamTasksParamsWithHTTPClient(client *http.Client) *StreamTasksParams

NewStreamTasksParamsWithHTTPClient creates a new StreamTasksParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewStreamTasksParamsWithTimeout 

func NewStreamTasksParamsWithTimeout(timeout time.Duration) *StreamTasksParams

NewStreamTasksParamsWithTimeout creates a new StreamTasksParams object with the default values initialized, and the ability to set a timeout on a request

func (*StreamTasksParams) SetContext 

func (o *StreamTasksParams) SetContext(ctx context.Context)

SetContext adds the context to the stream tasks params

func (*StreamTasksParams) SetEntityVersion 

func (o *StreamTasksParams) SetEntityVersion(entityVersion *string)

SetEntityVersion adds the entityVersion to the stream tasks params

func (*StreamTasksParams) SetHTTPClient 

func (o *StreamTasksParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the stream tasks params

func (*StreamTasksParams) SetTimeout 

func (o *StreamTasksParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the stream tasks params

func (*StreamTasksParams) WithContext 

func (o *StreamTasksParams) WithContext(ctx context.Context) *StreamTasksParams

WithContext adds the context to the stream tasks params

func (*StreamTasksParams) WithEntityVersion 

func (o *StreamTasksParams) WithEntityVersion(entityVersion *string) *StreamTasksParams

WithEntityVersion adds the entityVersion to the stream tasks params

func (*StreamTasksParams) WithHTTPClient 

func (o *StreamTasksParams) WithHTTPClient(client *http.Client) *StreamTasksParams

WithHTTPClient adds the HTTPClient to the stream tasks params

func (*StreamTasksParams) WithTimeout 

func (o *StreamTasksParams) WithTimeout(timeout time.Duration) *StreamTasksParams

WithTimeout adds the timeout to the stream tasks params

func (*StreamTasksParams) WriteToRequest 

func (o *StreamTasksParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type StreamTasksReader 

type StreamTasksReader struct {
	// contains filtered or unexported fields
}

StreamTasksReader is a Reader for the StreamTasks structure.

func (*StreamTasksReader) ReadResponse 

func (o *StreamTasksReader) 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.