replication

package
v5.0.0-...-41c6882 Latest Latest
Warning

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

Go to latest
Published: Feb 1, 2024 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) CreateReplicationPolicy

CreateReplicationPolicy creates a replication policy

Create a replication policy

func (*Client) DeleteReplicationPolicy

func (a *Client) DeleteReplicationPolicy(params *DeleteReplicationPolicyParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteReplicationPolicyOK, error)

DeleteReplicationPolicy deletes the specific replication policy

Delete the specific replication policy

func (*Client) GetReplicationExecution

func (a *Client) GetReplicationExecution(params *GetReplicationExecutionParams, authInfo runtime.ClientAuthInfoWriter) (*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) (*GetReplicationLogOK, error)

GetReplicationLog gets the log of the specific replication task

Get the log of the specific replication task

func (*Client) GetReplicationPolicy

func (a *Client) GetReplicationPolicy(params *GetReplicationPolicyParams, authInfo runtime.ClientAuthInfoWriter) (*GetReplicationPolicyOK, error)

GetReplicationPolicy gets the specific replication policy

Get the specific replication policy

func (*Client) ListReplicationExecutions

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

ListReplicationExecutions lists replication executions

List replication executions

func (*Client) ListReplicationPolicies

func (a *Client) ListReplicationPolicies(params *ListReplicationPoliciesParams, authInfo runtime.ClientAuthInfoWriter) (*ListReplicationPoliciesOK, error)

ListReplicationPolicies lists replication policies

List replication policies

func (*Client) ListReplicationTasks

func (a *Client) ListReplicationTasks(params *ListReplicationTasksParams, authInfo runtime.ClientAuthInfoWriter) (*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) (*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) (*StopReplicationOK, error)

StopReplication stops the specific replication execution

Stop the replication execution specified by ID

func (*Client) UpdateReplicationPolicy

func (a *Client) UpdateReplicationPolicy(params *UpdateReplicationPolicyParams, authInfo runtime.ClientAuthInfoWriter) (*UpdateReplicationPolicyOK, error)

UpdateReplicationPolicy updates the replication policy

Update the replication policy

type ClientService

