provenance

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

func (*Client) DeleteLineage

func (a *Client) DeleteLineage(params *DeleteLineageParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteLineageOK, error)

DeleteLineage deletes a lineage query

func (*Client) DeleteProvenance

func (a *Client) DeleteProvenance(params *DeleteProvenanceParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteProvenanceOK, error)

DeleteProvenance deletes a provenance query

func (*Client) GetLineage

func (a *Client) GetLineage(params *GetLineageParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetLineageOK, error)

GetLineage gets a lineage query

func (*Client) GetProvenance

func (a *Client) GetProvenance(params *GetProvenanceParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetProvenanceOK, error)

GetProvenance gets a provenance query

func (*Client) GetSearchOptions

func (a *Client) GetSearchOptions(params *GetSearchOptionsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetSearchOptionsOK, error)

GetSearchOptions gets the searchable attributes for provenance events

func (*Client) SetTransport

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

SetTransport changes the transport on the client

func (*Client) SubmitLineageRequest

func (a *Client) SubmitLineageRequest(params *SubmitLineageRequestParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*SubmitLineageRequestCreated, error)

SubmitLineageRequest submits a lineage query

Lineage queries may be long running so this endpoint submits a request. The response will include the current state of the query. If the request is not completed the URI in the response can be used at a later time to get the updated state of the query. Once the query has completed the lineage request should be deleted by the client who originally submitted it.

func (*Client) SubmitProvenanceRequest

func (a *Client) SubmitProvenanceRequest(params *SubmitProvenanceRequestParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*SubmitProvenanceRequestCreated, error)

SubmitProvenanceRequest submits a provenance query

Provenance queries may be long running so this endpoint submits a request. The response will include the current state of the query. If the request is not completed the URI in the response can be used at a later time to get the updated state of the query. Once the query has completed the provenance request should be deleted by the client who originally submitted it.

type ClientOption

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService

