input_ports

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 input ports API

func (*Client) GetInputPort 

func (a *Client) GetInputPort(params *GetInputPortParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetInputPortOK, error)

GetInputPort gets an input port

func (*Client) RemoveInputPort 

func (a *Client) RemoveInputPort(params *RemoveInputPortParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*RemoveInputPortOK, error)

RemoveInputPort deletes an input port

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

func (*Client) UpdateInputPort 

func (a *Client) UpdateInputPort(params *UpdateInputPortParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*UpdateInputPortOK, error)

UpdateInputPort updates an input port

type ClientOption 

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService 

type ClientService interface {
	GetInputPort(params *GetInputPortParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetInputPortOK, error)

	RemoveInputPort(params *RemoveInputPortParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*RemoveInputPortOK, error)

	UpdateInputPort(params *UpdateInputPortParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*UpdateInputPortOK, 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 input ports API client.

type GetInputPortBadRequest 

type GetInputPortBadRequest struct {
}

GetInputPortBadRequest 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 NewGetInputPortBadRequest 

func NewGetInputPortBadRequest() *GetInputPortBadRequest

NewGetInputPortBadRequest creates a GetInputPortBadRequest with default headers values

func (*GetInputPortBadRequest) Error 

func (o *GetInputPortBadRequest) Error() string

func (*GetInputPortBadRequest) IsClientError added in v1.19.1 

func (o *GetInputPortBadRequest) IsClientError() bool

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

func (*GetInputPortBadRequest) IsCode added in v1.19.1 

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

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

func (*GetInputPortBadRequest) IsRedirect added in v1.19.1 

func (o *GetInputPortBadRequest) IsRedirect() bool

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

func (*GetInputPortBadRequest) IsServerError added in v1.19.1 

func (o *GetInputPortBadRequest) IsServerError() bool

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

func (*GetInputPortBadRequest) IsSuccess added in v1.19.1 

func (o *GetInputPortBadRequest) IsSuccess() bool

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

func (*GetInputPortBadRequest) String added in v1.19.1 

func (o *GetInputPortBadRequest) String() string

type GetInputPortConflict 

type GetInputPortConflict struct {
}

GetInputPortConflict 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 NewGetInputPortConflict 

func NewGetInputPortConflict() *GetInputPortConflict

NewGetInputPortConflict creates a GetInputPortConflict with default headers values

func (*GetInputPortConflict) Error 

func (o *GetInputPortConflict) Error() string

func (*GetInputPortConflict) IsClientError added in v1.19.1 

func (o *GetInputPortConflict) IsClientError() bool

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

func (*GetInputPortConflict) IsCode added in v1.19.1 

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

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

func (*GetInputPortConflict) IsRedirect added in v1.19.1 

func (o *GetInputPortConflict) IsRedirect() bool

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

func (*GetInputPortConflict) IsServerError added in v1.19.1 

func (o *GetInputPortConflict) IsServerError() bool

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

func (*GetInputPortConflict) IsSuccess added in v1.19.1 

func (o *GetInputPortConflict) IsSuccess() bool

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

func (*GetInputPortConflict) String added in v1.19.1 

func (o *GetInputPortConflict) String() string

type GetInputPortForbidden 

type GetInputPortForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetInputPortForbidden 

func NewGetInputPortForbidden() *GetInputPortForbidden

NewGetInputPortForbidden creates a GetInputPortForbidden with default headers values

func (*GetInputPortForbidden) Error 

func (o *GetInputPortForbidden) Error() string

func (*GetInputPortForbidden) IsClientError added in v1.19.1 

func (o *GetInputPortForbidden) IsClientError() bool

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

func (*GetInputPortForbidden) IsCode added in v1.19.1 

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

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

func (*GetInputPortForbidden) IsRedirect added in v1.19.1 

func (o *GetInputPortForbidden) IsRedirect() bool

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

func (*GetInputPortForbidden) IsServerError added in v1.19.1 

func (o *GetInputPortForbidden) IsServerError() bool

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

func (*GetInputPortForbidden) IsSuccess added in v1.19.1 

func (o *GetInputPortForbidden) IsSuccess() bool

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

func (*GetInputPortForbidden) String added in v1.19.1 

func (o *GetInputPortForbidden) String() string

type GetInputPortNotFound 

type GetInputPortNotFound struct {
}

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

The specified resource could not be found.

func NewGetInputPortNotFound 

func NewGetInputPortNotFound() *GetInputPortNotFound

NewGetInputPortNotFound creates a GetInputPortNotFound with default headers values

func (*GetInputPortNotFound) Error 

func (o *GetInputPortNotFound) Error() string

func (*GetInputPortNotFound) IsClientError added in v1.19.1 

func (o *GetInputPortNotFound) IsClientError() bool

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

func (*GetInputPortNotFound) IsCode added in v1.19.1 

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

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

func (*GetInputPortNotFound) IsRedirect added in v1.19.1 

func (o *GetInputPortNotFound) IsRedirect() bool

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

func (*GetInputPortNotFound) IsServerError added in v1.19.1 

func (o *GetInputPortNotFound) IsServerError() bool

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

func (*GetInputPortNotFound) IsSuccess added in v1.19.1 

func (o *GetInputPortNotFound) IsSuccess() bool

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

func (*GetInputPortNotFound) String added in v1.19.1 

func (o *GetInputPortNotFound) String() string

type GetInputPortOK 

type GetInputPortOK struct {
	Payload *models.PortEntity
}

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

successful operation

func NewGetInputPortOK 

func NewGetInputPortOK() *GetInputPortOK

NewGetInputPortOK creates a GetInputPortOK with default headers values

func (*GetInputPortOK) Error 

func (o *GetInputPortOK) Error() string

func (*GetInputPortOK) GetPayload 

func (o *GetInputPortOK) GetPayload() *models.PortEntity

func (*GetInputPortOK) IsClientError added in v1.19.1 

func (o *GetInputPortOK) IsClientError() bool

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

func (*GetInputPortOK) IsCode added in v1.19.1 

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

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

func (*GetInputPortOK) IsRedirect added in v1.19.1 

func (o *GetInputPortOK) IsRedirect() bool

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

func (*GetInputPortOK) IsServerError added in v1.19.1 

func (o *GetInputPortOK) IsServerError() bool

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

func (*GetInputPortOK) IsSuccess added in v1.19.1 

func (o *GetInputPortOK) IsSuccess() bool

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

func (*GetInputPortOK) String added in v1.19.1 

func (o *GetInputPortOK) String() string

type GetInputPortParams 

type GetInputPortParams struct {

	/* ID.

	   The input port id.
	*/
	ID string

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

GetInputPortParams contains all the parameters to send to the API endpoint 

for the get input port operation.

Typically these are written to a http.Request.

func NewGetInputPortParams 

func NewGetInputPortParams() *GetInputPortParams

NewGetInputPortParams creates a new GetInputPortParams 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 NewGetInputPortParamsWithContext 

func NewGetInputPortParamsWithContext(ctx context.Context) *GetInputPortParams

NewGetInputPortParamsWithContext creates a new GetInputPortParams object with the ability to set a context for a request.

func NewGetInputPortParamsWithHTTPClient 

func NewGetInputPortParamsWithHTTPClient(client *http.Client) *GetInputPortParams

NewGetInputPortParamsWithHTTPClient creates a new GetInputPortParams object with the ability to set a custom HTTPClient for a request.

func NewGetInputPortParamsWithTimeout 

func NewGetInputPortParamsWithTimeout(timeout time.Duration) *GetInputPortParams

NewGetInputPortParamsWithTimeout creates a new GetInputPortParams object with the ability to set a timeout on a request.

func (*GetInputPortParams) SetContext 

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

SetContext adds the context to the get input port params

func (*GetInputPortParams) SetDefaults 

func (o *GetInputPortParams) SetDefaults()

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

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

func (*GetInputPortParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get input port params

func (*GetInputPortParams) SetID 

func (o *GetInputPortParams) SetID(id string)

SetID adds the id to the get input port params

func (*GetInputPortParams) SetTimeout 

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

SetTimeout adds the timeout to the get input port params

func (*GetInputPortParams) WithContext 

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

WithContext adds the context to the get input port params

func (*GetInputPortParams) WithDefaults 

func (o *GetInputPortParams) WithDefaults() *GetInputPortParams

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

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

func (*GetInputPortParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get input port params

func (*GetInputPortParams) WithID 

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

WithID adds the id to the get input port params

func (*GetInputPortParams) WithTimeout 

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

WithTimeout adds the timeout to the get input port params

func (*GetInputPortParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetInputPortReader 

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

GetInputPortReader is a Reader for the GetInputPort structure.

func (*GetInputPortReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetInputPortUnauthorized 

type GetInputPortUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetInputPortUnauthorized 

func NewGetInputPortUnauthorized() *GetInputPortUnauthorized

NewGetInputPortUnauthorized creates a GetInputPortUnauthorized with default headers values

func (*GetInputPortUnauthorized) Error 

func (o *GetInputPortUnauthorized) Error() string

func (*GetInputPortUnauthorized) IsClientError added in v1.19.1 

func (o *GetInputPortUnauthorized) IsClientError() bool

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

func (*GetInputPortUnauthorized) IsCode added in v1.19.1 

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

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

func (*GetInputPortUnauthorized) IsRedirect added in v1.19.1 

func (o *GetInputPortUnauthorized) IsRedirect() bool

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

func (*GetInputPortUnauthorized) IsServerError added in v1.19.1 

func (o *GetInputPortUnauthorized) IsServerError() bool

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

func (*GetInputPortUnauthorized) IsSuccess added in v1.19.1 

func (o *GetInputPortUnauthorized) IsSuccess() bool

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

func (*GetInputPortUnauthorized) String added in v1.19.1 

func (o *GetInputPortUnauthorized) String() string

type RemoveInputPortBadRequest 

type RemoveInputPortBadRequest struct {
}

RemoveInputPortBadRequest 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 NewRemoveInputPortBadRequest 

func NewRemoveInputPortBadRequest() *RemoveInputPortBadRequest

NewRemoveInputPortBadRequest creates a RemoveInputPortBadRequest with default headers values

func (*RemoveInputPortBadRequest) Error 

func (o *RemoveInputPortBadRequest) Error() string

func (*RemoveInputPortBadRequest) IsClientError added in v1.19.1 

func (o *RemoveInputPortBadRequest) IsClientError() bool

IsClientError returns true when this remove input port bad request response has a 4xx status code

func (*RemoveInputPortBadRequest) IsCode added in v1.19.1 

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

IsCode returns true when this remove input port bad request response a status code equal to that given

func (*RemoveInputPortBadRequest) IsRedirect added in v1.19.1 

func (o *RemoveInputPortBadRequest) IsRedirect() bool

IsRedirect returns true when this remove input port bad request response has a 3xx status code

func (*RemoveInputPortBadRequest) IsServerError added in v1.19.1 

func (o *RemoveInputPortBadRequest) IsServerError() bool

IsServerError returns true when this remove input port bad request response has a 5xx status code

func (*RemoveInputPortBadRequest) IsSuccess added in v1.19.1 

func (o *RemoveInputPortBadRequest) IsSuccess() bool

IsSuccess returns true when this remove input port bad request response has a 2xx status code

func (*RemoveInputPortBadRequest) String added in v1.19.1 

func (o *RemoveInputPortBadRequest) String() string

type RemoveInputPortConflict 

type RemoveInputPortConflict struct {
}

RemoveInputPortConflict 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 NewRemoveInputPortConflict 

func NewRemoveInputPortConflict() *RemoveInputPortConflict

NewRemoveInputPortConflict creates a RemoveInputPortConflict with default headers values

func (*RemoveInputPortConflict) Error 

func (o *RemoveInputPortConflict) Error() string

func (*RemoveInputPortConflict) IsClientError added in v1.19.1 

func (o *RemoveInputPortConflict) IsClientError() bool

IsClientError returns true when this remove input port conflict response has a 4xx status code

func (*RemoveInputPortConflict) IsCode added in v1.19.1 

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

IsCode returns true when this remove input port conflict response a status code equal to that given

func (*RemoveInputPortConflict) IsRedirect added in v1.19.1 

func (o *RemoveInputPortConflict) IsRedirect() bool

IsRedirect returns true when this remove input port conflict response has a 3xx status code

func (*RemoveInputPortConflict) IsServerError added in v1.19.1 

func (o *RemoveInputPortConflict) IsServerError() bool

IsServerError returns true when this remove input port conflict response has a 5xx status code

func (*RemoveInputPortConflict) IsSuccess added in v1.19.1 

func (o *RemoveInputPortConflict) IsSuccess() bool

IsSuccess returns true when this remove input port conflict response has a 2xx status code

func (*RemoveInputPortConflict) String added in v1.19.1 

func (o *RemoveInputPortConflict) String() string

type RemoveInputPortForbidden 

type RemoveInputPortForbidden struct {
}

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

Client is not authorized to make this request.

func NewRemoveInputPortForbidden 

func NewRemoveInputPortForbidden() *RemoveInputPortForbidden

NewRemoveInputPortForbidden creates a RemoveInputPortForbidden with default headers values

func (*RemoveInputPortForbidden) Error 

func (o *RemoveInputPortForbidden) Error() string

func (*RemoveInputPortForbidden) IsClientError added in v1.19.1 

func (o *RemoveInputPortForbidden) IsClientError() bool

IsClientError returns true when this remove input port forbidden response has a 4xx status code

func (*RemoveInputPortForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this remove input port forbidden response a status code equal to that given

func (*RemoveInputPortForbidden) IsRedirect added in v1.19.1 

func (o *RemoveInputPortForbidden) IsRedirect() bool

IsRedirect returns true when this remove input port forbidden response has a 3xx status code

func (*RemoveInputPortForbidden) IsServerError added in v1.19.1 

func (o *RemoveInputPortForbidden) IsServerError() bool

IsServerError returns true when this remove input port forbidden response has a 5xx status code

func (*RemoveInputPortForbidden) IsSuccess added in v1.19.1 

func (o *RemoveInputPortForbidden) IsSuccess() bool

IsSuccess returns true when this remove input port forbidden response has a 2xx status code

func (*RemoveInputPortForbidden) String added in v1.19.1 

func (o *RemoveInputPortForbidden) String() string

type RemoveInputPortNotFound 

type RemoveInputPortNotFound struct {
}

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

The specified resource could not be found.

func NewRemoveInputPortNotFound 

func NewRemoveInputPortNotFound() *RemoveInputPortNotFound

NewRemoveInputPortNotFound creates a RemoveInputPortNotFound with default headers values

func (*RemoveInputPortNotFound) Error 

func (o *RemoveInputPortNotFound) Error() string

func (*RemoveInputPortNotFound) IsClientError added in v1.19.1 

func (o *RemoveInputPortNotFound) IsClientError() bool

IsClientError returns true when this remove input port not found response has a 4xx status code

func (*RemoveInputPortNotFound) IsCode added in v1.19.1 

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

IsCode returns true when this remove input port not found response a status code equal to that given

func (*RemoveInputPortNotFound) IsRedirect added in v1.19.1 

func (o *RemoveInputPortNotFound) IsRedirect() bool

IsRedirect returns true when this remove input port not found response has a 3xx status code

func (*RemoveInputPortNotFound) IsServerError added in v1.19.1 

func (o *RemoveInputPortNotFound) IsServerError() bool

IsServerError returns true when this remove input port not found response has a 5xx status code

func (*RemoveInputPortNotFound) IsSuccess added in v1.19.1 

func (o *RemoveInputPortNotFound) IsSuccess() bool

IsSuccess returns true when this remove input port not found response has a 2xx status code

func (*RemoveInputPortNotFound) String added in v1.19.1 

func (o *RemoveInputPortNotFound) String() string

type RemoveInputPortOK 

type RemoveInputPortOK struct {
	Payload *models.PortEntity
}

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

successful operation

func NewRemoveInputPortOK 

func NewRemoveInputPortOK() *RemoveInputPortOK

NewRemoveInputPortOK creates a RemoveInputPortOK with default headers values

func (*RemoveInputPortOK) Error 

func (o *RemoveInputPortOK) Error() string

func (*RemoveInputPortOK) GetPayload 

func (o *RemoveInputPortOK) GetPayload() *models.PortEntity

func (*RemoveInputPortOK) IsClientError added in v1.19.1 

func (o *RemoveInputPortOK) IsClientError() bool

IsClientError returns true when this remove input port o k response has a 4xx status code

func (*RemoveInputPortOK) IsCode added in v1.19.1 

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

IsCode returns true when this remove input port o k response a status code equal to that given

func (*RemoveInputPortOK) IsRedirect added in v1.19.1 

func (o *RemoveInputPortOK) IsRedirect() bool

IsRedirect returns true when this remove input port o k response has a 3xx status code

func (*RemoveInputPortOK) IsServerError added in v1.19.1 

func (o *RemoveInputPortOK) IsServerError() bool

IsServerError returns true when this remove input port o k response has a 5xx status code

func (*RemoveInputPortOK) IsSuccess added in v1.19.1 

func (o *RemoveInputPortOK) IsSuccess() bool

IsSuccess returns true when this remove input port o k response has a 2xx status code

func (*RemoveInputPortOK) String added in v1.19.1 

func (o *RemoveInputPortOK) String() string

type RemoveInputPortParams 

type RemoveInputPortParams 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 input port 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
}

RemoveInputPortParams contains all the parameters to send to the API endpoint 

for the remove input port operation.

Typically these are written to a http.Request.

func NewRemoveInputPortParams 

func NewRemoveInputPortParams() *RemoveInputPortParams

NewRemoveInputPortParams creates a new RemoveInputPortParams 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 NewRemoveInputPortParamsWithContext 

func NewRemoveInputPortParamsWithContext(ctx context.Context) *RemoveInputPortParams

NewRemoveInputPortParamsWithContext creates a new RemoveInputPortParams object with the ability to set a context for a request.

func NewRemoveInputPortParamsWithHTTPClient 

func NewRemoveInputPortParamsWithHTTPClient(client *http.Client) *RemoveInputPortParams

NewRemoveInputPortParamsWithHTTPClient creates a new RemoveInputPortParams object with the ability to set a custom HTTPClient for a request.

func NewRemoveInputPortParamsWithTimeout 

func NewRemoveInputPortParamsWithTimeout(timeout time.Duration) *RemoveInputPortParams

NewRemoveInputPortParamsWithTimeout creates a new RemoveInputPortParams object with the ability to set a timeout on a request.

func (*RemoveInputPortParams) SetClientID 

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

SetClientID adds the clientId to the remove input port params

func (*RemoveInputPortParams) SetContext 

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

SetContext adds the context to the remove input port params

func (*RemoveInputPortParams) SetDefaults 

func (o *RemoveInputPortParams) SetDefaults()

SetDefaults hydrates default values in the remove input port params (not the query body).

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

func (*RemoveInputPortParams) SetDisconnectedNodeAcknowledged 

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

SetDisconnectedNodeAcknowledged adds the disconnectedNodeAcknowledged to the remove input port params

func (*RemoveInputPortParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the remove input port params

func (*RemoveInputPortParams) SetID 

func (o *RemoveInputPortParams) SetID(id string)

SetID adds the id to the remove input port params

func (*RemoveInputPortParams) SetTimeout 

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

SetTimeout adds the timeout to the remove input port params

func (*RemoveInputPortParams) SetVersion 

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

SetVersion adds the version to the remove input port params

func (*RemoveInputPortParams) WithClientID 

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

WithClientID adds the clientID to the remove input port params

func (*RemoveInputPortParams) WithContext 

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

WithContext adds the context to the remove input port params

func (*RemoveInputPortParams) WithDefaults 

func (o *RemoveInputPortParams) WithDefaults() *RemoveInputPortParams

WithDefaults hydrates default values in the remove input port params (not the query body).

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

func (*RemoveInputPortParams) WithDisconnectedNodeAcknowledged 

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

WithDisconnectedNodeAcknowledged adds the disconnectedNodeAcknowledged to the remove input port params

func (*RemoveInputPortParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the remove input port params

func (*RemoveInputPortParams) WithID 

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

WithID adds the id to the remove input port params

func (*RemoveInputPortParams) WithTimeout 

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

WithTimeout adds the timeout to the remove input port params

func (*RemoveInputPortParams) WithVersion 

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

WithVersion adds the version to the remove input port params

func (*RemoveInputPortParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type RemoveInputPortReader 

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

RemoveInputPortReader is a Reader for the RemoveInputPort structure.

func (*RemoveInputPortReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type RemoveInputPortUnauthorized 

type RemoveInputPortUnauthorized struct {
}

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

Client could not be authenticated.

func NewRemoveInputPortUnauthorized 

func NewRemoveInputPortUnauthorized() *RemoveInputPortUnauthorized

NewRemoveInputPortUnauthorized creates a RemoveInputPortUnauthorized with default headers values

func (*RemoveInputPortUnauthorized) Error 

func (o *RemoveInputPortUnauthorized) Error() string

func (*RemoveInputPortUnauthorized) IsClientError added in v1.19.1 

func (o *RemoveInputPortUnauthorized) IsClientError() bool

IsClientError returns true when this remove input port unauthorized response has a 4xx status code

func (*RemoveInputPortUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this remove input port unauthorized response a status code equal to that given

func (*RemoveInputPortUnauthorized) IsRedirect added in v1.19.1 

func (o *RemoveInputPortUnauthorized) IsRedirect() bool

IsRedirect returns true when this remove input port unauthorized response has a 3xx status code

func (*RemoveInputPortUnauthorized) IsServerError added in v1.19.1 

func (o *RemoveInputPortUnauthorized) IsServerError() bool

IsServerError returns true when this remove input port unauthorized response has a 5xx status code

func (*RemoveInputPortUnauthorized) IsSuccess added in v1.19.1 

func (o *RemoveInputPortUnauthorized) IsSuccess() bool

IsSuccess returns true when this remove input port unauthorized response has a 2xx status code

func (*RemoveInputPortUnauthorized) String added in v1.19.1 

func (o *RemoveInputPortUnauthorized) String() string

type UpdateInputPortBadRequest 

type UpdateInputPortBadRequest struct {
}

UpdateInputPortBadRequest 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 NewUpdateInputPortBadRequest 

func NewUpdateInputPortBadRequest() *UpdateInputPortBadRequest

NewUpdateInputPortBadRequest creates a UpdateInputPortBadRequest with default headers values

func (*UpdateInputPortBadRequest) Error 

func (o *UpdateInputPortBadRequest) Error() string

func (*UpdateInputPortBadRequest) IsClientError added in v1.19.1 

func (o *UpdateInputPortBadRequest) IsClientError() bool

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

func (*UpdateInputPortBadRequest) IsCode added in v1.19.1 

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

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

func (*UpdateInputPortBadRequest) IsRedirect added in v1.19.1 

func (o *UpdateInputPortBadRequest) IsRedirect() bool

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

func (*UpdateInputPortBadRequest) IsServerError added in v1.19.1 

func (o *UpdateInputPortBadRequest) IsServerError() bool

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

func (*UpdateInputPortBadRequest) IsSuccess added in v1.19.1 

func (o *UpdateInputPortBadRequest) IsSuccess() bool

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

func (*UpdateInputPortBadRequest) String added in v1.19.1 

func (o *UpdateInputPortBadRequest) String() string

type UpdateInputPortConflict 

type UpdateInputPortConflict struct {
}

UpdateInputPortConflict 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 NewUpdateInputPortConflict 

func NewUpdateInputPortConflict() *UpdateInputPortConflict

NewUpdateInputPortConflict creates a UpdateInputPortConflict with default headers values

func (*UpdateInputPortConflict) Error 

func (o *UpdateInputPortConflict) Error() string

func (*UpdateInputPortConflict) IsClientError added in v1.19.1 

func (o *UpdateInputPortConflict) IsClientError() bool

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

func (*UpdateInputPortConflict) IsCode added in v1.19.1 

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

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

func (*UpdateInputPortConflict) IsRedirect added in v1.19.1 

func (o *UpdateInputPortConflict) IsRedirect() bool

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

func (*UpdateInputPortConflict) IsServerError added in v1.19.1 

func (o *UpdateInputPortConflict) IsServerError() bool

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

func (*UpdateInputPortConflict) IsSuccess added in v1.19.1 

func (o *UpdateInputPortConflict) IsSuccess() bool

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

func (*UpdateInputPortConflict) String added in v1.19.1 

func (o *UpdateInputPortConflict) String() string

type UpdateInputPortForbidden 

type UpdateInputPortForbidden struct {
}

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

Client is not authorized to make this request.

func NewUpdateInputPortForbidden 

func NewUpdateInputPortForbidden() *UpdateInputPortForbidden

NewUpdateInputPortForbidden creates a UpdateInputPortForbidden with default headers values

func (*UpdateInputPortForbidden) Error 

func (o *UpdateInputPortForbidden) Error() string

func (*UpdateInputPortForbidden) IsClientError added in v1.19.1 

func (o *UpdateInputPortForbidden) IsClientError() bool

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

func (*UpdateInputPortForbidden) IsCode added in v1.19.1 

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

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

func (*UpdateInputPortForbidden) IsRedirect added in v1.19.1 

func (o *UpdateInputPortForbidden) IsRedirect() bool

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

func (*UpdateInputPortForbidden) IsServerError added in v1.19.1 

func (o *UpdateInputPortForbidden) IsServerError() bool

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

func (*UpdateInputPortForbidden) IsSuccess added in v1.19.1 

func (o *UpdateInputPortForbidden) IsSuccess() bool

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

func (*UpdateInputPortForbidden) String added in v1.19.1 

func (o *UpdateInputPortForbidden) String() string

type UpdateInputPortNotFound 

type UpdateInputPortNotFound struct {
}

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

The specified resource could not be found.

func NewUpdateInputPortNotFound 

func NewUpdateInputPortNotFound() *UpdateInputPortNotFound

NewUpdateInputPortNotFound creates a UpdateInputPortNotFound with default headers values

func (*UpdateInputPortNotFound) Error 

func (o *UpdateInputPortNotFound) Error() string

func (*UpdateInputPortNotFound) IsClientError added in v1.19.1 

func (o *UpdateInputPortNotFound) IsClientError() bool

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

func (*UpdateInputPortNotFound) IsCode added in v1.19.1 

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

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

func (*UpdateInputPortNotFound) IsRedirect added in v1.19.1 

func (o *UpdateInputPortNotFound) IsRedirect() bool

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

func (*UpdateInputPortNotFound) IsServerError added in v1.19.1 

func (o *UpdateInputPortNotFound) IsServerError() bool

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

func (*UpdateInputPortNotFound) IsSuccess added in v1.19.1 

func (o *UpdateInputPortNotFound) IsSuccess() bool

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

func (*UpdateInputPortNotFound) String added in v1.19.1 

func (o *UpdateInputPortNotFound) String() string

type UpdateInputPortOK 

type UpdateInputPortOK struct {
	Payload *models.PortEntity
}

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

successful operation

func NewUpdateInputPortOK 

func NewUpdateInputPortOK() *UpdateInputPortOK

NewUpdateInputPortOK creates a UpdateInputPortOK with default headers values

func (*UpdateInputPortOK) Error 

func (o *UpdateInputPortOK) Error() string

func (*UpdateInputPortOK) GetPayload 

func (o *UpdateInputPortOK) GetPayload() *models.PortEntity

func (*UpdateInputPortOK) IsClientError added in v1.19.1 

func (o *UpdateInputPortOK) IsClientError() bool

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

func (*UpdateInputPortOK) IsCode added in v1.19.1 

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

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

func (*UpdateInputPortOK) IsRedirect added in v1.19.1 

func (o *UpdateInputPortOK) IsRedirect() bool

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

func (*UpdateInputPortOK) IsServerError added in v1.19.1 

func (o *UpdateInputPortOK) IsServerError() bool

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

func (*UpdateInputPortOK) IsSuccess added in v1.19.1 

func (o *UpdateInputPortOK) IsSuccess() bool

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

func (*UpdateInputPortOK) String added in v1.19.1 

func (o *UpdateInputPortOK) String() string

type UpdateInputPortParams 

type UpdateInputPortParams struct {

	/* Body.

	   The input port configuration details.
	*/
	Body *models.PortEntity

	/* ID.

	   The input port id.
	*/
	ID string

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

UpdateInputPortParams contains all the parameters to send to the API endpoint 

for the update input port operation.

Typically these are written to a http.Request.

func NewUpdateInputPortParams 

func NewUpdateInputPortParams() *UpdateInputPortParams

NewUpdateInputPortParams creates a new UpdateInputPortParams 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 NewUpdateInputPortParamsWithContext 

func NewUpdateInputPortParamsWithContext(ctx context.Context) *UpdateInputPortParams

NewUpdateInputPortParamsWithContext creates a new UpdateInputPortParams object with the ability to set a context for a request.

func NewUpdateInputPortParamsWithHTTPClient 

func NewUpdateInputPortParamsWithHTTPClient(client *http.Client) *UpdateInputPortParams

NewUpdateInputPortParamsWithHTTPClient creates a new UpdateInputPortParams object with the ability to set a custom HTTPClient for a request.

func NewUpdateInputPortParamsWithTimeout 

func NewUpdateInputPortParamsWithTimeout(timeout time.Duration) *UpdateInputPortParams

NewUpdateInputPortParamsWithTimeout creates a new UpdateInputPortParams object with the ability to set a timeout on a request.

func (*UpdateInputPortParams) SetBody 

func (o *UpdateInputPortParams) SetBody(body *models.PortEntity)

SetBody adds the body to the update input port params

func (*UpdateInputPortParams) SetContext 

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

SetContext adds the context to the update input port params

func (*UpdateInputPortParams) SetDefaults 

func (o *UpdateInputPortParams) SetDefaults()

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

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

func (*UpdateInputPortParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the update input port params

func (*UpdateInputPortParams) SetID 

func (o *UpdateInputPortParams) SetID(id string)

SetID adds the id to the update input port params

func (*UpdateInputPortParams) SetTimeout 

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

SetTimeout adds the timeout to the update input port params

func (*UpdateInputPortParams) WithBody 

func (o *UpdateInputPortParams) WithBody(body *models.PortEntity) *UpdateInputPortParams

WithBody adds the body to the update input port params

func (*UpdateInputPortParams) WithContext 

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

WithContext adds the context to the update input port params

func (*UpdateInputPortParams) WithDefaults 

func (o *UpdateInputPortParams) WithDefaults() *UpdateInputPortParams

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

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

func (*UpdateInputPortParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the update input port params

func (*UpdateInputPortParams) WithID 

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

WithID adds the id to the update input port params

func (*UpdateInputPortParams) WithTimeout 

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

WithTimeout adds the timeout to the update input port params

func (*UpdateInputPortParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type UpdateInputPortReader 

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

UpdateInputPortReader is a Reader for the UpdateInputPort structure.

func (*UpdateInputPortReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type UpdateInputPortUnauthorized 

type UpdateInputPortUnauthorized struct {
}

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

Client could not be authenticated.

func NewUpdateInputPortUnauthorized 

func NewUpdateInputPortUnauthorized() *UpdateInputPortUnauthorized

NewUpdateInputPortUnauthorized creates a UpdateInputPortUnauthorized with default headers values

func (*UpdateInputPortUnauthorized) Error 

func (o *UpdateInputPortUnauthorized) Error() string

func (*UpdateInputPortUnauthorized) IsClientError added in v1.19.1 

func (o *UpdateInputPortUnauthorized) IsClientError() bool

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

func (*UpdateInputPortUnauthorized) IsCode added in v1.19.1 

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

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

func (*UpdateInputPortUnauthorized) IsRedirect added in v1.19.1 

func (o *UpdateInputPortUnauthorized) IsRedirect() bool

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

func (*UpdateInputPortUnauthorized) IsServerError added in v1.19.1 

func (o *UpdateInputPortUnauthorized) IsServerError() bool

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

func (*UpdateInputPortUnauthorized) IsSuccess added in v1.19.1 

func (o *UpdateInputPortUnauthorized) IsSuccess() bool

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

func (*UpdateInputPortUnauthorized) String added in v1.19.1 

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