type ClientService interface {
	CreateReplicationPolicy(params *CreateReplicationPolicyParams, authInfo runtime.ClientAuthInfoWriter) (*CreateReplicationPolicyCreated, error)

	DeleteReplicationPolicy(params *DeleteReplicationPolicyParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteReplicationPolicyOK, error)

	GetReplicationExecution(params *GetReplicationExecutionParams, authInfo runtime.ClientAuthInfoWriter) (*GetReplicationExecutionOK, error)

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

	GetReplicationPolicy(params *GetReplicationPolicyParams, authInfo runtime.ClientAuthInfoWriter) (*GetReplicationPolicyOK, error)

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

	ListReplicationPolicies(params *ListReplicationPoliciesParams, authInfo runtime.ClientAuthInfoWriter) (*ListReplicationPoliciesOK, error)

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

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

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

	UpdateReplicationPolicy(params *UpdateReplicationPolicyParams, authInfo runtime.ClientAuthInfoWriter) (*UpdateReplicationPolicyOK, 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 CreateReplicationPolicyBadRequest

type CreateReplicationPolicyBadRequest struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

CreateReplicationPolicyBadRequest handles this case with default header values.

Bad request

func NewCreateReplicationPolicyBadRequest

func NewCreateReplicationPolicyBadRequest() *CreateReplicationPolicyBadRequest

NewCreateReplicationPolicyBadRequest creates a CreateReplicationPolicyBadRequest with default headers values

func (*CreateReplicationPolicyBadRequest) Error

func (*CreateReplicationPolicyBadRequest) GetPayload

type CreateReplicationPolicyConflict

type CreateReplicationPolicyConflict struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

CreateReplicationPolicyConflict handles this case with default header values.

Conflict

func NewCreateReplicationPolicyConflict

func NewCreateReplicationPolicyConflict() *CreateReplicationPolicyConflict

NewCreateReplicationPolicyConflict creates a CreateReplicationPolicyConflict with default headers values

func (*CreateReplicationPolicyConflict) Error

func (*CreateReplicationPolicyConflict) GetPayload

func (o *CreateReplicationPolicyConflict) GetPayload() *model.Errors

type CreateReplicationPolicyCreated

type CreateReplicationPolicyCreated struct {
	/*The location of the resource
	 */
	Location string
	/*The ID of the corresponding request for the response
	 */
	XRequestID string
}

CreateReplicationPolicyCreated handles this case with default header values.

Created

func NewCreateReplicationPolicyCreated

func NewCreateReplicationPolicyCreated() *CreateReplicationPolicyCreated

NewCreateReplicationPolicyCreated creates a CreateReplicationPolicyCreated with default headers values

func (*CreateReplicationPolicyCreated) Error

type CreateReplicationPolicyForbidden

type CreateReplicationPolicyForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

CreateReplicationPolicyForbidden handles this case with default header values.

Forbidden

func NewCreateReplicationPolicyForbidden

func NewCreateReplicationPolicyForbidden() *CreateReplicationPolicyForbidden

NewCreateReplicationPolicyForbidden creates a CreateReplicationPolicyForbidden with default headers values

func (*CreateReplicationPolicyForbidden) Error

func (*CreateReplicationPolicyForbidden) GetPayload

type CreateReplicationPolicyInternalServerError

type CreateReplicationPolicyInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

CreateReplicationPolicyInternalServerError handles this case with default header values.

Internal server error

func NewCreateReplicationPolicyInternalServerError

func NewCreateReplicationPolicyInternalServerError() *CreateReplicationPolicyInternalServerError

NewCreateReplicationPolicyInternalServerError creates a CreateReplicationPolicyInternalServerError with default headers values

func (*CreateReplicationPolicyInternalServerError) Error

func (*CreateReplicationPolicyInternalServerError) GetPayload

type CreateReplicationPolicyParams

type CreateReplicationPolicyParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*Policy
	  The replication policy

	*/
	Policy *model.ReplicationPolicy

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

CreateReplicationPolicyParams contains all the parameters to send to the API endpoint for the create replication policy operation typically these are written to a http.Request

func NewCreateReplicationPolicyParams

func NewCreateReplicationPolicyParams() *CreateReplicationPolicyParams

NewCreateReplicationPolicyParams creates a new CreateReplicationPolicyParams object with the default values initialized.

func NewCreateReplicationPolicyParamsWithContext

func NewCreateReplicationPolicyParamsWithContext(ctx context.Context) *CreateReplicationPolicyParams

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

func NewCreateReplicationPolicyParamsWithHTTPClient

func NewCreateReplicationPolicyParamsWithHTTPClient(client *http.Client) *CreateReplicationPolicyParams

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

func NewCreateReplicationPolicyParamsWithTimeout

func NewCreateReplicationPolicyParamsWithTimeout(timeout time.Duration) *CreateReplicationPolicyParams

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

func (*CreateReplicationPolicyParams) SetContext

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

SetContext adds the context to the create replication policy params

func (*CreateReplicationPolicyParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the create replication policy params

func (*CreateReplicationPolicyParams) SetPolicy

SetPolicy adds the policy to the create replication policy params

func (*CreateReplicationPolicyParams) SetTimeout

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

SetTimeout adds the timeout to the create replication policy params

func (*CreateReplicationPolicyParams) SetXRequestID

func (o *CreateReplicationPolicyParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the create replication policy params

func (*CreateReplicationPolicyParams) WithContext

WithContext adds the context to the create replication policy params

func (*CreateReplicationPolicyParams) WithHTTPClient

WithHTTPClient adds the HTTPClient to the create replication policy params

func (*CreateReplicationPolicyParams) WithPolicy

WithPolicy adds the policy to the create replication policy params

func (*CreateReplicationPolicyParams) WithTimeout

WithTimeout adds the timeout to the create replication policy params

func (*CreateReplicationPolicyParams) WithXRequestID

func (o *CreateReplicationPolicyParams) WithXRequestID(xRequestID *string) *CreateReplicationPolicyParams

WithXRequestID adds the xRequestID to the create replication policy params

func (*CreateReplicationPolicyParams) WriteToRequest

WriteToRequest writes these params to a swagger request

type CreateReplicationPolicyReader

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

CreateReplicationPolicyReader is a Reader for the CreateReplicationPolicy structure.

func (*CreateReplicationPolicyReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type CreateReplicationPolicyUnauthorized

type CreateReplicationPolicyUnauthorized struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

CreateReplicationPolicyUnauthorized handles this case with default header values.

Unauthorized

func NewCreateReplicationPolicyUnauthorized

func NewCreateReplicationPolicyUnauthorized() *CreateReplicationPolicyUnauthorized

NewCreateReplicationPolicyUnauthorized creates a CreateReplicationPolicyUnauthorized with default headers values

func (*CreateReplicationPolicyUnauthorized) Error

func (*CreateReplicationPolicyUnauthorized) GetPayload

type DeleteReplicationPolicyForbidden

type DeleteReplicationPolicyForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

DeleteReplicationPolicyForbidden handles this case with default header values.

Forbidden

func NewDeleteReplicationPolicyForbidden

func NewDeleteReplicationPolicyForbidden() *DeleteReplicationPolicyForbidden

NewDeleteReplicationPolicyForbidden creates a DeleteReplicationPolicyForbidden with default headers values

func (*DeleteReplicationPolicyForbidden) Error

func (*DeleteReplicationPolicyForbidden) GetPayload

type DeleteReplicationPolicyInternalServerError

type DeleteReplicationPolicyInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

DeleteReplicationPolicyInternalServerError handles this case with default header values.

Internal server error

func NewDeleteReplicationPolicyInternalServerError

func NewDeleteReplicationPolicyInternalServerError() *DeleteReplicationPolicyInternalServerError

NewDeleteReplicationPolicyInternalServerError creates a DeleteReplicationPolicyInternalServerError with default headers values

func (*DeleteReplicationPolicyInternalServerError) Error

func (*DeleteReplicationPolicyInternalServerError) GetPayload

type DeleteReplicationPolicyNotFound

type DeleteReplicationPolicyNotFound struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

DeleteReplicationPolicyNotFound handles this case with default header values.

Not found

func NewDeleteReplicationPolicyNotFound

func NewDeleteReplicationPolicyNotFound() *DeleteReplicationPolicyNotFound

NewDeleteReplicationPolicyNotFound creates a DeleteReplicationPolicyNotFound with default headers values

func (*DeleteReplicationPolicyNotFound) Error

func (*DeleteReplicationPolicyNotFound) GetPayload

func (o *DeleteReplicationPolicyNotFound) GetPayload() *model.Errors

type DeleteReplicationPolicyOK

type DeleteReplicationPolicyOK struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string
}

DeleteReplicationPolicyOK handles this case with default header values.

Success

func NewDeleteReplicationPolicyOK

func NewDeleteReplicationPolicyOK() *DeleteReplicationPolicyOK

NewDeleteReplicationPolicyOK creates a DeleteReplicationPolicyOK with default headers values

func (*DeleteReplicationPolicyOK) Error

func (o *DeleteReplicationPolicyOK) Error() string

type DeleteReplicationPolicyParams

type DeleteReplicationPolicyParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*ID
	  Replication policy ID

	*/
	ID int64

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

DeleteReplicationPolicyParams contains all the parameters to send to the API endpoint for the delete replication policy operation typically these are written to a http.Request

func NewDeleteReplicationPolicyParams

func NewDeleteReplicationPolicyParams() *DeleteReplicationPolicyParams

NewDeleteReplicationPolicyParams creates a new DeleteReplicationPolicyParams object with the default values initialized.

func NewDeleteReplicationPolicyParamsWithContext

func NewDeleteReplicationPolicyParamsWithContext(ctx context.Context) *DeleteReplicationPolicyParams

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

func NewDeleteReplicationPolicyParamsWithHTTPClient

func NewDeleteReplicationPolicyParamsWithHTTPClient(client *http.Client) *DeleteReplicationPolicyParams

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

func NewDeleteReplicationPolicyParamsWithTimeout

func NewDeleteReplicationPolicyParamsWithTimeout(timeout time.Duration) *DeleteReplicationPolicyParams

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

func (*DeleteReplicationPolicyParams) SetContext

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

SetContext adds the context to the delete replication policy params

func (*DeleteReplicationPolicyParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the delete replication policy params

func (*DeleteReplicationPolicyParams) SetID

func (o *DeleteReplicationPolicyParams) SetID(id int64)

SetID adds the id to the delete replication policy params

func (*DeleteReplicationPolicyParams) SetTimeout

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

SetTimeout adds the timeout to the delete replication policy params

func (*DeleteReplicationPolicyParams) SetXRequestID

func (o *DeleteReplicationPolicyParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the delete replication policy params

func (*DeleteReplicationPolicyParams) WithContext

WithContext adds the context to the delete replication policy params

func (*DeleteReplicationPolicyParams) WithHTTPClient

WithHTTPClient adds the HTTPClient to the delete replication policy params

func (*DeleteReplicationPolicyParams) WithID

WithID adds the id to the delete replication policy params

func (*DeleteReplicationPolicyParams) WithTimeout

WithTimeout adds the timeout to the delete replication policy params

func (*DeleteReplicationPolicyParams) WithXRequestID

func (o *DeleteReplicationPolicyParams) WithXRequestID(xRequestID *string) *DeleteReplicationPolicyParams

WithXRequestID adds the xRequestID to the delete replication policy params

func (*DeleteReplicationPolicyParams) WriteToRequest

WriteToRequest writes these params to a swagger request

type DeleteReplicationPolicyPreconditionFailed

type DeleteReplicationPolicyPreconditionFailed struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

DeleteReplicationPolicyPreconditionFailed handles this case with default header values.

Precondition failed

func NewDeleteReplicationPolicyPreconditionFailed

func NewDeleteReplicationPolicyPreconditionFailed() *DeleteReplicationPolicyPreconditionFailed

NewDeleteReplicationPolicyPreconditionFailed creates a DeleteReplicationPolicyPreconditionFailed with default headers values

func (*DeleteReplicationPolicyPreconditionFailed) Error

func (*DeleteReplicationPolicyPreconditionFailed) GetPayload

type DeleteReplicationPolicyReader

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

DeleteReplicationPolicyReader is a Reader for the DeleteReplicationPolicy structure.

func (*DeleteReplicationPolicyReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type DeleteReplicationPolicyUnauthorized

type DeleteReplicationPolicyUnauthorized struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

DeleteReplicationPolicyUnauthorized handles this case with default header values.

Unauthorized

func NewDeleteReplicationPolicyUnauthorized

func NewDeleteReplicationPolicyUnauthorized() *DeleteReplicationPolicyUnauthorized

NewDeleteReplicationPolicyUnauthorized creates a DeleteReplicationPolicyUnauthorized with default headers values

func (*DeleteReplicationPolicyUnauthorized) Error

func (*DeleteReplicationPolicyUnauthorized) GetPayload

type GetReplicationExecutionForbidden

type GetReplicationExecutionForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetReplicationExecutionForbidden handles this case with default header values.

Forbidden

func NewGetReplicationExecutionForbidden

func NewGetReplicationExecutionForbidden() *GetReplicationExecutionForbidden

NewGetReplicationExecutionForbidden creates a GetReplicationExecutionForbidden with default headers values

func (*GetReplicationExecutionForbidden) Error

func (*GetReplicationExecutionForbidden) GetPayload

type GetReplicationExecutionInternalServerError

type GetReplicationExecutionInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetReplicationExecutionInternalServerError handles this case with default header values.

Internal server error

func NewGetReplicationExecutionInternalServerError

func NewGetReplicationExecutionInternalServerError() *GetReplicationExecutionInternalServerError

NewGetReplicationExecutionInternalServerError creates a GetReplicationExecutionInternalServerError with default headers values

func (*GetReplicationExecutionInternalServerError) Error

func (*GetReplicationExecutionInternalServerError) GetPayload

type GetReplicationExecutionNotFound

type GetReplicationExecutionNotFound struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetReplicationExecutionNotFound handles this case with default header values.

Not found

func NewGetReplicationExecutionNotFound

func NewGetReplicationExecutionNotFound() *GetReplicationExecutionNotFound

NewGetReplicationExecutionNotFound creates a GetReplicationExecutionNotFound with default headers values

func (*GetReplicationExecutionNotFound) Error

func (*GetReplicationExecutionNotFound) GetPayload

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

type GetReplicationExecutionOK

type GetReplicationExecutionOK struct {
	Payload *model.ReplicationExecution
}

GetReplicationExecutionOK handles this case 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

type GetReplicationExecutionParams

type GetReplicationExecutionParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*ID
	  The ID of the execution.

	*/
	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 values initialized.

func NewGetReplicationExecutionParamsWithContext

func NewGetReplicationExecutionParamsWithContext(ctx context.Context) *GetReplicationExecutionParams

NewGetReplicationExecutionParamsWithContext creates a new GetReplicationExecutionParams object with the default values initialized, and 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 default values initialized, and 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 default values initialized, and 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) 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) SetXRequestID

func (o *GetReplicationExecutionParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the get replication execution params

func (*GetReplicationExecutionParams) WithContext

WithContext adds the context to the get replication execution params

func (*GetReplicationExecutionParams) WithHTTPClient

WithHTTPClient adds the HTTPClient to the get replication execution params

func (*GetReplicationExecutionParams) WithID

WithID adds the id to the get replication execution params

func (*GetReplicationExecutionParams) WithTimeout

WithTimeout adds the timeout to the get replication execution params

func (*GetReplicationExecutionParams) WithXRequestID

func (o *GetReplicationExecutionParams) WithXRequestID(xRequestID *string) *GetReplicationExecutionParams

WithXRequestID adds the xRequestID to the get replication execution params

func (*GetReplicationExecutionParams) WriteToRequest

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 *model.Errors
}

GetReplicationExecutionUnauthorized handles this case with default header values.

Unauthorized

func NewGetReplicationExecutionUnauthorized

func NewGetReplicationExecutionUnauthorized() *GetReplicationExecutionUnauthorized

NewGetReplicationExecutionUnauthorized creates a GetReplicationExecutionUnauthorized with default headers values

func (*GetReplicationExecutionUnauthorized) Error

func (*GetReplicationExecutionUnauthorized) GetPayload

type GetReplicationLogForbidden

type GetReplicationLogForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetReplicationLogForbidden handles this case with default header values.

Forbidden

func NewGetReplicationLogForbidden

func NewGetReplicationLogForbidden() *GetReplicationLogForbidden

NewGetReplicationLogForbidden creates a GetReplicationLogForbidden with default headers values

func (*GetReplicationLogForbidden) Error

func (*GetReplicationLogForbidden) GetPayload

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

type GetReplicationLogInternalServerError

type GetReplicationLogInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetReplicationLogInternalServerError handles this case with default header values.

Internal server error

func NewGetReplicationLogInternalServerError

func NewGetReplicationLogInternalServerError() *GetReplicationLogInternalServerError

NewGetReplicationLogInternalServerError creates a GetReplicationLogInternalServerError with default headers values

func (*GetReplicationLogInternalServerError) Error

func (*GetReplicationLogInternalServerError) GetPayload

type GetReplicationLogNotFound

type GetReplicationLogNotFound struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetReplicationLogNotFound handles this case 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() *model.Errors

type GetReplicationLogOK

type GetReplicationLogOK struct {
	/*The content type of response body
	 */
	ContentType string

	Payload string
}

GetReplicationLogOK handles this case 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 {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*ID
	  The ID of the execution that the tasks belongs to.

	*/
	ID int64
	/*TaskID
	  The ID of the task.

	*/
	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 values initialized.

func NewGetReplicationLogParamsWithContext

func NewGetReplicationLogParamsWithContext(ctx context.Context) *GetReplicationLogParams

NewGetReplicationLogParamsWithContext creates a new GetReplicationLogParams object with the default values initialized, and 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 default values initialized, and 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 default values initialized, and 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) 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) SetXRequestID

func (o *GetReplicationLogParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the get replication log params

func (*GetReplicationLogParams) WithContext

WithContext adds the context to the get replication log params

func (*GetReplicationLogParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the get replication log params

func (*GetReplicationLogParams) WithID

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

WithTimeout adds the timeout to the get replication log params

func (*GetReplicationLogParams) WithXRequestID

func (o *GetReplicationLogParams) WithXRequestID(xRequestID *string) *GetReplicationLogParams

WithXRequestID adds the xRequestID to the get replication log params

func (*GetReplicationLogParams) WriteToRequest

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 *model.Errors
}

GetReplicationLogUnauthorized handles this case with default header values.

Unauthorized

func NewGetReplicationLogUnauthorized

func NewGetReplicationLogUnauthorized() *GetReplicationLogUnauthorized

NewGetReplicationLogUnauthorized creates a GetReplicationLogUnauthorized with default headers values

func (*GetReplicationLogUnauthorized) Error

func (*GetReplicationLogUnauthorized) GetPayload

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

type GetReplicationPolicyForbidden

type GetReplicationPolicyForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetReplicationPolicyForbidden handles this case with default header values.

Forbidden

func NewGetReplicationPolicyForbidden

func NewGetReplicationPolicyForbidden() *GetReplicationPolicyForbidden

NewGetReplicationPolicyForbidden creates a GetReplicationPolicyForbidden with default headers values

func (*GetReplicationPolicyForbidden) Error

func (*GetReplicationPolicyForbidden) GetPayload

func (o *GetReplicationPolicyForbidden) GetPayload() *model.Errors

type GetReplicationPolicyInternalServerError

type GetReplicationPolicyInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetReplicationPolicyInternalServerError handles this case with default header values.

Internal server error

func NewGetReplicationPolicyInternalServerError

func NewGetReplicationPolicyInternalServerError() *GetReplicationPolicyInternalServerError

NewGetReplicationPolicyInternalServerError creates a GetReplicationPolicyInternalServerError with default headers values

func (*GetReplicationPolicyInternalServerError) Error

func (*GetReplicationPolicyInternalServerError) GetPayload

type GetReplicationPolicyOK

type GetReplicationPolicyOK struct {
	Payload *model.ReplicationPolicy
}

GetReplicationPolicyOK handles this case with default header values.

Success

func NewGetReplicationPolicyOK

func NewGetReplicationPolicyOK() *GetReplicationPolicyOK

NewGetReplicationPolicyOK creates a GetReplicationPolicyOK with default headers values

func (*GetReplicationPolicyOK) Error

func (o *GetReplicationPolicyOK) Error() string

func (*GetReplicationPolicyOK) GetPayload

type GetReplicationPolicyParams

type GetReplicationPolicyParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*ID
	  Policy ID

	*/
	ID int64

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

GetReplicationPolicyParams contains all the parameters to send to the API endpoint for the get replication policy operation typically these are written to a http.Request

func NewGetReplicationPolicyParams

func NewGetReplicationPolicyParams() *GetReplicationPolicyParams

NewGetReplicationPolicyParams creates a new GetReplicationPolicyParams object with the default values initialized.

func NewGetReplicationPolicyParamsWithContext

func NewGetReplicationPolicyParamsWithContext(ctx context.Context) *GetReplicationPolicyParams

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

func NewGetReplicationPolicyParamsWithHTTPClient

func NewGetReplicationPolicyParamsWithHTTPClient(client *http.Client) *GetReplicationPolicyParams

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

func NewGetReplicationPolicyParamsWithTimeout

func NewGetReplicationPolicyParamsWithTimeout(timeout time.Duration) *GetReplicationPolicyParams

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

func (*GetReplicationPolicyParams) SetContext

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

SetContext adds the context to the get replication policy params

func (*GetReplicationPolicyParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the get replication policy params

func (*GetReplicationPolicyParams) SetID

func (o *GetReplicationPolicyParams) SetID(id int64)

SetID adds the id to the get replication policy params

func (*GetReplicationPolicyParams) SetTimeout

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

SetTimeout adds the timeout to the get replication policy params

func (*GetReplicationPolicyParams) SetXRequestID

func (o *GetReplicationPolicyParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the get replication policy params

func (*GetReplicationPolicyParams) WithContext

WithContext adds the context to the get replication policy params

func (*GetReplicationPolicyParams) WithHTTPClient

WithHTTPClient adds the HTTPClient to the get replication policy params

func (*GetReplicationPolicyParams) WithID

WithID adds the id to the get replication policy params

func (*GetReplicationPolicyParams) WithTimeout

WithTimeout adds the timeout to the get replication policy params

func (*GetReplicationPolicyParams) WithXRequestID

func (o *GetReplicationPolicyParams) WithXRequestID(xRequestID *string) *GetReplicationPolicyParams

WithXRequestID adds the xRequestID to the get replication policy params

func (*GetReplicationPolicyParams) WriteToRequest

WriteToRequest writes these params to a swagger request

type GetReplicationPolicyReader

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

GetReplicationPolicyReader is a Reader for the GetReplicationPolicy structure.

func (*GetReplicationPolicyReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type GetReplicationPolicyUnauthorized

type GetReplicationPolicyUnauthorized struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetReplicationPolicyUnauthorized handles this case with default header values.

Unauthorized

func NewGetReplicationPolicyUnauthorized

func NewGetReplicationPolicyUnauthorized() *GetReplicationPolicyUnauthorized

NewGetReplicationPolicyUnauthorized creates a GetReplicationPolicyUnauthorized with default headers values

func (*GetReplicationPolicyUnauthorized) Error

func (*GetReplicationPolicyUnauthorized) GetPayload

type ListReplicationExecutionsForbidden

type ListReplicationExecutionsForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ListReplicationExecutionsForbidden handles this case with default header values.

Forbidden

func NewListReplicationExecutionsForbidden

func NewListReplicationExecutionsForbidden() *ListReplicationExecutionsForbidden

NewListReplicationExecutionsForbidden creates a ListReplicationExecutionsForbidden with default headers values

func (*ListReplicationExecutionsForbidden) Error

func (*ListReplicationExecutionsForbidden) GetPayload

type ListReplicationExecutionsInternalServerError

type ListReplicationExecutionsInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ListReplicationExecutionsInternalServerError handles this case with default header values.

Internal server error

func NewListReplicationExecutionsInternalServerError

func NewListReplicationExecutionsInternalServerError() *ListReplicationExecutionsInternalServerError

NewListReplicationExecutionsInternalServerError creates a ListReplicationExecutionsInternalServerError with default headers values

func (*ListReplicationExecutionsInternalServerError) Error

func (*ListReplicationExecutionsInternalServerError) GetPayload

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 []*model.ReplicationExecution
}

ListReplicationExecutionsOK handles this case with default header values.

Success

func NewListReplicationExecutionsOK

func NewListReplicationExecutionsOK() *ListReplicationExecutionsOK

NewListReplicationExecutionsOK creates a ListReplicationExecutionsOK with default headers values

func (*ListReplicationExecutionsOK) Error

func (*ListReplicationExecutionsOK) GetPayload

type ListReplicationExecutionsParams

type ListReplicationExecutionsParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*Page
	  The page number

	*/
	Page *int64
	/*PageSize
	  The size of per page

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

	*/
	PolicyID *int64
	/*Sort
	  Sort the resource list in ascending or descending order. e.g. sort by field1 in ascending orderr and field2 in descending order with "sort=field1,-field2"

	*/
	Sort *string
	/*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 values initialized.

func NewListReplicationExecutionsParamsWithContext

func NewListReplicationExecutionsParamsWithContext(ctx context.Context) *ListReplicationExecutionsParams

NewListReplicationExecutionsParamsWithContext creates a new ListReplicationExecutionsParams object with the default values initialized, and 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 default values initialized, and 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 default values initialized, and 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) 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) SetSort

func (o *ListReplicationExecutionsParams) SetSort(sort *string)

SetSort adds the sort 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) SetXRequestID

func (o *ListReplicationExecutionsParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the list replication executions params

func (*ListReplicationExecutionsParams) WithContext

WithContext adds the context to the list replication executions params

func (*ListReplicationExecutionsParams) WithHTTPClient

WithHTTPClient adds the HTTPClient to the list replication executions params

func (*ListReplicationExecutionsParams) WithPage

WithPage adds the page to the list replication executions params

func (*ListReplicationExecutionsParams) WithPageSize

WithPageSize adds the pageSize to the list replication executions params

func (*ListReplicationExecutionsParams) WithPolicyID

WithPolicyID adds the policyID to the list replication executions params

func (*ListReplicationExecutionsParams) WithSort

WithSort adds the sort to the list replication executions params

func (*ListReplicationExecutionsParams) WithStatus

WithStatus adds the status to the list replication executions params

func (*ListReplicationExecutionsParams) WithTimeout

WithTimeout adds the timeout to the list replication executions params

func (*ListReplicationExecutionsParams) WithTrigger

WithTrigger adds the trigger to the list replication executions params

func (*ListReplicationExecutionsParams) WithXRequestID

WithXRequestID adds the xRequestID to the list replication executions params

func (*ListReplicationExecutionsParams) WriteToRequest

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 *model.Errors
}

ListReplicationExecutionsUnauthorized handles this case with default header values.

Unauthorized

func NewListReplicationExecutionsUnauthorized

func NewListReplicationExecutionsUnauthorized() *ListReplicationExecutionsUnauthorized

NewListReplicationExecutionsUnauthorized creates a ListReplicationExecutionsUnauthorized with default headers values

func (*ListReplicationExecutionsUnauthorized) Error

func (*ListReplicationExecutionsUnauthorized) GetPayload

type ListReplicationPoliciesForbidden

type ListReplicationPoliciesForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ListReplicationPoliciesForbidden handles this case with default header values.

Forbidden

func NewListReplicationPoliciesForbidden

func NewListReplicationPoliciesForbidden() *ListReplicationPoliciesForbidden

NewListReplicationPoliciesForbidden creates a ListReplicationPoliciesForbidden with default headers values

func (*ListReplicationPoliciesForbidden) Error

func (*ListReplicationPoliciesForbidden) GetPayload

type ListReplicationPoliciesInternalServerError

type ListReplicationPoliciesInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ListReplicationPoliciesInternalServerError handles this case with default header values.

Internal server error

func NewListReplicationPoliciesInternalServerError

func NewListReplicationPoliciesInternalServerError() *ListReplicationPoliciesInternalServerError

NewListReplicationPoliciesInternalServerError creates a ListReplicationPoliciesInternalServerError with default headers values

func (*ListReplicationPoliciesInternalServerError) Error

func (*ListReplicationPoliciesInternalServerError) GetPayload

type ListReplicationPoliciesOK

type ListReplicationPoliciesOK struct {
	/*Link refers to the previous page and next page
	 */
	Link string
	/*The total count of the resources
	 */
	XTotalCount int64

	Payload []*model.ReplicationPolicy
}

ListReplicationPoliciesOK handles this case with default header values.

Success

func NewListReplicationPoliciesOK

func NewListReplicationPoliciesOK() *ListReplicationPoliciesOK

NewListReplicationPoliciesOK creates a ListReplicationPoliciesOK with default headers values

func (*ListReplicationPoliciesOK) Error

func (o *ListReplicationPoliciesOK) Error() string

func (*ListReplicationPoliciesOK) GetPayload

type ListReplicationPoliciesParams

type ListReplicationPoliciesParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*Name
	  Deprecated, use "query" instead. The policy name.

	*/
	Name *string
	/*Page
	  The page number

	*/
	Page *int64
	/*PageSize
	  The size of per page

	*/
	PageSize *int64
	/*Q
	  Query string to query resources. Supported query patterns are "exact match(k=v)", "fuzzy match(k=~v)", "range(k=[min~max])", "list with union releationship(k={v1 v2 v3})" and "list with intersetion relationship(k=(v1 v2 v3))". The value of range and list can be string(enclosed by " or '), integer or time(in format "2020-04-09 02:36:00"). All of these query patterns should be put in the query string "q=xxx" and splitted by ",". e.g. q=k1=v1,k2=~v2,k3=[min~max]

	*/
	Q *string
	/*Sort
	  Sort the resource list in ascending or descending order. e.g. sort by field1 in ascending orderr and field2 in descending order with "sort=field1,-field2"

	*/
	Sort *string

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

ListReplicationPoliciesParams contains all the parameters to send to the API endpoint for the list replication policies operation typically these are written to a http.Request

func NewListReplicationPoliciesParams

func NewListReplicationPoliciesParams() *ListReplicationPoliciesParams

NewListReplicationPoliciesParams creates a new ListReplicationPoliciesParams object with the default values initialized.

func NewListReplicationPoliciesParamsWithContext

func NewListReplicationPoliciesParamsWithContext(ctx context.Context) *ListReplicationPoliciesParams

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

func NewListReplicationPoliciesParamsWithHTTPClient

func NewListReplicationPoliciesParamsWithHTTPClient(client *http.Client) *ListReplicationPoliciesParams

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

func NewListReplicationPoliciesParamsWithTimeout

func NewListReplicationPoliciesParamsWithTimeout(timeout time.Duration) *ListReplicationPoliciesParams

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

func (*ListReplicationPoliciesParams) SetContext

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

SetContext adds the context to the list replication policies params

func (*ListReplicationPoliciesParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the list replication policies params

func (*ListReplicationPoliciesParams) SetName

func (o *ListReplicationPoliciesParams) SetName(name *string)

SetName adds the name to the list replication policies params

func (*ListReplicationPoliciesParams) SetPage

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

SetPage adds the page to the list replication policies params

func (*ListReplicationPoliciesParams) SetPageSize

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

SetPageSize adds the pageSize to the list replication policies params

func (*ListReplicationPoliciesParams) SetQ

SetQ adds the q to the list replication policies params

func (*ListReplicationPoliciesParams) SetSort

func (o *ListReplicationPoliciesParams) SetSort(sort *string)

SetSort adds the sort to the list replication policies params

func (*ListReplicationPoliciesParams) SetTimeout

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

SetTimeout adds the timeout to the list replication policies params

func (*ListReplicationPoliciesParams) SetXRequestID

func (o *ListReplicationPoliciesParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the list replication policies params

func (*ListReplicationPoliciesParams) WithContext

WithContext adds the context to the list replication policies params

func (*ListReplicationPoliciesParams) WithHTTPClient

WithHTTPClient adds the HTTPClient to the list replication policies params

func (*ListReplicationPoliciesParams) WithName

WithName adds the name to the list replication policies params

func (*ListReplicationPoliciesParams) WithPage

WithPage adds the page to the list replication policies params

func (*ListReplicationPoliciesParams) WithPageSize

WithPageSize adds the pageSize to the list replication policies params

func (*ListReplicationPoliciesParams) WithQ

WithQ adds the q to the list replication policies params

func (*ListReplicationPoliciesParams) WithSort

WithSort adds the sort to the list replication policies params

func (*ListReplicationPoliciesParams) WithTimeout

WithTimeout adds the timeout to the list replication policies params

func (*ListReplicationPoliciesParams) WithXRequestID

func (o *ListReplicationPoliciesParams) WithXRequestID(xRequestID *string) *ListReplicationPoliciesParams

WithXRequestID adds the xRequestID to the list replication policies params

func (*ListReplicationPoliciesParams) WriteToRequest

WriteToRequest writes these params to a swagger request

type ListReplicationPoliciesReader

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

ListReplicationPoliciesReader is a Reader for the ListReplicationPolicies structure.

func (*ListReplicationPoliciesReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type ListReplicationPoliciesUnauthorized

type ListReplicationPoliciesUnauthorized struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ListReplicationPoliciesUnauthorized handles this case with default header values.

Unauthorized

func NewListReplicationPoliciesUnauthorized

func NewListReplicationPoliciesUnauthorized() *ListReplicationPoliciesUnauthorized

NewListReplicationPoliciesUnauthorized creates a ListReplicationPoliciesUnauthorized with default headers values

func (*ListReplicationPoliciesUnauthorized) Error

func (*ListReplicationPoliciesUnauthorized) GetPayload

type ListReplicationTasksForbidden

type ListReplicationTasksForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ListReplicationTasksForbidden handles this case with default header values.

Forbidden

func NewListReplicationTasksForbidden

func NewListReplicationTasksForbidden() *ListReplicationTasksForbidden

NewListReplicationTasksForbidden creates a ListReplicationTasksForbidden with default headers values

func (*ListReplicationTasksForbidden) Error

func (*ListReplicationTasksForbidden) GetPayload

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

type ListReplicationTasksInternalServerError

type ListReplicationTasksInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ListReplicationTasksInternalServerError handles this case with default header values.

Internal server error

func NewListReplicationTasksInternalServerError

func NewListReplicationTasksInternalServerError() *ListReplicationTasksInternalServerError

NewListReplicationTasksInternalServerError creates a ListReplicationTasksInternalServerError with default headers values

func (*ListReplicationTasksInternalServerError) Error

func (*ListReplicationTasksInternalServerError) GetPayload

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 []*model.ReplicationTask
}

ListReplicationTasksOK handles this case 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() []*model.ReplicationTask

type ListReplicationTasksParams

type ListReplicationTasksParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*ID
	  The ID of the execution that the tasks belongs to.

	*/
	ID int64
	/*Page
	  The page number

	*/
	Page *int64
	/*PageSize
	  The size of per page

	*/
	PageSize *int64
	/*ResourceType
	  The resource type.

	*/
	ResourceType *string
	/*Sort
	  Sort the resource list in ascending or descending order. e.g. sort by field1 in ascending orderr and field2 in descending order with "sort=field1,-field2"

	*/
	Sort *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 values initialized.

func NewListReplicationTasksParamsWithContext

func NewListReplicationTasksParamsWithContext(ctx context.Context) *ListReplicationTasksParams

NewListReplicationTasksParamsWithContext creates a new ListReplicationTasksParams object with the default values initialized, and 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 default values initialized, and 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 default values initialized, and 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) 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) SetSort

func (o *ListReplicationTasksParams) SetSort(sort *string)

SetSort adds the sort 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) SetXRequestID

func (o *ListReplicationTasksParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the list replication tasks params

func (*ListReplicationTasksParams) WithContext

WithContext adds the context to the list replication tasks params

func (*ListReplicationTasksParams) WithHTTPClient

WithHTTPClient adds the HTTPClient to the list replication tasks params

func (*ListReplicationTasksParams) WithID

WithID adds the id to the list replication tasks params

func (*ListReplicationTasksParams) WithPage

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

WithSort adds the sort to the list replication tasks params

func (*ListReplicationTasksParams) WithStatus

WithStatus adds the status to the list replication tasks params

func (*ListReplicationTasksParams) WithTimeout

WithTimeout adds the timeout to the list replication tasks params

func (*ListReplicationTasksParams) WithXRequestID

func (o *ListReplicationTasksParams) WithXRequestID(xRequestID *string) *ListReplicationTasksParams

WithXRequestID adds the xRequestID to the list replication tasks params

func (*ListReplicationTasksParams) WriteToRequest

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 *model.Errors
}

ListReplicationTasksUnauthorized handles this case with default header values.

Unauthorized

func NewListReplicationTasksUnauthorized

func NewListReplicationTasksUnauthorized() *ListReplicationTasksUnauthorized

NewListReplicationTasksUnauthorized creates a ListReplicationTasksUnauthorized with default headers values

func (*ListReplicationTasksUnauthorized) Error

func (*ListReplicationTasksUnauthorized) GetPayload

type StartReplicationBadRequest

type StartReplicationBadRequest struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

StartReplicationBadRequest handles this case with default header values.

Bad request

func NewStartReplicationBadRequest

func NewStartReplicationBadRequest() *StartReplicationBadRequest

NewStartReplicationBadRequest creates a StartReplicationBadRequest with default headers values

func (*StartReplicationBadRequest) Error

func (*StartReplicationBadRequest) GetPayload

func (o *StartReplicationBadRequest) GetPayload() *model.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 handles this case 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 *model.Errors
}

StartReplicationForbidden handles this case 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() *model.Errors

type StartReplicationInternalServerError

type StartReplicationInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

StartReplicationInternalServerError handles this case with default header values.

Internal server error

func NewStartReplicationInternalServerError

func NewStartReplicationInternalServerError() *StartReplicationInternalServerError

NewStartReplicationInternalServerError creates a StartReplicationInternalServerError with default headers values

func (*StartReplicationInternalServerError) Error

func (*StartReplicationInternalServerError) GetPayload

type StartReplicationParams

type StartReplicationParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*Execution
	  The ID of policy that the execution belongs to

	*/
	Execution *model.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 values initialized.

func NewStartReplicationParamsWithContext

func NewStartReplicationParamsWithContext(ctx context.Context) *StartReplicationParams

NewStartReplicationParamsWithContext creates a new StartReplicationParams object with the default values initialized, and 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 default values initialized, and 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 default values initialized, and 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) SetExecution

func (o *StartReplicationParams) SetExecution(execution *model.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) SetXRequestID

func (o *StartReplicationParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the start replication params

func (*StartReplicationParams) WithContext

WithContext adds the context to the start replication params

func (*StartReplicationParams) WithExecution

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

WithTimeout adds the timeout to the start replication params

func (*StartReplicationParams) WithXRequestID

func (o *StartReplicationParams) WithXRequestID(xRequestID *string) *StartReplicationParams

WithXRequestID adds the xRequestID to the start replication params

func (*StartReplicationParams) WriteToRequest

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 *model.Errors
}

StartReplicationUnauthorized handles this case with default header values.

Unauthorized

func NewStartReplicationUnauthorized

func NewStartReplicationUnauthorized() *StartReplicationUnauthorized

NewStartReplicationUnauthorized creates a StartReplicationUnauthorized with default headers values

func (*StartReplicationUnauthorized) Error

func (*StartReplicationUnauthorized) GetPayload

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

type StopReplicationForbidden

type StopReplicationForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

StopReplicationForbidden handles this case 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() *model.Errors

type StopReplicationInternalServerError

type StopReplicationInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

StopReplicationInternalServerError handles this case with default header values.

Internal server error

func NewStopReplicationInternalServerError

func NewStopReplicationInternalServerError() *StopReplicationInternalServerError

NewStopReplicationInternalServerError creates a StopReplicationInternalServerError with default headers values

func (*StopReplicationInternalServerError) Error

func (*StopReplicationInternalServerError) GetPayload

type StopReplicationNotFound

type StopReplicationNotFound struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

StopReplicationNotFound handles this case 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() *model.Errors

type StopReplicationOK

type StopReplicationOK struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string
}

StopReplicationOK handles this case 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 {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*ID
	  The ID of the execution.

	*/
	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 values initialized.

func NewStopReplicationParamsWithContext

func NewStopReplicationParamsWithContext(ctx context.Context) *StopReplicationParams

NewStopReplicationParamsWithContext creates a new StopReplicationParams object with the default values initialized, and 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 default values initialized, and 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 default values initialized, and 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) 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) SetXRequestID

func (o *StopReplicationParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the stop replication params

func (*StopReplicationParams) WithContext

WithContext adds the context to the stop replication params

func (*StopReplicationParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the stop replication params

func (*StopReplicationParams) WithID

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

func (o *StopReplicationParams) WithXRequestID(xRequestID *string) *StopReplicationParams

WithXRequestID adds the xRequestID 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 *model.Errors
}

StopReplicationUnauthorized handles this case with default header values.

Unauthorized

func NewStopReplicationUnauthorized

func NewStopReplicationUnauthorized() *StopReplicationUnauthorized

NewStopReplicationUnauthorized creates a StopReplicationUnauthorized with default headers values

func (*StopReplicationUnauthorized) Error

func (*StopReplicationUnauthorized) GetPayload

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

type UpdateReplicationPolicyConflict

type UpdateReplicationPolicyConflict struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

UpdateReplicationPolicyConflict handles this case with default header values.

Conflict

func NewUpdateReplicationPolicyConflict

func NewUpdateReplicationPolicyConflict() *UpdateReplicationPolicyConflict

NewUpdateReplicationPolicyConflict creates a UpdateReplicationPolicyConflict with default headers values

func (*UpdateReplicationPolicyConflict) Error

func (*UpdateReplicationPolicyConflict) GetPayload

func (o *UpdateReplicationPolicyConflict) GetPayload() *model.Errors

type UpdateReplicationPolicyForbidden

type UpdateReplicationPolicyForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

UpdateReplicationPolicyForbidden handles this case with default header values.

Forbidden

func NewUpdateReplicationPolicyForbidden

func NewUpdateReplicationPolicyForbidden() *UpdateReplicationPolicyForbidden

NewUpdateReplicationPolicyForbidden creates a UpdateReplicationPolicyForbidden with default headers values

func (*UpdateReplicationPolicyForbidden) Error

func (*UpdateReplicationPolicyForbidden) GetPayload

type UpdateReplicationPolicyInternalServerError

type UpdateReplicationPolicyInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

UpdateReplicationPolicyInternalServerError handles this case with default header values.

Internal server error

func NewUpdateReplicationPolicyInternalServerError

func NewUpdateReplicationPolicyInternalServerError() *UpdateReplicationPolicyInternalServerError

NewUpdateReplicationPolicyInternalServerError creates a UpdateReplicationPolicyInternalServerError with default headers values

func (*UpdateReplicationPolicyInternalServerError) Error

func (*UpdateReplicationPolicyInternalServerError) GetPayload

type UpdateReplicationPolicyNotFound

type UpdateReplicationPolicyNotFound struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

UpdateReplicationPolicyNotFound handles this case with default header values.

Not found

func NewUpdateReplicationPolicyNotFound

func NewUpdateReplicationPolicyNotFound() *UpdateReplicationPolicyNotFound

NewUpdateReplicationPolicyNotFound creates a UpdateReplicationPolicyNotFound with default headers values

func (*UpdateReplicationPolicyNotFound) Error

func (*UpdateReplicationPolicyNotFound) GetPayload

func (o *UpdateReplicationPolicyNotFound) GetPayload() *model.Errors

type UpdateReplicationPolicyOK

type UpdateReplicationPolicyOK struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string
}

UpdateReplicationPolicyOK handles this case with default header values.

Success

func NewUpdateReplicationPolicyOK

func NewUpdateReplicationPolicyOK() *UpdateReplicationPolicyOK

NewUpdateReplicationPolicyOK creates a UpdateReplicationPolicyOK with default headers values

func (*UpdateReplicationPolicyOK) Error

func (o *UpdateReplicationPolicyOK) Error() string

type UpdateReplicationPolicyParams

type UpdateReplicationPolicyParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*ID
	  The policy ID

	*/
	ID int64
	/*Policy
	  The replication policy

	*/
	Policy *model.ReplicationPolicy

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

UpdateReplicationPolicyParams contains all the parameters to send to the API endpoint for the update replication policy operation typically these are written to a http.Request

func NewUpdateReplicationPolicyParams

func NewUpdateReplicationPolicyParams() *UpdateReplicationPolicyParams

NewUpdateReplicationPolicyParams creates a new UpdateReplicationPolicyParams object with the default values initialized.

func NewUpdateReplicationPolicyParamsWithContext

func NewUpdateReplicationPolicyParamsWithContext(ctx context.Context) *UpdateReplicationPolicyParams

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

func NewUpdateReplicationPolicyParamsWithHTTPClient

func NewUpdateReplicationPolicyParamsWithHTTPClient(client *http.Client) *UpdateReplicationPolicyParams

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

func NewUpdateReplicationPolicyParamsWithTimeout

func NewUpdateReplicationPolicyParamsWithTimeout(timeout time.Duration) *UpdateReplicationPolicyParams

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

func (*UpdateReplicationPolicyParams) SetContext

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

SetContext adds the context to the update replication policy params

func (*UpdateReplicationPolicyParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the update replication policy params

func (*UpdateReplicationPolicyParams) SetID

func (o *UpdateReplicationPolicyParams) SetID(id int64)

SetID adds the id to the update replication policy params

func (*UpdateReplicationPolicyParams) SetPolicy

SetPolicy adds the policy to the update replication policy params

func (*UpdateReplicationPolicyParams) SetTimeout

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

SetTimeout adds the timeout to the update replication policy params

func (*UpdateReplicationPolicyParams) SetXRequestID

func (o *UpdateReplicationPolicyParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the update replication policy params

func (*UpdateReplicationPolicyParams) WithContext

WithContext adds the context to the update replication policy params

func (*UpdateReplicationPolicyParams) WithHTTPClient

WithHTTPClient adds the HTTPClient to the update replication policy params

func (*UpdateReplicationPolicyParams) WithID

WithID adds the id to the update replication policy params

func (*UpdateReplicationPolicyParams) WithPolicy

WithPolicy adds the policy to the update replication policy params

func (*UpdateReplicationPolicyParams) WithTimeout

WithTimeout adds the timeout to the update replication policy params

func (*UpdateReplicationPolicyParams) WithXRequestID

func (o *UpdateReplicationPolicyParams) WithXRequestID(xRequestID *string) *UpdateReplicationPolicyParams

WithXRequestID adds the xRequestID to the update replication policy params

func (*UpdateReplicationPolicyParams) WriteToRequest

WriteToRequest writes these params to a swagger request

type UpdateReplicationPolicyReader

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

UpdateReplicationPolicyReader is a Reader for the UpdateReplicationPolicy structure.

func (*UpdateReplicationPolicyReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type UpdateReplicationPolicyUnauthorized

type UpdateReplicationPolicyUnauthorized struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

UpdateReplicationPolicyUnauthorized handles this case with default header values.

Unauthorized

func NewUpdateReplicationPolicyUnauthorized

func NewUpdateReplicationPolicyUnauthorized() *UpdateReplicationPolicyUnauthorized

NewUpdateReplicationPolicyUnauthorized creates a UpdateReplicationPolicyUnauthorized with default headers values

func (*UpdateReplicationPolicyUnauthorized) Error

func (*UpdateReplicationPolicyUnauthorized) GetPayload

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL