processors

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 processors API

func (*Client) DeleteProcessor 

func (a *Client) DeleteProcessor(params *DeleteProcessorParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteProcessorOK, error)

DeleteProcessor deletes a processor

func (*Client) GetProcessor 

func (a *Client) GetProcessor(params *GetProcessorParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetProcessorOK, error)

GetProcessor gets a processor

func (*Client) GetProcessorDiagnostics 

func (a *Client) GetProcessorDiagnostics(params *GetProcessorDiagnosticsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetProcessorDiagnosticsOK, error)

GetProcessorDiagnostics gets diagnostics information about a processor

Note: This endpoint is subject to change as NiFi and it's REST API evolve.

func (*Client) GetProcessorRunStatusDetails 

func (a *Client) GetProcessorRunStatusDetails(params *GetProcessorRunStatusDetailsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetProcessorRunStatusDetailsOK, error)

GetProcessorRunStatusDetails submits a query to retrieve the run status details of all processors that are in the given list of processor i ds

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

func (*Client) SubmitProcessorVerificationRequest 

func (a *Client) SubmitProcessorVerificationRequest(params *SubmitProcessorVerificationRequestParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*SubmitProcessorVerificationRequestOK, error)

SubmitProcessorVerificationRequest performs verification of the processor s configuration

This will initiate the process of verifying a given Processor configuration. This may be a long-running task. As a result, this endpoint will immediately return a ProcessorConfigVerificationRequestEntity, and the process of performing the verification will occur asynchronously in the background. The client may then periodically poll the status of the request by issuing a GET request to /processors/{processorId}/verification-requests/{requestId}. Once the request is completed, the client is expected to issue a DELETE request to /processors/{processorId}/verification-requests/{requestId}.

func (*Client) TerminateProcessor 

func (a *Client) TerminateProcessor(params *TerminateProcessorParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*TerminateProcessorOK, error)

TerminateProcessor terminates a processor essentially deleting its threads and any active tasks

func (*Client) UpdateProcessor 

func (a *Client) UpdateProcessor(params *UpdateProcessorParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*UpdateProcessorOK, error)

UpdateProcessor updates a processor

type ClientOption 

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService 