type ClientService interface {
	DeleteLineage(params *DeleteLineageParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteLineageOK, error)

	DeleteProvenance(params *DeleteProvenanceParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteProvenanceOK, error)

	GetLineage(params *GetLineageParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetLineageOK, error)

	GetProvenance(params *GetProvenanceParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetProvenanceOK, error)

	GetSearchOptions(params *GetSearchOptionsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetSearchOptionsOK, error)

	SubmitLineageRequest(params *SubmitLineageRequestParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*SubmitLineageRequestCreated, error)

	SubmitProvenanceRequest(params *SubmitProvenanceRequestParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*SubmitProvenanceRequestCreated, 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 provenance API client.

type DeleteLineageBadRequest

type DeleteLineageBadRequest struct {
}

DeleteLineageBadRequest 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 NewDeleteLineageBadRequest

func NewDeleteLineageBadRequest() *DeleteLineageBadRequest

NewDeleteLineageBadRequest creates a DeleteLineageBadRequest with default headers values

func (*DeleteLineageBadRequest) Error

func (o *DeleteLineageBadRequest) Error() string

func (*DeleteLineageBadRequest) IsClientError added in v1.19.1

func (o *DeleteLineageBadRequest) IsClientError() bool

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

func (*DeleteLineageBadRequest) IsCode added in v1.19.1

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

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

func (*DeleteLineageBadRequest) IsRedirect added in v1.19.1

func (o *DeleteLineageBadRequest) IsRedirect() bool

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

func (*DeleteLineageBadRequest) IsServerError added in v1.19.1

func (o *DeleteLineageBadRequest) IsServerError() bool

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

func (*DeleteLineageBadRequest) IsSuccess added in v1.19.1

func (o *DeleteLineageBadRequest) IsSuccess() bool

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

func (*DeleteLineageBadRequest) String added in v1.19.1

func (o *DeleteLineageBadRequest) String() string

type DeleteLineageConflict

type DeleteLineageConflict struct {
}

DeleteLineageConflict 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 NewDeleteLineageConflict

func NewDeleteLineageConflict() *DeleteLineageConflict

NewDeleteLineageConflict creates a DeleteLineageConflict with default headers values

func (*DeleteLineageConflict) Error

func (o *DeleteLineageConflict) Error() string

func (*DeleteLineageConflict) IsClientError added in v1.19.1

func (o *DeleteLineageConflict) IsClientError() bool

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

func (*DeleteLineageConflict) IsCode added in v1.19.1

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

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

func (*DeleteLineageConflict) IsRedirect added in v1.19.1

func (o *DeleteLineageConflict) IsRedirect() bool

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

func (*DeleteLineageConflict) IsServerError added in v1.19.1

func (o *DeleteLineageConflict) IsServerError() bool

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

func (*DeleteLineageConflict) IsSuccess added in v1.19.1

func (o *DeleteLineageConflict) IsSuccess() bool

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

func (*DeleteLineageConflict) String added in v1.19.1

func (o *DeleteLineageConflict) String() string

type DeleteLineageForbidden

type DeleteLineageForbidden struct {
}

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

Client is not authorized to make this request.

func NewDeleteLineageForbidden

func NewDeleteLineageForbidden() *DeleteLineageForbidden

NewDeleteLineageForbidden creates a DeleteLineageForbidden with default headers values

func (*DeleteLineageForbidden) Error

func (o *DeleteLineageForbidden) Error() string

func (*DeleteLineageForbidden) IsClientError added in v1.19.1

func (o *DeleteLineageForbidden) IsClientError() bool

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

func (*DeleteLineageForbidden) IsCode added in v1.19.1

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

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

func (*DeleteLineageForbidden) IsRedirect added in v1.19.1

func (o *DeleteLineageForbidden) IsRedirect() bool

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

func (*DeleteLineageForbidden) IsServerError added in v1.19.1

func (o *DeleteLineageForbidden) IsServerError() bool

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

func (*DeleteLineageForbidden) IsSuccess added in v1.19.1

func (o *DeleteLineageForbidden) IsSuccess() bool

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

func (*DeleteLineageForbidden) String added in v1.19.1

func (o *DeleteLineageForbidden) String() string

type DeleteLineageNotFound

type DeleteLineageNotFound struct {
}

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

The specified resource could not be found.

func NewDeleteLineageNotFound

func NewDeleteLineageNotFound() *DeleteLineageNotFound

NewDeleteLineageNotFound creates a DeleteLineageNotFound with default headers values

func (*DeleteLineageNotFound) Error

func (o *DeleteLineageNotFound) Error() string

func (*DeleteLineageNotFound) IsClientError added in v1.19.1

func (o *DeleteLineageNotFound) IsClientError() bool

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

func (*DeleteLineageNotFound) IsCode added in v1.19.1

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

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

func (*DeleteLineageNotFound) IsRedirect added in v1.19.1

func (o *DeleteLineageNotFound) IsRedirect() bool

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

func (*DeleteLineageNotFound) IsServerError added in v1.19.1

func (o *DeleteLineageNotFound) IsServerError() bool

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

func (*DeleteLineageNotFound) IsSuccess added in v1.19.1

func (o *DeleteLineageNotFound) IsSuccess() bool

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

func (*DeleteLineageNotFound) String added in v1.19.1

func (o *DeleteLineageNotFound) String() string

type DeleteLineageOK

type DeleteLineageOK struct {
	Payload *models.LineageEntity
}

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

successful operation

func NewDeleteLineageOK

func NewDeleteLineageOK() *DeleteLineageOK

NewDeleteLineageOK creates a DeleteLineageOK with default headers values

func (*DeleteLineageOK) Error

func (o *DeleteLineageOK) Error() string

func (*DeleteLineageOK) GetPayload

func (o *DeleteLineageOK) GetPayload() *models.LineageEntity

func (*DeleteLineageOK) IsClientError added in v1.19.1

func (o *DeleteLineageOK) IsClientError() bool

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

func (*DeleteLineageOK) IsCode added in v1.19.1

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

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

func (*DeleteLineageOK) IsRedirect added in v1.19.1

func (o *DeleteLineageOK) IsRedirect() bool

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

func (*DeleteLineageOK) IsServerError added in v1.19.1

func (o *DeleteLineageOK) IsServerError() bool

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

func (*DeleteLineageOK) IsSuccess added in v1.19.1

func (o *DeleteLineageOK) IsSuccess() bool

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

func (*DeleteLineageOK) String added in v1.19.1

func (o *DeleteLineageOK) String() string

type DeleteLineageParams

type DeleteLineageParams struct {

	/* ClusterNodeID.

	   The id of the node where this query exists if clustered.
	*/
	ClusterNodeID *string

	/* ID.

	   The id of the lineage query.
	*/
	ID string

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

DeleteLineageParams contains all the parameters to send to the API endpoint

for the delete lineage operation.

Typically these are written to a http.Request.

func NewDeleteLineageParams

func NewDeleteLineageParams() *DeleteLineageParams

NewDeleteLineageParams creates a new DeleteLineageParams 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 NewDeleteLineageParamsWithContext

func NewDeleteLineageParamsWithContext(ctx context.Context) *DeleteLineageParams

NewDeleteLineageParamsWithContext creates a new DeleteLineageParams object with the ability to set a context for a request.

func NewDeleteLineageParamsWithHTTPClient

func NewDeleteLineageParamsWithHTTPClient(client *http.Client) *DeleteLineageParams

NewDeleteLineageParamsWithHTTPClient creates a new DeleteLineageParams object with the ability to set a custom HTTPClient for a request.

func NewDeleteLineageParamsWithTimeout

func NewDeleteLineageParamsWithTimeout(timeout time.Duration) *DeleteLineageParams

NewDeleteLineageParamsWithTimeout creates a new DeleteLineageParams object with the ability to set a timeout on a request.

func (*DeleteLineageParams) SetClusterNodeID

func (o *DeleteLineageParams) SetClusterNodeID(clusterNodeID *string)

SetClusterNodeID adds the clusterNodeId to the delete lineage params

func (*DeleteLineageParams) SetContext

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

SetContext adds the context to the delete lineage params

func (*DeleteLineageParams) SetDefaults

func (o *DeleteLineageParams) SetDefaults()

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

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

func (*DeleteLineageParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the delete lineage params

func (*DeleteLineageParams) SetID

func (o *DeleteLineageParams) SetID(id string)

SetID adds the id to the delete lineage params

func (*DeleteLineageParams) SetTimeout

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

SetTimeout adds the timeout to the delete lineage params

func (*DeleteLineageParams) WithClusterNodeID

func (o *DeleteLineageParams) WithClusterNodeID(clusterNodeID *string) *DeleteLineageParams

WithClusterNodeID adds the clusterNodeID to the delete lineage params

func (*DeleteLineageParams) WithContext

WithContext adds the context to the delete lineage params

func (*DeleteLineageParams) WithDefaults

func (o *DeleteLineageParams) WithDefaults() *DeleteLineageParams

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

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

func (*DeleteLineageParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the delete lineage params

func (*DeleteLineageParams) WithID

WithID adds the id to the delete lineage params

func (*DeleteLineageParams) WithTimeout

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

WithTimeout adds the timeout to the delete lineage params

func (*DeleteLineageParams) WriteToRequest

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

WriteToRequest writes these params to a swagger request

type DeleteLineageReader

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

DeleteLineageReader is a Reader for the DeleteLineage structure.

func (*DeleteLineageReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type DeleteLineageUnauthorized

type DeleteLineageUnauthorized struct {
}

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

Client could not be authenticated.

func NewDeleteLineageUnauthorized

func NewDeleteLineageUnauthorized() *DeleteLineageUnauthorized

NewDeleteLineageUnauthorized creates a DeleteLineageUnauthorized with default headers values

func (*DeleteLineageUnauthorized) Error

func (o *DeleteLineageUnauthorized) Error() string

func (*DeleteLineageUnauthorized) IsClientError added in v1.19.1

func (o *DeleteLineageUnauthorized) IsClientError() bool

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

func (*DeleteLineageUnauthorized) IsCode added in v1.19.1

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

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

func (*DeleteLineageUnauthorized) IsRedirect added in v1.19.1

func (o *DeleteLineageUnauthorized) IsRedirect() bool

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

func (*DeleteLineageUnauthorized) IsServerError added in v1.19.1

func (o *DeleteLineageUnauthorized) IsServerError() bool

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

func (*DeleteLineageUnauthorized) IsSuccess added in v1.19.1

func (o *DeleteLineageUnauthorized) IsSuccess() bool

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

func (*DeleteLineageUnauthorized) String added in v1.19.1

func (o *DeleteLineageUnauthorized) String() string

type DeleteProvenanceBadRequest

type DeleteProvenanceBadRequest struct {
}

DeleteProvenanceBadRequest 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 NewDeleteProvenanceBadRequest

func NewDeleteProvenanceBadRequest() *DeleteProvenanceBadRequest

NewDeleteProvenanceBadRequest creates a DeleteProvenanceBadRequest with default headers values

func (*DeleteProvenanceBadRequest) Error

func (*DeleteProvenanceBadRequest) IsClientError added in v1.19.1

func (o *DeleteProvenanceBadRequest) IsClientError() bool

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

func (*DeleteProvenanceBadRequest) IsCode added in v1.19.1

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

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

func (*DeleteProvenanceBadRequest) IsRedirect added in v1.19.1

func (o *DeleteProvenanceBadRequest) IsRedirect() bool

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

func (*DeleteProvenanceBadRequest) IsServerError added in v1.19.1

func (o *DeleteProvenanceBadRequest) IsServerError() bool

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

func (*DeleteProvenanceBadRequest) IsSuccess added in v1.19.1

func (o *DeleteProvenanceBadRequest) IsSuccess() bool

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

func (*DeleteProvenanceBadRequest) String added in v1.19.1

func (o *DeleteProvenanceBadRequest) String() string

type DeleteProvenanceConflict

type DeleteProvenanceConflict struct {
}

DeleteProvenanceConflict 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 NewDeleteProvenanceConflict

func NewDeleteProvenanceConflict() *DeleteProvenanceConflict

NewDeleteProvenanceConflict creates a DeleteProvenanceConflict with default headers values

func (*DeleteProvenanceConflict) Error

func (o *DeleteProvenanceConflict) Error() string

func (*DeleteProvenanceConflict) IsClientError added in v1.19.1

func (o *DeleteProvenanceConflict) IsClientError() bool

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

func (*DeleteProvenanceConflict) IsCode added in v1.19.1

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

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

func (*DeleteProvenanceConflict) IsRedirect added in v1.19.1

func (o *DeleteProvenanceConflict) IsRedirect() bool

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

func (*DeleteProvenanceConflict) IsServerError added in v1.19.1

func (o *DeleteProvenanceConflict) IsServerError() bool

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

func (*DeleteProvenanceConflict) IsSuccess added in v1.19.1

func (o *DeleteProvenanceConflict) IsSuccess() bool

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

func (*DeleteProvenanceConflict) String added in v1.19.1

func (o *DeleteProvenanceConflict) String() string

type DeleteProvenanceForbidden

type DeleteProvenanceForbidden struct {
}

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

Client is not authorized to make this request.

func NewDeleteProvenanceForbidden

func NewDeleteProvenanceForbidden() *DeleteProvenanceForbidden

NewDeleteProvenanceForbidden creates a DeleteProvenanceForbidden with default headers values

func (*DeleteProvenanceForbidden) Error

func (o *DeleteProvenanceForbidden) Error() string

func (*DeleteProvenanceForbidden) IsClientError added in v1.19.1

func (o *DeleteProvenanceForbidden) IsClientError() bool

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

func (*DeleteProvenanceForbidden) IsCode added in v1.19.1

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

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

func (*DeleteProvenanceForbidden) IsRedirect added in v1.19.1

func (o *DeleteProvenanceForbidden) IsRedirect() bool

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

func (*DeleteProvenanceForbidden) IsServerError added in v1.19.1

func (o *DeleteProvenanceForbidden) IsServerError() bool

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

func (*DeleteProvenanceForbidden) IsSuccess added in v1.19.1

func (o *DeleteProvenanceForbidden) IsSuccess() bool

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

func (*DeleteProvenanceForbidden) String added in v1.19.1

func (o *DeleteProvenanceForbidden) String() string

type DeleteProvenanceNotFound

type DeleteProvenanceNotFound struct {
}

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

The specified resource could not be found.

func NewDeleteProvenanceNotFound

func NewDeleteProvenanceNotFound() *DeleteProvenanceNotFound

NewDeleteProvenanceNotFound creates a DeleteProvenanceNotFound with default headers values

func (*DeleteProvenanceNotFound) Error

func (o *DeleteProvenanceNotFound) Error() string

func (*DeleteProvenanceNotFound) IsClientError added in v1.19.1

func (o *DeleteProvenanceNotFound) IsClientError() bool

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

func (*DeleteProvenanceNotFound) IsCode added in v1.19.1

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

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

func (*DeleteProvenanceNotFound) IsRedirect added in v1.19.1

func (o *DeleteProvenanceNotFound) IsRedirect() bool

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

func (*DeleteProvenanceNotFound) IsServerError added in v1.19.1

func (o *DeleteProvenanceNotFound) IsServerError() bool

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

func (*DeleteProvenanceNotFound) IsSuccess added in v1.19.1

func (o *DeleteProvenanceNotFound) IsSuccess() bool

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

func (*DeleteProvenanceNotFound) String added in v1.19.1

func (o *DeleteProvenanceNotFound) String() string

type DeleteProvenanceOK

type DeleteProvenanceOK struct {
	Payload *models.ProvenanceEntity
}

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

successful operation

func NewDeleteProvenanceOK

func NewDeleteProvenanceOK() *DeleteProvenanceOK

NewDeleteProvenanceOK creates a DeleteProvenanceOK with default headers values

func (*DeleteProvenanceOK) Error

func (o *DeleteProvenanceOK) Error() string

func (*DeleteProvenanceOK) GetPayload

func (o *DeleteProvenanceOK) GetPayload() *models.ProvenanceEntity

func (*DeleteProvenanceOK) IsClientError added in v1.19.1

func (o *DeleteProvenanceOK) IsClientError() bool

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

func (*DeleteProvenanceOK) IsCode added in v1.19.1

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

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

func (*DeleteProvenanceOK) IsRedirect added in v1.19.1

func (o *DeleteProvenanceOK) IsRedirect() bool

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

func (*DeleteProvenanceOK) IsServerError added in v1.19.1

func (o *DeleteProvenanceOK) IsServerError() bool

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

func (*DeleteProvenanceOK) IsSuccess added in v1.19.1

func (o *DeleteProvenanceOK) IsSuccess() bool

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

func (*DeleteProvenanceOK) String added in v1.19.1

func (o *DeleteProvenanceOK) String() string

type DeleteProvenanceParams

type DeleteProvenanceParams struct {

	/* ClusterNodeID.

	   The id of the node where this query exists if clustered.
	*/
	ClusterNodeID *string

	/* ID.

	   The id of the provenance query.
	*/
	ID string

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

DeleteProvenanceParams contains all the parameters to send to the API endpoint

for the delete provenance operation.

Typically these are written to a http.Request.

func NewDeleteProvenanceParams

func NewDeleteProvenanceParams() *DeleteProvenanceParams

NewDeleteProvenanceParams creates a new DeleteProvenanceParams 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 NewDeleteProvenanceParamsWithContext

func NewDeleteProvenanceParamsWithContext(ctx context.Context) *DeleteProvenanceParams

NewDeleteProvenanceParamsWithContext creates a new DeleteProvenanceParams object with the ability to set a context for a request.

func NewDeleteProvenanceParamsWithHTTPClient

func NewDeleteProvenanceParamsWithHTTPClient(client *http.Client) *DeleteProvenanceParams

NewDeleteProvenanceParamsWithHTTPClient creates a new DeleteProvenanceParams object with the ability to set a custom HTTPClient for a request.

func NewDeleteProvenanceParamsWithTimeout

func NewDeleteProvenanceParamsWithTimeout(timeout time.Duration) *DeleteProvenanceParams

NewDeleteProvenanceParamsWithTimeout creates a new DeleteProvenanceParams object with the ability to set a timeout on a request.

func (*DeleteProvenanceParams) SetClusterNodeID

func (o *DeleteProvenanceParams) SetClusterNodeID(clusterNodeID *string)

SetClusterNodeID adds the clusterNodeId to the delete provenance params

func (*DeleteProvenanceParams) SetContext

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

SetContext adds the context to the delete provenance params

func (*DeleteProvenanceParams) SetDefaults

func (o *DeleteProvenanceParams) SetDefaults()

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

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

func (*DeleteProvenanceParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the delete provenance params

func (*DeleteProvenanceParams) SetID

func (o *DeleteProvenanceParams) SetID(id string)

SetID adds the id to the delete provenance params

func (*DeleteProvenanceParams) SetTimeout

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

SetTimeout adds the timeout to the delete provenance params

func (*DeleteProvenanceParams) WithClusterNodeID

func (o *DeleteProvenanceParams) WithClusterNodeID(clusterNodeID *string) *DeleteProvenanceParams

WithClusterNodeID adds the clusterNodeID to the delete provenance params

func (*DeleteProvenanceParams) WithContext

WithContext adds the context to the delete provenance params

func (*DeleteProvenanceParams) WithDefaults

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

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

func (*DeleteProvenanceParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the delete provenance params

func (*DeleteProvenanceParams) WithID

WithID adds the id to the delete provenance params

func (*DeleteProvenanceParams) WithTimeout

WithTimeout adds the timeout to the delete provenance params

func (*DeleteProvenanceParams) WriteToRequest

WriteToRequest writes these params to a swagger request

type DeleteProvenanceReader

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

DeleteProvenanceReader is a Reader for the DeleteProvenance structure.

func (*DeleteProvenanceReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type DeleteProvenanceUnauthorized

type DeleteProvenanceUnauthorized struct {
}

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

Client could not be authenticated.

func NewDeleteProvenanceUnauthorized

func NewDeleteProvenanceUnauthorized() *DeleteProvenanceUnauthorized

NewDeleteProvenanceUnauthorized creates a DeleteProvenanceUnauthorized with default headers values

func (*DeleteProvenanceUnauthorized) Error

func (*DeleteProvenanceUnauthorized) IsClientError added in v1.19.1

func (o *DeleteProvenanceUnauthorized) IsClientError() bool

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

func (*DeleteProvenanceUnauthorized) IsCode added in v1.19.1

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

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

func (*DeleteProvenanceUnauthorized) IsRedirect added in v1.19.1

func (o *DeleteProvenanceUnauthorized) IsRedirect() bool

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

func (*DeleteProvenanceUnauthorized) IsServerError added in v1.19.1

func (o *DeleteProvenanceUnauthorized) IsServerError() bool

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

func (*DeleteProvenanceUnauthorized) IsSuccess added in v1.19.1

func (o *DeleteProvenanceUnauthorized) IsSuccess() bool

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

func (*DeleteProvenanceUnauthorized) String added in v1.19.1

type GetLineageBadRequest

type GetLineageBadRequest struct {
}

GetLineageBadRequest 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 NewGetLineageBadRequest

func NewGetLineageBadRequest() *GetLineageBadRequest

NewGetLineageBadRequest creates a GetLineageBadRequest with default headers values

func (*GetLineageBadRequest) Error

func (o *GetLineageBadRequest) Error() string

func (*GetLineageBadRequest) IsClientError added in v1.19.1

func (o *GetLineageBadRequest) IsClientError() bool

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

func (*GetLineageBadRequest) IsCode added in v1.19.1

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

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

func (*GetLineageBadRequest) IsRedirect added in v1.19.1

func (o *GetLineageBadRequest) IsRedirect() bool

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

func (*GetLineageBadRequest) IsServerError added in v1.19.1

func (o *GetLineageBadRequest) IsServerError() bool

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

func (*GetLineageBadRequest) IsSuccess added in v1.19.1

func (o *GetLineageBadRequest) IsSuccess() bool

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

func (*GetLineageBadRequest) String added in v1.19.1

func (o *GetLineageBadRequest) String() string

type GetLineageConflict

type GetLineageConflict struct {
}

GetLineageConflict 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 NewGetLineageConflict

func NewGetLineageConflict() *GetLineageConflict

NewGetLineageConflict creates a GetLineageConflict with default headers values

func (*GetLineageConflict) Error

func (o *GetLineageConflict) Error() string

func (*GetLineageConflict) IsClientError added in v1.19.1

func (o *GetLineageConflict) IsClientError() bool

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

func (*GetLineageConflict) IsCode added in v1.19.1

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

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

func (*GetLineageConflict) IsRedirect added in v1.19.1

func (o *GetLineageConflict) IsRedirect() bool

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

func (*GetLineageConflict) IsServerError added in v1.19.1

func (o *GetLineageConflict) IsServerError() bool

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

func (*GetLineageConflict) IsSuccess added in v1.19.1

func (o *GetLineageConflict) IsSuccess() bool

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

func (*GetLineageConflict) String added in v1.19.1

func (o *GetLineageConflict) String() string

type GetLineageForbidden

type GetLineageForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetLineageForbidden

func NewGetLineageForbidden() *GetLineageForbidden

NewGetLineageForbidden creates a GetLineageForbidden with default headers values

func (*GetLineageForbidden) Error

func (o *GetLineageForbidden) Error() string

func (*GetLineageForbidden) IsClientError added in v1.19.1

func (o *GetLineageForbidden) IsClientError() bool

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

func (*GetLineageForbidden) IsCode added in v1.19.1

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

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

func (*GetLineageForbidden) IsRedirect added in v1.19.1

func (o *GetLineageForbidden) IsRedirect() bool

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

func (*GetLineageForbidden) IsServerError added in v1.19.1

func (o *GetLineageForbidden) IsServerError() bool

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

func (*GetLineageForbidden) IsSuccess added in v1.19.1

func (o *GetLineageForbidden) IsSuccess() bool

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

func (*GetLineageForbidden) String added in v1.19.1

func (o *GetLineageForbidden) String() string

type GetLineageNotFound

type GetLineageNotFound struct {
}

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

The specified resource could not be found.

func NewGetLineageNotFound

func NewGetLineageNotFound() *GetLineageNotFound

NewGetLineageNotFound creates a GetLineageNotFound with default headers values

func (*GetLineageNotFound) Error

func (o *GetLineageNotFound) Error() string

func (*GetLineageNotFound) IsClientError added in v1.19.1

func (o *GetLineageNotFound) IsClientError() bool

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

func (*GetLineageNotFound) IsCode added in v1.19.1

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

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

func (*GetLineageNotFound) IsRedirect added in v1.19.1

func (o *GetLineageNotFound) IsRedirect() bool

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

func (*GetLineageNotFound) IsServerError added in v1.19.1

func (o *GetLineageNotFound) IsServerError() bool

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

func (*GetLineageNotFound) IsSuccess added in v1.19.1

func (o *GetLineageNotFound) IsSuccess() bool

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

func (*GetLineageNotFound) String added in v1.19.1

func (o *GetLineageNotFound) String() string

type GetLineageOK

type GetLineageOK struct {
	Payload *models.LineageEntity
}

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

successful operation

func NewGetLineageOK

func NewGetLineageOK() *GetLineageOK

NewGetLineageOK creates a GetLineageOK with default headers values

func (*GetLineageOK) Error

func (o *GetLineageOK) Error() string

func (*GetLineageOK) GetPayload

func (o *GetLineageOK) GetPayload() *models.LineageEntity

func (*GetLineageOK) IsClientError added in v1.19.1

func (o *GetLineageOK) IsClientError() bool

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

func (*GetLineageOK) IsCode added in v1.19.1

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

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

func (*GetLineageOK) IsRedirect added in v1.19.1

func (o *GetLineageOK) IsRedirect() bool

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

func (*GetLineageOK) IsServerError added in v1.19.1

func (o *GetLineageOK) IsServerError() bool

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

func (*GetLineageOK) IsSuccess added in v1.19.1

func (o *GetLineageOK) IsSuccess() bool

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

func (*GetLineageOK) String added in v1.19.1

func (o *GetLineageOK) String() string

type GetLineageParams

type GetLineageParams struct {

	/* ClusterNodeID.

	   The id of the node where this query exists if clustered.
	*/
	ClusterNodeID *string

	/* ID.

	   The id of the lineage query.
	*/
	ID string

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

GetLineageParams contains all the parameters to send to the API endpoint

for the get lineage operation.

Typically these are written to a http.Request.

func NewGetLineageParams

func NewGetLineageParams() *GetLineageParams

NewGetLineageParams creates a new GetLineageParams 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 NewGetLineageParamsWithContext

func NewGetLineageParamsWithContext(ctx context.Context) *GetLineageParams

NewGetLineageParamsWithContext creates a new GetLineageParams object with the ability to set a context for a request.

func NewGetLineageParamsWithHTTPClient

func NewGetLineageParamsWithHTTPClient(client *http.Client) *GetLineageParams

NewGetLineageParamsWithHTTPClient creates a new GetLineageParams object with the ability to set a custom HTTPClient for a request.

func NewGetLineageParamsWithTimeout

func NewGetLineageParamsWithTimeout(timeout time.Duration) *GetLineageParams

NewGetLineageParamsWithTimeout creates a new GetLineageParams object with the ability to set a timeout on a request.

func (*GetLineageParams) SetClusterNodeID

func (o *GetLineageParams) SetClusterNodeID(clusterNodeID *string)

SetClusterNodeID adds the clusterNodeId to the get lineage params

func (*GetLineageParams) SetContext

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

SetContext adds the context to the get lineage params

func (*GetLineageParams) SetDefaults

func (o *GetLineageParams) SetDefaults()

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

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

func (*GetLineageParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the get lineage params

func (*GetLineageParams) SetID

func (o *GetLineageParams) SetID(id string)

SetID adds the id to the get lineage params

func (*GetLineageParams) SetTimeout

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

SetTimeout adds the timeout to the get lineage params

func (*GetLineageParams) WithClusterNodeID

func (o *GetLineageParams) WithClusterNodeID(clusterNodeID *string) *GetLineageParams

WithClusterNodeID adds the clusterNodeID to the get lineage params

func (*GetLineageParams) WithContext

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

WithContext adds the context to the get lineage params

func (*GetLineageParams) WithDefaults

func (o *GetLineageParams) WithDefaults() *GetLineageParams

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

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

func (*GetLineageParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the get lineage params

func (*GetLineageParams) WithID

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

WithID adds the id to the get lineage params

func (*GetLineageParams) WithTimeout

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

WithTimeout adds the timeout to the get lineage params

func (*GetLineageParams) WriteToRequest

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

WriteToRequest writes these params to a swagger request

type GetLineageReader

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

GetLineageReader is a Reader for the GetLineage structure.

func (*GetLineageReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type GetLineageUnauthorized

type GetLineageUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetLineageUnauthorized

func NewGetLineageUnauthorized() *GetLineageUnauthorized

NewGetLineageUnauthorized creates a GetLineageUnauthorized with default headers values

func (*GetLineageUnauthorized) Error

func (o *GetLineageUnauthorized) Error() string

func (*GetLineageUnauthorized) IsClientError added in v1.19.1

func (o *GetLineageUnauthorized) IsClientError() bool

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

func (*GetLineageUnauthorized) IsCode added in v1.19.1

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

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

func (*GetLineageUnauthorized) IsRedirect added in v1.19.1

func (o *GetLineageUnauthorized) IsRedirect() bool

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

func (*GetLineageUnauthorized) IsServerError added in v1.19.1

func (o *GetLineageUnauthorized) IsServerError() bool

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

func (*GetLineageUnauthorized) IsSuccess added in v1.19.1

func (o *GetLineageUnauthorized) IsSuccess() bool

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

func (*GetLineageUnauthorized) String added in v1.19.1

func (o *GetLineageUnauthorized) String() string

type GetProvenanceBadRequest

type GetProvenanceBadRequest struct {
}

GetProvenanceBadRequest 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 NewGetProvenanceBadRequest

func NewGetProvenanceBadRequest() *GetProvenanceBadRequest

NewGetProvenanceBadRequest creates a GetProvenanceBadRequest with default headers values

func (*GetProvenanceBadRequest) Error

func (o *GetProvenanceBadRequest) Error() string

func (*GetProvenanceBadRequest) IsClientError added in v1.19.1

func (o *GetProvenanceBadRequest) IsClientError() bool

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

func (*GetProvenanceBadRequest) IsCode added in v1.19.1

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

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

func (*GetProvenanceBadRequest) IsRedirect added in v1.19.1

func (o *GetProvenanceBadRequest) IsRedirect() bool

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

func (*GetProvenanceBadRequest) IsServerError added in v1.19.1

func (o *GetProvenanceBadRequest) IsServerError() bool

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

func (*GetProvenanceBadRequest) IsSuccess added in v1.19.1

func (o *GetProvenanceBadRequest) IsSuccess() bool

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

func (*GetProvenanceBadRequest) String added in v1.19.1

func (o *GetProvenanceBadRequest) String() string

type GetProvenanceConflict

type GetProvenanceConflict struct {
}

GetProvenanceConflict 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 NewGetProvenanceConflict

func NewGetProvenanceConflict() *GetProvenanceConflict

NewGetProvenanceConflict creates a GetProvenanceConflict with default headers values

func (*GetProvenanceConflict) Error

func (o *GetProvenanceConflict) Error() string

func (*GetProvenanceConflict) IsClientError added in v1.19.1

func (o *GetProvenanceConflict) IsClientError() bool

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

func (*GetProvenanceConflict) IsCode added in v1.19.1

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

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

func (*GetProvenanceConflict) IsRedirect added in v1.19.1

func (o *GetProvenanceConflict) IsRedirect() bool

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

func (*GetProvenanceConflict) IsServerError added in v1.19.1

func (o *GetProvenanceConflict) IsServerError() bool

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

func (*GetProvenanceConflict) IsSuccess added in v1.19.1

func (o *GetProvenanceConflict) IsSuccess() bool

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

func (*GetProvenanceConflict) String added in v1.19.1

func (o *GetProvenanceConflict) String() string

type GetProvenanceForbidden

type GetProvenanceForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetProvenanceForbidden

func NewGetProvenanceForbidden() *GetProvenanceForbidden

NewGetProvenanceForbidden creates a GetProvenanceForbidden with default headers values

func (*GetProvenanceForbidden) Error

func (o *GetProvenanceForbidden) Error() string

func (*GetProvenanceForbidden) IsClientError added in v1.19.1

func (o *GetProvenanceForbidden) IsClientError() bool

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

func (*GetProvenanceForbidden) IsCode added in v1.19.1

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

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

func (*GetProvenanceForbidden) IsRedirect added in v1.19.1

func (o *GetProvenanceForbidden) IsRedirect() bool

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

func (*GetProvenanceForbidden) IsServerError added in v1.19.1

func (o *GetProvenanceForbidden) IsServerError() bool

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

func (*GetProvenanceForbidden) IsSuccess added in v1.19.1

func (o *GetProvenanceForbidden) IsSuccess() bool

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

func (*GetProvenanceForbidden) String added in v1.19.1

func (o *GetProvenanceForbidden) String() string

type GetProvenanceNotFound

type GetProvenanceNotFound struct {
}

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

The specified resource could not be found.

func NewGetProvenanceNotFound

func NewGetProvenanceNotFound() *GetProvenanceNotFound

NewGetProvenanceNotFound creates a GetProvenanceNotFound with default headers values

func (*GetProvenanceNotFound) Error

func (o *GetProvenanceNotFound) Error() string

func (*GetProvenanceNotFound) IsClientError added in v1.19.1

func (o *GetProvenanceNotFound) IsClientError() bool

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

func (*GetProvenanceNotFound) IsCode added in v1.19.1

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

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

func (*GetProvenanceNotFound) IsRedirect added in v1.19.1

func (o *GetProvenanceNotFound) IsRedirect() bool

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

func (*GetProvenanceNotFound) IsServerError added in v1.19.1

func (o *GetProvenanceNotFound) IsServerError() bool

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

func (*GetProvenanceNotFound) IsSuccess added in v1.19.1

func (o *GetProvenanceNotFound) IsSuccess() bool

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

func (*GetProvenanceNotFound) String added in v1.19.1

func (o *GetProvenanceNotFound) String() string

type GetProvenanceOK

type GetProvenanceOK struct {
	Payload *models.ProvenanceEntity
}

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

successful operation

func NewGetProvenanceOK

func NewGetProvenanceOK() *GetProvenanceOK

NewGetProvenanceOK creates a GetProvenanceOK with default headers values

func (*GetProvenanceOK) Error

func (o *GetProvenanceOK) Error() string

func (*GetProvenanceOK) GetPayload

func (o *GetProvenanceOK) GetPayload() *models.ProvenanceEntity

func (*GetProvenanceOK) IsClientError added in v1.19.1

func (o *GetProvenanceOK) IsClientError() bool

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

func (*GetProvenanceOK) IsCode added in v1.19.1

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

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

func (*GetProvenanceOK) IsRedirect added in v1.19.1

func (o *GetProvenanceOK) IsRedirect() bool

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

func (*GetProvenanceOK) IsServerError added in v1.19.1

func (o *GetProvenanceOK) IsServerError() bool

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

func (*GetProvenanceOK) IsSuccess added in v1.19.1

func (o *GetProvenanceOK) IsSuccess() bool

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

func (*GetProvenanceOK) String added in v1.19.1

func (o *GetProvenanceOK) String() string

type GetProvenanceParams

type GetProvenanceParams struct {

	/* ClusterNodeID.

	   The id of the node where this query exists if clustered.
	*/
	ClusterNodeID *string

	/* ID.

	   The id of the provenance query.
	*/
	ID string

	/* IncrementalResults.

	   Whether or not to summarize provenance events returned. This property is false by default.

	   Default: true
	*/
	IncrementalResults *bool

	/* Summarize.

	   Whether or not incremental results are returned. If false, provenance events are only returned once the query completes. This property is true by default.
	*/
	Summarize *bool

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

GetProvenanceParams contains all the parameters to send to the API endpoint

for the get provenance operation.

Typically these are written to a http.Request.

func NewGetProvenanceParams

func NewGetProvenanceParams() *GetProvenanceParams

NewGetProvenanceParams creates a new GetProvenanceParams 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 NewGetProvenanceParamsWithContext

func NewGetProvenanceParamsWithContext(ctx context.Context) *GetProvenanceParams

NewGetProvenanceParamsWithContext creates a new GetProvenanceParams object with the ability to set a context for a request.

func NewGetProvenanceParamsWithHTTPClient

func NewGetProvenanceParamsWithHTTPClient(client *http.Client) *GetProvenanceParams

NewGetProvenanceParamsWithHTTPClient creates a new GetProvenanceParams object with the ability to set a custom HTTPClient for a request.

func NewGetProvenanceParamsWithTimeout

func NewGetProvenanceParamsWithTimeout(timeout time.Duration) *GetProvenanceParams

NewGetProvenanceParamsWithTimeout creates a new GetProvenanceParams object with the ability to set a timeout on a request.

func (*GetProvenanceParams) SetClusterNodeID

func (o *GetProvenanceParams) SetClusterNodeID(clusterNodeID *string)

SetClusterNodeID adds the clusterNodeId to the get provenance params

func (*GetProvenanceParams) SetContext

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

SetContext adds the context to the get provenance params

func (*GetProvenanceParams) SetDefaults

func (o *GetProvenanceParams) SetDefaults()

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

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

func (*GetProvenanceParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the get provenance params

func (*GetProvenanceParams) SetID

func (o *GetProvenanceParams) SetID(id string)

SetID adds the id to the get provenance params

func (*GetProvenanceParams) SetIncrementalResults

func (o *GetProvenanceParams) SetIncrementalResults(incrementalResults *bool)

SetIncrementalResults adds the incrementalResults to the get provenance params

func (*GetProvenanceParams) SetSummarize

func (o *GetProvenanceParams) SetSummarize(summarize *bool)

SetSummarize adds the summarize to the get provenance params

func (*GetProvenanceParams) SetTimeout

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

SetTimeout adds the timeout to the get provenance params

func (*GetProvenanceParams) WithClusterNodeID

func (o *GetProvenanceParams) WithClusterNodeID(clusterNodeID *string) *GetProvenanceParams

WithClusterNodeID adds the clusterNodeID to the get provenance params

func (*GetProvenanceParams) WithContext

WithContext adds the context to the get provenance params

func (*GetProvenanceParams) WithDefaults

func (o *GetProvenanceParams) WithDefaults() *GetProvenanceParams

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

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

func (*GetProvenanceParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the get provenance params

func (*GetProvenanceParams) WithID

WithID adds the id to the get provenance params

func (*GetProvenanceParams) WithIncrementalResults

func (o *GetProvenanceParams) WithIncrementalResults(incrementalResults *bool) *GetProvenanceParams

WithIncrementalResults adds the incrementalResults to the get provenance params

func (*GetProvenanceParams) WithSummarize

func (o *GetProvenanceParams) WithSummarize(summarize *bool) *GetProvenanceParams

WithSummarize adds the summarize to the get provenance params

func (*GetProvenanceParams) WithTimeout

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

WithTimeout adds the timeout to the get provenance params

func (*GetProvenanceParams) WriteToRequest

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

WriteToRequest writes these params to a swagger request

type GetProvenanceReader

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

GetProvenanceReader is a Reader for the GetProvenance structure.

func (*GetProvenanceReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type GetProvenanceUnauthorized

type GetProvenanceUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetProvenanceUnauthorized

func NewGetProvenanceUnauthorized() *GetProvenanceUnauthorized

NewGetProvenanceUnauthorized creates a GetProvenanceUnauthorized with default headers values

func (*GetProvenanceUnauthorized) Error

func (o *GetProvenanceUnauthorized) Error() string

func (*GetProvenanceUnauthorized) IsClientError added in v1.19.1

func (o *GetProvenanceUnauthorized) IsClientError() bool

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

func (*GetProvenanceUnauthorized) IsCode added in v1.19.1

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

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

func (*GetProvenanceUnauthorized) IsRedirect added in v1.19.1

func (o *GetProvenanceUnauthorized) IsRedirect() bool

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

func (*GetProvenanceUnauthorized) IsServerError added in v1.19.1

func (o *GetProvenanceUnauthorized) IsServerError() bool

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

func (*GetProvenanceUnauthorized) IsSuccess added in v1.19.1

func (o *GetProvenanceUnauthorized) IsSuccess() bool

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

func (*GetProvenanceUnauthorized) String added in v1.19.1

func (o *GetProvenanceUnauthorized) String() string

type GetSearchOptionsBadRequest

type GetSearchOptionsBadRequest struct {
}

GetSearchOptionsBadRequest 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 NewGetSearchOptionsBadRequest

func NewGetSearchOptionsBadRequest() *GetSearchOptionsBadRequest

NewGetSearchOptionsBadRequest creates a GetSearchOptionsBadRequest with default headers values

func (*GetSearchOptionsBadRequest) Error

func (*GetSearchOptionsBadRequest) IsClientError added in v1.19.1

func (o *GetSearchOptionsBadRequest) IsClientError() bool

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

func (*GetSearchOptionsBadRequest) IsCode added in v1.19.1

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

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

func (*GetSearchOptionsBadRequest) IsRedirect added in v1.19.1

func (o *GetSearchOptionsBadRequest) IsRedirect() bool

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

func (*GetSearchOptionsBadRequest) IsServerError added in v1.19.1

func (o *GetSearchOptionsBadRequest) IsServerError() bool

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

func (*GetSearchOptionsBadRequest) IsSuccess added in v1.19.1

func (o *GetSearchOptionsBadRequest) IsSuccess() bool

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

func (*GetSearchOptionsBadRequest) String added in v1.19.1

func (o *GetSearchOptionsBadRequest) String() string

type GetSearchOptionsConflict

type GetSearchOptionsConflict struct {
}

GetSearchOptionsConflict 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 NewGetSearchOptionsConflict

func NewGetSearchOptionsConflict() *GetSearchOptionsConflict

NewGetSearchOptionsConflict creates a GetSearchOptionsConflict with default headers values

func (*GetSearchOptionsConflict) Error

func (o *GetSearchOptionsConflict) Error() string

func (*GetSearchOptionsConflict) IsClientError added in v1.19.1

func (o *GetSearchOptionsConflict) IsClientError() bool

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

func (*GetSearchOptionsConflict) IsCode added in v1.19.1

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

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

func (*GetSearchOptionsConflict) IsRedirect added in v1.19.1

func (o *GetSearchOptionsConflict) IsRedirect() bool

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

func (*GetSearchOptionsConflict) IsServerError added in v1.19.1

func (o *GetSearchOptionsConflict) IsServerError() bool

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

func (*GetSearchOptionsConflict) IsSuccess added in v1.19.1

func (o *GetSearchOptionsConflict) IsSuccess() bool

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

func (*GetSearchOptionsConflict) String added in v1.19.1

func (o *GetSearchOptionsConflict) String() string

type GetSearchOptionsForbidden

type GetSearchOptionsForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetSearchOptionsForbidden

func NewGetSearchOptionsForbidden() *GetSearchOptionsForbidden

NewGetSearchOptionsForbidden creates a GetSearchOptionsForbidden with default headers values

func (*GetSearchOptionsForbidden) Error

func (o *GetSearchOptionsForbidden) Error() string

func (*GetSearchOptionsForbidden) IsClientError added in v1.19.1

func (o *GetSearchOptionsForbidden) IsClientError() bool

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

func (*GetSearchOptionsForbidden) IsCode added in v1.19.1

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

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

func (*GetSearchOptionsForbidden) IsRedirect added in v1.19.1

func (o *GetSearchOptionsForbidden) IsRedirect() bool

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

func (*GetSearchOptionsForbidden) IsServerError added in v1.19.1

func (o *GetSearchOptionsForbidden) IsServerError() bool

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

func (*GetSearchOptionsForbidden) IsSuccess added in v1.19.1

func (o *GetSearchOptionsForbidden) IsSuccess() bool

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

func (*GetSearchOptionsForbidden) String added in v1.19.1

func (o *GetSearchOptionsForbidden) String() string

type GetSearchOptionsOK

type GetSearchOptionsOK struct {
	Payload *models.ProvenanceOptionsEntity
}

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

successful operation

func NewGetSearchOptionsOK

func NewGetSearchOptionsOK() *GetSearchOptionsOK

NewGetSearchOptionsOK creates a GetSearchOptionsOK with default headers values

func (*GetSearchOptionsOK) Error

func (o *GetSearchOptionsOK) Error() string

func (*GetSearchOptionsOK) GetPayload

func (*GetSearchOptionsOK) IsClientError added in v1.19.1

func (o *GetSearchOptionsOK) IsClientError() bool

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

func (*GetSearchOptionsOK) IsCode added in v1.19.1

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

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

func (*GetSearchOptionsOK) IsRedirect added in v1.19.1

func (o *GetSearchOptionsOK) IsRedirect() bool

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

func (*GetSearchOptionsOK) IsServerError added in v1.19.1

func (o *GetSearchOptionsOK) IsServerError() bool

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

func (*GetSearchOptionsOK) IsSuccess added in v1.19.1

func (o *GetSearchOptionsOK) IsSuccess() bool

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

func (*GetSearchOptionsOK) String added in v1.19.1

func (o *GetSearchOptionsOK) String() string

type GetSearchOptionsParams

type GetSearchOptionsParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetSearchOptionsParams contains all the parameters to send to the API endpoint

for the get search options operation.

Typically these are written to a http.Request.

func NewGetSearchOptionsParams

func NewGetSearchOptionsParams() *GetSearchOptionsParams

NewGetSearchOptionsParams creates a new GetSearchOptionsParams 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 NewGetSearchOptionsParamsWithContext

func NewGetSearchOptionsParamsWithContext(ctx context.Context) *GetSearchOptionsParams

NewGetSearchOptionsParamsWithContext creates a new GetSearchOptionsParams object with the ability to set a context for a request.

func NewGetSearchOptionsParamsWithHTTPClient

func NewGetSearchOptionsParamsWithHTTPClient(client *http.Client) *GetSearchOptionsParams

NewGetSearchOptionsParamsWithHTTPClient creates a new GetSearchOptionsParams object with the ability to set a custom HTTPClient for a request.

func NewGetSearchOptionsParamsWithTimeout

func NewGetSearchOptionsParamsWithTimeout(timeout time.Duration) *GetSearchOptionsParams

NewGetSearchOptionsParamsWithTimeout creates a new GetSearchOptionsParams object with the ability to set a timeout on a request.

func (*GetSearchOptionsParams) SetContext

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

SetContext adds the context to the get search options params

func (*GetSearchOptionsParams) SetDefaults

func (o *GetSearchOptionsParams) SetDefaults()

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

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

func (*GetSearchOptionsParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the get search options params

func (*GetSearchOptionsParams) SetTimeout

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

SetTimeout adds the timeout to the get search options params

func (*GetSearchOptionsParams) WithContext

WithContext adds the context to the get search options params

func (*GetSearchOptionsParams) WithDefaults

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

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

func (*GetSearchOptionsParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the get search options params

func (*GetSearchOptionsParams) WithTimeout

WithTimeout adds the timeout to the get search options params

func (*GetSearchOptionsParams) WriteToRequest

WriteToRequest writes these params to a swagger request

type GetSearchOptionsReader

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

GetSearchOptionsReader is a Reader for the GetSearchOptions structure.

func (*GetSearchOptionsReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type GetSearchOptionsUnauthorized

type GetSearchOptionsUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetSearchOptionsUnauthorized

func NewGetSearchOptionsUnauthorized() *GetSearchOptionsUnauthorized

NewGetSearchOptionsUnauthorized creates a GetSearchOptionsUnauthorized with default headers values

func (*GetSearchOptionsUnauthorized) Error

func (*GetSearchOptionsUnauthorized) IsClientError added in v1.19.1

func (o *GetSearchOptionsUnauthorized) IsClientError() bool

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

func (*GetSearchOptionsUnauthorized) IsCode added in v1.19.1

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

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

func (*GetSearchOptionsUnauthorized) IsRedirect added in v1.19.1

func (o *GetSearchOptionsUnauthorized) IsRedirect() bool

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

func (*GetSearchOptionsUnauthorized) IsServerError added in v1.19.1

func (o *GetSearchOptionsUnauthorized) IsServerError() bool

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

func (*GetSearchOptionsUnauthorized) IsSuccess added in v1.19.1

func (o *GetSearchOptionsUnauthorized) IsSuccess() bool

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

func (*GetSearchOptionsUnauthorized) String added in v1.19.1

type SubmitLineageRequestBadRequest

type SubmitLineageRequestBadRequest struct {
}

SubmitLineageRequestBadRequest 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 NewSubmitLineageRequestBadRequest

func NewSubmitLineageRequestBadRequest() *SubmitLineageRequestBadRequest

NewSubmitLineageRequestBadRequest creates a SubmitLineageRequestBadRequest with default headers values

func (*SubmitLineageRequestBadRequest) Error

func (*SubmitLineageRequestBadRequest) IsClientError added in v1.19.1

func (o *SubmitLineageRequestBadRequest) IsClientError() bool

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

func (*SubmitLineageRequestBadRequest) IsCode added in v1.19.1

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

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

func (*SubmitLineageRequestBadRequest) IsRedirect added in v1.19.1

func (o *SubmitLineageRequestBadRequest) IsRedirect() bool

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

func (*SubmitLineageRequestBadRequest) IsServerError added in v1.19.1

func (o *SubmitLineageRequestBadRequest) IsServerError() bool

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

func (*SubmitLineageRequestBadRequest) IsSuccess added in v1.19.1

func (o *SubmitLineageRequestBadRequest) IsSuccess() bool

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

func (*SubmitLineageRequestBadRequest) String added in v1.19.1

type SubmitLineageRequestConflict

type SubmitLineageRequestConflict struct {
}

SubmitLineageRequestConflict 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 NewSubmitLineageRequestConflict

func NewSubmitLineageRequestConflict() *SubmitLineageRequestConflict

NewSubmitLineageRequestConflict creates a SubmitLineageRequestConflict with default headers values

func (*SubmitLineageRequestConflict) Error

func (*SubmitLineageRequestConflict) IsClientError added in v1.19.1

func (o *SubmitLineageRequestConflict) IsClientError() bool

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

func (*SubmitLineageRequestConflict) IsCode added in v1.19.1

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

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

func (*SubmitLineageRequestConflict) IsRedirect added in v1.19.1

func (o *SubmitLineageRequestConflict) IsRedirect() bool

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

func (*SubmitLineageRequestConflict) IsServerError added in v1.19.1

func (o *SubmitLineageRequestConflict) IsServerError() bool

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

func (*SubmitLineageRequestConflict) IsSuccess added in v1.19.1

func (o *SubmitLineageRequestConflict) IsSuccess() bool

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

func (*SubmitLineageRequestConflict) String added in v1.19.1

type SubmitLineageRequestCreated added in v1.19.1

type SubmitLineageRequestCreated struct {
	Payload *models.LineageEntity
}

SubmitLineageRequestCreated describes a response with status code 201, with default header values.

successful operation

func NewSubmitLineageRequestCreated added in v1.19.1

func NewSubmitLineageRequestCreated() *SubmitLineageRequestCreated

NewSubmitLineageRequestCreated creates a SubmitLineageRequestCreated with default headers values

func (*SubmitLineageRequestCreated) Error added in v1.19.1

func (*SubmitLineageRequestCreated) GetPayload added in v1.19.1

func (*SubmitLineageRequestCreated) IsClientError added in v1.19.1

func (o *SubmitLineageRequestCreated) IsClientError() bool

IsClientError returns true when this submit lineage request created response has a 4xx status code

func (*SubmitLineageRequestCreated) IsCode added in v1.19.1

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

IsCode returns true when this submit lineage request created response a status code equal to that given

func (*SubmitLineageRequestCreated) IsRedirect added in v1.19.1

func (o *SubmitLineageRequestCreated) IsRedirect() bool

IsRedirect returns true when this submit lineage request created response has a 3xx status code

func (*SubmitLineageRequestCreated) IsServerError added in v1.19.1

func (o *SubmitLineageRequestCreated) IsServerError() bool

IsServerError returns true when this submit lineage request created response has a 5xx status code

func (*SubmitLineageRequestCreated) IsSuccess added in v1.19.1

func (o *SubmitLineageRequestCreated) IsSuccess() bool

IsSuccess returns true when this submit lineage request created response has a 2xx status code

func (*SubmitLineageRequestCreated) String added in v1.19.1

func (o *SubmitLineageRequestCreated) String() string

type SubmitLineageRequestForbidden

type SubmitLineageRequestForbidden struct {
}

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

Client is not authorized to make this request.

func NewSubmitLineageRequestForbidden

func NewSubmitLineageRequestForbidden() *SubmitLineageRequestForbidden

NewSubmitLineageRequestForbidden creates a SubmitLineageRequestForbidden with default headers values

func (*SubmitLineageRequestForbidden) Error

func (*SubmitLineageRequestForbidden) IsClientError added in v1.19.1

func (o *SubmitLineageRequestForbidden) IsClientError() bool

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

func (*SubmitLineageRequestForbidden) IsCode added in v1.19.1

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

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

func (*SubmitLineageRequestForbidden) IsRedirect added in v1.19.1

func (o *SubmitLineageRequestForbidden) IsRedirect() bool

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

func (*SubmitLineageRequestForbidden) IsServerError added in v1.19.1

func (o *SubmitLineageRequestForbidden) IsServerError() bool

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

func (*SubmitLineageRequestForbidden) IsSuccess added in v1.19.1

func (o *SubmitLineageRequestForbidden) IsSuccess() bool

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

func (*SubmitLineageRequestForbidden) String added in v1.19.1

type SubmitLineageRequestNotFound

type SubmitLineageRequestNotFound struct {
}

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

The specified resource could not be found.

func NewSubmitLineageRequestNotFound

func NewSubmitLineageRequestNotFound() *SubmitLineageRequestNotFound

NewSubmitLineageRequestNotFound creates a SubmitLineageRequestNotFound with default headers values

func (*SubmitLineageRequestNotFound) Error

func (*SubmitLineageRequestNotFound) IsClientError added in v1.19.1

func (o *SubmitLineageRequestNotFound) IsClientError() bool

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

func (*SubmitLineageRequestNotFound) IsCode added in v1.19.1

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

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

func (*SubmitLineageRequestNotFound) IsRedirect added in v1.19.1

func (o *SubmitLineageRequestNotFound) IsRedirect() bool

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

func (*SubmitLineageRequestNotFound) IsServerError added in v1.19.1

func (o *SubmitLineageRequestNotFound) IsServerError() bool

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

func (*SubmitLineageRequestNotFound) IsSuccess added in v1.19.1

func (o *SubmitLineageRequestNotFound) IsSuccess() bool

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

func (*SubmitLineageRequestNotFound) String added in v1.19.1

type SubmitLineageRequestParams

type SubmitLineageRequestParams struct {

	/* Body.

	   The lineage query details.
	*/
	Body *models.LineageEntity

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

SubmitLineageRequestParams contains all the parameters to send to the API endpoint

for the submit lineage request operation.

Typically these are written to a http.Request.

func NewSubmitLineageRequestParams

func NewSubmitLineageRequestParams() *SubmitLineageRequestParams

NewSubmitLineageRequestParams creates a new SubmitLineageRequestParams 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 NewSubmitLineageRequestParamsWithContext

func NewSubmitLineageRequestParamsWithContext(ctx context.Context) *SubmitLineageRequestParams

NewSubmitLineageRequestParamsWithContext creates a new SubmitLineageRequestParams object with the ability to set a context for a request.

func NewSubmitLineageRequestParamsWithHTTPClient

func NewSubmitLineageRequestParamsWithHTTPClient(client *http.Client) *SubmitLineageRequestParams

NewSubmitLineageRequestParamsWithHTTPClient creates a new SubmitLineageRequestParams object with the ability to set a custom HTTPClient for a request.

func NewSubmitLineageRequestParamsWithTimeout

func NewSubmitLineageRequestParamsWithTimeout(timeout time.Duration) *SubmitLineageRequestParams

NewSubmitLineageRequestParamsWithTimeout creates a new SubmitLineageRequestParams object with the ability to set a timeout on a request.

func (*SubmitLineageRequestParams) SetBody

SetBody adds the body to the submit lineage request params

func (*SubmitLineageRequestParams) SetContext

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

SetContext adds the context to the submit lineage request params

func (*SubmitLineageRequestParams) SetDefaults

func (o *SubmitLineageRequestParams) SetDefaults()

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

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

func (*SubmitLineageRequestParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the submit lineage request params

func (*SubmitLineageRequestParams) SetTimeout

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

SetTimeout adds the timeout to the submit lineage request params

func (*SubmitLineageRequestParams) WithBody

WithBody adds the body to the submit lineage request params

func (*SubmitLineageRequestParams) WithContext

WithContext adds the context to the submit lineage request params

func (*SubmitLineageRequestParams) WithDefaults

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

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

func (*SubmitLineageRequestParams) WithHTTPClient

WithHTTPClient adds the HTTPClient to the submit lineage request params

func (*SubmitLineageRequestParams) WithTimeout

WithTimeout adds the timeout to the submit lineage request params

func (*SubmitLineageRequestParams) WriteToRequest

WriteToRequest writes these params to a swagger request

type SubmitLineageRequestReader

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

SubmitLineageRequestReader is a Reader for the SubmitLineageRequest structure.

func (*SubmitLineageRequestReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type SubmitLineageRequestUnauthorized

type SubmitLineageRequestUnauthorized struct {
}

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

Client could not be authenticated.

func NewSubmitLineageRequestUnauthorized

func NewSubmitLineageRequestUnauthorized() *SubmitLineageRequestUnauthorized

NewSubmitLineageRequestUnauthorized creates a SubmitLineageRequestUnauthorized with default headers values

func (*SubmitLineageRequestUnauthorized) Error

func (*SubmitLineageRequestUnauthorized) IsClientError added in v1.19.1

func (o *SubmitLineageRequestUnauthorized) IsClientError() bool

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

func (*SubmitLineageRequestUnauthorized) IsCode added in v1.19.1

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

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

func (*SubmitLineageRequestUnauthorized) IsRedirect added in v1.19.1

func (o *SubmitLineageRequestUnauthorized) IsRedirect() bool

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

func (*SubmitLineageRequestUnauthorized) IsServerError added in v1.19.1

func (o *SubmitLineageRequestUnauthorized) IsServerError() bool

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

func (*SubmitLineageRequestUnauthorized) IsSuccess added in v1.19.1

func (o *SubmitLineageRequestUnauthorized) IsSuccess() bool

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

func (*SubmitLineageRequestUnauthorized) String added in v1.19.1

type SubmitProvenanceRequestBadRequest

type SubmitProvenanceRequestBadRequest struct {
}

SubmitProvenanceRequestBadRequest 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 NewSubmitProvenanceRequestBadRequest

func NewSubmitProvenanceRequestBadRequest() *SubmitProvenanceRequestBadRequest

NewSubmitProvenanceRequestBadRequest creates a SubmitProvenanceRequestBadRequest with default headers values

func (*SubmitProvenanceRequestBadRequest) Error

func (*SubmitProvenanceRequestBadRequest) IsClientError added in v1.19.1

func (o *SubmitProvenanceRequestBadRequest) IsClientError() bool

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

func (*SubmitProvenanceRequestBadRequest) IsCode added in v1.19.1

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

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

func (*SubmitProvenanceRequestBadRequest) IsRedirect added in v1.19.1

func (o *SubmitProvenanceRequestBadRequest) IsRedirect() bool

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

func (*SubmitProvenanceRequestBadRequest) IsServerError added in v1.19.1

func (o *SubmitProvenanceRequestBadRequest) IsServerError() bool

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

func (*SubmitProvenanceRequestBadRequest) IsSuccess added in v1.19.1

func (o *SubmitProvenanceRequestBadRequest) IsSuccess() bool

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

func (*SubmitProvenanceRequestBadRequest) String added in v1.19.1

type SubmitProvenanceRequestConflict

type SubmitProvenanceRequestConflict struct {
}

SubmitProvenanceRequestConflict 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 NewSubmitProvenanceRequestConflict

func NewSubmitProvenanceRequestConflict() *SubmitProvenanceRequestConflict

NewSubmitProvenanceRequestConflict creates a SubmitProvenanceRequestConflict with default headers values

func (*SubmitProvenanceRequestConflict) Error

func (*SubmitProvenanceRequestConflict) IsClientError added in v1.19.1

func (o *SubmitProvenanceRequestConflict) IsClientError() bool

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

func (*SubmitProvenanceRequestConflict) IsCode added in v1.19.1

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

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

func (*SubmitProvenanceRequestConflict) IsRedirect added in v1.19.1

func (o *SubmitProvenanceRequestConflict) IsRedirect() bool

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

func (*SubmitProvenanceRequestConflict) IsServerError added in v1.19.1

func (o *SubmitProvenanceRequestConflict) IsServerError() bool

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

func (*SubmitProvenanceRequestConflict) IsSuccess added in v1.19.1

func (o *SubmitProvenanceRequestConflict) IsSuccess() bool

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

func (*SubmitProvenanceRequestConflict) String added in v1.19.1

type SubmitProvenanceRequestCreated added in v1.19.1

type SubmitProvenanceRequestCreated struct {
	Payload *models.ProvenanceEntity
}

SubmitProvenanceRequestCreated describes a response with status code 201, with default header values.

successful operation

func NewSubmitProvenanceRequestCreated added in v1.19.1

func NewSubmitProvenanceRequestCreated() *SubmitProvenanceRequestCreated

NewSubmitProvenanceRequestCreated creates a SubmitProvenanceRequestCreated with default headers values

func (*SubmitProvenanceRequestCreated) Error added in v1.19.1

func (*SubmitProvenanceRequestCreated) GetPayload added in v1.19.1

func (*SubmitProvenanceRequestCreated) IsClientError added in v1.19.1

func (o *SubmitProvenanceRequestCreated) IsClientError() bool

IsClientError returns true when this submit provenance request created response has a 4xx status code

func (*SubmitProvenanceRequestCreated) IsCode added in v1.19.1

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

IsCode returns true when this submit provenance request created response a status code equal to that given

func (*SubmitProvenanceRequestCreated) IsRedirect added in v1.19.1

func (o *SubmitProvenanceRequestCreated) IsRedirect() bool

IsRedirect returns true when this submit provenance request created response has a 3xx status code

func (*SubmitProvenanceRequestCreated) IsServerError added in v1.19.1

func (o *SubmitProvenanceRequestCreated) IsServerError() bool

IsServerError returns true when this submit provenance request created response has a 5xx status code

func (*SubmitProvenanceRequestCreated) IsSuccess added in v1.19.1

func (o *SubmitProvenanceRequestCreated) IsSuccess() bool

IsSuccess returns true when this submit provenance request created response has a 2xx status code

func (*SubmitProvenanceRequestCreated) String added in v1.19.1

type SubmitProvenanceRequestForbidden

type SubmitProvenanceRequestForbidden struct {
}

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

Client is not authorized to make this request.

func NewSubmitProvenanceRequestForbidden

func NewSubmitProvenanceRequestForbidden() *SubmitProvenanceRequestForbidden

NewSubmitProvenanceRequestForbidden creates a SubmitProvenanceRequestForbidden with default headers values

func (*SubmitProvenanceRequestForbidden) Error

func (*SubmitProvenanceRequestForbidden) IsClientError added in v1.19.1

func (o *SubmitProvenanceRequestForbidden) IsClientError() bool

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

func (*SubmitProvenanceRequestForbidden) IsCode added in v1.19.1

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

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

func (*SubmitProvenanceRequestForbidden) IsRedirect added in v1.19.1

func (o *SubmitProvenanceRequestForbidden) IsRedirect() bool

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

func (*SubmitProvenanceRequestForbidden) IsServerError added in v1.19.1

func (o *SubmitProvenanceRequestForbidden) IsServerError() bool

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

func (*SubmitProvenanceRequestForbidden) IsSuccess added in v1.19.1

func (o *SubmitProvenanceRequestForbidden) IsSuccess() bool

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

func (*SubmitProvenanceRequestForbidden) String added in v1.19.1

type SubmitProvenanceRequestParams

type SubmitProvenanceRequestParams struct {

	/* Body.

	   The provenance query details.
	*/
	Body *models.ProvenanceEntity

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

SubmitProvenanceRequestParams contains all the parameters to send to the API endpoint

for the submit provenance request operation.

Typically these are written to a http.Request.

func NewSubmitProvenanceRequestParams

func NewSubmitProvenanceRequestParams() *SubmitProvenanceRequestParams

NewSubmitProvenanceRequestParams creates a new SubmitProvenanceRequestParams 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 NewSubmitProvenanceRequestParamsWithContext

func NewSubmitProvenanceRequestParamsWithContext(ctx context.Context) *SubmitProvenanceRequestParams

NewSubmitProvenanceRequestParamsWithContext creates a new SubmitProvenanceRequestParams object with the ability to set a context for a request.

func NewSubmitProvenanceRequestParamsWithHTTPClient

func NewSubmitProvenanceRequestParamsWithHTTPClient(client *http.Client) *SubmitProvenanceRequestParams

NewSubmitProvenanceRequestParamsWithHTTPClient creates a new SubmitProvenanceRequestParams object with the ability to set a custom HTTPClient for a request.

func NewSubmitProvenanceRequestParamsWithTimeout

func NewSubmitProvenanceRequestParamsWithTimeout(timeout time.Duration) *SubmitProvenanceRequestParams

NewSubmitProvenanceRequestParamsWithTimeout creates a new SubmitProvenanceRequestParams object with the ability to set a timeout on a request.

func (*SubmitProvenanceRequestParams) SetBody

SetBody adds the body to the submit provenance request params

func (*SubmitProvenanceRequestParams) SetContext

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

SetContext adds the context to the submit provenance request params

func (*SubmitProvenanceRequestParams) SetDefaults

func (o *SubmitProvenanceRequestParams) SetDefaults()

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

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

func (*SubmitProvenanceRequestParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the submit provenance request params

func (*SubmitProvenanceRequestParams) SetTimeout

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

SetTimeout adds the timeout to the submit provenance request params

func (*SubmitProvenanceRequestParams) WithBody

WithBody adds the body to the submit provenance request params

func (*SubmitProvenanceRequestParams) WithContext

WithContext adds the context to the submit provenance request params

func (*SubmitProvenanceRequestParams) WithDefaults

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

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

func (*SubmitProvenanceRequestParams) WithHTTPClient

WithHTTPClient adds the HTTPClient to the submit provenance request params

func (*SubmitProvenanceRequestParams) WithTimeout

WithTimeout adds the timeout to the submit provenance request params

func (*SubmitProvenanceRequestParams) WriteToRequest

WriteToRequest writes these params to a swagger request

type SubmitProvenanceRequestReader

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

SubmitProvenanceRequestReader is a Reader for the SubmitProvenanceRequest structure.

func (*SubmitProvenanceRequestReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type SubmitProvenanceRequestUnauthorized

type SubmitProvenanceRequestUnauthorized struct {
}

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

Client could not be authenticated.

func NewSubmitProvenanceRequestUnauthorized

func NewSubmitProvenanceRequestUnauthorized() *SubmitProvenanceRequestUnauthorized

NewSubmitProvenanceRequestUnauthorized creates a SubmitProvenanceRequestUnauthorized with default headers values

func (*SubmitProvenanceRequestUnauthorized) Error

func (*SubmitProvenanceRequestUnauthorized) IsClientError added in v1.19.1

func (o *SubmitProvenanceRequestUnauthorized) IsClientError() bool

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

func (*SubmitProvenanceRequestUnauthorized) IsCode added in v1.19.1

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

func (*SubmitProvenanceRequestUnauthorized) IsRedirect added in v1.19.1

func (o *SubmitProvenanceRequestUnauthorized) IsRedirect() bool

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

func (*SubmitProvenanceRequestUnauthorized) IsServerError added in v1.19.1

func (o *SubmitProvenanceRequestUnauthorized) IsServerError() bool

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

func (*SubmitProvenanceRequestUnauthorized) IsSuccess added in v1.19.1

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

func (*SubmitProvenanceRequestUnauthorized) String added in v1.19.1

Jump to

Keyboard shortcuts

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