connections

package
v1.19.1 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

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

Client for connections API

func (*Client) DeleteConnection 

func (a *Client) DeleteConnection(params *DeleteConnectionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteConnectionOK, error)

DeleteConnection deletes a connection

func (*Client) GetConnection 

func (a *Client) GetConnection(params *GetConnectionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetConnectionOK, error)

GetConnection gets a connection

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

func (*Client) UpdateConnection 

func (a *Client) UpdateConnection(params *UpdateConnectionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*UpdateConnectionOK, error)

UpdateConnection updates a connection

type ClientOption 

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService 

type ClientService interface {
	DeleteConnection(params *DeleteConnectionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteConnectionOK, error)

	GetConnection(params *GetConnectionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetConnectionOK, error)

	UpdateConnection(params *UpdateConnectionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*UpdateConnectionOK, 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 connections API client.

type DeleteConnectionBadRequest 

type DeleteConnectionBadRequest struct {
}

DeleteConnectionBadRequest describes a response with status code 400, with default header values.

NiFi was unable to complete the request because it was invalid. The request should not be retried without modification.

func NewDeleteConnectionBadRequest 

func NewDeleteConnectionBadRequest() *DeleteConnectionBadRequest

NewDeleteConnectionBadRequest creates a DeleteConnectionBadRequest with default headers values

func (*DeleteConnectionBadRequest) Error 

func (o *DeleteConnectionBadRequest) Error() string

func (*DeleteConnectionBadRequest) IsClientError added in v1.19.1 

func (o *DeleteConnectionBadRequest) IsClientError() bool

IsClientError returns true when this delete connection bad request response has a 4xx status code

func (*DeleteConnectionBadRequest) IsCode added in v1.19.1 

func (o *DeleteConnectionBadRequest) IsCode(code int) bool

IsCode returns true when this delete connection bad request response a status code equal to that given

func (*DeleteConnectionBadRequest) IsRedirect added in v1.19.1 

func (o *DeleteConnectionBadRequest) IsRedirect() bool

IsRedirect returns true when this delete connection bad request response has a 3xx status code

func (*DeleteConnectionBadRequest) IsServerError added in v1.19.1 

func (o *DeleteConnectionBadRequest) IsServerError() bool

IsServerError returns true when this delete connection bad request response has a 5xx status code

func (*DeleteConnectionBadRequest) IsSuccess added in v1.19.1 

func (o *DeleteConnectionBadRequest) IsSuccess() bool

IsSuccess returns true when this delete connection bad request response has a 2xx status code

func (*DeleteConnectionBadRequest) String added in v1.19.1 

func (o *DeleteConnectionBadRequest) String() string

type DeleteConnectionConflict 

type DeleteConnectionConflict struct {
}

DeleteConnectionConflict describes a response with status code 409, with default header values.

The request was valid but NiFi was not in the appropriate state to process it. Retrying the same request later may be successful.

func NewDeleteConnectionConflict 

func NewDeleteConnectionConflict() *DeleteConnectionConflict

NewDeleteConnectionConflict creates a DeleteConnectionConflict with default headers values

func (*DeleteConnectionConflict) Error 

func (o *DeleteConnectionConflict) Error() string

func (*DeleteConnectionConflict) IsClientError added in v1.19.1 

func (o *DeleteConnectionConflict) IsClientError() bool

IsClientError returns true when this delete connection conflict response has a 4xx status code

func (*DeleteConnectionConflict) IsCode added in v1.19.1 

func (o *DeleteConnectionConflict) IsCode(code int) bool

IsCode returns true when this delete connection conflict response a status code equal to that given

func (*DeleteConnectionConflict) IsRedirect added in v1.19.1 

func (o *DeleteConnectionConflict) IsRedirect() bool

IsRedirect returns true when this delete connection conflict response has a 3xx status code

func (*DeleteConnectionConflict) IsServerError added in v1.19.1 

func (o *DeleteConnectionConflict) IsServerError() bool

IsServerError returns true when this delete connection conflict response has a 5xx status code

func (*DeleteConnectionConflict) IsSuccess added in v1.19.1 

func (o *DeleteConnectionConflict) IsSuccess() bool

IsSuccess returns true when this delete connection conflict response has a 2xx status code

func (*DeleteConnectionConflict) String added in v1.19.1 

func (o *DeleteConnectionConflict) String() string

type DeleteConnectionForbidden 

type DeleteConnectionForbidden struct {
}

DeleteConnectionForbidden describes a response with status code 403, with default header values.

Client is not authorized to make this request.

func NewDeleteConnectionForbidden 

func NewDeleteConnectionForbidden() *DeleteConnectionForbidden

NewDeleteConnectionForbidden creates a DeleteConnectionForbidden with default headers values

func (*DeleteConnectionForbidden) Error 

func (o *DeleteConnectionForbidden) Error() string

func (*DeleteConnectionForbidden) IsClientError added in v1.19.1 

func (o *DeleteConnectionForbidden) IsClientError() bool

IsClientError returns true when this delete connection forbidden response has a 4xx status code

func (*DeleteConnectionForbidden) IsCode added in v1.19.1 

func (o *DeleteConnectionForbidden) IsCode(code int) bool

IsCode returns true when this delete connection forbidden response a status code equal to that given

func (*DeleteConnectionForbidden) IsRedirect added in v1.19.1 

func (o *DeleteConnectionForbidden) IsRedirect() bool

IsRedirect returns true when this delete connection forbidden response has a 3xx status code

func (*DeleteConnectionForbidden) IsServerError added in v1.19.1 

func (o *DeleteConnectionForbidden) IsServerError() bool

IsServerError returns true when this delete connection forbidden response has a 5xx status code

func (*DeleteConnectionForbidden) IsSuccess added in v1.19.1 

func (o *DeleteConnectionForbidden) IsSuccess() bool

IsSuccess returns true when this delete connection forbidden response has a 2xx status code

func (*DeleteConnectionForbidden) String added in v1.19.1 

func (o *DeleteConnectionForbidden) String() string

type DeleteConnectionNotFound 

type DeleteConnectionNotFound struct {
}

DeleteConnectionNotFound describes a response with status code 404, with default header values.

The specified resource could not be found.

func NewDeleteConnectionNotFound 

func NewDeleteConnectionNotFound() *DeleteConnectionNotFound

NewDeleteConnectionNotFound creates a DeleteConnectionNotFound with default headers values

func (*DeleteConnectionNotFound) Error 

func (o *DeleteConnectionNotFound) Error() string

func (*DeleteConnectionNotFound) IsClientError added in v1.19.1 

func (o *DeleteConnectionNotFound) IsClientError() bool

IsClientError returns true when this delete connection not found response has a 4xx status code

func (*DeleteConnectionNotFound) IsCode added in v1.19.1 

func (o *DeleteConnectionNotFound) IsCode(code int) bool

IsCode returns true when this delete connection not found response a status code equal to that given

func (*DeleteConnectionNotFound) IsRedirect added in v1.19.1 

func (o *DeleteConnectionNotFound) IsRedirect() bool

IsRedirect returns true when this delete connection not found response has a 3xx status code

func (*DeleteConnectionNotFound) IsServerError added in v1.19.1 

func (o *DeleteConnectionNotFound) IsServerError() bool

IsServerError returns true when this delete connection not found response has a 5xx status code

func (*DeleteConnectionNotFound) IsSuccess added in v1.19.1 

func (o *DeleteConnectionNotFound) IsSuccess() bool

IsSuccess returns true when this delete connection not found response has a 2xx status code

func (*DeleteConnectionNotFound) String added in v1.19.1 

func (o *DeleteConnectionNotFound) String() string

type DeleteConnectionOK 

type DeleteConnectionOK struct {
	Payload *models.ConnectionEntity
}

DeleteConnectionOK describes a response with status code 200, with default header values.

successful operation

func NewDeleteConnectionOK 

func NewDeleteConnectionOK() *DeleteConnectionOK

NewDeleteConnectionOK creates a DeleteConnectionOK with default headers values

func (*DeleteConnectionOK) Error 

func (o *DeleteConnectionOK) Error() string

func (*DeleteConnectionOK) GetPayload 

func (o *DeleteConnectionOK) GetPayload() *models.ConnectionEntity

func (*DeleteConnectionOK) IsClientError added in v1.19.1 

func (o *DeleteConnectionOK) IsClientError() bool

IsClientError returns true when this delete connection o k response has a 4xx status code

func (*DeleteConnectionOK) IsCode added in v1.19.1 

func (o *DeleteConnectionOK) IsCode(code int) bool

IsCode returns true when this delete connection o k response a status code equal to that given

func (*DeleteConnectionOK) IsRedirect added in v1.19.1 

func (o *DeleteConnectionOK) IsRedirect() bool

IsRedirect returns true when this delete connection o k response has a 3xx status code

func (*DeleteConnectionOK) IsServerError added in v1.19.1 

func (o *DeleteConnectionOK) IsServerError() bool

IsServerError returns true when this delete connection o k response has a 5xx status code

func (*DeleteConnectionOK) IsSuccess added in v1.19.1 

func (o *DeleteConnectionOK) IsSuccess() bool

IsSuccess returns true when this delete connection o k response has a 2xx status code

func (*DeleteConnectionOK) String added in v1.19.1 

func (o *DeleteConnectionOK) String() string

type DeleteConnectionParams 

type DeleteConnectionParams struct {

	/* ClientID.

	   If the client id is not specified, new one will be generated. This value (whether specified or generated) is included in the response.
	*/
	ClientID *string

	/* DisconnectedNodeAcknowledged.

	   Acknowledges that this node is disconnected to allow for mutable requests to proceed.
	*/
	DisconnectedNodeAcknowledged *bool

	/* ID.

	   The connection id.
	*/
	ID string

	/* Version.

	   The revision is used to verify the client is working with the latest version of the flow.
	*/
	Version *string

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

DeleteConnectionParams contains all the parameters to send to the API endpoint 

for the delete connection operation.

Typically these are written to a http.Request.

func NewDeleteConnectionParams 

func NewDeleteConnectionParams() *DeleteConnectionParams

NewDeleteConnectionParams creates a new DeleteConnectionParams 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 NewDeleteConnectionParamsWithContext 

func NewDeleteConnectionParamsWithContext(ctx context.Context) *DeleteConnectionParams

NewDeleteConnectionParamsWithContext creates a new DeleteConnectionParams object with the ability to set a context for a request.

func NewDeleteConnectionParamsWithHTTPClient 

func NewDeleteConnectionParamsWithHTTPClient(client *http.Client) *DeleteConnectionParams

NewDeleteConnectionParamsWithHTTPClient creates a new DeleteConnectionParams object with the ability to set a custom HTTPClient for a request.

func NewDeleteConnectionParamsWithTimeout 

func NewDeleteConnectionParamsWithTimeout(timeout time.Duration) *DeleteConnectionParams

NewDeleteConnectionParamsWithTimeout creates a new DeleteConnectionParams object with the ability to set a timeout on a request.

func (*DeleteConnectionParams) SetClientID 

func (o *DeleteConnectionParams) SetClientID(clientID *string)

SetClientID adds the clientId to the delete connection params

func (*DeleteConnectionParams) SetContext 

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

SetContext adds the context to the delete connection params

func (*DeleteConnectionParams) SetDefaults 

func (o *DeleteConnectionParams) SetDefaults()

SetDefaults hydrates default values in the delete connection params (not the query body).

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

func (*DeleteConnectionParams) SetDisconnectedNodeAcknowledged 

func (o *DeleteConnectionParams) SetDisconnectedNodeAcknowledged(disconnectedNodeAcknowledged *bool)

SetDisconnectedNodeAcknowledged adds the disconnectedNodeAcknowledged to the delete connection params

func (*DeleteConnectionParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the delete connection params

func (*DeleteConnectionParams) SetID 

func (o *DeleteConnectionParams) SetID(id string)

SetID adds the id to the delete connection params

func (*DeleteConnectionParams) SetTimeout 

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

SetTimeout adds the timeout to the delete connection params

func (*DeleteConnectionParams) SetVersion 

func (o *DeleteConnectionParams) SetVersion(version *string)

SetVersion adds the version to the delete connection params

func (*DeleteConnectionParams) WithClientID 

func (o *DeleteConnectionParams) WithClientID(clientID *string) *DeleteConnectionParams

WithClientID adds the clientID to the delete connection params

func (*DeleteConnectionParams) WithContext 

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

WithContext adds the context to the delete connection params

func (*DeleteConnectionParams) WithDefaults 

func (o *DeleteConnectionParams) WithDefaults() *DeleteConnectionParams

WithDefaults hydrates default values in the delete connection params (not the query body).

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

func (*DeleteConnectionParams) WithDisconnectedNodeAcknowledged 

func (o *DeleteConnectionParams) WithDisconnectedNodeAcknowledged(disconnectedNodeAcknowledged *bool) *DeleteConnectionParams

WithDisconnectedNodeAcknowledged adds the disconnectedNodeAcknowledged to the delete connection params

func (*DeleteConnectionParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the delete connection params

func (*DeleteConnectionParams) WithID 

func (o *DeleteConnectionParams) WithID(id string) *DeleteConnectionParams

WithID adds the id to the delete connection params

func (*DeleteConnectionParams) WithTimeout 

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

WithTimeout adds the timeout to the delete connection params

func (*DeleteConnectionParams) WithVersion 

func (o *DeleteConnectionParams) WithVersion(version *string) *DeleteConnectionParams

WithVersion adds the version to the delete connection params

func (*DeleteConnectionParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type DeleteConnectionReader 

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

DeleteConnectionReader is a Reader for the DeleteConnection structure.

func (*DeleteConnectionReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type DeleteConnectionUnauthorized 

type DeleteConnectionUnauthorized struct {
}

DeleteConnectionUnauthorized describes a response with status code 401, with default header values.

Client could not be authenticated.

func NewDeleteConnectionUnauthorized 

func NewDeleteConnectionUnauthorized() *DeleteConnectionUnauthorized

NewDeleteConnectionUnauthorized creates a DeleteConnectionUnauthorized with default headers values

func (*DeleteConnectionUnauthorized) Error 

func (o *DeleteConnectionUnauthorized) Error() string

func (*DeleteConnectionUnauthorized) IsClientError added in v1.19.1 

func (o *DeleteConnectionUnauthorized) IsClientError() bool

IsClientError returns true when this delete connection unauthorized response has a 4xx status code

func (*DeleteConnectionUnauthorized) IsCode added in v1.19.1 

func (o *DeleteConnectionUnauthorized) IsCode(code int) bool

IsCode returns true when this delete connection unauthorized response a status code equal to that given

func (*DeleteConnectionUnauthorized) IsRedirect added in v1.19.1 

func (o *DeleteConnectionUnauthorized) IsRedirect() bool

IsRedirect returns true when this delete connection unauthorized response has a 3xx status code

func (*DeleteConnectionUnauthorized) IsServerError added in v1.19.1 

func (o *DeleteConnectionUnauthorized) IsServerError() bool

IsServerError returns true when this delete connection unauthorized response has a 5xx status code

func (*DeleteConnectionUnauthorized) IsSuccess added in v1.19.1 

func (o *DeleteConnectionUnauthorized) IsSuccess() bool

IsSuccess returns true when this delete connection unauthorized response has a 2xx status code

func (*DeleteConnectionUnauthorized) String added in v1.19.1 

func (o *DeleteConnectionUnauthorized) String() string

type GetConnectionBadRequest 

type GetConnectionBadRequest struct {
}

GetConnectionBadRequest describes a response with status code 400, with default header values.

NiFi was unable to complete the request because it was invalid. The request should not be retried without modification.

func NewGetConnectionBadRequest 

func NewGetConnectionBadRequest() *GetConnectionBadRequest

NewGetConnectionBadRequest creates a GetConnectionBadRequest with default headers values

func (*GetConnectionBadRequest) Error 

func (o *GetConnectionBadRequest) Error() string

func (*GetConnectionBadRequest) IsClientError added in v1.19.1 

func (o *GetConnectionBadRequest) IsClientError() bool

IsClientError returns true when this get connection bad request response has a 4xx status code

func (*GetConnectionBadRequest) IsCode added in v1.19.1 

func (o *GetConnectionBadRequest) IsCode(code int) bool

IsCode returns true when this get connection bad request response a status code equal to that given

func (*GetConnectionBadRequest) IsRedirect added in v1.19.1 

func (o *GetConnectionBadRequest) IsRedirect() bool

IsRedirect returns true when this get connection bad request response has a 3xx status code

func (*GetConnectionBadRequest) IsServerError added in v1.19.1 

func (o *GetConnectionBadRequest) IsServerError() bool

IsServerError returns true when this get connection bad request response has a 5xx status code

func (*GetConnectionBadRequest) IsSuccess added in v1.19.1 

func (o *GetConnectionBadRequest) IsSuccess() bool

IsSuccess returns true when this get connection bad request response has a 2xx status code

func (*GetConnectionBadRequest) String added in v1.19.1 

func (o *GetConnectionBadRequest) String() string

type GetConnectionConflict 

type GetConnectionConflict struct {
}

GetConnectionConflict describes a response with status code 409, with default header values.

The request was valid but NiFi was not in the appropriate state to process it. Retrying the same request later may be successful.

func NewGetConnectionConflict 

func NewGetConnectionConflict() *GetConnectionConflict

NewGetConnectionConflict creates a GetConnectionConflict with default headers values

func (*GetConnectionConflict) Error 

func (o *GetConnectionConflict) Error() string

func (*GetConnectionConflict) IsClientError added in v1.19.1 

func (o *GetConnectionConflict) IsClientError() bool

IsClientError returns true when this get connection conflict response has a 4xx status code

func (*GetConnectionConflict) IsCode added in v1.19.1 

func (o *GetConnectionConflict) IsCode(code int) bool

IsCode returns true when this get connection conflict response a status code equal to that given

func (*GetConnectionConflict) IsRedirect added in v1.19.1 

func (o *GetConnectionConflict) IsRedirect() bool

IsRedirect returns true when this get connection conflict response has a 3xx status code

func (*GetConnectionConflict) IsServerError added in v1.19.1 

func (o *GetConnectionConflict) IsServerError() bool

IsServerError returns true when this get connection conflict response has a 5xx status code

func (*GetConnectionConflict) IsSuccess added in v1.19.1 

func (o *GetConnectionConflict) IsSuccess() bool

IsSuccess returns true when this get connection conflict response has a 2xx status code

func (*GetConnectionConflict) String added in v1.19.1 

func (o *GetConnectionConflict) String() string

type GetConnectionForbidden 

type GetConnectionForbidden struct {
}

GetConnectionForbidden describes a response with status code 403, with default header values.

Client is not authorized to make this request.

func NewGetConnectionForbidden 

func NewGetConnectionForbidden() *GetConnectionForbidden

NewGetConnectionForbidden creates a GetConnectionForbidden with default headers values

func (*GetConnectionForbidden) Error 

func (o *GetConnectionForbidden) Error() string

func (*GetConnectionForbidden) IsClientError added in v1.19.1 

func (o *GetConnectionForbidden) IsClientError() bool

IsClientError returns true when this get connection forbidden response has a 4xx status code

func (*GetConnectionForbidden) IsCode added in v1.19.1 

func (o *GetConnectionForbidden) IsCode(code int) bool

IsCode returns true when this get connection forbidden response a status code equal to that given

func (*GetConnectionForbidden) IsRedirect added in v1.19.1 

func (o *GetConnectionForbidden) IsRedirect() bool

IsRedirect returns true when this get connection forbidden response has a 3xx status code

func (*GetConnectionForbidden) IsServerError added in v1.19.1 

func (o *GetConnectionForbidden) IsServerError() bool

IsServerError returns true when this get connection forbidden response has a 5xx status code

func (*GetConnectionForbidden) IsSuccess added in v1.19.1 

func (o *GetConnectionForbidden) IsSuccess() bool

IsSuccess returns true when this get connection forbidden response has a 2xx status code

func (*GetConnectionForbidden) String added in v1.19.1 

func (o *GetConnectionForbidden) String() string

type GetConnectionNotFound 

type GetConnectionNotFound struct {
}

GetConnectionNotFound describes a response with status code 404, with default header values.

The specified resource could not be found.

func NewGetConnectionNotFound 

func NewGetConnectionNotFound() *GetConnectionNotFound

NewGetConnectionNotFound creates a GetConnectionNotFound with default headers values

func (*GetConnectionNotFound) Error 

func (o *GetConnectionNotFound) Error() string

func (*GetConnectionNotFound) IsClientError added in v1.19.1 

func (o *GetConnectionNotFound) IsClientError() bool

IsClientError returns true when this get connection not found response has a 4xx status code

func (*GetConnectionNotFound) IsCode added in v1.19.1 

func (o *GetConnectionNotFound) IsCode(code int) bool

IsCode returns true when this get connection not found response a status code equal to that given

func (*GetConnectionNotFound) IsRedirect added in v1.19.1 

func (o *GetConnectionNotFound) IsRedirect() bool

IsRedirect returns true when this get connection not found response has a 3xx status code

func (*GetConnectionNotFound) IsServerError added in v1.19.1 

func (o *GetConnectionNotFound) IsServerError() bool

IsServerError returns true when this get connection not found response has a 5xx status code

func (*GetConnectionNotFound) IsSuccess added in v1.19.1 

func (o *GetConnectionNotFound) IsSuccess() bool

IsSuccess returns true when this get connection not found response has a 2xx status code

func (*GetConnectionNotFound) String added in v1.19.1 

func (o *GetConnectionNotFound) String() string

type GetConnectionOK 

type GetConnectionOK struct {
	Payload *models.ConnectionEntity
}

GetConnectionOK describes a response with status code 200, with default header values.

successful operation

func NewGetConnectionOK 

func NewGetConnectionOK() *GetConnectionOK

NewGetConnectionOK creates a GetConnectionOK with default headers values

func (*GetConnectionOK) Error 

func (o *GetConnectionOK) Error() string

func (*GetConnectionOK) GetPayload 

func (o *GetConnectionOK) GetPayload() *models.ConnectionEntity

func (*GetConnectionOK) IsClientError added in v1.19.1 

func (o *GetConnectionOK) IsClientError() bool

IsClientError returns true when this get connection o k response has a 4xx status code

func (*GetConnectionOK) IsCode added in v1.19.1 

func (o *GetConnectionOK) IsCode(code int) bool

IsCode returns true when this get connection o k response a status code equal to that given

func (*GetConnectionOK) IsRedirect added in v1.19.1 

func (o *GetConnectionOK) IsRedirect() bool

IsRedirect returns true when this get connection o k response has a 3xx status code

func (*GetConnectionOK) IsServerError added in v1.19.1 

func (o *GetConnectionOK) IsServerError() bool

IsServerError returns true when this get connection o k response has a 5xx status code

func (*GetConnectionOK) IsSuccess added in v1.19.1 

func (o *GetConnectionOK) IsSuccess() bool

IsSuccess returns true when this get connection o k response has a 2xx status code

func (*GetConnectionOK) String added in v1.19.1 

func (o *GetConnectionOK) String() string

type GetConnectionParams 

type GetConnectionParams struct {

	/* ID.

	   The connection id.
	*/
	ID string

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

GetConnectionParams contains all the parameters to send to the API endpoint 

for the get connection operation.

Typically these are written to a http.Request.

func NewGetConnectionParams 

func NewGetConnectionParams() *GetConnectionParams

NewGetConnectionParams creates a new GetConnectionParams 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 NewGetConnectionParamsWithContext 

func NewGetConnectionParamsWithContext(ctx context.Context) *GetConnectionParams

NewGetConnectionParamsWithContext creates a new GetConnectionParams object with the ability to set a context for a request.

func NewGetConnectionParamsWithHTTPClient 

func NewGetConnectionParamsWithHTTPClient(client *http.Client) *GetConnectionParams

NewGetConnectionParamsWithHTTPClient creates a new GetConnectionParams object with the ability to set a custom HTTPClient for a request.

func NewGetConnectionParamsWithTimeout 

func NewGetConnectionParamsWithTimeout(timeout time.Duration) *GetConnectionParams

NewGetConnectionParamsWithTimeout creates a new GetConnectionParams object with the ability to set a timeout on a request.

func (*GetConnectionParams) SetContext 

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

SetContext adds the context to the get connection params

func (*GetConnectionParams) SetDefaults 

func (o *GetConnectionParams) SetDefaults()

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

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

func (*GetConnectionParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get connection params

func (*GetConnectionParams) SetID 

func (o *GetConnectionParams) SetID(id string)

SetID adds the id to the get connection params

func (*GetConnectionParams) SetTimeout 

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

SetTimeout adds the timeout to the get connection params

func (*GetConnectionParams) WithContext 

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

WithContext adds the context to the get connection params

func (*GetConnectionParams) WithDefaults 

func (o *GetConnectionParams) WithDefaults() *GetConnectionParams

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

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

func (*GetConnectionParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get connection params

func (*GetConnectionParams) WithID 

func (o *GetConnectionParams) WithID(id string) *GetConnectionParams

WithID adds the id to the get connection params

func (*GetConnectionParams) WithTimeout 

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

WithTimeout adds the timeout to the get connection params

func (*GetConnectionParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetConnectionReader 

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

GetConnectionReader is a Reader for the GetConnection structure.

func (*GetConnectionReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetConnectionUnauthorized 

type GetConnectionUnauthorized struct {
}

GetConnectionUnauthorized describes a response with status code 401, with default header values.

Client could not be authenticated.

func NewGetConnectionUnauthorized 

func NewGetConnectionUnauthorized() *GetConnectionUnauthorized

NewGetConnectionUnauthorized creates a GetConnectionUnauthorized with default headers values

func (*GetConnectionUnauthorized) Error 

func (o *GetConnectionUnauthorized) Error() string

func (*GetConnectionUnauthorized) IsClientError added in v1.19.1 

func (o *GetConnectionUnauthorized) IsClientError() bool

IsClientError returns true when this get connection unauthorized response has a 4xx status code

func (*GetConnectionUnauthorized) IsCode added in v1.19.1 

func (o *GetConnectionUnauthorized) IsCode(code int) bool

IsCode returns true when this get connection unauthorized response a status code equal to that given

func (*GetConnectionUnauthorized) IsRedirect added in v1.19.1 

func (o *GetConnectionUnauthorized) IsRedirect() bool

IsRedirect returns true when this get connection unauthorized response has a 3xx status code

func (*GetConnectionUnauthorized) IsServerError added in v1.19.1 

func (o *GetConnectionUnauthorized) IsServerError() bool

IsServerError returns true when this get connection unauthorized response has a 5xx status code

func (*GetConnectionUnauthorized) IsSuccess added in v1.19.1 

func (o *GetConnectionUnauthorized) IsSuccess() bool

IsSuccess returns true when this get connection unauthorized response has a 2xx status code

func (*GetConnectionUnauthorized) String added in v1.19.1 

func (o *GetConnectionUnauthorized) String() string

type UpdateConnectionBadRequest 

type UpdateConnectionBadRequest struct {
}

UpdateConnectionBadRequest describes a response with status code 400, with default header values.

NiFi was unable to complete the request because it was invalid. The request should not be retried without modification.

func NewUpdateConnectionBadRequest 

func NewUpdateConnectionBadRequest() *UpdateConnectionBadRequest

NewUpdateConnectionBadRequest creates a UpdateConnectionBadRequest with default headers values

func (*UpdateConnectionBadRequest) Error 

func (o *UpdateConnectionBadRequest) Error() string

func (*UpdateConnectionBadRequest) IsClientError added in v1.19.1 

func (o *UpdateConnectionBadRequest) IsClientError() bool

IsClientError returns true when this update connection bad request response has a 4xx status code

func (*UpdateConnectionBadRequest) IsCode added in v1.19.1 

func (o *UpdateConnectionBadRequest) IsCode(code int) bool

IsCode returns true when this update connection bad request response a status code equal to that given

func (*UpdateConnectionBadRequest) IsRedirect added in v1.19.1 

func (o *UpdateConnectionBadRequest) IsRedirect() bool

IsRedirect returns true when this update connection bad request response has a 3xx status code

func (*UpdateConnectionBadRequest) IsServerError added in v1.19.1 

func (o *UpdateConnectionBadRequest) IsServerError() bool

IsServerError returns true when this update connection bad request response has a 5xx status code

func (*UpdateConnectionBadRequest) IsSuccess added in v1.19.1 

func (o *UpdateConnectionBadRequest) IsSuccess() bool

IsSuccess returns true when this update connection bad request response has a 2xx status code

func (*UpdateConnectionBadRequest) String added in v1.19.1 

func (o *UpdateConnectionBadRequest) String() string

type UpdateConnectionConflict 

type UpdateConnectionConflict struct {
}

UpdateConnectionConflict describes a response with status code 409, with default header values.

The request was valid but NiFi was not in the appropriate state to process it. Retrying the same request later may be successful.

func NewUpdateConnectionConflict 

func NewUpdateConnectionConflict() *UpdateConnectionConflict

NewUpdateConnectionConflict creates a UpdateConnectionConflict with default headers values

func (*UpdateConnectionConflict) Error 

func (o *UpdateConnectionConflict) Error() string

func (*UpdateConnectionConflict) IsClientError added in v1.19.1 

func (o *UpdateConnectionConflict) IsClientError() bool

IsClientError returns true when this update connection conflict response has a 4xx status code

func (*UpdateConnectionConflict) IsCode added in v1.19.1 

func (o *UpdateConnectionConflict) IsCode(code int) bool

IsCode returns true when this update connection conflict response a status code equal to that given

func (*UpdateConnectionConflict) IsRedirect added in v1.19.1 

func (o *UpdateConnectionConflict) IsRedirect() bool

IsRedirect returns true when this update connection conflict response has a 3xx status code

func (*UpdateConnectionConflict) IsServerError added in v1.19.1 

func (o *UpdateConnectionConflict) IsServerError() bool

IsServerError returns true when this update connection conflict response has a 5xx status code

func (*UpdateConnectionConflict) IsSuccess added in v1.19.1 

func (o *UpdateConnectionConflict) IsSuccess() bool

IsSuccess returns true when this update connection conflict response has a 2xx status code

func (*UpdateConnectionConflict) String added in v1.19.1 

func (o *UpdateConnectionConflict) String() string

type UpdateConnectionForbidden 

type UpdateConnectionForbidden struct {
}

UpdateConnectionForbidden describes a response with status code 403, with default header values.

Client is not authorized to make this request.

func NewUpdateConnectionForbidden 

func NewUpdateConnectionForbidden() *UpdateConnectionForbidden

NewUpdateConnectionForbidden creates a UpdateConnectionForbidden with default headers values

func (*UpdateConnectionForbidden) Error 

func (o *UpdateConnectionForbidden) Error() string

func (*UpdateConnectionForbidden) IsClientError added in v1.19.1 

func (o *UpdateConnectionForbidden) IsClientError() bool

IsClientError returns true when this update connection forbidden response has a 4xx status code

func (*UpdateConnectionForbidden) IsCode added in v1.19.1 

func (o *UpdateConnectionForbidden) IsCode(code int) bool

IsCode returns true when this update connection forbidden response a status code equal to that given

func (*UpdateConnectionForbidden) IsRedirect added in v1.19.1 

func (o *UpdateConnectionForbidden) IsRedirect() bool

IsRedirect returns true when this update connection forbidden response has a 3xx status code

func (*UpdateConnectionForbidden) IsServerError added in v1.19.1 

func (o *UpdateConnectionForbidden) IsServerError() bool

IsServerError returns true when this update connection forbidden response has a 5xx status code

func (*UpdateConnectionForbidden) IsSuccess added in v1.19.1 

func (o *UpdateConnectionForbidden) IsSuccess() bool

IsSuccess returns true when this update connection forbidden response has a 2xx status code

func (*UpdateConnectionForbidden) String added in v1.19.1 

func (o *UpdateConnectionForbidden) String() string

type UpdateConnectionNotFound 

type UpdateConnectionNotFound struct {
}

UpdateConnectionNotFound describes a response with status code 404, with default header values.

The specified resource could not be found.

func NewUpdateConnectionNotFound 

func NewUpdateConnectionNotFound() *UpdateConnectionNotFound

NewUpdateConnectionNotFound creates a UpdateConnectionNotFound with default headers values

func (*UpdateConnectionNotFound) Error 

func (o *UpdateConnectionNotFound) Error() string

func (*UpdateConnectionNotFound) IsClientError added in v1.19.1 

func (o *UpdateConnectionNotFound) IsClientError() bool

IsClientError returns true when this update connection not found response has a 4xx status code

func (*UpdateConnectionNotFound) IsCode added in v1.19.1 

func (o *UpdateConnectionNotFound) IsCode(code int) bool

IsCode returns true when this update connection not found response a status code equal to that given

func (*UpdateConnectionNotFound) IsRedirect added in v1.19.1 

func (o *UpdateConnectionNotFound) IsRedirect() bool

IsRedirect returns true when this update connection not found response has a 3xx status code

func (*UpdateConnectionNotFound) IsServerError added in v1.19.1 

func (o *UpdateConnectionNotFound) IsServerError() bool

IsServerError returns true when this update connection not found response has a 5xx status code

func (*UpdateConnectionNotFound) IsSuccess added in v1.19.1 

func (o *UpdateConnectionNotFound) IsSuccess() bool

IsSuccess returns true when this update connection not found response has a 2xx status code

func (*UpdateConnectionNotFound) String added in v1.19.1 

func (o *UpdateConnectionNotFound) String() string

type UpdateConnectionOK 

type UpdateConnectionOK struct {
	Payload *models.ConnectionEntity
}

UpdateConnectionOK describes a response with status code 200, with default header values.

successful operation

func NewUpdateConnectionOK 

func NewUpdateConnectionOK() *UpdateConnectionOK

NewUpdateConnectionOK creates a UpdateConnectionOK with default headers values

func (*UpdateConnectionOK) Error 

func (o *UpdateConnectionOK) Error() string

func (*UpdateConnectionOK) GetPayload 

func (o *UpdateConnectionOK) GetPayload() *models.ConnectionEntity

func (*UpdateConnectionOK) IsClientError added in v1.19.1 

func (o *UpdateConnectionOK) IsClientError() bool

IsClientError returns true when this update connection o k response has a 4xx status code

func (*UpdateConnectionOK) IsCode added in v1.19.1 

func (o *UpdateConnectionOK) IsCode(code int) bool

IsCode returns true when this update connection o k response a status code equal to that given

func (*UpdateConnectionOK) IsRedirect added in v1.19.1 

func (o *UpdateConnectionOK) IsRedirect() bool

IsRedirect returns true when this update connection o k response has a 3xx status code

func (*UpdateConnectionOK) IsServerError added in v1.19.1 

func (o *UpdateConnectionOK) IsServerError() bool

IsServerError returns true when this update connection o k response has a 5xx status code

func (*UpdateConnectionOK) IsSuccess added in v1.19.1 

func (o *UpdateConnectionOK) IsSuccess() bool

IsSuccess returns true when this update connection o k response has a 2xx status code

func (*UpdateConnectionOK) String added in v1.19.1 

func (o *UpdateConnectionOK) String() string

type UpdateConnectionParams 

type UpdateConnectionParams struct {

	/* Body.

	   The connection configuration details.
	*/
	Body *models.ConnectionEntity

	/* ID.

	   The connection id.
	*/
	ID string

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

UpdateConnectionParams contains all the parameters to send to the API endpoint 

for the update connection operation.

Typically these are written to a http.Request.

func NewUpdateConnectionParams 

func NewUpdateConnectionParams() *UpdateConnectionParams

NewUpdateConnectionParams creates a new UpdateConnectionParams 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 NewUpdateConnectionParamsWithContext 

func NewUpdateConnectionParamsWithContext(ctx context.Context) *UpdateConnectionParams

NewUpdateConnectionParamsWithContext creates a new UpdateConnectionParams object with the ability to set a context for a request.

func NewUpdateConnectionParamsWithHTTPClient 

func NewUpdateConnectionParamsWithHTTPClient(client *http.Client) *UpdateConnectionParams

NewUpdateConnectionParamsWithHTTPClient creates a new UpdateConnectionParams object with the ability to set a custom HTTPClient for a request.

func NewUpdateConnectionParamsWithTimeout 

func NewUpdateConnectionParamsWithTimeout(timeout time.Duration) *UpdateConnectionParams

NewUpdateConnectionParamsWithTimeout creates a new UpdateConnectionParams object with the ability to set a timeout on a request.

func (*UpdateConnectionParams) SetBody 

func (o *UpdateConnectionParams) SetBody(body *models.ConnectionEntity)

SetBody adds the body to the update connection params

func (*UpdateConnectionParams) SetContext 

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

SetContext adds the context to the update connection params

func (*UpdateConnectionParams) SetDefaults 

func (o *UpdateConnectionParams) SetDefaults()

SetDefaults hydrates default values in the update connection params (not the query body).

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

func (*UpdateConnectionParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the update connection params

func (*UpdateConnectionParams) SetID 

func (o *UpdateConnectionParams) SetID(id string)

SetID adds the id to the update connection params

func (*UpdateConnectionParams) SetTimeout 

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

SetTimeout adds the timeout to the update connection params

func (*UpdateConnectionParams) WithBody 

func (o *UpdateConnectionParams) WithBody(body *models.ConnectionEntity) *UpdateConnectionParams

WithBody adds the body to the update connection params

func (*UpdateConnectionParams) WithContext 

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

WithContext adds the context to the update connection params

func (*UpdateConnectionParams) WithDefaults 

func (o *UpdateConnectionParams) WithDefaults() *UpdateConnectionParams

WithDefaults hydrates default values in the update connection params (not the query body).

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

func (*UpdateConnectionParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the update connection params

func (*UpdateConnectionParams) WithID 

func (o *UpdateConnectionParams) WithID(id string) *UpdateConnectionParams

WithID adds the id to the update connection params

func (*UpdateConnectionParams) WithTimeout 

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

WithTimeout adds the timeout to the update connection params

func (*UpdateConnectionParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type UpdateConnectionReader 

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

UpdateConnectionReader is a Reader for the UpdateConnection structure.

func (*UpdateConnectionReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type UpdateConnectionUnauthorized 

type UpdateConnectionUnauthorized struct {
}

UpdateConnectionUnauthorized describes a response with status code 401, with default header values.

Client could not be authenticated.

func NewUpdateConnectionUnauthorized 

func NewUpdateConnectionUnauthorized() *UpdateConnectionUnauthorized

NewUpdateConnectionUnauthorized creates a UpdateConnectionUnauthorized with default headers values

func (*UpdateConnectionUnauthorized) Error 

func (o *UpdateConnectionUnauthorized) Error() string

func (*UpdateConnectionUnauthorized) IsClientError added in v1.19.1 

func (o *UpdateConnectionUnauthorized) IsClientError() bool

IsClientError returns true when this update connection unauthorized response has a 4xx status code

func (*UpdateConnectionUnauthorized) IsCode added in v1.19.1 

func (o *UpdateConnectionUnauthorized) IsCode(code int) bool

IsCode returns true when this update connection unauthorized response a status code equal to that given

func (*UpdateConnectionUnauthorized) IsRedirect added in v1.19.1 

func (o *UpdateConnectionUnauthorized) IsRedirect() bool

IsRedirect returns true when this update connection unauthorized response has a 3xx status code

func (*UpdateConnectionUnauthorized) IsServerError added in v1.19.1 

func (o *UpdateConnectionUnauthorized) IsServerError() bool

IsServerError returns true when this update connection unauthorized response has a 5xx status code

func (*UpdateConnectionUnauthorized) IsSuccess added in v1.19.1 

func (o *UpdateConnectionUnauthorized) IsSuccess() bool

IsSuccess returns true when this update connection unauthorized response has a 2xx status code

func (*UpdateConnectionUnauthorized) String added in v1.19.1 

func (o *UpdateConnectionUnauthorized) String() string

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.