replication

package
v0.0.0-...-fde7ecd Latest Latest
Warning

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

 Go to latest Published: May 4, 2021 License: MIT Imports: 11 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 replication API

func (*Client) GetReplicationExecution 

func (a *Client) GetReplicationExecution(params *GetReplicationExecutionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetReplicationExecutionOK, error)

GetReplicationExecution gets the specific replication execution

Get the replication execution specified by ID

func (*Client) GetReplicationLog 

func (a *Client) GetReplicationLog(params *GetReplicationLogParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetReplicationLogOK, error)

GetReplicationLog gets the log of the specific replication task

Get the log of the specific replication task

func (*Client) ListReplicationExecutions 

func (a *Client) ListReplicationExecutions(params *ListReplicationExecutionsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ListReplicationExecutionsOK, error)

ListReplicationExecutions lists replication executions

List replication executions

func (*Client) ListReplicationTasks 

func (a *Client) ListReplicationTasks(params *ListReplicationTasksParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ListReplicationTasksOK, error)

ListReplicationTasks lists replication tasks for a specific execution

List replication tasks for a specific execution

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

func (*Client) StartReplication 

func (a *Client) StartReplication(params *StartReplicationParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*StartReplicationCreated, error)

StartReplication starts one replication execution

Start one replication execution according to the policy

func (*Client) StopReplication 

func (a *Client) StopReplication(params *StopReplicationParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*StopReplicationOK, error)

StopReplication stops the specific replication execution

Stop the replication execution specified by ID

type ClientOption 

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService 

type ClientService interface {
	GetReplicationExecution(params *GetReplicationExecutionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetReplicationExecutionOK, error)

	GetReplicationLog(params *GetReplicationLogParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetReplicationLogOK, error)

	ListReplicationExecutions(params *ListReplicationExecutionsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ListReplicationExecutionsOK, error)

	ListReplicationTasks(params *ListReplicationTasksParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ListReplicationTasksOK, error)

	StartReplication(params *StartReplicationParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*StartReplicationCreated, error)

	StopReplication(params *StopReplicationParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*StopReplicationOK, error)

	SetTransport(transport runtime.ClientTransport)
}

ClientService is the interface for Client methods

func New 

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

New creates a new replication API client.

type GetReplicationExecutionForbidden 

type GetReplicationExecutionForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
GetReplicationExecutionForbidden describes a response with status code 403, with default header values.

Forbidden

func NewGetReplicationExecutionForbidden 

func NewGetReplicationExecutionForbidden() *GetReplicationExecutionForbidden

NewGetReplicationExecutionForbidden creates a GetReplicationExecutionForbidden with default headers values

func (*GetReplicationExecutionForbidden) Error 

func (o *GetReplicationExecutionForbidden) Error() string

func (*GetReplicationExecutionForbidden) GetPayload 

func (o *GetReplicationExecutionForbidden) GetPayload() *models.Errors

type GetReplicationExecutionInternalServerError 

type GetReplicationExecutionInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
GetReplicationExecutionInternalServerError describes a response with status code 500, with default header values.

Internal server error

func NewGetReplicationExecutionInternalServerError 

func NewGetReplicationExecutionInternalServerError() *GetReplicationExecutionInternalServerError

NewGetReplicationExecutionInternalServerError creates a GetReplicationExecutionInternalServerError with default headers values

func (*GetReplicationExecutionInternalServerError) Error 

func (o *GetReplicationExecutionInternalServerError) Error() string

func (*GetReplicationExecutionInternalServerError) GetPayload 

func (o *GetReplicationExecutionInternalServerError) GetPayload() *models.Errors

type GetReplicationExecutionNotFound 

type GetReplicationExecutionNotFound struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
GetReplicationExecutionNotFound describes a response with status code 404, with default header values.

Not found

func NewGetReplicationExecutionNotFound 

func NewGetReplicationExecutionNotFound() *GetReplicationExecutionNotFound

NewGetReplicationExecutionNotFound creates a GetReplicationExecutionNotFound with default headers values

func (*GetReplicationExecutionNotFound) Error 

func (o *GetReplicationExecutionNotFound) Error() string

func (*GetReplicationExecutionNotFound) GetPayload 

func (o *GetReplicationExecutionNotFound) GetPayload() *models.Errors

type GetReplicationExecutionOK 

type GetReplicationExecutionOK struct {
	Payload *models.ReplicationExecution
}
GetReplicationExecutionOK describes a response with status code 200, with default header values.

Success

func NewGetReplicationExecutionOK 

func NewGetReplicationExecutionOK() *GetReplicationExecutionOK

NewGetReplicationExecutionOK creates a GetReplicationExecutionOK with default headers values

func (*GetReplicationExecutionOK) Error 

func (o *GetReplicationExecutionOK) Error() string

func (*GetReplicationExecutionOK) GetPayload 

func (o *GetReplicationExecutionOK) GetPayload() *models.ReplicationExecution

type GetReplicationExecutionParams 