type ClientService interface {
	DeleteProcessor(params *DeleteProcessorParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteProcessorOK, error)

	GetProcessor(params *GetProcessorParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetProcessorOK, error)

	GetProcessorDiagnostics(params *GetProcessorDiagnosticsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetProcessorDiagnosticsOK, error)

	GetProcessorRunStatusDetails(params *GetProcessorRunStatusDetailsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetProcessorRunStatusDetailsOK, error)

	SubmitProcessorVerificationRequest(params *SubmitProcessorVerificationRequestParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*SubmitProcessorVerificationRequestOK, error)

	TerminateProcessor(params *TerminateProcessorParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*TerminateProcessorOK, error)

	UpdateProcessor(params *UpdateProcessorParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*UpdateProcessorOK, 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 processors API client.

type DeleteProcessorBadRequest 

type DeleteProcessorBadRequest struct {
}

DeleteProcessorBadRequest 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 NewDeleteProcessorBadRequest 

func NewDeleteProcessorBadRequest() *DeleteProcessorBadRequest

NewDeleteProcessorBadRequest creates a DeleteProcessorBadRequest with default headers values

func (*DeleteProcessorBadRequest) Error 

func (o *DeleteProcessorBadRequest) Error() string

func (*DeleteProcessorBadRequest) IsClientError added in v1.19.1 

func (o *DeleteProcessorBadRequest) IsClientError() bool

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

func (*DeleteProcessorBadRequest) IsCode added in v1.19.1 

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

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

func (*DeleteProcessorBadRequest) IsRedirect added in v1.19.1 

func (o *DeleteProcessorBadRequest) IsRedirect() bool

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

func (*DeleteProcessorBadRequest) IsServerError added in v1.19.1 

func (o *DeleteProcessorBadRequest) IsServerError() bool

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

func (*DeleteProcessorBadRequest) IsSuccess added in v1.19.1 

func (o *DeleteProcessorBadRequest) IsSuccess() bool

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

func (*DeleteProcessorBadRequest) String added in v1.19.1 

func (o *DeleteProcessorBadRequest) String() string

type DeleteProcessorConflict 

type DeleteProcessorConflict struct {
}

DeleteProcessorConflict 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 NewDeleteProcessorConflict 

func NewDeleteProcessorConflict() *DeleteProcessorConflict

NewDeleteProcessorConflict creates a DeleteProcessorConflict with default headers values

func (*DeleteProcessorConflict) Error 

func (o *DeleteProcessorConflict) Error() string

func (*DeleteProcessorConflict) IsClientError added in v1.19.1 

func (o *DeleteProcessorConflict) IsClientError() bool

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

func (*DeleteProcessorConflict) IsCode added in v1.19.1 

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

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

func (*DeleteProcessorConflict) IsRedirect added in v1.19.1 

func (o *DeleteProcessorConflict) IsRedirect() bool

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

func (*DeleteProcessorConflict) IsServerError added in v1.19.1 

func (o *DeleteProcessorConflict) IsServerError() bool

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

func (*DeleteProcessorConflict) IsSuccess added in v1.19.1 

func (o *DeleteProcessorConflict) IsSuccess() bool

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

func (*DeleteProcessorConflict) String added in v1.19.1 

func (o *DeleteProcessorConflict) String() string

type DeleteProcessorForbidden 

type DeleteProcessorForbidden struct {
}

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

Client is not authorized to make this request.

func NewDeleteProcessorForbidden 

func NewDeleteProcessorForbidden() *DeleteProcessorForbidden

NewDeleteProcessorForbidden creates a DeleteProcessorForbidden with default headers values

func (*DeleteProcessorForbidden) Error 

func (o *DeleteProcessorForbidden) Error() string

func (*DeleteProcessorForbidden) IsClientError added in v1.19.1 

func (o *DeleteProcessorForbidden) IsClientError() bool

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

func (*DeleteProcessorForbidden) IsCode added in v1.19.1 

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

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

func (*DeleteProcessorForbidden) IsRedirect added in v1.19.1 

func (o *DeleteProcessorForbidden) IsRedirect() bool

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

func (*DeleteProcessorForbidden) IsServerError added in v1.19.1 

func (o *DeleteProcessorForbidden) IsServerError() bool

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

func (*DeleteProcessorForbidden) IsSuccess added in v1.19.1 

func (o *DeleteProcessorForbidden) IsSuccess() bool

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

func (*DeleteProcessorForbidden) String added in v1.19.1 

func (o *DeleteProcessorForbidden) String() string

type DeleteProcessorNotFound 

type DeleteProcessorNotFound struct {
}

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

The specified resource could not be found.

func NewDeleteProcessorNotFound 

func NewDeleteProcessorNotFound() *DeleteProcessorNotFound

NewDeleteProcessorNotFound creates a DeleteProcessorNotFound with default headers values

func (*DeleteProcessorNotFound) Error 

func (o *DeleteProcessorNotFound) Error() string

func (*DeleteProcessorNotFound) IsClientError added in v1.19.1 

func (o *DeleteProcessorNotFound) IsClientError() bool

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

func (*DeleteProcessorNotFound) IsCode added in v1.19.1 

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

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

func (*DeleteProcessorNotFound) IsRedirect added in v1.19.1 

func (o *DeleteProcessorNotFound) IsRedirect() bool

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

func (*DeleteProcessorNotFound) IsServerError added in v1.19.1 

func (o *DeleteProcessorNotFound) IsServerError() bool

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

func (*DeleteProcessorNotFound) IsSuccess added in v1.19.1 

func (o *DeleteProcessorNotFound) IsSuccess() bool

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

func (*DeleteProcessorNotFound) String added in v1.19.1 

func (o *DeleteProcessorNotFound) String() string

type DeleteProcessorOK 

type DeleteProcessorOK struct {
	Payload *models.ProcessorEntity
}

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

successful operation

func NewDeleteProcessorOK 

func NewDeleteProcessorOK() *DeleteProcessorOK

NewDeleteProcessorOK creates a DeleteProcessorOK with default headers values

func (*DeleteProcessorOK) Error 

func (o *DeleteProcessorOK) Error() string

func (*DeleteProcessorOK) GetPayload 

func (o *DeleteProcessorOK) GetPayload() *models.ProcessorEntity

func (*DeleteProcessorOK) IsClientError added in v1.19.1 

func (o *DeleteProcessorOK) IsClientError() bool

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

func (*DeleteProcessorOK) IsCode added in v1.19.1 

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

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

func (*DeleteProcessorOK) IsRedirect added in v1.19.1 

func (o *DeleteProcessorOK) IsRedirect() bool

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

func (*DeleteProcessorOK) IsServerError added in v1.19.1 

func (o *DeleteProcessorOK) IsServerError() bool

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

func (*DeleteProcessorOK) IsSuccess added in v1.19.1 

func (o *DeleteProcessorOK) IsSuccess() bool

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

func (*DeleteProcessorOK) String added in v1.19.1 

func (o *DeleteProcessorOK) String() string

type DeleteProcessorParams 

type DeleteProcessorParams 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 processor 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
}

DeleteProcessorParams contains all the parameters to send to the API endpoint 

for the delete processor operation.

Typically these are written to a http.Request.

func NewDeleteProcessorParams 

func NewDeleteProcessorParams() *DeleteProcessorParams

NewDeleteProcessorParams creates a new DeleteProcessorParams 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 NewDeleteProcessorParamsWithContext 

func NewDeleteProcessorParamsWithContext(ctx context.Context) *DeleteProcessorParams

NewDeleteProcessorParamsWithContext creates a new DeleteProcessorParams object with the ability to set a context for a request.

func NewDeleteProcessorParamsWithHTTPClient 

func NewDeleteProcessorParamsWithHTTPClient(client *http.Client) *DeleteProcessorParams

NewDeleteProcessorParamsWithHTTPClient creates a new DeleteProcessorParams object with the ability to set a custom HTTPClient for a request.

func NewDeleteProcessorParamsWithTimeout 

func NewDeleteProcessorParamsWithTimeout(timeout time.Duration) *DeleteProcessorParams

NewDeleteProcessorParamsWithTimeout creates a new DeleteProcessorParams object with the ability to set a timeout on a request.

func (*DeleteProcessorParams) SetClientID 

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

SetClientID adds the clientId to the delete processor params

func (*DeleteProcessorParams) SetContext 

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

SetContext adds the context to the delete processor params

func (*DeleteProcessorParams) SetDefaults 

func (o *DeleteProcessorParams) SetDefaults()

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

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

func (*DeleteProcessorParams) SetDisconnectedNodeAcknowledged 

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

SetDisconnectedNodeAcknowledged adds the disconnectedNodeAcknowledged to the delete processor params

func (*DeleteProcessorParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the delete processor params

func (*DeleteProcessorParams) SetID 

func (o *DeleteProcessorParams) SetID(id string)

SetID adds the id to the delete processor params

func (*DeleteProcessorParams) SetTimeout 

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

SetTimeout adds the timeout to the delete processor params

func (*DeleteProcessorParams) SetVersion 

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

SetVersion adds the version to the delete processor params

func (*DeleteProcessorParams) WithClientID 

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

WithClientID adds the clientID to the delete processor params

func (*DeleteProcessorParams) WithContext 

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

WithContext adds the context to the delete processor params

func (*DeleteProcessorParams) WithDefaults 

func (o *DeleteProcessorParams) WithDefaults() *DeleteProcessorParams

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

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

func (*DeleteProcessorParams) WithDisconnectedNodeAcknowledged 

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

WithDisconnectedNodeAcknowledged adds the disconnectedNodeAcknowledged to the delete processor params

func (*DeleteProcessorParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the delete processor params

func (*DeleteProcessorParams) WithID 

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

WithID adds the id to the delete processor params

func (*DeleteProcessorParams) WithTimeout 

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

WithTimeout adds the timeout to the delete processor params

func (*DeleteProcessorParams) WithVersion 

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

WithVersion adds the version to the delete processor params

func (*DeleteProcessorParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type DeleteProcessorReader 

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

DeleteProcessorReader is a Reader for the DeleteProcessor structure.

func (*DeleteProcessorReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type DeleteProcessorUnauthorized 

type DeleteProcessorUnauthorized struct {
}

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

Client could not be authenticated.

func NewDeleteProcessorUnauthorized 

func NewDeleteProcessorUnauthorized() *DeleteProcessorUnauthorized

NewDeleteProcessorUnauthorized creates a DeleteProcessorUnauthorized with default headers values

func (*DeleteProcessorUnauthorized) Error 

func (o *DeleteProcessorUnauthorized) Error() string

func (*DeleteProcessorUnauthorized) IsClientError added in v1.19.1 

func (o *DeleteProcessorUnauthorized) IsClientError() bool

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

func (*DeleteProcessorUnauthorized) IsCode added in v1.19.1 

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

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

func (*DeleteProcessorUnauthorized) IsRedirect added in v1.19.1 

func (o *DeleteProcessorUnauthorized) IsRedirect() bool

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

func (*DeleteProcessorUnauthorized) IsServerError added in v1.19.1 

func (o *DeleteProcessorUnauthorized) IsServerError() bool

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

func (*DeleteProcessorUnauthorized) IsSuccess added in v1.19.1 

func (o *DeleteProcessorUnauthorized) IsSuccess() bool

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

func (*DeleteProcessorUnauthorized) String added in v1.19.1 

func (o *DeleteProcessorUnauthorized) String() string

type GetProcessorBadRequest 

type GetProcessorBadRequest struct {
}

GetProcessorBadRequest 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 NewGetProcessorBadRequest 

func NewGetProcessorBadRequest() *GetProcessorBadRequest

NewGetProcessorBadRequest creates a GetProcessorBadRequest with default headers values

func (*GetProcessorBadRequest) Error 

func (o *GetProcessorBadRequest) Error() string

func (*GetProcessorBadRequest) IsClientError added in v1.19.1 

func (o *GetProcessorBadRequest) IsClientError() bool

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

func (*GetProcessorBadRequest) IsCode added in v1.19.1 

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

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

func (*GetProcessorBadRequest) IsRedirect added in v1.19.1 

func (o *GetProcessorBadRequest) IsRedirect() bool

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

func (*GetProcessorBadRequest) IsServerError added in v1.19.1 

func (o *GetProcessorBadRequest) IsServerError() bool

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

func (*GetProcessorBadRequest) IsSuccess added in v1.19.1 

func (o *GetProcessorBadRequest) IsSuccess() bool

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

func (*GetProcessorBadRequest) String added in v1.19.1 

func (o *GetProcessorBadRequest) String() string

type GetProcessorConflict 

type GetProcessorConflict struct {
}

GetProcessorConflict 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 NewGetProcessorConflict 

func NewGetProcessorConflict() *GetProcessorConflict

NewGetProcessorConflict creates a GetProcessorConflict with default headers values

func (*GetProcessorConflict) Error 

func (o *GetProcessorConflict) Error() string

func (*GetProcessorConflict) IsClientError added in v1.19.1 

func (o *GetProcessorConflict) IsClientError() bool

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

func (*GetProcessorConflict) IsCode added in v1.19.1 

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

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

func (*GetProcessorConflict) IsRedirect added in v1.19.1 

func (o *GetProcessorConflict) IsRedirect() bool

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

func (*GetProcessorConflict) IsServerError added in v1.19.1 

func (o *GetProcessorConflict) IsServerError() bool

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

func (*GetProcessorConflict) IsSuccess added in v1.19.1 

func (o *GetProcessorConflict) IsSuccess() bool

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

func (*GetProcessorConflict) String added in v1.19.1 

func (o *GetProcessorConflict) String() string

type GetProcessorDiagnosticsBadRequest 

type GetProcessorDiagnosticsBadRequest struct {
}

GetProcessorDiagnosticsBadRequest 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 NewGetProcessorDiagnosticsBadRequest 

func NewGetProcessorDiagnosticsBadRequest() *GetProcessorDiagnosticsBadRequest

NewGetProcessorDiagnosticsBadRequest creates a GetProcessorDiagnosticsBadRequest with default headers values

func (*GetProcessorDiagnosticsBadRequest) Error 

func (o *GetProcessorDiagnosticsBadRequest) Error() string

func (*GetProcessorDiagnosticsBadRequest) IsClientError added in v1.19.1 

func (o *GetProcessorDiagnosticsBadRequest) IsClientError() bool

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

func (*GetProcessorDiagnosticsBadRequest) IsCode added in v1.19.1 

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

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

func (*GetProcessorDiagnosticsBadRequest) IsRedirect added in v1.19.1 

func (o *GetProcessorDiagnosticsBadRequest) IsRedirect() bool

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

func (*GetProcessorDiagnosticsBadRequest) IsServerError added in v1.19.1 

func (o *GetProcessorDiagnosticsBadRequest) IsServerError() bool

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

func (*GetProcessorDiagnosticsBadRequest) IsSuccess added in v1.19.1 

func (o *GetProcessorDiagnosticsBadRequest) IsSuccess() bool

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

func (*GetProcessorDiagnosticsBadRequest) String added in v1.19.1 

func (o *GetProcessorDiagnosticsBadRequest) String() string

type GetProcessorDiagnosticsConflict 

type GetProcessorDiagnosticsConflict struct {
}

GetProcessorDiagnosticsConflict 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 NewGetProcessorDiagnosticsConflict 

func NewGetProcessorDiagnosticsConflict() *GetProcessorDiagnosticsConflict

NewGetProcessorDiagnosticsConflict creates a GetProcessorDiagnosticsConflict with default headers values

func (*GetProcessorDiagnosticsConflict) Error 

func (o *GetProcessorDiagnosticsConflict) Error() string

func (*GetProcessorDiagnosticsConflict) IsClientError added in v1.19.1 

func (o *GetProcessorDiagnosticsConflict) IsClientError() bool

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

func (*GetProcessorDiagnosticsConflict) IsCode added in v1.19.1 

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

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

func (*GetProcessorDiagnosticsConflict) IsRedirect added in v1.19.1 

func (o *GetProcessorDiagnosticsConflict) IsRedirect() bool

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

func (*GetProcessorDiagnosticsConflict) IsServerError added in v1.19.1 

func (o *GetProcessorDiagnosticsConflict) IsServerError() bool

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

func (*GetProcessorDiagnosticsConflict) IsSuccess added in v1.19.1 

func (o *GetProcessorDiagnosticsConflict) IsSuccess() bool

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

func (*GetProcessorDiagnosticsConflict) String added in v1.19.1 

func (o *GetProcessorDiagnosticsConflict) String() string

type GetProcessorDiagnosticsForbidden 

type GetProcessorDiagnosticsForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetProcessorDiagnosticsForbidden 

func NewGetProcessorDiagnosticsForbidden() *GetProcessorDiagnosticsForbidden

NewGetProcessorDiagnosticsForbidden creates a GetProcessorDiagnosticsForbidden with default headers values

func (*GetProcessorDiagnosticsForbidden) Error 

func (o *GetProcessorDiagnosticsForbidden) Error() string

func (*GetProcessorDiagnosticsForbidden) IsClientError added in v1.19.1 

func (o *GetProcessorDiagnosticsForbidden) IsClientError() bool

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

func (*GetProcessorDiagnosticsForbidden) IsCode added in v1.19.1 

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

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

func (*GetProcessorDiagnosticsForbidden) IsRedirect added in v1.19.1 

func (o *GetProcessorDiagnosticsForbidden) IsRedirect() bool

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

func (*GetProcessorDiagnosticsForbidden) IsServerError added in v1.19.1 

func (o *GetProcessorDiagnosticsForbidden) IsServerError() bool

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

func (*GetProcessorDiagnosticsForbidden) IsSuccess added in v1.19.1 

func (o *GetProcessorDiagnosticsForbidden) IsSuccess() bool

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

func (*GetProcessorDiagnosticsForbidden) String added in v1.19.1 

func (o *GetProcessorDiagnosticsForbidden) String() string

type GetProcessorDiagnosticsNotFound 

type GetProcessorDiagnosticsNotFound struct {
}

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

The specified resource could not be found.

func NewGetProcessorDiagnosticsNotFound 

func NewGetProcessorDiagnosticsNotFound() *GetProcessorDiagnosticsNotFound

NewGetProcessorDiagnosticsNotFound creates a GetProcessorDiagnosticsNotFound with default headers values

func (*GetProcessorDiagnosticsNotFound) Error 

func (o *GetProcessorDiagnosticsNotFound) Error() string

func (*GetProcessorDiagnosticsNotFound) IsClientError added in v1.19.1 

func (o *GetProcessorDiagnosticsNotFound) IsClientError() bool

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

func (*GetProcessorDiagnosticsNotFound) IsCode added in v1.19.1 

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

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

func (*GetProcessorDiagnosticsNotFound) IsRedirect added in v1.19.1 

func (o *GetProcessorDiagnosticsNotFound) IsRedirect() bool

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

func (*GetProcessorDiagnosticsNotFound) IsServerError added in v1.19.1 

func (o *GetProcessorDiagnosticsNotFound) IsServerError() bool

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

func (*GetProcessorDiagnosticsNotFound) IsSuccess added in v1.19.1 

func (o *GetProcessorDiagnosticsNotFound) IsSuccess() bool

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

func (*GetProcessorDiagnosticsNotFound) String added in v1.19.1 

func (o *GetProcessorDiagnosticsNotFound) String() string

type GetProcessorDiagnosticsOK 

type GetProcessorDiagnosticsOK struct {
	Payload *models.ProcessorEntity
}

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

successful operation

func NewGetProcessorDiagnosticsOK 

func NewGetProcessorDiagnosticsOK() *GetProcessorDiagnosticsOK

NewGetProcessorDiagnosticsOK creates a GetProcessorDiagnosticsOK with default headers values

func (*GetProcessorDiagnosticsOK) Error 

func (o *GetProcessorDiagnosticsOK) Error() string

func (*GetProcessorDiagnosticsOK) GetPayload 

func (o *GetProcessorDiagnosticsOK) GetPayload() *models.ProcessorEntity

func (*GetProcessorDiagnosticsOK) IsClientError added in v1.19.1 

func (o *GetProcessorDiagnosticsOK) IsClientError() bool

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

func (*GetProcessorDiagnosticsOK) IsCode added in v1.19.1 

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

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

func (*GetProcessorDiagnosticsOK) IsRedirect added in v1.19.1 

func (o *GetProcessorDiagnosticsOK) IsRedirect() bool

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

func (*GetProcessorDiagnosticsOK) IsServerError added in v1.19.1 

func (o *GetProcessorDiagnosticsOK) IsServerError() bool

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

func (*GetProcessorDiagnosticsOK) IsSuccess added in v1.19.1 

func (o *GetProcessorDiagnosticsOK) IsSuccess() bool

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

func (*GetProcessorDiagnosticsOK) String added in v1.19.1 

func (o *GetProcessorDiagnosticsOK) String() string

type GetProcessorDiagnosticsParams 

type GetProcessorDiagnosticsParams struct {

	/* ID.

	   The processor id.
	*/
	ID string

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

GetProcessorDiagnosticsParams contains all the parameters to send to the API endpoint 

for the get processor diagnostics operation.

Typically these are written to a http.Request.

func NewGetProcessorDiagnosticsParams 

func NewGetProcessorDiagnosticsParams() *GetProcessorDiagnosticsParams

NewGetProcessorDiagnosticsParams creates a new GetProcessorDiagnosticsParams 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 NewGetProcessorDiagnosticsParamsWithContext 

func NewGetProcessorDiagnosticsParamsWithContext(ctx context.Context) *GetProcessorDiagnosticsParams

NewGetProcessorDiagnosticsParamsWithContext creates a new GetProcessorDiagnosticsParams object with the ability to set a context for a request.

func NewGetProcessorDiagnosticsParamsWithHTTPClient 

func NewGetProcessorDiagnosticsParamsWithHTTPClient(client *http.Client) *GetProcessorDiagnosticsParams

NewGetProcessorDiagnosticsParamsWithHTTPClient creates a new GetProcessorDiagnosticsParams object with the ability to set a custom HTTPClient for a request.

func NewGetProcessorDiagnosticsParamsWithTimeout 

func NewGetProcessorDiagnosticsParamsWithTimeout(timeout time.Duration) *GetProcessorDiagnosticsParams

NewGetProcessorDiagnosticsParamsWithTimeout creates a new GetProcessorDiagnosticsParams object with the ability to set a timeout on a request.

func (*GetProcessorDiagnosticsParams) SetContext 

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

SetContext adds the context to the get processor diagnostics params

func (*GetProcessorDiagnosticsParams) SetDefaults 

func (o *GetProcessorDiagnosticsParams) SetDefaults()

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

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

func (*GetProcessorDiagnosticsParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get processor diagnostics params

func (*GetProcessorDiagnosticsParams) SetID 

func (o *GetProcessorDiagnosticsParams) SetID(id string)

SetID adds the id to the get processor diagnostics params

func (*GetProcessorDiagnosticsParams) SetTimeout 

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

SetTimeout adds the timeout to the get processor diagnostics params

func (*GetProcessorDiagnosticsParams) WithContext 

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

WithContext adds the context to the get processor diagnostics params

func (*GetProcessorDiagnosticsParams) WithDefaults 

func (o *GetProcessorDiagnosticsParams) WithDefaults() *GetProcessorDiagnosticsParams

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

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

func (*GetProcessorDiagnosticsParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get processor diagnostics params

func (*GetProcessorDiagnosticsParams) WithID 

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

WithID adds the id to the get processor diagnostics params

func (*GetProcessorDiagnosticsParams) WithTimeout 

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

WithTimeout adds the timeout to the get processor diagnostics params

func (*GetProcessorDiagnosticsParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetProcessorDiagnosticsReader 

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

GetProcessorDiagnosticsReader is a Reader for the GetProcessorDiagnostics structure.

func (*GetProcessorDiagnosticsReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetProcessorDiagnosticsUnauthorized 

type GetProcessorDiagnosticsUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetProcessorDiagnosticsUnauthorized 

func NewGetProcessorDiagnosticsUnauthorized() *GetProcessorDiagnosticsUnauthorized

NewGetProcessorDiagnosticsUnauthorized creates a GetProcessorDiagnosticsUnauthorized with default headers values

func (*GetProcessorDiagnosticsUnauthorized) Error 

func (o *GetProcessorDiagnosticsUnauthorized) Error() string

func (*GetProcessorDiagnosticsUnauthorized) IsClientError added in v1.19.1 

func (o *GetProcessorDiagnosticsUnauthorized) IsClientError() bool

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

func (*GetProcessorDiagnosticsUnauthorized) IsCode added in v1.19.1 

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

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

func (*GetProcessorDiagnosticsUnauthorized) IsRedirect added in v1.19.1 

func (o *GetProcessorDiagnosticsUnauthorized) IsRedirect() bool

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

func (*GetProcessorDiagnosticsUnauthorized) IsServerError added in v1.19.1 

func (o *GetProcessorDiagnosticsUnauthorized) IsServerError() bool

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

func (*GetProcessorDiagnosticsUnauthorized) IsSuccess added in v1.19.1 

func (o *GetProcessorDiagnosticsUnauthorized) IsSuccess() bool

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

func (*GetProcessorDiagnosticsUnauthorized) String added in v1.19.1 

func (o *GetProcessorDiagnosticsUnauthorized) String() string

type GetProcessorForbidden 

type GetProcessorForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetProcessorForbidden 

func NewGetProcessorForbidden() *GetProcessorForbidden

NewGetProcessorForbidden creates a GetProcessorForbidden with default headers values

func (*GetProcessorForbidden) Error 

func (o *GetProcessorForbidden) Error() string

func (*GetProcessorForbidden) IsClientError added in v1.19.1 

func (o *GetProcessorForbidden) IsClientError() bool

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

func (*GetProcessorForbidden) IsCode added in v1.19.1 

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

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

func (*GetProcessorForbidden) IsRedirect added in v1.19.1 

func (o *GetProcessorForbidden) IsRedirect() bool

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

func (*GetProcessorForbidden) IsServerError added in v1.19.1 

func (o *GetProcessorForbidden) IsServerError() bool

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

func (*GetProcessorForbidden) IsSuccess added in v1.19.1 

func (o *GetProcessorForbidden) IsSuccess() bool

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

func (*GetProcessorForbidden) String added in v1.19.1 

func (o *GetProcessorForbidden) String() string

type GetProcessorNotFound 

type GetProcessorNotFound struct {
}

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

The specified resource could not be found.

func NewGetProcessorNotFound 

func NewGetProcessorNotFound() *GetProcessorNotFound

NewGetProcessorNotFound creates a GetProcessorNotFound with default headers values

func (*GetProcessorNotFound) Error 

func (o *GetProcessorNotFound) Error() string

func (*GetProcessorNotFound) IsClientError added in v1.19.1 

func (o *GetProcessorNotFound) IsClientError() bool

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

func (*GetProcessorNotFound) IsCode added in v1.19.1 

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

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

func (*GetProcessorNotFound) IsRedirect added in v1.19.1 

func (o *GetProcessorNotFound) IsRedirect() bool

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

func (*GetProcessorNotFound) IsServerError added in v1.19.1 

func (o *GetProcessorNotFound) IsServerError() bool

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

func (*GetProcessorNotFound) IsSuccess added in v1.19.1 

func (o *GetProcessorNotFound) IsSuccess() bool

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

func (*GetProcessorNotFound) String added in v1.19.1 

func (o *GetProcessorNotFound) String() string

type GetProcessorOK 

type GetProcessorOK struct {
	Payload *models.ProcessorEntity
}

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

successful operation

func NewGetProcessorOK 

func NewGetProcessorOK() *GetProcessorOK

NewGetProcessorOK creates a GetProcessorOK with default headers values

func (*GetProcessorOK) Error 

func (o *GetProcessorOK) Error() string

func (*GetProcessorOK) GetPayload 

func (o *GetProcessorOK) GetPayload() *models.ProcessorEntity

func (*GetProcessorOK) IsClientError added in v1.19.1 

func (o *GetProcessorOK) IsClientError() bool

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

func (*GetProcessorOK) IsCode added in v1.19.1 

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

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

func (*GetProcessorOK) IsRedirect added in v1.19.1 

func (o *GetProcessorOK) IsRedirect() bool

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

func (*GetProcessorOK) IsServerError added in v1.19.1 

func (o *GetProcessorOK) IsServerError() bool

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

func (*GetProcessorOK) IsSuccess added in v1.19.1 

func (o *GetProcessorOK) IsSuccess() bool

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

func (*GetProcessorOK) String added in v1.19.1 

func (o *GetProcessorOK) String() string

type GetProcessorParams 

type GetProcessorParams struct {

	/* ID.

	   The processor id.
	*/
	ID string

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

GetProcessorParams contains all the parameters to send to the API endpoint 

for the get processor operation.

Typically these are written to a http.Request.

func NewGetProcessorParams 

func NewGetProcessorParams() *GetProcessorParams

NewGetProcessorParams creates a new GetProcessorParams 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 NewGetProcessorParamsWithContext 

func NewGetProcessorParamsWithContext(ctx context.Context) *GetProcessorParams

NewGetProcessorParamsWithContext creates a new GetProcessorParams object with the ability to set a context for a request.

func NewGetProcessorParamsWithHTTPClient 

func NewGetProcessorParamsWithHTTPClient(client *http.Client) *GetProcessorParams

NewGetProcessorParamsWithHTTPClient creates a new GetProcessorParams object with the ability to set a custom HTTPClient for a request.

func NewGetProcessorParamsWithTimeout 

func NewGetProcessorParamsWithTimeout(timeout time.Duration) *GetProcessorParams

NewGetProcessorParamsWithTimeout creates a new GetProcessorParams object with the ability to set a timeout on a request.

func (*GetProcessorParams) SetContext 

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

SetContext adds the context to the get processor params

func (*GetProcessorParams) SetDefaults 

func (o *GetProcessorParams) SetDefaults()

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

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

func (*GetProcessorParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get processor params

func (*GetProcessorParams) SetID 

func (o *GetProcessorParams) SetID(id string)

SetID adds the id to the get processor params

func (*GetProcessorParams) SetTimeout 

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

SetTimeout adds the timeout to the get processor params

func (*GetProcessorParams) WithContext 

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

WithContext adds the context to the get processor params

func (*GetProcessorParams) WithDefaults 

func (o *GetProcessorParams) WithDefaults() *GetProcessorParams

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

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

func (*GetProcessorParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get processor params

func (*GetProcessorParams) WithID 

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

WithID adds the id to the get processor params

func (*GetProcessorParams) WithTimeout 

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

WithTimeout adds the timeout to the get processor params

func (*GetProcessorParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetProcessorReader 

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

GetProcessorReader is a Reader for the GetProcessor structure.

func (*GetProcessorReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetProcessorRunStatusDetailsBadRequest 

type GetProcessorRunStatusDetailsBadRequest struct {
}

GetProcessorRunStatusDetailsBadRequest 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 NewGetProcessorRunStatusDetailsBadRequest 

func NewGetProcessorRunStatusDetailsBadRequest() *GetProcessorRunStatusDetailsBadRequest

NewGetProcessorRunStatusDetailsBadRequest creates a GetProcessorRunStatusDetailsBadRequest with default headers values

func (*GetProcessorRunStatusDetailsBadRequest) Error 

func (o *GetProcessorRunStatusDetailsBadRequest) Error() string

func (*GetProcessorRunStatusDetailsBadRequest) IsClientError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsBadRequest) IsClientError() bool

IsClientError returns true when this get processor run status details bad request response has a 4xx status code

func (*GetProcessorRunStatusDetailsBadRequest) IsCode added in v1.19.1 

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

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

func (*GetProcessorRunStatusDetailsBadRequest) IsRedirect added in v1.19.1 

func (o *GetProcessorRunStatusDetailsBadRequest) IsRedirect() bool

IsRedirect returns true when this get processor run status details bad request response has a 3xx status code

func (*GetProcessorRunStatusDetailsBadRequest) IsServerError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsBadRequest) IsServerError() bool

IsServerError returns true when this get processor run status details bad request response has a 5xx status code

func (*GetProcessorRunStatusDetailsBadRequest) IsSuccess added in v1.19.1 

func (o *GetProcessorRunStatusDetailsBadRequest) IsSuccess() bool

IsSuccess returns true when this get processor run status details bad request response has a 2xx status code

func (*GetProcessorRunStatusDetailsBadRequest) String added in v1.19.1 

func (o *GetProcessorRunStatusDetailsBadRequest) String() string

type GetProcessorRunStatusDetailsConflict 

type GetProcessorRunStatusDetailsConflict struct {
}

GetProcessorRunStatusDetailsConflict 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 NewGetProcessorRunStatusDetailsConflict 

func NewGetProcessorRunStatusDetailsConflict() *GetProcessorRunStatusDetailsConflict

NewGetProcessorRunStatusDetailsConflict creates a GetProcessorRunStatusDetailsConflict with default headers values

func (*GetProcessorRunStatusDetailsConflict) Error 

func (o *GetProcessorRunStatusDetailsConflict) Error() string

func (*GetProcessorRunStatusDetailsConflict) IsClientError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsConflict) IsClientError() bool

IsClientError returns true when this get processor run status details conflict response has a 4xx status code

func (*GetProcessorRunStatusDetailsConflict) IsCode added in v1.19.1 

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

IsCode returns true when this get processor run status details conflict response a status code equal to that given

func (*GetProcessorRunStatusDetailsConflict) IsRedirect added in v1.19.1 

func (o *GetProcessorRunStatusDetailsConflict) IsRedirect() bool

IsRedirect returns true when this get processor run status details conflict response has a 3xx status code

func (*GetProcessorRunStatusDetailsConflict) IsServerError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsConflict) IsServerError() bool

IsServerError returns true when this get processor run status details conflict response has a 5xx status code

func (*GetProcessorRunStatusDetailsConflict) IsSuccess added in v1.19.1 

func (o *GetProcessorRunStatusDetailsConflict) IsSuccess() bool

IsSuccess returns true when this get processor run status details conflict response has a 2xx status code

func (*GetProcessorRunStatusDetailsConflict) String added in v1.19.1 

func (o *GetProcessorRunStatusDetailsConflict) String() string

type GetProcessorRunStatusDetailsForbidden 

type GetProcessorRunStatusDetailsForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetProcessorRunStatusDetailsForbidden 

func NewGetProcessorRunStatusDetailsForbidden() *GetProcessorRunStatusDetailsForbidden

NewGetProcessorRunStatusDetailsForbidden creates a GetProcessorRunStatusDetailsForbidden with default headers values

func (*GetProcessorRunStatusDetailsForbidden) Error 

func (o *GetProcessorRunStatusDetailsForbidden) Error() string

func (*GetProcessorRunStatusDetailsForbidden) IsClientError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsForbidden) IsClientError() bool

IsClientError returns true when this get processor run status details forbidden response has a 4xx status code

func (*GetProcessorRunStatusDetailsForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this get processor run status details forbidden response a status code equal to that given

func (*GetProcessorRunStatusDetailsForbidden) IsRedirect added in v1.19.1 

func (o *GetProcessorRunStatusDetailsForbidden) IsRedirect() bool

IsRedirect returns true when this get processor run status details forbidden response has a 3xx status code

func (*GetProcessorRunStatusDetailsForbidden) IsServerError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsForbidden) IsServerError() bool

IsServerError returns true when this get processor run status details forbidden response has a 5xx status code

func (*GetProcessorRunStatusDetailsForbidden) IsSuccess added in v1.19.1 

func (o *GetProcessorRunStatusDetailsForbidden) IsSuccess() bool

IsSuccess returns true when this get processor run status details forbidden response has a 2xx status code

func (*GetProcessorRunStatusDetailsForbidden) String added in v1.19.1 

func (o *GetProcessorRunStatusDetailsForbidden) String() string

type GetProcessorRunStatusDetailsNotFound 

type GetProcessorRunStatusDetailsNotFound struct {
}

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

The specified resource could not be found.

func NewGetProcessorRunStatusDetailsNotFound 

func NewGetProcessorRunStatusDetailsNotFound() *GetProcessorRunStatusDetailsNotFound

NewGetProcessorRunStatusDetailsNotFound creates a GetProcessorRunStatusDetailsNotFound with default headers values

func (*GetProcessorRunStatusDetailsNotFound) Error 

func (o *GetProcessorRunStatusDetailsNotFound) Error() string

func (*GetProcessorRunStatusDetailsNotFound) IsClientError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsNotFound) IsClientError() bool

IsClientError returns true when this get processor run status details not found response has a 4xx status code

func (*GetProcessorRunStatusDetailsNotFound) IsCode added in v1.19.1 

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

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

func (*GetProcessorRunStatusDetailsNotFound) IsRedirect added in v1.19.1 

func (o *GetProcessorRunStatusDetailsNotFound) IsRedirect() bool

IsRedirect returns true when this get processor run status details not found response has a 3xx status code

func (*GetProcessorRunStatusDetailsNotFound) IsServerError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsNotFound) IsServerError() bool

IsServerError returns true when this get processor run status details not found response has a 5xx status code

func (*GetProcessorRunStatusDetailsNotFound) IsSuccess added in v1.19.1 

func (o *GetProcessorRunStatusDetailsNotFound) IsSuccess() bool

IsSuccess returns true when this get processor run status details not found response has a 2xx status code

func (*GetProcessorRunStatusDetailsNotFound) String added in v1.19.1 

func (o *GetProcessorRunStatusDetailsNotFound) String() string

type GetProcessorRunStatusDetailsOK 

type GetProcessorRunStatusDetailsOK struct {
	Payload *models.ProcessorsRunStatusDetailsEntity
}

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

successful operation

func NewGetProcessorRunStatusDetailsOK 

func NewGetProcessorRunStatusDetailsOK() *GetProcessorRunStatusDetailsOK

NewGetProcessorRunStatusDetailsOK creates a GetProcessorRunStatusDetailsOK with default headers values

func (*GetProcessorRunStatusDetailsOK) Error 

func (o *GetProcessorRunStatusDetailsOK) Error() string

func (*GetProcessorRunStatusDetailsOK) GetPayload 

func (o *GetProcessorRunStatusDetailsOK) GetPayload() *models.ProcessorsRunStatusDetailsEntity

func (*GetProcessorRunStatusDetailsOK) IsClientError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsOK) IsClientError() bool

IsClientError returns true when this get processor run status details o k response has a 4xx status code

func (*GetProcessorRunStatusDetailsOK) IsCode added in v1.19.1 

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

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

func (*GetProcessorRunStatusDetailsOK) IsRedirect added in v1.19.1 

func (o *GetProcessorRunStatusDetailsOK) IsRedirect() bool

IsRedirect returns true when this get processor run status details o k response has a 3xx status code

func (*GetProcessorRunStatusDetailsOK) IsServerError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsOK) IsServerError() bool

IsServerError returns true when this get processor run status details o k response has a 5xx status code

func (*GetProcessorRunStatusDetailsOK) IsSuccess added in v1.19.1 

func (o *GetProcessorRunStatusDetailsOK) IsSuccess() bool

IsSuccess returns true when this get processor run status details o k response has a 2xx status code

func (*GetProcessorRunStatusDetailsOK) String added in v1.19.1 

func (o *GetProcessorRunStatusDetailsOK) String() string

type GetProcessorRunStatusDetailsParams 

type GetProcessorRunStatusDetailsParams struct {

	/* Body.

	   The request for the processors that should be included in the results
	*/
	Body *models.RunStatusDetailsRequestEntity

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

GetProcessorRunStatusDetailsParams contains all the parameters to send to the API endpoint 

for the get processor run status details operation.

Typically these are written to a http.Request.

func NewGetProcessorRunStatusDetailsParams 

func NewGetProcessorRunStatusDetailsParams() *GetProcessorRunStatusDetailsParams

NewGetProcessorRunStatusDetailsParams creates a new GetProcessorRunStatusDetailsParams 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 NewGetProcessorRunStatusDetailsParamsWithContext 

func NewGetProcessorRunStatusDetailsParamsWithContext(ctx context.Context) *GetProcessorRunStatusDetailsParams

NewGetProcessorRunStatusDetailsParamsWithContext creates a new GetProcessorRunStatusDetailsParams object with the ability to set a context for a request.

func NewGetProcessorRunStatusDetailsParamsWithHTTPClient 

func NewGetProcessorRunStatusDetailsParamsWithHTTPClient(client *http.Client) *GetProcessorRunStatusDetailsParams

NewGetProcessorRunStatusDetailsParamsWithHTTPClient creates a new GetProcessorRunStatusDetailsParams object with the ability to set a custom HTTPClient for a request.

func NewGetProcessorRunStatusDetailsParamsWithTimeout 

func NewGetProcessorRunStatusDetailsParamsWithTimeout(timeout time.Duration) *GetProcessorRunStatusDetailsParams

NewGetProcessorRunStatusDetailsParamsWithTimeout creates a new GetProcessorRunStatusDetailsParams object with the ability to set a timeout on a request.

func (*GetProcessorRunStatusDetailsParams) SetBody 

func (o *GetProcessorRunStatusDetailsParams) SetBody(body *models.RunStatusDetailsRequestEntity)

SetBody adds the body to the get processor run status details params

func (*GetProcessorRunStatusDetailsParams) SetContext 

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

SetContext adds the context to the get processor run status details params

func (*GetProcessorRunStatusDetailsParams) SetDefaults 

func (o *GetProcessorRunStatusDetailsParams) SetDefaults()

SetDefaults hydrates default values in the get processor run status details params (not the query body).

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

func (*GetProcessorRunStatusDetailsParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get processor run status details params

func (*GetProcessorRunStatusDetailsParams) SetTimeout 

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

SetTimeout adds the timeout to the get processor run status details params

func (*GetProcessorRunStatusDetailsParams) WithBody 

func (o *GetProcessorRunStatusDetailsParams) WithBody(body *models.RunStatusDetailsRequestEntity) *GetProcessorRunStatusDetailsParams

WithBody adds the body to the get processor run status details params

func (*GetProcessorRunStatusDetailsParams) WithContext 

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

WithContext adds the context to the get processor run status details params

func (*GetProcessorRunStatusDetailsParams) WithDefaults 

func (o *GetProcessorRunStatusDetailsParams) WithDefaults() *GetProcessorRunStatusDetailsParams

WithDefaults hydrates default values in the get processor run status details params (not the query body).

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

func (*GetProcessorRunStatusDetailsParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get processor run status details params

func (*GetProcessorRunStatusDetailsParams) WithTimeout 

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

WithTimeout adds the timeout to the get processor run status details params

func (*GetProcessorRunStatusDetailsParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetProcessorRunStatusDetailsReader 

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

GetProcessorRunStatusDetailsReader is a Reader for the GetProcessorRunStatusDetails structure.

func (*GetProcessorRunStatusDetailsReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetProcessorRunStatusDetailsUnauthorized 

type GetProcessorRunStatusDetailsUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetProcessorRunStatusDetailsUnauthorized 

func NewGetProcessorRunStatusDetailsUnauthorized() *GetProcessorRunStatusDetailsUnauthorized

NewGetProcessorRunStatusDetailsUnauthorized creates a GetProcessorRunStatusDetailsUnauthorized with default headers values

func (*GetProcessorRunStatusDetailsUnauthorized) Error 

func (o *GetProcessorRunStatusDetailsUnauthorized) Error() string

func (*GetProcessorRunStatusDetailsUnauthorized) IsClientError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsUnauthorized) IsClientError() bool

IsClientError returns true when this get processor run status details unauthorized response has a 4xx status code

func (*GetProcessorRunStatusDetailsUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this get processor run status details unauthorized response a status code equal to that given

func (*GetProcessorRunStatusDetailsUnauthorized) IsRedirect added in v1.19.1 

func (o *GetProcessorRunStatusDetailsUnauthorized) IsRedirect() bool

IsRedirect returns true when this get processor run status details unauthorized response has a 3xx status code

func (*GetProcessorRunStatusDetailsUnauthorized) IsServerError added in v1.19.1 

func (o *GetProcessorRunStatusDetailsUnauthorized) IsServerError() bool

IsServerError returns true when this get processor run status details unauthorized response has a 5xx status code

func (*GetProcessorRunStatusDetailsUnauthorized) IsSuccess added in v1.19.1 

func (o *GetProcessorRunStatusDetailsUnauthorized) IsSuccess() bool

IsSuccess returns true when this get processor run status details unauthorized response has a 2xx status code

func (*GetProcessorRunStatusDetailsUnauthorized) String added in v1.19.1 

func (o *GetProcessorRunStatusDetailsUnauthorized) String() string

type GetProcessorUnauthorized 

type GetProcessorUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetProcessorUnauthorized 

func NewGetProcessorUnauthorized() *GetProcessorUnauthorized

NewGetProcessorUnauthorized creates a GetProcessorUnauthorized with default headers values

func (*GetProcessorUnauthorized) Error 

func (o *GetProcessorUnauthorized) Error() string

func (*GetProcessorUnauthorized) IsClientError added in v1.19.1 

func (o *GetProcessorUnauthorized) IsClientError() bool

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

func (*GetProcessorUnauthorized) IsCode added in v1.19.1 

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

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

func (*GetProcessorUnauthorized) IsRedirect added in v1.19.1 

func (o *GetProcessorUnauthorized) IsRedirect() bool

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

func (*GetProcessorUnauthorized) IsServerError added in v1.19.1 

func (o *GetProcessorUnauthorized) IsServerError() bool

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

func (*GetProcessorUnauthorized) IsSuccess added in v1.19.1 

func (o *GetProcessorUnauthorized) IsSuccess() bool

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

func (*GetProcessorUnauthorized) String added in v1.19.1 

func (o *GetProcessorUnauthorized) String() string

type SubmitProcessorVerificationRequestBadRequest 

type SubmitProcessorVerificationRequestBadRequest struct {
}

SubmitProcessorVerificationRequestBadRequest 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 NewSubmitProcessorVerificationRequestBadRequest 

func NewSubmitProcessorVerificationRequestBadRequest() *SubmitProcessorVerificationRequestBadRequest

NewSubmitProcessorVerificationRequestBadRequest creates a SubmitProcessorVerificationRequestBadRequest with default headers values

func (*SubmitProcessorVerificationRequestBadRequest) Error 

func (o *SubmitProcessorVerificationRequestBadRequest) Error() string

func (*SubmitProcessorVerificationRequestBadRequest) IsClientError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestBadRequest) IsClientError() bool

IsClientError returns true when this submit processor verification request bad request response has a 4xx status code

func (*SubmitProcessorVerificationRequestBadRequest) IsCode added in v1.19.1 

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

IsCode returns true when this submit processor verification request bad request response a status code equal to that given

func (*SubmitProcessorVerificationRequestBadRequest) IsRedirect added in v1.19.1 

func (o *SubmitProcessorVerificationRequestBadRequest) IsRedirect() bool

IsRedirect returns true when this submit processor verification request bad request response has a 3xx status code

func (*SubmitProcessorVerificationRequestBadRequest) IsServerError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestBadRequest) IsServerError() bool

IsServerError returns true when this submit processor verification request bad request response has a 5xx status code

func (*SubmitProcessorVerificationRequestBadRequest) IsSuccess added in v1.19.1 

func (o *SubmitProcessorVerificationRequestBadRequest) IsSuccess() bool

IsSuccess returns true when this submit processor verification request bad request response has a 2xx status code

func (*SubmitProcessorVerificationRequestBadRequest) String added in v1.19.1 

func (o *SubmitProcessorVerificationRequestBadRequest) String() string

type SubmitProcessorVerificationRequestConflict 

type SubmitProcessorVerificationRequestConflict struct {
}

SubmitProcessorVerificationRequestConflict 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 NewSubmitProcessorVerificationRequestConflict 

func NewSubmitProcessorVerificationRequestConflict() *SubmitProcessorVerificationRequestConflict

NewSubmitProcessorVerificationRequestConflict creates a SubmitProcessorVerificationRequestConflict with default headers values

func (*SubmitProcessorVerificationRequestConflict) Error 

func (o *SubmitProcessorVerificationRequestConflict) Error() string

func (*SubmitProcessorVerificationRequestConflict) IsClientError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestConflict) IsClientError() bool

IsClientError returns true when this submit processor verification request conflict response has a 4xx status code

func (*SubmitProcessorVerificationRequestConflict) IsCode added in v1.19.1 

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

IsCode returns true when this submit processor verification request conflict response a status code equal to that given

func (*SubmitProcessorVerificationRequestConflict) IsRedirect added in v1.19.1 

func (o *SubmitProcessorVerificationRequestConflict) IsRedirect() bool

IsRedirect returns true when this submit processor verification request conflict response has a 3xx status code

func (*SubmitProcessorVerificationRequestConflict) IsServerError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestConflict) IsServerError() bool

IsServerError returns true when this submit processor verification request conflict response has a 5xx status code

func (*SubmitProcessorVerificationRequestConflict) IsSuccess added in v1.19.1 

func (o *SubmitProcessorVerificationRequestConflict) IsSuccess() bool

IsSuccess returns true when this submit processor verification request conflict response has a 2xx status code

func (*SubmitProcessorVerificationRequestConflict) String added in v1.19.1 

func (o *SubmitProcessorVerificationRequestConflict) String() string

type SubmitProcessorVerificationRequestForbidden 

type SubmitProcessorVerificationRequestForbidden struct {
}

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

Client is not authorized to make this request.

func NewSubmitProcessorVerificationRequestForbidden 

func NewSubmitProcessorVerificationRequestForbidden() *SubmitProcessorVerificationRequestForbidden

NewSubmitProcessorVerificationRequestForbidden creates a SubmitProcessorVerificationRequestForbidden with default headers values

func (*SubmitProcessorVerificationRequestForbidden) Error 

func (o *SubmitProcessorVerificationRequestForbidden) Error() string

func (*SubmitProcessorVerificationRequestForbidden) IsClientError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestForbidden) IsClientError() bool

IsClientError returns true when this submit processor verification request forbidden response has a 4xx status code

func (*SubmitProcessorVerificationRequestForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this submit processor verification request forbidden response a status code equal to that given

func (*SubmitProcessorVerificationRequestForbidden) IsRedirect added in v1.19.1 

func (o *SubmitProcessorVerificationRequestForbidden) IsRedirect() bool

IsRedirect returns true when this submit processor verification request forbidden response has a 3xx status code

func (*SubmitProcessorVerificationRequestForbidden) IsServerError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestForbidden) IsServerError() bool

IsServerError returns true when this submit processor verification request forbidden response has a 5xx status code

func (*SubmitProcessorVerificationRequestForbidden) IsSuccess added in v1.19.1 

func (o *SubmitProcessorVerificationRequestForbidden) IsSuccess() bool

IsSuccess returns true when this submit processor verification request forbidden response has a 2xx status code

func (*SubmitProcessorVerificationRequestForbidden) String added in v1.19.1 

func (o *SubmitProcessorVerificationRequestForbidden) String() string

type SubmitProcessorVerificationRequestNotFound 

type SubmitProcessorVerificationRequestNotFound struct {
}

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

The specified resource could not be found.

func NewSubmitProcessorVerificationRequestNotFound 

func NewSubmitProcessorVerificationRequestNotFound() *SubmitProcessorVerificationRequestNotFound

NewSubmitProcessorVerificationRequestNotFound creates a SubmitProcessorVerificationRequestNotFound with default headers values

func (*SubmitProcessorVerificationRequestNotFound) Error 

func (o *SubmitProcessorVerificationRequestNotFound) Error() string

func (*SubmitProcessorVerificationRequestNotFound) IsClientError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestNotFound) IsClientError() bool

IsClientError returns true when this submit processor verification request not found response has a 4xx status code

func (*SubmitProcessorVerificationRequestNotFound) IsCode added in v1.19.1 

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

IsCode returns true when this submit processor verification request not found response a status code equal to that given

func (*SubmitProcessorVerificationRequestNotFound) IsRedirect added in v1.19.1 

func (o *SubmitProcessorVerificationRequestNotFound) IsRedirect() bool

IsRedirect returns true when this submit processor verification request not found response has a 3xx status code

func (*SubmitProcessorVerificationRequestNotFound) IsServerError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestNotFound) IsServerError() bool

IsServerError returns true when this submit processor verification request not found response has a 5xx status code

func (*SubmitProcessorVerificationRequestNotFound) IsSuccess added in v1.19.1 

func (o *SubmitProcessorVerificationRequestNotFound) IsSuccess() bool

IsSuccess returns true when this submit processor verification request not found response has a 2xx status code

func (*SubmitProcessorVerificationRequestNotFound) String added in v1.19.1 

func (o *SubmitProcessorVerificationRequestNotFound) String() string

type SubmitProcessorVerificationRequestOK 

type SubmitProcessorVerificationRequestOK struct {
	Payload *models.VerifyConfigRequestEntity
}

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

successful operation

func NewSubmitProcessorVerificationRequestOK 

func NewSubmitProcessorVerificationRequestOK() *SubmitProcessorVerificationRequestOK

NewSubmitProcessorVerificationRequestOK creates a SubmitProcessorVerificationRequestOK with default headers values

func (*SubmitProcessorVerificationRequestOK) Error 

func (o *SubmitProcessorVerificationRequestOK) Error() string

func (*SubmitProcessorVerificationRequestOK) GetPayload 

func (o *SubmitProcessorVerificationRequestOK) GetPayload() *models.VerifyConfigRequestEntity

func (*SubmitProcessorVerificationRequestOK) IsClientError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestOK) IsClientError() bool

IsClientError returns true when this submit processor verification request o k response has a 4xx status code

func (*SubmitProcessorVerificationRequestOK) IsCode added in v1.19.1 

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

IsCode returns true when this submit processor verification request o k response a status code equal to that given

func (*SubmitProcessorVerificationRequestOK) IsRedirect added in v1.19.1 

func (o *SubmitProcessorVerificationRequestOK) IsRedirect() bool

IsRedirect returns true when this submit processor verification request o k response has a 3xx status code

func (*SubmitProcessorVerificationRequestOK) IsServerError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestOK) IsServerError() bool

IsServerError returns true when this submit processor verification request o k response has a 5xx status code

func (*SubmitProcessorVerificationRequestOK) IsSuccess added in v1.19.1 

func (o *SubmitProcessorVerificationRequestOK) IsSuccess() bool

IsSuccess returns true when this submit processor verification request o k response has a 2xx status code

func (*SubmitProcessorVerificationRequestOK) String added in v1.19.1 

func (o *SubmitProcessorVerificationRequestOK) String() string

type SubmitProcessorVerificationRequestParams 

type SubmitProcessorVerificationRequestParams struct {

	/* Body.

	   The processor configuration verification request.
	*/
	Body *models.VerifyConfigRequestEntity

	/* ID.

	   The processor id.
	*/
	ID string

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

SubmitProcessorVerificationRequestParams contains all the parameters to send to the API endpoint 

for the submit processor verification request operation.

Typically these are written to a http.Request.

func NewSubmitProcessorVerificationRequestParams 

func NewSubmitProcessorVerificationRequestParams() *SubmitProcessorVerificationRequestParams

NewSubmitProcessorVerificationRequestParams creates a new SubmitProcessorVerificationRequestParams 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 NewSubmitProcessorVerificationRequestParamsWithContext 

func NewSubmitProcessorVerificationRequestParamsWithContext(ctx context.Context) *SubmitProcessorVerificationRequestParams

NewSubmitProcessorVerificationRequestParamsWithContext creates a new SubmitProcessorVerificationRequestParams object with the ability to set a context for a request.

func NewSubmitProcessorVerificationRequestParamsWithHTTPClient 

func NewSubmitProcessorVerificationRequestParamsWithHTTPClient(client *http.Client) *SubmitProcessorVerificationRequestParams

NewSubmitProcessorVerificationRequestParamsWithHTTPClient creates a new SubmitProcessorVerificationRequestParams object with the ability to set a custom HTTPClient for a request.

func NewSubmitProcessorVerificationRequestParamsWithTimeout 

func NewSubmitProcessorVerificationRequestParamsWithTimeout(timeout time.Duration) *SubmitProcessorVerificationRequestParams

NewSubmitProcessorVerificationRequestParamsWithTimeout creates a new SubmitProcessorVerificationRequestParams object with the ability to set a timeout on a request.

func (*SubmitProcessorVerificationRequestParams) SetBody 

func (o *SubmitProcessorVerificationRequestParams) SetBody(body *models.VerifyConfigRequestEntity)

SetBody adds the body to the submit processor verification request params

func (*SubmitProcessorVerificationRequestParams) SetContext 

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

SetContext adds the context to the submit processor verification request params

func (*SubmitProcessorVerificationRequestParams) SetDefaults 

func (o *SubmitProcessorVerificationRequestParams) SetDefaults()

SetDefaults hydrates default values in the submit processor verification request params (not the query body).

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

func (*SubmitProcessorVerificationRequestParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the submit processor verification request params

func (*SubmitProcessorVerificationRequestParams) SetID 

func (o *SubmitProcessorVerificationRequestParams) SetID(id string)

SetID adds the id to the submit processor verification request params

func (*SubmitProcessorVerificationRequestParams) SetTimeout 

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

SetTimeout adds the timeout to the submit processor verification request params

func (*SubmitProcessorVerificationRequestParams) WithBody 

func (o *SubmitProcessorVerificationRequestParams) WithBody(body *models.VerifyConfigRequestEntity) *SubmitProcessorVerificationRequestParams

WithBody adds the body to the submit processor verification request params

func (*SubmitProcessorVerificationRequestParams) WithContext 

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

WithContext adds the context to the submit processor verification request params

func (*SubmitProcessorVerificationRequestParams) WithDefaults 

func (o *SubmitProcessorVerificationRequestParams) WithDefaults() *SubmitProcessorVerificationRequestParams

WithDefaults hydrates default values in the submit processor verification request params (not the query body).

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

func (*SubmitProcessorVerificationRequestParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the submit processor verification request params

func (*SubmitProcessorVerificationRequestParams) WithID 

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

WithID adds the id to the submit processor verification request params

func (*SubmitProcessorVerificationRequestParams) WithTimeout 

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

WithTimeout adds the timeout to the submit processor verification request params

func (*SubmitProcessorVerificationRequestParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type SubmitProcessorVerificationRequestReader 

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

SubmitProcessorVerificationRequestReader is a Reader for the SubmitProcessorVerificationRequest structure.

func (*SubmitProcessorVerificationRequestReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type SubmitProcessorVerificationRequestUnauthorized 

type SubmitProcessorVerificationRequestUnauthorized struct {
}

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

Client could not be authenticated.

func NewSubmitProcessorVerificationRequestUnauthorized 

func NewSubmitProcessorVerificationRequestUnauthorized() *SubmitProcessorVerificationRequestUnauthorized

NewSubmitProcessorVerificationRequestUnauthorized creates a SubmitProcessorVerificationRequestUnauthorized with default headers values

func (*SubmitProcessorVerificationRequestUnauthorized) Error 

func (o *SubmitProcessorVerificationRequestUnauthorized) Error() string

func (*SubmitProcessorVerificationRequestUnauthorized) IsClientError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestUnauthorized) IsClientError() bool

IsClientError returns true when this submit processor verification request unauthorized response has a 4xx status code

func (*SubmitProcessorVerificationRequestUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this submit processor verification request unauthorized response a status code equal to that given

func (*SubmitProcessorVerificationRequestUnauthorized) IsRedirect added in v1.19.1 

func (o *SubmitProcessorVerificationRequestUnauthorized) IsRedirect() bool

IsRedirect returns true when this submit processor verification request unauthorized response has a 3xx status code

func (*SubmitProcessorVerificationRequestUnauthorized) IsServerError added in v1.19.1 

func (o *SubmitProcessorVerificationRequestUnauthorized) IsServerError() bool

IsServerError returns true when this submit processor verification request unauthorized response has a 5xx status code

func (*SubmitProcessorVerificationRequestUnauthorized) IsSuccess added in v1.19.1 

func (o *SubmitProcessorVerificationRequestUnauthorized) IsSuccess() bool

IsSuccess returns true when this submit processor verification request unauthorized response has a 2xx status code

func (*SubmitProcessorVerificationRequestUnauthorized) String added in v1.19.1 

func (o *SubmitProcessorVerificationRequestUnauthorized) String() string

type TerminateProcessorBadRequest 

type TerminateProcessorBadRequest struct {
}

TerminateProcessorBadRequest 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 NewTerminateProcessorBadRequest 

func NewTerminateProcessorBadRequest() *TerminateProcessorBadRequest

NewTerminateProcessorBadRequest creates a TerminateProcessorBadRequest with default headers values

func (*TerminateProcessorBadRequest) Error 

func (o *TerminateProcessorBadRequest) Error() string

func (*TerminateProcessorBadRequest) IsClientError added in v1.19.1 

func (o *TerminateProcessorBadRequest) IsClientError() bool

IsClientError returns true when this terminate processor bad request response has a 4xx status code

func (*TerminateProcessorBadRequest) IsCode added in v1.19.1 

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

IsCode returns true when this terminate processor bad request response a status code equal to that given

func (*TerminateProcessorBadRequest) IsRedirect added in v1.19.1 

func (o *TerminateProcessorBadRequest) IsRedirect() bool

IsRedirect returns true when this terminate processor bad request response has a 3xx status code

func (*TerminateProcessorBadRequest) IsServerError added in v1.19.1 

func (o *TerminateProcessorBadRequest) IsServerError() bool

IsServerError returns true when this terminate processor bad request response has a 5xx status code

func (*TerminateProcessorBadRequest) IsSuccess added in v1.19.1 

func (o *TerminateProcessorBadRequest) IsSuccess() bool

IsSuccess returns true when this terminate processor bad request response has a 2xx status code

func (*TerminateProcessorBadRequest) String added in v1.19.1 

func (o *TerminateProcessorBadRequest) String() string

type TerminateProcessorConflict 

type TerminateProcessorConflict struct {
}

TerminateProcessorConflict 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 NewTerminateProcessorConflict 

func NewTerminateProcessorConflict() *TerminateProcessorConflict

NewTerminateProcessorConflict creates a TerminateProcessorConflict with default headers values

func (*TerminateProcessorConflict) Error 

func (o *TerminateProcessorConflict) Error() string

func (*TerminateProcessorConflict) IsClientError added in v1.19.1 

func (o *TerminateProcessorConflict) IsClientError() bool

IsClientError returns true when this terminate processor conflict response has a 4xx status code

func (*TerminateProcessorConflict) IsCode added in v1.19.1 

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

IsCode returns true when this terminate processor conflict response a status code equal to that given

func (*TerminateProcessorConflict) IsRedirect added in v1.19.1 

func (o *TerminateProcessorConflict) IsRedirect() bool

IsRedirect returns true when this terminate processor conflict response has a 3xx status code

func (*TerminateProcessorConflict) IsServerError added in v1.19.1 

func (o *TerminateProcessorConflict) IsServerError() bool

IsServerError returns true when this terminate processor conflict response has a 5xx status code

func (*TerminateProcessorConflict) IsSuccess added in v1.19.1 

func (o *TerminateProcessorConflict) IsSuccess() bool

IsSuccess returns true when this terminate processor conflict response has a 2xx status code

func (*TerminateProcessorConflict) String added in v1.19.1 

func (o *TerminateProcessorConflict) String() string

type TerminateProcessorForbidden 

type TerminateProcessorForbidden struct {
}

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

Client is not authorized to make this request.

func NewTerminateProcessorForbidden 

func NewTerminateProcessorForbidden() *TerminateProcessorForbidden

NewTerminateProcessorForbidden creates a TerminateProcessorForbidden with default headers values

func (*TerminateProcessorForbidden) Error 

func (o *TerminateProcessorForbidden) Error() string

func (*TerminateProcessorForbidden) IsClientError added in v1.19.1 

func (o *TerminateProcessorForbidden) IsClientError() bool

IsClientError returns true when this terminate processor forbidden response has a 4xx status code

func (*TerminateProcessorForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this terminate processor forbidden response a status code equal to that given

func (*TerminateProcessorForbidden) IsRedirect added in v1.19.1 

func (o *TerminateProcessorForbidden) IsRedirect() bool

IsRedirect returns true when this terminate processor forbidden response has a 3xx status code

func (*TerminateProcessorForbidden) IsServerError added in v1.19.1 

func (o *TerminateProcessorForbidden) IsServerError() bool

IsServerError returns true when this terminate processor forbidden response has a 5xx status code

func (*TerminateProcessorForbidden) IsSuccess added in v1.19.1 

func (o *TerminateProcessorForbidden) IsSuccess() bool

IsSuccess returns true when this terminate processor forbidden response has a 2xx status code

func (*TerminateProcessorForbidden) String added in v1.19.1 

func (o *TerminateProcessorForbidden) String() string

type TerminateProcessorNotFound 

type TerminateProcessorNotFound struct {
}

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

The specified resource could not be found.

func NewTerminateProcessorNotFound 

func NewTerminateProcessorNotFound() *TerminateProcessorNotFound

NewTerminateProcessorNotFound creates a TerminateProcessorNotFound with default headers values

func (*TerminateProcessorNotFound) Error 

func (o *TerminateProcessorNotFound) Error() string

func (*TerminateProcessorNotFound) IsClientError added in v1.19.1 

func (o *TerminateProcessorNotFound) IsClientError() bool

IsClientError returns true when this terminate processor not found response has a 4xx status code

func (*TerminateProcessorNotFound) IsCode added in v1.19.1 

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

IsCode returns true when this terminate processor not found response a status code equal to that given

func (*TerminateProcessorNotFound) IsRedirect added in v1.19.1 

func (o *TerminateProcessorNotFound) IsRedirect() bool

IsRedirect returns true when this terminate processor not found response has a 3xx status code

func (*TerminateProcessorNotFound) IsServerError added in v1.19.1 

func (o *TerminateProcessorNotFound) IsServerError() bool

IsServerError returns true when this terminate processor not found response has a 5xx status code

func (*TerminateProcessorNotFound) IsSuccess added in v1.19.1 

func (o *TerminateProcessorNotFound) IsSuccess() bool

IsSuccess returns true when this terminate processor not found response has a 2xx status code

func (*TerminateProcessorNotFound) String added in v1.19.1 

func (o *TerminateProcessorNotFound) String() string

type TerminateProcessorOK 

type TerminateProcessorOK struct {
	Payload *models.ProcessorEntity
}

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

successful operation

func NewTerminateProcessorOK 

func NewTerminateProcessorOK() *TerminateProcessorOK

NewTerminateProcessorOK creates a TerminateProcessorOK with default headers values

func (*TerminateProcessorOK) Error 

func (o *TerminateProcessorOK) Error() string

func (*TerminateProcessorOK) GetPayload 

func (o *TerminateProcessorOK) GetPayload() *models.ProcessorEntity

func (*TerminateProcessorOK) IsClientError added in v1.19.1 

func (o *TerminateProcessorOK) IsClientError() bool

IsClientError returns true when this terminate processor o k response has a 4xx status code

func (*TerminateProcessorOK) IsCode added in v1.19.1 

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

IsCode returns true when this terminate processor o k response a status code equal to that given

func (*TerminateProcessorOK) IsRedirect added in v1.19.1 

func (o *TerminateProcessorOK) IsRedirect() bool

IsRedirect returns true when this terminate processor o k response has a 3xx status code

func (*TerminateProcessorOK) IsServerError added in v1.19.1 

func (o *TerminateProcessorOK) IsServerError() bool

IsServerError returns true when this terminate processor o k response has a 5xx status code

func (*TerminateProcessorOK) IsSuccess added in v1.19.1 

func (o *TerminateProcessorOK) IsSuccess() bool

IsSuccess returns true when this terminate processor o k response has a 2xx status code

func (*TerminateProcessorOK) String added in v1.19.1 

func (o *TerminateProcessorOK) String() string

type TerminateProcessorParams 

type TerminateProcessorParams struct {

	/* ID.

	   The processor id.
	*/
	ID string

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

TerminateProcessorParams contains all the parameters to send to the API endpoint 

for the terminate processor operation.

Typically these are written to a http.Request.

func NewTerminateProcessorParams 

func NewTerminateProcessorParams() *TerminateProcessorParams

NewTerminateProcessorParams creates a new TerminateProcessorParams 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 NewTerminateProcessorParamsWithContext 

func NewTerminateProcessorParamsWithContext(ctx context.Context) *TerminateProcessorParams

NewTerminateProcessorParamsWithContext creates a new TerminateProcessorParams object with the ability to set a context for a request.

func NewTerminateProcessorParamsWithHTTPClient 

func NewTerminateProcessorParamsWithHTTPClient(client *http.Client) *TerminateProcessorParams

NewTerminateProcessorParamsWithHTTPClient creates a new TerminateProcessorParams object with the ability to set a custom HTTPClient for a request.

func NewTerminateProcessorParamsWithTimeout 

func NewTerminateProcessorParamsWithTimeout(timeout time.Duration) *TerminateProcessorParams

NewTerminateProcessorParamsWithTimeout creates a new TerminateProcessorParams object with the ability to set a timeout on a request.

func (*TerminateProcessorParams) SetContext 

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

SetContext adds the context to the terminate processor params

func (*TerminateProcessorParams) SetDefaults 

func (o *TerminateProcessorParams) SetDefaults()

SetDefaults hydrates default values in the terminate processor params (not the query body).

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

func (*TerminateProcessorParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the terminate processor params

func (*TerminateProcessorParams) SetID 

func (o *TerminateProcessorParams) SetID(id string)

SetID adds the id to the terminate processor params

func (*TerminateProcessorParams) SetTimeout 

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

SetTimeout adds the timeout to the terminate processor params

func (*TerminateProcessorParams) WithContext 

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

WithContext adds the context to the terminate processor params

func (*TerminateProcessorParams) WithDefaults 

func (o *TerminateProcessorParams) WithDefaults() *TerminateProcessorParams

WithDefaults hydrates default values in the terminate processor params (not the query body).

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

func (*TerminateProcessorParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the terminate processor params

func (*TerminateProcessorParams) WithID 

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

WithID adds the id to the terminate processor params

func (*TerminateProcessorParams) WithTimeout 

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

WithTimeout adds the timeout to the terminate processor params

func (*TerminateProcessorParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type TerminateProcessorReader 

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

TerminateProcessorReader is a Reader for the TerminateProcessor structure.

func (*TerminateProcessorReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type TerminateProcessorUnauthorized 

type TerminateProcessorUnauthorized struct {
}

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

Client could not be authenticated.

func NewTerminateProcessorUnauthorized 

func NewTerminateProcessorUnauthorized() *TerminateProcessorUnauthorized

NewTerminateProcessorUnauthorized creates a TerminateProcessorUnauthorized with default headers values

func (*TerminateProcessorUnauthorized) Error 

func (o *TerminateProcessorUnauthorized) Error() string

func (*TerminateProcessorUnauthorized) IsClientError added in v1.19.1 

func (o *TerminateProcessorUnauthorized) IsClientError() bool

IsClientError returns true when this terminate processor unauthorized response has a 4xx status code

func (*TerminateProcessorUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this terminate processor unauthorized response a status code equal to that given

func (*TerminateProcessorUnauthorized) IsRedirect added in v1.19.1 

func (o *TerminateProcessorUnauthorized) IsRedirect() bool

IsRedirect returns true when this terminate processor unauthorized response has a 3xx status code

func (*TerminateProcessorUnauthorized) IsServerError added in v1.19.1 

func (o *TerminateProcessorUnauthorized) IsServerError() bool

IsServerError returns true when this terminate processor unauthorized response has a 5xx status code

func (*TerminateProcessorUnauthorized) IsSuccess added in v1.19.1 

func (o *TerminateProcessorUnauthorized) IsSuccess() bool

IsSuccess returns true when this terminate processor unauthorized response has a 2xx status code

func (*TerminateProcessorUnauthorized) String added in v1.19.1 

func (o *TerminateProcessorUnauthorized) String() string

type UpdateProcessorBadRequest 

type UpdateProcessorBadRequest struct {
}

UpdateProcessorBadRequest 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 NewUpdateProcessorBadRequest 

func NewUpdateProcessorBadRequest() *UpdateProcessorBadRequest

NewUpdateProcessorBadRequest creates a UpdateProcessorBadRequest with default headers values

func (*UpdateProcessorBadRequest) Error 

func (o *UpdateProcessorBadRequest) Error() string

func (*UpdateProcessorBadRequest) IsClientError added in v1.19.1 

func (o *UpdateProcessorBadRequest) IsClientError() bool

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

func (*UpdateProcessorBadRequest) IsCode added in v1.19.1 

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

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

func (*UpdateProcessorBadRequest) IsRedirect added in v1.19.1 

func (o *UpdateProcessorBadRequest) IsRedirect() bool

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

func (*UpdateProcessorBadRequest) IsServerError added in v1.19.1 

func (o *UpdateProcessorBadRequest) IsServerError() bool

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

func (*UpdateProcessorBadRequest) IsSuccess added in v1.19.1 

func (o *UpdateProcessorBadRequest) IsSuccess() bool

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

func (*UpdateProcessorBadRequest) String added in v1.19.1 

func (o *UpdateProcessorBadRequest) String() string

type UpdateProcessorConflict 

type UpdateProcessorConflict struct {
}

UpdateProcessorConflict 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 NewUpdateProcessorConflict 

func NewUpdateProcessorConflict() *UpdateProcessorConflict

NewUpdateProcessorConflict creates a UpdateProcessorConflict with default headers values

func (*UpdateProcessorConflict) Error 

func (o *UpdateProcessorConflict) Error() string

func (*UpdateProcessorConflict) IsClientError added in v1.19.1 

func (o *UpdateProcessorConflict) IsClientError() bool

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

func (*UpdateProcessorConflict) IsCode added in v1.19.1 

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

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

func (*UpdateProcessorConflict) IsRedirect added in v1.19.1 

func (o *UpdateProcessorConflict) IsRedirect() bool

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

func (*UpdateProcessorConflict) IsServerError added in v1.19.1 

func (o *UpdateProcessorConflict) IsServerError() bool

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

func (*UpdateProcessorConflict) IsSuccess added in v1.19.1 

func (o *UpdateProcessorConflict) IsSuccess() bool

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

func (*UpdateProcessorConflict) String added in v1.19.1 

func (o *UpdateProcessorConflict) String() string

type UpdateProcessorForbidden 

type UpdateProcessorForbidden struct {
}

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

Client is not authorized to make this request.

func NewUpdateProcessorForbidden 

func NewUpdateProcessorForbidden() *UpdateProcessorForbidden

NewUpdateProcessorForbidden creates a UpdateProcessorForbidden with default headers values

func (*UpdateProcessorForbidden) Error 

func (o *UpdateProcessorForbidden) Error() string

func (*UpdateProcessorForbidden) IsClientError added in v1.19.1 

func (o *UpdateProcessorForbidden) IsClientError() bool

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

func (*UpdateProcessorForbidden) IsCode added in v1.19.1 

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

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

func (*UpdateProcessorForbidden) IsRedirect added in v1.19.1 

func (o *UpdateProcessorForbidden) IsRedirect() bool

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

func (*UpdateProcessorForbidden) IsServerError added in v1.19.1 

func (o *UpdateProcessorForbidden) IsServerError() bool

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

func (*UpdateProcessorForbidden) IsSuccess added in v1.19.1 

func (o *UpdateProcessorForbidden) IsSuccess() bool

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

func (*UpdateProcessorForbidden) String added in v1.19.1 

func (o *UpdateProcessorForbidden) String() string

type UpdateProcessorNotFound 

type UpdateProcessorNotFound struct {
}

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

The specified resource could not be found.

func NewUpdateProcessorNotFound 

func NewUpdateProcessorNotFound() *UpdateProcessorNotFound

NewUpdateProcessorNotFound creates a UpdateProcessorNotFound with default headers values

func (*UpdateProcessorNotFound) Error 

func (o *UpdateProcessorNotFound) Error() string

func (*UpdateProcessorNotFound) IsClientError added in v1.19.1 

func (o *UpdateProcessorNotFound) IsClientError() bool

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

func (*UpdateProcessorNotFound) IsCode added in v1.19.1 

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

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

func (*UpdateProcessorNotFound) IsRedirect added in v1.19.1 

func (o *UpdateProcessorNotFound) IsRedirect() bool

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

func (*UpdateProcessorNotFound) IsServerError added in v1.19.1 

func (o *UpdateProcessorNotFound) IsServerError() bool

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

func (*UpdateProcessorNotFound) IsSuccess added in v1.19.1 

func (o *UpdateProcessorNotFound) IsSuccess() bool

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

func (*UpdateProcessorNotFound) String added in v1.19.1 

func (o *UpdateProcessorNotFound) String() string

type UpdateProcessorOK 

type UpdateProcessorOK struct {
	Payload *models.ProcessorEntity
}

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

successful operation

func NewUpdateProcessorOK 

func NewUpdateProcessorOK() *UpdateProcessorOK

NewUpdateProcessorOK creates a UpdateProcessorOK with default headers values

func (*UpdateProcessorOK) Error 

func (o *UpdateProcessorOK) Error() string

func (*UpdateProcessorOK) GetPayload 

func (o *UpdateProcessorOK) GetPayload() *models.ProcessorEntity

func (*UpdateProcessorOK) IsClientError added in v1.19.1 

func (o *UpdateProcessorOK) IsClientError() bool

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

func (*UpdateProcessorOK) IsCode added in v1.19.1 

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

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

func (*UpdateProcessorOK) IsRedirect added in v1.19.1 

func (o *UpdateProcessorOK) IsRedirect() bool

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

func (*UpdateProcessorOK) IsServerError added in v1.19.1 

func (o *UpdateProcessorOK) IsServerError() bool

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

func (*UpdateProcessorOK) IsSuccess added in v1.19.1 

func (o *UpdateProcessorOK) IsSuccess() bool

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

func (*UpdateProcessorOK) String added in v1.19.1 

func (o *UpdateProcessorOK) String() string

type UpdateProcessorParams 

type UpdateProcessorParams struct {

	/* Body.

	   The processor configuration details.
	*/
	Body *models.ProcessorEntity

	/* ID.

	   The processor id.
	*/
	ID string

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

UpdateProcessorParams contains all the parameters to send to the API endpoint 

for the update processor operation.

Typically these are written to a http.Request.

func NewUpdateProcessorParams 

func NewUpdateProcessorParams() *UpdateProcessorParams

NewUpdateProcessorParams creates a new UpdateProcessorParams 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 NewUpdateProcessorParamsWithContext 

func NewUpdateProcessorParamsWithContext(ctx context.Context) *UpdateProcessorParams

NewUpdateProcessorParamsWithContext creates a new UpdateProcessorParams object with the ability to set a context for a request.

func NewUpdateProcessorParamsWithHTTPClient 

func NewUpdateProcessorParamsWithHTTPClient(client *http.Client) *UpdateProcessorParams

NewUpdateProcessorParamsWithHTTPClient creates a new UpdateProcessorParams object with the ability to set a custom HTTPClient for a request.

func NewUpdateProcessorParamsWithTimeout 

func NewUpdateProcessorParamsWithTimeout(timeout time.Duration) *UpdateProcessorParams

NewUpdateProcessorParamsWithTimeout creates a new UpdateProcessorParams object with the ability to set a timeout on a request.

func (*UpdateProcessorParams) SetBody 

func (o *UpdateProcessorParams) SetBody(body *models.ProcessorEntity)

SetBody adds the body to the update processor params

func (*UpdateProcessorParams) SetContext 

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

SetContext adds the context to the update processor params

func (*UpdateProcessorParams) SetDefaults 

func (o *UpdateProcessorParams) SetDefaults()

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

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

func (*UpdateProcessorParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the update processor params

func (*UpdateProcessorParams) SetID 

func (o *UpdateProcessorParams) SetID(id string)

SetID adds the id to the update processor params

func (*UpdateProcessorParams) SetTimeout 

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

SetTimeout adds the timeout to the update processor params

func (*UpdateProcessorParams) WithBody 

func (o *UpdateProcessorParams) WithBody(body *models.ProcessorEntity) *UpdateProcessorParams

WithBody adds the body to the update processor params

func (*UpdateProcessorParams) WithContext 

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

WithContext adds the context to the update processor params

func (*UpdateProcessorParams) WithDefaults 

func (o *UpdateProcessorParams) WithDefaults() *UpdateProcessorParams

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

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

func (*UpdateProcessorParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the update processor params

func (*UpdateProcessorParams) WithID 

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

WithID adds the id to the update processor params

func (*UpdateProcessorParams) WithTimeout 

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

WithTimeout adds the timeout to the update processor params

func (*UpdateProcessorParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type UpdateProcessorReader 

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

UpdateProcessorReader is a Reader for the UpdateProcessor structure.

func (*UpdateProcessorReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type UpdateProcessorUnauthorized 

type UpdateProcessorUnauthorized struct {
}

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

Client could not be authenticated.

func NewUpdateProcessorUnauthorized 

func NewUpdateProcessorUnauthorized() *UpdateProcessorUnauthorized

NewUpdateProcessorUnauthorized creates a UpdateProcessorUnauthorized with default headers values

func (*UpdateProcessorUnauthorized) Error 

func (o *UpdateProcessorUnauthorized) Error() string

func (*UpdateProcessorUnauthorized) IsClientError added in v1.19.1 

func (o *UpdateProcessorUnauthorized) IsClientError() bool

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

func (*UpdateProcessorUnauthorized) IsCode added in v1.19.1 

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

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

func (*UpdateProcessorUnauthorized) IsRedirect added in v1.19.1 

func (o *UpdateProcessorUnauthorized) IsRedirect() bool

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

func (*UpdateProcessorUnauthorized) IsServerError added in v1.19.1 

func (o *UpdateProcessorUnauthorized) IsServerError() bool

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

func (*UpdateProcessorUnauthorized) IsSuccess added in v1.19.1 

func (o *UpdateProcessorUnauthorized) IsSuccess() bool

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

func (*UpdateProcessorUnauthorized) String added in v1.19.1 

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