type GetReplicationExecutionParams struct {

	/* ID.

	   The ID of the execution.

	   Format: int64
	*/
	ID int64

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

GetReplicationExecutionParams contains all the parameters to send to the API endpoint 

for the get replication execution operation.

Typically these are written to a http.Request.

func NewGetReplicationExecutionParams 

func NewGetReplicationExecutionParams() *GetReplicationExecutionParams

NewGetReplicationExecutionParams creates a new GetReplicationExecutionParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewGetReplicationExecutionParamsWithContext 

func NewGetReplicationExecutionParamsWithContext(ctx context.Context) *GetReplicationExecutionParams

NewGetReplicationExecutionParamsWithContext creates a new GetReplicationExecutionParams object with the ability to set a context for a request.

func NewGetReplicationExecutionParamsWithHTTPClient 

func NewGetReplicationExecutionParamsWithHTTPClient(client *http.Client) *GetReplicationExecutionParams

NewGetReplicationExecutionParamsWithHTTPClient creates a new GetReplicationExecutionParams object with the ability to set a custom HTTPClient for a request.

func NewGetReplicationExecutionParamsWithTimeout 

func NewGetReplicationExecutionParamsWithTimeout(timeout time.Duration) *GetReplicationExecutionParams

NewGetReplicationExecutionParamsWithTimeout creates a new GetReplicationExecutionParams object with the ability to set a timeout on a request.

func (*GetReplicationExecutionParams) SetContext 

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

SetContext adds the context to the get replication execution params

func (*GetReplicationExecutionParams) SetDefaults 

func (o *GetReplicationExecutionParams) SetDefaults()

SetDefaults hydrates default values in the get replication execution params (not the query body).

All values with no default are reset to their zero value.

func (*GetReplicationExecutionParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get replication execution params

func (*GetReplicationExecutionParams) SetID 

func (o *GetReplicationExecutionParams) SetID(id int64)

SetID adds the id to the get replication execution params

func (*GetReplicationExecutionParams) SetTimeout 

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

SetTimeout adds the timeout to the get replication execution params

func (*GetReplicationExecutionParams) WithContext 

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

WithContext adds the context to the get replication execution params

func (*GetReplicationExecutionParams) WithDefaults 

func (o *GetReplicationExecutionParams) WithDefaults() *GetReplicationExecutionParams

WithDefaults hydrates default values in the get replication execution params (not the query body).

All values with no default are reset to their zero value.

func (*GetReplicationExecutionParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get replication execution params

func (*GetReplicationExecutionParams) WithID 

func (o *GetReplicationExecutionParams) WithID(id int64) *GetReplicationExecutionParams

WithID adds the id to the get replication execution params

func (*GetReplicationExecutionParams) WithTimeout 

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

WithTimeout adds the timeout to the get replication execution params

func (*GetReplicationExecutionParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetReplicationExecutionReader 

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

GetReplicationExecutionReader is a Reader for the GetReplicationExecution structure.

func (*GetReplicationExecutionReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetReplicationExecutionUnauthorized 

type GetReplicationExecutionUnauthorized struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
GetReplicationExecutionUnauthorized describes a response with status code 401, with default header values.

Unauthorized

func NewGetReplicationExecutionUnauthorized 

func NewGetReplicationExecutionUnauthorized() *GetReplicationExecutionUnauthorized

NewGetReplicationExecutionUnauthorized creates a GetReplicationExecutionUnauthorized with default headers values

func (*GetReplicationExecutionUnauthorized) Error 

func (o *GetReplicationExecutionUnauthorized) Error() string

func (*GetReplicationExecutionUnauthorized) GetPayload 

func (o *GetReplicationExecutionUnauthorized) GetPayload() *models.Errors

type GetReplicationLogForbidden 

type GetReplicationLogForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
GetReplicationLogForbidden describes a response with status code 403, with default header values.

Forbidden

func NewGetReplicationLogForbidden 

func NewGetReplicationLogForbidden() *GetReplicationLogForbidden

NewGetReplicationLogForbidden creates a GetReplicationLogForbidden with default headers values

func (*GetReplicationLogForbidden) Error 

func (o *GetReplicationLogForbidden) Error() string

func (*GetReplicationLogForbidden) GetPayload 

func (o *GetReplicationLogForbidden) GetPayload() *models.Errors

type GetReplicationLogInternalServerError 

type GetReplicationLogInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
GetReplicationLogInternalServerError describes a response with status code 500, with default header values.

Internal server error

func NewGetReplicationLogInternalServerError 

func NewGetReplicationLogInternalServerError() *GetReplicationLogInternalServerError

NewGetReplicationLogInternalServerError creates a GetReplicationLogInternalServerError with default headers values

func (*GetReplicationLogInternalServerError) Error 

func (o *GetReplicationLogInternalServerError) Error() string

func (*GetReplicationLogInternalServerError) GetPayload 

func (o *GetReplicationLogInternalServerError) GetPayload() *models.Errors

type GetReplicationLogNotFound 

type GetReplicationLogNotFound struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
GetReplicationLogNotFound describes a response with status code 404, with default header values.

Not found

func NewGetReplicationLogNotFound 

func NewGetReplicationLogNotFound() *GetReplicationLogNotFound

NewGetReplicationLogNotFound creates a GetReplicationLogNotFound with default headers values

func (*GetReplicationLogNotFound) Error 

func (o *GetReplicationLogNotFound) Error() string

func (*GetReplicationLogNotFound) GetPayload 

func (o *GetReplicationLogNotFound) GetPayload() *models.Errors

type GetReplicationLogOK 

type GetReplicationLogOK struct {

	/* The content type of response body
	 */
	ContentType string

	Payload string
}
GetReplicationLogOK describes a response with status code 200, with default header values.

Success

func NewGetReplicationLogOK 

func NewGetReplicationLogOK() *GetReplicationLogOK

NewGetReplicationLogOK creates a GetReplicationLogOK with default headers values

func (*GetReplicationLogOK) Error 

func (o *GetReplicationLogOK) Error() string

func (*GetReplicationLogOK) GetPayload 

func (o *GetReplicationLogOK) GetPayload() string

type GetReplicationLogParams 

type GetReplicationLogParams struct {

	/* ID.

	   The ID of the execution that the tasks belongs to.

	   Format: int64
	*/
	ID int64

	/* TaskID.

	   The ID of the task.

	   Format: int64
	*/
	TaskID int64

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

GetReplicationLogParams contains all the parameters to send to the API endpoint 

for the get replication log operation.

Typically these are written to a http.Request.

func NewGetReplicationLogParams 

func NewGetReplicationLogParams() *GetReplicationLogParams

NewGetReplicationLogParams creates a new GetReplicationLogParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewGetReplicationLogParamsWithContext 

func NewGetReplicationLogParamsWithContext(ctx context.Context) *GetReplicationLogParams

NewGetReplicationLogParamsWithContext creates a new GetReplicationLogParams object with the ability to set a context for a request.

func NewGetReplicationLogParamsWithHTTPClient 

func NewGetReplicationLogParamsWithHTTPClient(client *http.Client) *GetReplicationLogParams

NewGetReplicationLogParamsWithHTTPClient creates a new GetReplicationLogParams object with the ability to set a custom HTTPClient for a request.

func NewGetReplicationLogParamsWithTimeout 

func NewGetReplicationLogParamsWithTimeout(timeout time.Duration) *GetReplicationLogParams

NewGetReplicationLogParamsWithTimeout creates a new GetReplicationLogParams object with the ability to set a timeout on a request.

func (*GetReplicationLogParams) SetContext 

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

SetContext adds the context to the get replication log params

func (*GetReplicationLogParams) SetDefaults 

func (o *GetReplicationLogParams) SetDefaults()

SetDefaults hydrates default values in the get replication log params (not the query body).

All values with no default are reset to their zero value.

func (*GetReplicationLogParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get replication log params

func (*GetReplicationLogParams) SetID 

func (o *GetReplicationLogParams) SetID(id int64)

SetID adds the id to the get replication log params

func (*GetReplicationLogParams) SetTaskID 

func (o *GetReplicationLogParams) SetTaskID(taskID int64)

SetTaskID adds the taskId to the get replication log params

func (*GetReplicationLogParams) SetTimeout 

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

SetTimeout adds the timeout to the get replication log params

func (*GetReplicationLogParams) WithContext 

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

WithContext adds the context to the get replication log params

func (*GetReplicationLogParams) WithDefaults 

func (o *GetReplicationLogParams) WithDefaults() *GetReplicationLogParams

WithDefaults hydrates default values in the get replication log params (not the query body).

All values with no default are reset to their zero value.

func (*GetReplicationLogParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get replication log params

func (*GetReplicationLogParams) WithID 

func (o *GetReplicationLogParams) WithID(id int64) *GetReplicationLogParams

WithID adds the id to the get replication log params

func (*GetReplicationLogParams) WithTaskID 

func (o *GetReplicationLogParams) WithTaskID(taskID int64) *GetReplicationLogParams

WithTaskID adds the taskID to the get replication log params

func (*GetReplicationLogParams) WithTimeout 

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

WithTimeout adds the timeout to the get replication log params

func (*GetReplicationLogParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetReplicationLogReader 

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

GetReplicationLogReader is a Reader for the GetReplicationLog structure.

func (*GetReplicationLogReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetReplicationLogUnauthorized 

type GetReplicationLogUnauthorized struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
GetReplicationLogUnauthorized describes a response with status code 401, with default header values.

Unauthorized

func NewGetReplicationLogUnauthorized 

func NewGetReplicationLogUnauthorized() *GetReplicationLogUnauthorized

NewGetReplicationLogUnauthorized creates a GetReplicationLogUnauthorized with default headers values

func (*GetReplicationLogUnauthorized) Error 

func (o *GetReplicationLogUnauthorized) Error() string

func (*GetReplicationLogUnauthorized) GetPayload 

func (o *GetReplicationLogUnauthorized) GetPayload() *models.Errors

type ListReplicationExecutionsForbidden 

type ListReplicationExecutionsForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
ListReplicationExecutionsForbidden describes a response with status code 403, with default header values.

Forbidden

func NewListReplicationExecutionsForbidden 

func NewListReplicationExecutionsForbidden() *ListReplicationExecutionsForbidden

NewListReplicationExecutionsForbidden creates a ListReplicationExecutionsForbidden with default headers values

func (*ListReplicationExecutionsForbidden) Error 

func (o *ListReplicationExecutionsForbidden) Error() string

func (*ListReplicationExecutionsForbidden) GetPayload 

func (o *ListReplicationExecutionsForbidden) GetPayload() *models.Errors

type ListReplicationExecutionsInternalServerError 

type ListReplicationExecutionsInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
ListReplicationExecutionsInternalServerError describes a response with status code 500, with default header values.

Internal server error

func NewListReplicationExecutionsInternalServerError 

func NewListReplicationExecutionsInternalServerError() *ListReplicationExecutionsInternalServerError

NewListReplicationExecutionsInternalServerError creates a ListReplicationExecutionsInternalServerError with default headers values

func (*ListReplicationExecutionsInternalServerError) Error 

func (o *ListReplicationExecutionsInternalServerError) Error() string

func (*ListReplicationExecutionsInternalServerError) GetPayload 

func (o *ListReplicationExecutionsInternalServerError) GetPayload() *models.Errors

type ListReplicationExecutionsOK 

type ListReplicationExecutionsOK struct {

	/* Link refers to the previous page and next page
	 */
	Link string

	/* The total count of the resources
	 */
	XTotalCount int64

	Payload []*models.ReplicationExecution
}
ListReplicationExecutionsOK describes a response with status code 200, with default header values.

Success

func NewListReplicationExecutionsOK 

func NewListReplicationExecutionsOK() *ListReplicationExecutionsOK

NewListReplicationExecutionsOK creates a ListReplicationExecutionsOK with default headers values

func (*ListReplicationExecutionsOK) Error 

func (o *ListReplicationExecutionsOK) Error() string

func (*ListReplicationExecutionsOK) GetPayload 

func (o *ListReplicationExecutionsOK) GetPayload() []*models.ReplicationExecution

type ListReplicationExecutionsParams 

type ListReplicationExecutionsParams struct {

	/* Page.

	   The page number

	   Format: int64
	   Default: 1
	*/
	Page *int64

	/* PageSize.

	   The size of per page

	   Format: int64
	   Default: 10
	*/
	PageSize *int64

	/* PolicyID.

	   The ID of the policy that the executions belong to.
	*/
	PolicyID *int64

	/* Status.

	   The execution status.
	*/
	Status *string

	/* Trigger.

	   The trigger mode.
	*/
	Trigger *string

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

ListReplicationExecutionsParams contains all the parameters to send to the API endpoint 

for the list replication executions operation.

Typically these are written to a http.Request.

func NewListReplicationExecutionsParams 

func NewListReplicationExecutionsParams() *ListReplicationExecutionsParams

NewListReplicationExecutionsParams creates a new ListReplicationExecutionsParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewListReplicationExecutionsParamsWithContext 

func NewListReplicationExecutionsParamsWithContext(ctx context.Context) *ListReplicationExecutionsParams

NewListReplicationExecutionsParamsWithContext creates a new ListReplicationExecutionsParams object with the ability to set a context for a request.

func NewListReplicationExecutionsParamsWithHTTPClient 

func NewListReplicationExecutionsParamsWithHTTPClient(client *http.Client) *ListReplicationExecutionsParams

NewListReplicationExecutionsParamsWithHTTPClient creates a new ListReplicationExecutionsParams object with the ability to set a custom HTTPClient for a request.

func NewListReplicationExecutionsParamsWithTimeout 

func NewListReplicationExecutionsParamsWithTimeout(timeout time.Duration) *ListReplicationExecutionsParams

NewListReplicationExecutionsParamsWithTimeout creates a new ListReplicationExecutionsParams object with the ability to set a timeout on a request.

func (*ListReplicationExecutionsParams) SetContext 

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

SetContext adds the context to the list replication executions params

func (*ListReplicationExecutionsParams) SetDefaults 

func (o *ListReplicationExecutionsParams) SetDefaults()

SetDefaults hydrates default values in the list replication executions params (not the query body).

All values with no default are reset to their zero value.

func (*ListReplicationExecutionsParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the list replication executions params

func (*ListReplicationExecutionsParams) SetPage 

func (o *ListReplicationExecutionsParams) SetPage(page *int64)

SetPage adds the page to the list replication executions params

func (*ListReplicationExecutionsParams) SetPageSize 

func (o *ListReplicationExecutionsParams) SetPageSize(pageSize *int64)

SetPageSize adds the pageSize to the list replication executions params

func (*ListReplicationExecutionsParams) SetPolicyID 

func (o *ListReplicationExecutionsParams) SetPolicyID(policyID *int64)

SetPolicyID adds the policyId to the list replication executions params

func (*ListReplicationExecutionsParams) SetStatus 

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

SetStatus adds the status to the list replication executions params

func (*ListReplicationExecutionsParams) SetTimeout 

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

SetTimeout adds the timeout to the list replication executions params

func (*ListReplicationExecutionsParams) SetTrigger 

func (o *ListReplicationExecutionsParams) SetTrigger(trigger *string)

SetTrigger adds the trigger to the list replication executions params

func (*ListReplicationExecutionsParams) WithContext 

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

WithContext adds the context to the list replication executions params

func (*ListReplicationExecutionsParams) WithDefaults 

func (o *ListReplicationExecutionsParams) WithDefaults() *ListReplicationExecutionsParams

WithDefaults hydrates default values in the list replication executions params (not the query body).

All values with no default are reset to their zero value.

func (*ListReplicationExecutionsParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the list replication executions params

func (*ListReplicationExecutionsParams) WithPage 

func (o *ListReplicationExecutionsParams) WithPage(page *int64) *ListReplicationExecutionsParams

WithPage adds the page to the list replication executions params

func (*ListReplicationExecutionsParams) WithPageSize 

func (o *ListReplicationExecutionsParams) WithPageSize(pageSize *int64) *ListReplicationExecutionsParams

WithPageSize adds the pageSize to the list replication executions params

func (*ListReplicationExecutionsParams) WithPolicyID 

func (o *ListReplicationExecutionsParams) WithPolicyID(policyID *int64) *ListReplicationExecutionsParams

WithPolicyID adds the policyID to the list replication executions params

func (*ListReplicationExecutionsParams) WithStatus 

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

WithStatus adds the status to the list replication executions params

func (*ListReplicationExecutionsParams) WithTimeout 

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

WithTimeout adds the timeout to the list replication executions params

func (*ListReplicationExecutionsParams) WithTrigger 

func (o *ListReplicationExecutionsParams) WithTrigger(trigger *string) *ListReplicationExecutionsParams

WithTrigger adds the trigger to the list replication executions params

func (*ListReplicationExecutionsParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ListReplicationExecutionsReader 

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

ListReplicationExecutionsReader is a Reader for the ListReplicationExecutions structure.

func (*ListReplicationExecutionsReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ListReplicationExecutionsUnauthorized 

type ListReplicationExecutionsUnauthorized struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
ListReplicationExecutionsUnauthorized describes a response with status code 401, with default header values.

Unauthorized

func NewListReplicationExecutionsUnauthorized 

func NewListReplicationExecutionsUnauthorized() *ListReplicationExecutionsUnauthorized

NewListReplicationExecutionsUnauthorized creates a ListReplicationExecutionsUnauthorized with default headers values

func (*ListReplicationExecutionsUnauthorized) Error 

func (o *ListReplicationExecutionsUnauthorized) Error() string

func (*ListReplicationExecutionsUnauthorized) GetPayload 

func (o *ListReplicationExecutionsUnauthorized) GetPayload() *models.Errors

type ListReplicationTasksForbidden 

type ListReplicationTasksForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
ListReplicationTasksForbidden describes a response with status code 403, with default header values.

Forbidden

func NewListReplicationTasksForbidden 

func NewListReplicationTasksForbidden() *ListReplicationTasksForbidden

NewListReplicationTasksForbidden creates a ListReplicationTasksForbidden with default headers values

func (*ListReplicationTasksForbidden) Error 

func (o *ListReplicationTasksForbidden) Error() string

func (*ListReplicationTasksForbidden) GetPayload 

func (o *ListReplicationTasksForbidden) GetPayload() *models.Errors

type ListReplicationTasksInternalServerError 

type ListReplicationTasksInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
ListReplicationTasksInternalServerError describes a response with status code 500, with default header values.

Internal server error

func NewListReplicationTasksInternalServerError 

func NewListReplicationTasksInternalServerError() *ListReplicationTasksInternalServerError

NewListReplicationTasksInternalServerError creates a ListReplicationTasksInternalServerError with default headers values

func (*ListReplicationTasksInternalServerError) Error 

func (o *ListReplicationTasksInternalServerError) Error() string

func (*ListReplicationTasksInternalServerError) GetPayload 

func (o *ListReplicationTasksInternalServerError) GetPayload() *models.Errors

type ListReplicationTasksOK 

type ListReplicationTasksOK struct {

	/* Link refers to the previous page and next page
	 */
	Link string

	/* The total count of the resources
	 */
	XTotalCount int64

	Payload []*models.ReplicationTask
}
ListReplicationTasksOK describes a response with status code 200, with default header values.

Success

func NewListReplicationTasksOK 

func NewListReplicationTasksOK() *ListReplicationTasksOK

NewListReplicationTasksOK creates a ListReplicationTasksOK with default headers values

func (*ListReplicationTasksOK) Error 

func (o *ListReplicationTasksOK) Error() string

func (*ListReplicationTasksOK) GetPayload 

func (o *ListReplicationTasksOK) GetPayload() []*models.ReplicationTask

type ListReplicationTasksParams 

type ListReplicationTasksParams struct {

	/* ID.

	   The ID of the execution that the tasks belongs to.

	   Format: int64
	*/
	ID int64

	/* Page.

	   The page number

	   Format: int64
	   Default: 1
	*/
	Page *int64

	/* PageSize.

	   The size of per page

	   Format: int64
	   Default: 10
	*/
	PageSize *int64

	/* ResourceType.

	   The resource type.
	*/
	ResourceType *string

	/* Status.

	   The task status.
	*/
	Status *string

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

ListReplicationTasksParams contains all the parameters to send to the API endpoint 

for the list replication tasks operation.

Typically these are written to a http.Request.

func NewListReplicationTasksParams 

func NewListReplicationTasksParams() *ListReplicationTasksParams

NewListReplicationTasksParams creates a new ListReplicationTasksParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewListReplicationTasksParamsWithContext 

func NewListReplicationTasksParamsWithContext(ctx context.Context) *ListReplicationTasksParams

NewListReplicationTasksParamsWithContext creates a new ListReplicationTasksParams object with the ability to set a context for a request.

func NewListReplicationTasksParamsWithHTTPClient 

func NewListReplicationTasksParamsWithHTTPClient(client *http.Client) *ListReplicationTasksParams

NewListReplicationTasksParamsWithHTTPClient creates a new ListReplicationTasksParams object with the ability to set a custom HTTPClient for a request.

func NewListReplicationTasksParamsWithTimeout 

func NewListReplicationTasksParamsWithTimeout(timeout time.Duration) *ListReplicationTasksParams

NewListReplicationTasksParamsWithTimeout creates a new ListReplicationTasksParams object with the ability to set a timeout on a request.

func (*ListReplicationTasksParams) SetContext 

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

SetContext adds the context to the list replication tasks params

func (*ListReplicationTasksParams) SetDefaults 

func (o *ListReplicationTasksParams) SetDefaults()

SetDefaults hydrates default values in the list replication tasks params (not the query body).

All values with no default are reset to their zero value.

func (*ListReplicationTasksParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the list replication tasks params

func (*ListReplicationTasksParams) SetID 

func (o *ListReplicationTasksParams) SetID(id int64)

SetID adds the id to the list replication tasks params

func (*ListReplicationTasksParams) SetPage 

func (o *ListReplicationTasksParams) SetPage(page *int64)

SetPage adds the page to the list replication tasks params

func (*ListReplicationTasksParams) SetPageSize 

func (o *ListReplicationTasksParams) SetPageSize(pageSize *int64)

SetPageSize adds the pageSize to the list replication tasks params

func (*ListReplicationTasksParams) SetResourceType 

func (o *ListReplicationTasksParams) SetResourceType(resourceType *string)

SetResourceType adds the resourceType to the list replication tasks params

func (*ListReplicationTasksParams) SetStatus 

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

SetStatus adds the status to the list replication tasks params

func (*ListReplicationTasksParams) SetTimeout 

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

SetTimeout adds the timeout to the list replication tasks params

func (*ListReplicationTasksParams) WithContext 

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

WithContext adds the context to the list replication tasks params

func (*ListReplicationTasksParams) WithDefaults 

func (o *ListReplicationTasksParams) WithDefaults() *ListReplicationTasksParams

WithDefaults hydrates default values in the list replication tasks params (not the query body).

All values with no default are reset to their zero value.

func (*ListReplicationTasksParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the list replication tasks params

func (*ListReplicationTasksParams) WithID 

func (o *ListReplicationTasksParams) WithID(id int64) *ListReplicationTasksParams

WithID adds the id to the list replication tasks params

func (*ListReplicationTasksParams) WithPage 

func (o *ListReplicationTasksParams) WithPage(page *int64) *ListReplicationTasksParams

WithPage adds the page to the list replication tasks params

func (*ListReplicationTasksParams) WithPageSize 

func (o *ListReplicationTasksParams) WithPageSize(pageSize *int64) *ListReplicationTasksParams

WithPageSize adds the pageSize to the list replication tasks params

func (*ListReplicationTasksParams) WithResourceType 

func (o *ListReplicationTasksParams) WithResourceType(resourceType *string) *ListReplicationTasksParams

WithResourceType adds the resourceType to the list replication tasks params

func (*ListReplicationTasksParams) WithStatus 

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

WithStatus adds the status to the list replication tasks params

func (*ListReplicationTasksParams) WithTimeout 

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

WithTimeout adds the timeout to the list replication tasks params

func (*ListReplicationTasksParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ListReplicationTasksReader 

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

ListReplicationTasksReader is a Reader for the ListReplicationTasks structure.

func (*ListReplicationTasksReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ListReplicationTasksUnauthorized 

type ListReplicationTasksUnauthorized struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
ListReplicationTasksUnauthorized describes a response with status code 401, with default header values.

Unauthorized

func NewListReplicationTasksUnauthorized 

func NewListReplicationTasksUnauthorized() *ListReplicationTasksUnauthorized

NewListReplicationTasksUnauthorized creates a ListReplicationTasksUnauthorized with default headers values

func (*ListReplicationTasksUnauthorized) Error 

func (o *ListReplicationTasksUnauthorized) Error() string

func (*ListReplicationTasksUnauthorized) GetPayload 

func (o *ListReplicationTasksUnauthorized) GetPayload() *models.Errors

type StartReplicationBadRequest 

type StartReplicationBadRequest struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
StartReplicationBadRequest describes a response with status code 400, with default header values.

Bad request

func NewStartReplicationBadRequest 

func NewStartReplicationBadRequest() *StartReplicationBadRequest

NewStartReplicationBadRequest creates a StartReplicationBadRequest with default headers values

func (*StartReplicationBadRequest) Error 

func (o *StartReplicationBadRequest) Error() string

func (*StartReplicationBadRequest) GetPayload 

func (o *StartReplicationBadRequest) GetPayload() *models.Errors

type StartReplicationCreated 

type StartReplicationCreated struct {

	/* The location of the resource
	 */
	Location string

	/* The ID of the corresponding request for the response
	 */
	XRequestID string
}
StartReplicationCreated describes a response with status code 201, with default header values.

Created

func NewStartReplicationCreated 

func NewStartReplicationCreated() *StartReplicationCreated

NewStartReplicationCreated creates a StartReplicationCreated with default headers values

func (*StartReplicationCreated) Error 

func (o *StartReplicationCreated) Error() string

type StartReplicationForbidden 

type StartReplicationForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
StartReplicationForbidden describes a response with status code 403, with default header values.

Forbidden

func NewStartReplicationForbidden 

func NewStartReplicationForbidden() *StartReplicationForbidden

NewStartReplicationForbidden creates a StartReplicationForbidden with default headers values

func (*StartReplicationForbidden) Error 

func (o *StartReplicationForbidden) Error() string

func (*StartReplicationForbidden) GetPayload 

func (o *StartReplicationForbidden) GetPayload() *models.Errors

type StartReplicationInternalServerError 

type StartReplicationInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
StartReplicationInternalServerError describes a response with status code 500, with default header values.

Internal server error

func NewStartReplicationInternalServerError 

func NewStartReplicationInternalServerError() *StartReplicationInternalServerError

NewStartReplicationInternalServerError creates a StartReplicationInternalServerError with default headers values

func (*StartReplicationInternalServerError) Error 

func (o *StartReplicationInternalServerError) Error() string

func (*StartReplicationInternalServerError) GetPayload 

func (o *StartReplicationInternalServerError) GetPayload() *models.Errors

type StartReplicationParams 

type StartReplicationParams struct {

	/* Execution.

	   The ID of policy that the execution belongs to
	*/
	Execution *models.StartReplicationExecution

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

StartReplicationParams contains all the parameters to send to the API endpoint 

for the start replication operation.

Typically these are written to a http.Request.

func NewStartReplicationParams 

func NewStartReplicationParams() *StartReplicationParams

NewStartReplicationParams creates a new StartReplicationParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewStartReplicationParamsWithContext 

func NewStartReplicationParamsWithContext(ctx context.Context) *StartReplicationParams

NewStartReplicationParamsWithContext creates a new StartReplicationParams object with the ability to set a context for a request.

func NewStartReplicationParamsWithHTTPClient 

func NewStartReplicationParamsWithHTTPClient(client *http.Client) *StartReplicationParams

NewStartReplicationParamsWithHTTPClient creates a new StartReplicationParams object with the ability to set a custom HTTPClient for a request.

func NewStartReplicationParamsWithTimeout 

func NewStartReplicationParamsWithTimeout(timeout time.Duration) *StartReplicationParams

NewStartReplicationParamsWithTimeout creates a new StartReplicationParams object with the ability to set a timeout on a request.

func (*StartReplicationParams) SetContext 

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

SetContext adds the context to the start replication params

func (*StartReplicationParams) SetDefaults 

func (o *StartReplicationParams) SetDefaults()

SetDefaults hydrates default values in the start replication params (not the query body).

All values with no default are reset to their zero value.

func (*StartReplicationParams) SetExecution 

func (o *StartReplicationParams) SetExecution(execution *models.StartReplicationExecution)

SetExecution adds the execution to the start replication params

func (*StartReplicationParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the start replication params

func (*StartReplicationParams) SetTimeout 

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

SetTimeout adds the timeout to the start replication params

func (*StartReplicationParams) WithContext 

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

WithContext adds the context to the start replication params

func (*StartReplicationParams) WithDefaults 

func (o *StartReplicationParams) WithDefaults() *StartReplicationParams

WithDefaults hydrates default values in the start replication params (not the query body).

All values with no default are reset to their zero value.

func (*StartReplicationParams) WithExecution 

func (o *StartReplicationParams) WithExecution(execution *models.StartReplicationExecution) *StartReplicationParams

WithExecution adds the execution to the start replication params

func (*StartReplicationParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the start replication params

func (*StartReplicationParams) WithTimeout 

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

WithTimeout adds the timeout to the start replication params

func (*StartReplicationParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type StartReplicationReader 

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

StartReplicationReader is a Reader for the StartReplication structure.

func (*StartReplicationReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type StartReplicationUnauthorized 

type StartReplicationUnauthorized struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
StartReplicationUnauthorized describes a response with status code 401, with default header values.

Unauthorized

func NewStartReplicationUnauthorized 

func NewStartReplicationUnauthorized() *StartReplicationUnauthorized

NewStartReplicationUnauthorized creates a StartReplicationUnauthorized with default headers values

func (*StartReplicationUnauthorized) Error 

func (o *StartReplicationUnauthorized) Error() string

func (*StartReplicationUnauthorized) GetPayload 

func (o *StartReplicationUnauthorized) GetPayload() *models.Errors

type StopReplicationForbidden 

type StopReplicationForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
StopReplicationForbidden describes a response with status code 403, with default header values.

Forbidden

func NewStopReplicationForbidden 

func NewStopReplicationForbidden() *StopReplicationForbidden

NewStopReplicationForbidden creates a StopReplicationForbidden with default headers values

func (*StopReplicationForbidden) Error 

func (o *StopReplicationForbidden) Error() string

func (*StopReplicationForbidden) GetPayload 

func (o *StopReplicationForbidden) GetPayload() *models.Errors

type StopReplicationInternalServerError 

type StopReplicationInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
StopReplicationInternalServerError describes a response with status code 500, with default header values.

Internal server error

func NewStopReplicationInternalServerError 

func NewStopReplicationInternalServerError() *StopReplicationInternalServerError

NewStopReplicationInternalServerError creates a StopReplicationInternalServerError with default headers values

func (*StopReplicationInternalServerError) Error 

func (o *StopReplicationInternalServerError) Error() string

func (*StopReplicationInternalServerError) GetPayload 

func (o *StopReplicationInternalServerError) GetPayload() *models.Errors

type StopReplicationNotFound 

type StopReplicationNotFound struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
StopReplicationNotFound describes a response with status code 404, with default header values.

Not found

func NewStopReplicationNotFound 

func NewStopReplicationNotFound() *StopReplicationNotFound

NewStopReplicationNotFound creates a StopReplicationNotFound with default headers values

func (*StopReplicationNotFound) Error 

func (o *StopReplicationNotFound) Error() string

func (*StopReplicationNotFound) GetPayload 

func (o *StopReplicationNotFound) GetPayload() *models.Errors

type StopReplicationOK 

type StopReplicationOK struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string
}
StopReplicationOK describes a response with status code 200, with default header values.

Success

func NewStopReplicationOK 

func NewStopReplicationOK() *StopReplicationOK

NewStopReplicationOK creates a StopReplicationOK with default headers values

func (*StopReplicationOK) Error 

func (o *StopReplicationOK) Error() string

type StopReplicationParams 

type StopReplicationParams struct {

	/* ID.

	   The ID of the execution.

	   Format: int64
	*/
	ID int64

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

StopReplicationParams contains all the parameters to send to the API endpoint 

for the stop replication operation.

Typically these are written to a http.Request.

func NewStopReplicationParams 

func NewStopReplicationParams() *StopReplicationParams

NewStopReplicationParams creates a new StopReplicationParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewStopReplicationParamsWithContext 

func NewStopReplicationParamsWithContext(ctx context.Context) *StopReplicationParams

NewStopReplicationParamsWithContext creates a new StopReplicationParams object with the ability to set a context for a request.

func NewStopReplicationParamsWithHTTPClient 

func NewStopReplicationParamsWithHTTPClient(client *http.Client) *StopReplicationParams

NewStopReplicationParamsWithHTTPClient creates a new StopReplicationParams object with the ability to set a custom HTTPClient for a request.

func NewStopReplicationParamsWithTimeout 

func NewStopReplicationParamsWithTimeout(timeout time.Duration) *StopReplicationParams

NewStopReplicationParamsWithTimeout creates a new StopReplicationParams object with the ability to set a timeout on a request.

func (*StopReplicationParams) SetContext 

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

SetContext adds the context to the stop replication params

func (*StopReplicationParams) SetDefaults 

func (o *StopReplicationParams) SetDefaults()

SetDefaults hydrates default values in the stop replication params (not the query body).

All values with no default are reset to their zero value.

func (*StopReplicationParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the stop replication params

func (*StopReplicationParams) SetID 

func (o *StopReplicationParams) SetID(id int64)

SetID adds the id to the stop replication params

func (*StopReplicationParams) SetTimeout 

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

SetTimeout adds the timeout to the stop replication params

func (*StopReplicationParams) WithContext 

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

WithContext adds the context to the stop replication params

func (*StopReplicationParams) WithDefaults 

func (o *StopReplicationParams) WithDefaults() *StopReplicationParams

WithDefaults hydrates default values in the stop replication params (not the query body).

All values with no default are reset to their zero value.

func (*StopReplicationParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the stop replication params

func (*StopReplicationParams) WithID 

func (o *StopReplicationParams) WithID(id int64) *StopReplicationParams

WithID adds the id to the stop replication params

func (*StopReplicationParams) WithTimeout 

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

WithTimeout adds the timeout to the stop replication params

func (*StopReplicationParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type StopReplicationReader 

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

StopReplicationReader is a Reader for the StopReplication structure.

func (*StopReplicationReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type StopReplicationUnauthorized 

type StopReplicationUnauthorized struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}
StopReplicationUnauthorized describes a response with status code 401, with default header values.

Unauthorized

func NewStopReplicationUnauthorized 

func NewStopReplicationUnauthorized() *StopReplicationUnauthorized

NewStopReplicationUnauthorized creates a StopReplicationUnauthorized with default headers values

func (*StopReplicationUnauthorized) Error 

func (o *StopReplicationUnauthorized) Error() string

func (*StopReplicationUnauthorized) GetPayload 

func (o *StopReplicationUnauthorized) GetPayload() *models.Errors

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.