bucket_flows

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 bucket flows API

func (*Client) CreateFlow 

func (a *Client) CreateFlow(params *CreateFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CreateFlowOK, error)

CreateFlow creates flow

Creates a flow in the given bucket. The flow id is created by the server and populated in the returned entity.

func (*Client) CreateFlowVersion 

func (a *Client) CreateFlowVersion(params *CreateFlowVersionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CreateFlowVersionOK, error)

CreateFlowVersion creates flow version

Creates the next version of a flow. The version number of the object being created must be the next available version integer. Flow versions are immutable after they are created.

func (*Client) DeleteFlow 

func (a *Client) DeleteFlow(params *DeleteFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteFlowOK, error)

DeleteFlow deletes bucket flow

Deletes a flow, including all saved versions of that flow.

func (*Client) ExportVersionedFlow 

func (a *Client) ExportVersionedFlow(params *ExportVersionedFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ExportVersionedFlowOK, error)

ExportVersionedFlow exports specified bucket flow version content

Exports the specified version of a flow, including the metadata and content of the flow.

func (*Client) GetFlow 

func (a *Client) GetFlow(params *GetFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetFlowOK, error)

GetFlow gets bucket flow

Retrieves the flow with the given id in the given bucket.

func (*Client) GetFlowDiff 

func (a *Client) GetFlowDiff(params *GetFlowDiffParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetFlowDiffOK, error)

GetFlowDiff gets bucket flow diff

Computes the differences between two given versions of a flow.

func (*Client) GetFlowVersion 

func (a *Client) GetFlowVersion(params *GetFlowVersionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetFlowVersionOK, error)

GetFlowVersion gets bucket flow version

Gets the given version of a flow, including the metadata and content for the version.

func (*Client) GetFlowVersions 

func (a *Client) GetFlowVersions(params *GetFlowVersionsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetFlowVersionsOK, error)

GetFlowVersions gets bucket flow versions

Gets summary information for all versions of a flow. Versions are ordered newest->oldest.

func (*Client) GetFlows 

func (a *Client) GetFlows(params *GetFlowsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetFlowsOK, error)

GetFlows gets bucket flows

Retrieves all flows in the given bucket.

func (*Client) GetLatestFlowVersion 

func (a *Client) GetLatestFlowVersion(params *GetLatestFlowVersionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetLatestFlowVersionOK, error)

GetLatestFlowVersion gets latest bucket flow version content

Gets the latest version of a flow, including the metadata and content of the flow.

func (*Client) GetLatestFlowVersionMetadata 

func (a *Client) GetLatestFlowVersionMetadata(params *GetLatestFlowVersionMetadataParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetLatestFlowVersionMetadataOK, error)

GetLatestFlowVersionMetadata gets latest bucket flow version metadata

Gets the metadata for the latest version of a flow.

func (*Client) ImportVersionedFlow 

func (a *Client) ImportVersionedFlow(params *ImportVersionedFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ImportVersionedFlowOK, *ImportVersionedFlowCreated, error)

ImportVersionedFlow imports flow version

Import the next version of a flow. The version number of the object being created will be the next available version integer. Flow versions are immutable after they are created.

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

func (*Client) UpdateFlow 

func (a *Client) UpdateFlow(params *UpdateFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*UpdateFlowOK, error)

UpdateFlow updates bucket flow

Updates the flow with the given id in the given bucket.

type ClientOption 

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService 

type ClientService interface {
	CreateFlow(params *CreateFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CreateFlowOK, error)

	CreateFlowVersion(params *CreateFlowVersionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CreateFlowVersionOK, error)

	DeleteFlow(params *DeleteFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteFlowOK, error)

	ExportVersionedFlow(params *ExportVersionedFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ExportVersionedFlowOK, error)

	GetFlow(params *GetFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetFlowOK, error)

	GetFlowDiff(params *GetFlowDiffParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetFlowDiffOK, error)

	GetFlowVersion(params *GetFlowVersionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetFlowVersionOK, error)

	GetFlowVersions(params *GetFlowVersionsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetFlowVersionsOK, error)

	GetFlows(params *GetFlowsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetFlowsOK, error)

	GetLatestFlowVersion(params *GetLatestFlowVersionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetLatestFlowVersionOK, error)

	GetLatestFlowVersionMetadata(params *GetLatestFlowVersionMetadataParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*GetLatestFlowVersionMetadataOK, error)

	ImportVersionedFlow(params *ImportVersionedFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ImportVersionedFlowOK, *ImportVersionedFlowCreated, error)

	UpdateFlow(params *UpdateFlowParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*UpdateFlowOK, 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 bucket flows API client.

type CreateFlowBadRequest 

type CreateFlowBadRequest struct {
}

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

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

func NewCreateFlowBadRequest 

func NewCreateFlowBadRequest() *CreateFlowBadRequest

NewCreateFlowBadRequest creates a CreateFlowBadRequest with default headers values

func (*CreateFlowBadRequest) Error 

func (o *CreateFlowBadRequest) Error() string

func (*CreateFlowBadRequest) IsClientError added in v1.19.1 

func (o *CreateFlowBadRequest) IsClientError() bool

IsClientError returns true when this create flow bad request response has a 4xx status code

func (*CreateFlowBadRequest) IsCode added in v1.19.1 

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

IsCode returns true when this create flow bad request response a status code equal to that given

func (*CreateFlowBadRequest) IsRedirect added in v1.19.1 

func (o *CreateFlowBadRequest) IsRedirect() bool

IsRedirect returns true when this create flow bad request response has a 3xx status code

func (*CreateFlowBadRequest) IsServerError added in v1.19.1 

func (o *CreateFlowBadRequest) IsServerError() bool

IsServerError returns true when this create flow bad request response has a 5xx status code

func (*CreateFlowBadRequest) IsSuccess added in v1.19.1 

func (o *CreateFlowBadRequest) IsSuccess() bool

IsSuccess returns true when this create flow bad request response has a 2xx status code

func (*CreateFlowBadRequest) String added in v1.19.1 

func (o *CreateFlowBadRequest) String() string

type CreateFlowConflict 

type CreateFlowConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewCreateFlowConflict 

func NewCreateFlowConflict() *CreateFlowConflict

NewCreateFlowConflict creates a CreateFlowConflict with default headers values

func (*CreateFlowConflict) Error 

func (o *CreateFlowConflict) Error() string

func (*CreateFlowConflict) IsClientError added in v1.19.1 

func (o *CreateFlowConflict) IsClientError() bool

IsClientError returns true when this create flow conflict response has a 4xx status code

func (*CreateFlowConflict) IsCode added in v1.19.1 

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

IsCode returns true when this create flow conflict response a status code equal to that given

func (*CreateFlowConflict) IsRedirect added in v1.19.1 

func (o *CreateFlowConflict) IsRedirect() bool

IsRedirect returns true when this create flow conflict response has a 3xx status code

func (*CreateFlowConflict) IsServerError added in v1.19.1 

func (o *CreateFlowConflict) IsServerError() bool

IsServerError returns true when this create flow conflict response has a 5xx status code

func (*CreateFlowConflict) IsSuccess added in v1.19.1 

func (o *CreateFlowConflict) IsSuccess() bool

IsSuccess returns true when this create flow conflict response has a 2xx status code

func (*CreateFlowConflict) String added in v1.19.1 

func (o *CreateFlowConflict) String() string

type CreateFlowForbidden 

type CreateFlowForbidden struct {
}

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

Client is not authorized to make this request.

func NewCreateFlowForbidden 

func NewCreateFlowForbidden() *CreateFlowForbidden

NewCreateFlowForbidden creates a CreateFlowForbidden with default headers values

func (*CreateFlowForbidden) Error 

func (o *CreateFlowForbidden) Error() string

func (*CreateFlowForbidden) IsClientError added in v1.19.1 

func (o *CreateFlowForbidden) IsClientError() bool

IsClientError returns true when this create flow forbidden response has a 4xx status code

func (*CreateFlowForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this create flow forbidden response a status code equal to that given

func (*CreateFlowForbidden) IsRedirect added in v1.19.1 

func (o *CreateFlowForbidden) IsRedirect() bool

IsRedirect returns true when this create flow forbidden response has a 3xx status code

func (*CreateFlowForbidden) IsServerError added in v1.19.1 

func (o *CreateFlowForbidden) IsServerError() bool

IsServerError returns true when this create flow forbidden response has a 5xx status code

func (*CreateFlowForbidden) IsSuccess added in v1.19.1 

func (o *CreateFlowForbidden) IsSuccess() bool

IsSuccess returns true when this create flow forbidden response has a 2xx status code

func (*CreateFlowForbidden) String added in v1.19.1 

func (o *CreateFlowForbidden) String() string

type CreateFlowNotFound 

type CreateFlowNotFound struct {
}

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

The specified resource could not be found.

func NewCreateFlowNotFound 

func NewCreateFlowNotFound() *CreateFlowNotFound

NewCreateFlowNotFound creates a CreateFlowNotFound with default headers values

func (*CreateFlowNotFound) Error 

func (o *CreateFlowNotFound) Error() string

func (*CreateFlowNotFound) IsClientError added in v1.19.1 

func (o *CreateFlowNotFound) IsClientError() bool

IsClientError returns true when this create flow not found response has a 4xx status code

func (*CreateFlowNotFound) IsCode added in v1.19.1 

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

IsCode returns true when this create flow not found response a status code equal to that given

func (*CreateFlowNotFound) IsRedirect added in v1.19.1 

func (o *CreateFlowNotFound) IsRedirect() bool

IsRedirect returns true when this create flow not found response has a 3xx status code

func (*CreateFlowNotFound) IsServerError added in v1.19.1 

func (o *CreateFlowNotFound) IsServerError() bool

IsServerError returns true when this create flow not found response has a 5xx status code

func (*CreateFlowNotFound) IsSuccess added in v1.19.1 

func (o *CreateFlowNotFound) IsSuccess() bool

IsSuccess returns true when this create flow not found response has a 2xx status code

func (*CreateFlowNotFound) String added in v1.19.1 

func (o *CreateFlowNotFound) String() string

type CreateFlowOK 

type CreateFlowOK struct {
	Payload *models.VersionedFlow
}

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

successful operation

func NewCreateFlowOK 

func NewCreateFlowOK() *CreateFlowOK

NewCreateFlowOK creates a CreateFlowOK with default headers values

func (*CreateFlowOK) Error 

func (o *CreateFlowOK) Error() string

func (*CreateFlowOK) GetPayload 

func (o *CreateFlowOK) GetPayload() *models.VersionedFlow

func (*CreateFlowOK) IsClientError added in v1.19.1 

func (o *CreateFlowOK) IsClientError() bool

IsClientError returns true when this create flow o k response has a 4xx status code

func (*CreateFlowOK) IsCode added in v1.19.1 

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

IsCode returns true when this create flow o k response a status code equal to that given

func (*CreateFlowOK) IsRedirect added in v1.19.1 

func (o *CreateFlowOK) IsRedirect() bool

IsRedirect returns true when this create flow o k response has a 3xx status code

func (*CreateFlowOK) IsServerError added in v1.19.1 

func (o *CreateFlowOK) IsServerError() bool

IsServerError returns true when this create flow o k response has a 5xx status code

func (*CreateFlowOK) IsSuccess added in v1.19.1 

func (o *CreateFlowOK) IsSuccess() bool

IsSuccess returns true when this create flow o k response has a 2xx status code

func (*CreateFlowOK) String added in v1.19.1 

func (o *CreateFlowOK) String() string

type CreateFlowParams 

type CreateFlowParams struct {

	/* Body.

	   The details of the flow to create.
	*/
	Body *models.VersionedFlow

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

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

CreateFlowParams contains all the parameters to send to the API endpoint 

for the create flow operation.

Typically these are written to a http.Request.

func NewCreateFlowParams 

func NewCreateFlowParams() *CreateFlowParams

NewCreateFlowParams creates a new CreateFlowParams 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 NewCreateFlowParamsWithContext 

func NewCreateFlowParamsWithContext(ctx context.Context) *CreateFlowParams

NewCreateFlowParamsWithContext creates a new CreateFlowParams object with the ability to set a context for a request.

func NewCreateFlowParamsWithHTTPClient 

func NewCreateFlowParamsWithHTTPClient(client *http.Client) *CreateFlowParams

NewCreateFlowParamsWithHTTPClient creates a new CreateFlowParams object with the ability to set a custom HTTPClient for a request.

func NewCreateFlowParamsWithTimeout 

func NewCreateFlowParamsWithTimeout(timeout time.Duration) *CreateFlowParams

NewCreateFlowParamsWithTimeout creates a new CreateFlowParams object with the ability to set a timeout on a request.

func (*CreateFlowParams) SetBody 

func (o *CreateFlowParams) SetBody(body *models.VersionedFlow)

SetBody adds the body to the create flow params

func (*CreateFlowParams) SetBucketID 

func (o *CreateFlowParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the create flow params

func (*CreateFlowParams) SetContext 

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

SetContext adds the context to the create flow params

func (*CreateFlowParams) SetDefaults 

func (o *CreateFlowParams) SetDefaults()

SetDefaults hydrates default values in the create flow params (not the query body).

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

func (*CreateFlowParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the create flow params

func (*CreateFlowParams) SetTimeout 

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

SetTimeout adds the timeout to the create flow params

func (*CreateFlowParams) WithBody 

func (o *CreateFlowParams) WithBody(body *models.VersionedFlow) *CreateFlowParams

WithBody adds the body to the create flow params

func (*CreateFlowParams) WithBucketID 

func (o *CreateFlowParams) WithBucketID(bucketID string) *CreateFlowParams

WithBucketID adds the bucketID to the create flow params

func (*CreateFlowParams) WithContext 

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

WithContext adds the context to the create flow params

func (*CreateFlowParams) WithDefaults 

func (o *CreateFlowParams) WithDefaults() *CreateFlowParams

WithDefaults hydrates default values in the create flow params (not the query body).

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

func (*CreateFlowParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the create flow params

func (*CreateFlowParams) WithTimeout 

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

WithTimeout adds the timeout to the create flow params

func (*CreateFlowParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type CreateFlowReader 

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

CreateFlowReader is a Reader for the CreateFlow structure.

func (*CreateFlowReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type CreateFlowUnauthorized 

type CreateFlowUnauthorized struct {
}

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

Client could not be authenticated.

func NewCreateFlowUnauthorized 

func NewCreateFlowUnauthorized() *CreateFlowUnauthorized

NewCreateFlowUnauthorized creates a CreateFlowUnauthorized with default headers values

func (*CreateFlowUnauthorized) Error 

func (o *CreateFlowUnauthorized) Error() string

func (*CreateFlowUnauthorized) IsClientError added in v1.19.1 

func (o *CreateFlowUnauthorized) IsClientError() bool

IsClientError returns true when this create flow unauthorized response has a 4xx status code

func (*CreateFlowUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this create flow unauthorized response a status code equal to that given

func (*CreateFlowUnauthorized) IsRedirect added in v1.19.1 

func (o *CreateFlowUnauthorized) IsRedirect() bool

IsRedirect returns true when this create flow unauthorized response has a 3xx status code

func (*CreateFlowUnauthorized) IsServerError added in v1.19.1 

func (o *CreateFlowUnauthorized) IsServerError() bool

IsServerError returns true when this create flow unauthorized response has a 5xx status code

func (*CreateFlowUnauthorized) IsSuccess added in v1.19.1 

func (o *CreateFlowUnauthorized) IsSuccess() bool

IsSuccess returns true when this create flow unauthorized response has a 2xx status code

func (*CreateFlowUnauthorized) String added in v1.19.1 

func (o *CreateFlowUnauthorized) String() string

type CreateFlowVersionBadRequest 

type CreateFlowVersionBadRequest struct {
}

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

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

func NewCreateFlowVersionBadRequest 

func NewCreateFlowVersionBadRequest() *CreateFlowVersionBadRequest

NewCreateFlowVersionBadRequest creates a CreateFlowVersionBadRequest with default headers values

func (*CreateFlowVersionBadRequest) Error 

func (o *CreateFlowVersionBadRequest) Error() string

func (*CreateFlowVersionBadRequest) IsClientError added in v1.19.1 

func (o *CreateFlowVersionBadRequest) IsClientError() bool

IsClientError returns true when this create flow version bad request response has a 4xx status code

func (*CreateFlowVersionBadRequest) IsCode added in v1.19.1 

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

IsCode returns true when this create flow version bad request response a status code equal to that given

func (*CreateFlowVersionBadRequest) IsRedirect added in v1.19.1 

func (o *CreateFlowVersionBadRequest) IsRedirect() bool

IsRedirect returns true when this create flow version bad request response has a 3xx status code

func (*CreateFlowVersionBadRequest) IsServerError added in v1.19.1 

func (o *CreateFlowVersionBadRequest) IsServerError() bool

IsServerError returns true when this create flow version bad request response has a 5xx status code

func (*CreateFlowVersionBadRequest) IsSuccess added in v1.19.1 

func (o *CreateFlowVersionBadRequest) IsSuccess() bool

IsSuccess returns true when this create flow version bad request response has a 2xx status code

func (*CreateFlowVersionBadRequest) String added in v1.19.1 

func (o *CreateFlowVersionBadRequest) String() string

type CreateFlowVersionConflict 

type CreateFlowVersionConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewCreateFlowVersionConflict 

func NewCreateFlowVersionConflict() *CreateFlowVersionConflict

NewCreateFlowVersionConflict creates a CreateFlowVersionConflict with default headers values

func (*CreateFlowVersionConflict) Error 

func (o *CreateFlowVersionConflict) Error() string

func (*CreateFlowVersionConflict) IsClientError added in v1.19.1 

func (o *CreateFlowVersionConflict) IsClientError() bool

IsClientError returns true when this create flow version conflict response has a 4xx status code

func (*CreateFlowVersionConflict) IsCode added in v1.19.1 

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

IsCode returns true when this create flow version conflict response a status code equal to that given

func (*CreateFlowVersionConflict) IsRedirect added in v1.19.1 

func (o *CreateFlowVersionConflict) IsRedirect() bool

IsRedirect returns true when this create flow version conflict response has a 3xx status code

func (*CreateFlowVersionConflict) IsServerError added in v1.19.1 

func (o *CreateFlowVersionConflict) IsServerError() bool

IsServerError returns true when this create flow version conflict response has a 5xx status code

func (*CreateFlowVersionConflict) IsSuccess added in v1.19.1 

func (o *CreateFlowVersionConflict) IsSuccess() bool

IsSuccess returns true when this create flow version conflict response has a 2xx status code

func (*CreateFlowVersionConflict) String added in v1.19.1 

func (o *CreateFlowVersionConflict) String() string

type CreateFlowVersionForbidden 

type CreateFlowVersionForbidden struct {
}

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

Client is not authorized to make this request.

func NewCreateFlowVersionForbidden 

func NewCreateFlowVersionForbidden() *CreateFlowVersionForbidden

NewCreateFlowVersionForbidden creates a CreateFlowVersionForbidden with default headers values

func (*CreateFlowVersionForbidden) Error 

func (o *CreateFlowVersionForbidden) Error() string

func (*CreateFlowVersionForbidden) IsClientError added in v1.19.1 

func (o *CreateFlowVersionForbidden) IsClientError() bool

IsClientError returns true when this create flow version forbidden response has a 4xx status code

func (*CreateFlowVersionForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this create flow version forbidden response a status code equal to that given

func (*CreateFlowVersionForbidden) IsRedirect added in v1.19.1 

func (o *CreateFlowVersionForbidden) IsRedirect() bool

IsRedirect returns true when this create flow version forbidden response has a 3xx status code

func (*CreateFlowVersionForbidden) IsServerError added in v1.19.1 

func (o *CreateFlowVersionForbidden) IsServerError() bool

IsServerError returns true when this create flow version forbidden response has a 5xx status code

func (*CreateFlowVersionForbidden) IsSuccess added in v1.19.1 

func (o *CreateFlowVersionForbidden) IsSuccess() bool

IsSuccess returns true when this create flow version forbidden response has a 2xx status code

func (*CreateFlowVersionForbidden) String added in v1.19.1 

func (o *CreateFlowVersionForbidden) String() string

type CreateFlowVersionNotFound 

type CreateFlowVersionNotFound struct {
}

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

The specified resource could not be found.

func NewCreateFlowVersionNotFound 

func NewCreateFlowVersionNotFound() *CreateFlowVersionNotFound

NewCreateFlowVersionNotFound creates a CreateFlowVersionNotFound with default headers values

func (*CreateFlowVersionNotFound) Error 

func (o *CreateFlowVersionNotFound) Error() string

func (*CreateFlowVersionNotFound) IsClientError added in v1.19.1 

func (o *CreateFlowVersionNotFound) IsClientError() bool

IsClientError returns true when this create flow version not found response has a 4xx status code

func (*CreateFlowVersionNotFound) IsCode added in v1.19.1 

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

IsCode returns true when this create flow version not found response a status code equal to that given

func (*CreateFlowVersionNotFound) IsRedirect added in v1.19.1 

func (o *CreateFlowVersionNotFound) IsRedirect() bool

IsRedirect returns true when this create flow version not found response has a 3xx status code

func (*CreateFlowVersionNotFound) IsServerError added in v1.19.1 

func (o *CreateFlowVersionNotFound) IsServerError() bool

IsServerError returns true when this create flow version not found response has a 5xx status code

func (*CreateFlowVersionNotFound) IsSuccess added in v1.19.1 

func (o *CreateFlowVersionNotFound) IsSuccess() bool

IsSuccess returns true when this create flow version not found response has a 2xx status code

func (*CreateFlowVersionNotFound) String added in v1.19.1 

func (o *CreateFlowVersionNotFound) String() string

type CreateFlowVersionOK 

type CreateFlowVersionOK struct {
	Payload *models.VersionedFlowSnapshot
}

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

successful operation

func NewCreateFlowVersionOK 

func NewCreateFlowVersionOK() *CreateFlowVersionOK

NewCreateFlowVersionOK creates a CreateFlowVersionOK with default headers values

func (*CreateFlowVersionOK) Error 

func (o *CreateFlowVersionOK) Error() string

func (*CreateFlowVersionOK) GetPayload 

func (o *CreateFlowVersionOK) GetPayload() *models.VersionedFlowSnapshot

func (*CreateFlowVersionOK) IsClientError added in v1.19.1 

func (o *CreateFlowVersionOK) IsClientError() bool

IsClientError returns true when this create flow version o k response has a 4xx status code

func (*CreateFlowVersionOK) IsCode added in v1.19.1 

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

IsCode returns true when this create flow version o k response a status code equal to that given

func (*CreateFlowVersionOK) IsRedirect added in v1.19.1 

func (o *CreateFlowVersionOK) IsRedirect() bool

IsRedirect returns true when this create flow version o k response has a 3xx status code

func (*CreateFlowVersionOK) IsServerError added in v1.19.1 

func (o *CreateFlowVersionOK) IsServerError() bool

IsServerError returns true when this create flow version o k response has a 5xx status code

func (*CreateFlowVersionOK) IsSuccess added in v1.19.1 

func (o *CreateFlowVersionOK) IsSuccess() bool

IsSuccess returns true when this create flow version o k response has a 2xx status code

func (*CreateFlowVersionOK) String added in v1.19.1 

func (o *CreateFlowVersionOK) String() string

type CreateFlowVersionParams 

type CreateFlowVersionParams struct {

	/* Body.

	   The new versioned flow snapshot.
	*/
	Body *models.VersionedFlowSnapshot

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

	/* FlowID.

	   The flow identifier
	*/
	FlowID string

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

CreateFlowVersionParams contains all the parameters to send to the API endpoint 

for the create flow version operation.

Typically these are written to a http.Request.

func NewCreateFlowVersionParams 

func NewCreateFlowVersionParams() *CreateFlowVersionParams

NewCreateFlowVersionParams creates a new CreateFlowVersionParams 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 NewCreateFlowVersionParamsWithContext 

func NewCreateFlowVersionParamsWithContext(ctx context.Context) *CreateFlowVersionParams

NewCreateFlowVersionParamsWithContext creates a new CreateFlowVersionParams object with the ability to set a context for a request.

func NewCreateFlowVersionParamsWithHTTPClient 

func NewCreateFlowVersionParamsWithHTTPClient(client *http.Client) *CreateFlowVersionParams

NewCreateFlowVersionParamsWithHTTPClient creates a new CreateFlowVersionParams object with the ability to set a custom HTTPClient for a request.

func NewCreateFlowVersionParamsWithTimeout 

func NewCreateFlowVersionParamsWithTimeout(timeout time.Duration) *CreateFlowVersionParams

NewCreateFlowVersionParamsWithTimeout creates a new CreateFlowVersionParams object with the ability to set a timeout on a request.

func (*CreateFlowVersionParams) SetBody 

func (o *CreateFlowVersionParams) SetBody(body *models.VersionedFlowSnapshot)

SetBody adds the body to the create flow version params

func (*CreateFlowVersionParams) SetBucketID 

func (o *CreateFlowVersionParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the create flow version params

func (*CreateFlowVersionParams) SetContext 

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

SetContext adds the context to the create flow version params

func (*CreateFlowVersionParams) SetDefaults 

func (o *CreateFlowVersionParams) SetDefaults()

SetDefaults hydrates default values in the create flow version params (not the query body).

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

func (*CreateFlowVersionParams) SetFlowID 

func (o *CreateFlowVersionParams) SetFlowID(flowID string)

SetFlowID adds the flowId to the create flow version params

func (*CreateFlowVersionParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the create flow version params

func (*CreateFlowVersionParams) SetTimeout 

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

SetTimeout adds the timeout to the create flow version params

func (*CreateFlowVersionParams) WithBody 

func (o *CreateFlowVersionParams) WithBody(body *models.VersionedFlowSnapshot) *CreateFlowVersionParams

WithBody adds the body to the create flow version params

func (*CreateFlowVersionParams) WithBucketID 

func (o *CreateFlowVersionParams) WithBucketID(bucketID string) *CreateFlowVersionParams

WithBucketID adds the bucketID to the create flow version params

func (*CreateFlowVersionParams) WithContext 

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

WithContext adds the context to the create flow version params

func (*CreateFlowVersionParams) WithDefaults 

func (o *CreateFlowVersionParams) WithDefaults() *CreateFlowVersionParams

WithDefaults hydrates default values in the create flow version params (not the query body).

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

func (*CreateFlowVersionParams) WithFlowID 

func (o *CreateFlowVersionParams) WithFlowID(flowID string) *CreateFlowVersionParams

WithFlowID adds the flowID to the create flow version params

func (*CreateFlowVersionParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the create flow version params

func (*CreateFlowVersionParams) WithTimeout 

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

WithTimeout adds the timeout to the create flow version params

func (*CreateFlowVersionParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type CreateFlowVersionReader 

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

CreateFlowVersionReader is a Reader for the CreateFlowVersion structure.

func (*CreateFlowVersionReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type CreateFlowVersionUnauthorized 

type CreateFlowVersionUnauthorized struct {
}

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

Client could not be authenticated.

func NewCreateFlowVersionUnauthorized 

func NewCreateFlowVersionUnauthorized() *CreateFlowVersionUnauthorized

NewCreateFlowVersionUnauthorized creates a CreateFlowVersionUnauthorized with default headers values

func (*CreateFlowVersionUnauthorized) Error 

func (o *CreateFlowVersionUnauthorized) Error() string

func (*CreateFlowVersionUnauthorized) IsClientError added in v1.19.1 

func (o *CreateFlowVersionUnauthorized) IsClientError() bool

IsClientError returns true when this create flow version unauthorized response has a 4xx status code

func (*CreateFlowVersionUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this create flow version unauthorized response a status code equal to that given

func (*CreateFlowVersionUnauthorized) IsRedirect added in v1.19.1 

func (o *CreateFlowVersionUnauthorized) IsRedirect() bool

IsRedirect returns true when this create flow version unauthorized response has a 3xx status code

func (*CreateFlowVersionUnauthorized) IsServerError added in v1.19.1 

func (o *CreateFlowVersionUnauthorized) IsServerError() bool

IsServerError returns true when this create flow version unauthorized response has a 5xx status code

func (*CreateFlowVersionUnauthorized) IsSuccess added in v1.19.1 

func (o *CreateFlowVersionUnauthorized) IsSuccess() bool

IsSuccess returns true when this create flow version unauthorized response has a 2xx status code

func (*CreateFlowVersionUnauthorized) String added in v1.19.1 

func (o *CreateFlowVersionUnauthorized) String() string

type DeleteFlowConflict 

type DeleteFlowConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewDeleteFlowConflict 

func NewDeleteFlowConflict() *DeleteFlowConflict

NewDeleteFlowConflict creates a DeleteFlowConflict with default headers values

func (*DeleteFlowConflict) Error 

func (o *DeleteFlowConflict) Error() string

func (*DeleteFlowConflict) IsClientError added in v1.19.1 

func (o *DeleteFlowConflict) IsClientError() bool

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

func (*DeleteFlowConflict) IsCode added in v1.19.1 

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

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

func (*DeleteFlowConflict) IsRedirect added in v1.19.1 

func (o *DeleteFlowConflict) IsRedirect() bool

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

func (*DeleteFlowConflict) IsServerError added in v1.19.1 

func (o *DeleteFlowConflict) IsServerError() bool

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

func (*DeleteFlowConflict) IsSuccess added in v1.19.1 

func (o *DeleteFlowConflict) IsSuccess() bool

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

func (*DeleteFlowConflict) String added in v1.19.1 

func (o *DeleteFlowConflict) String() string

type DeleteFlowForbidden 

type DeleteFlowForbidden struct {
}

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

Client is not authorized to make this request.

func NewDeleteFlowForbidden 

func NewDeleteFlowForbidden() *DeleteFlowForbidden

NewDeleteFlowForbidden creates a DeleteFlowForbidden with default headers values

func (*DeleteFlowForbidden) Error 

func (o *DeleteFlowForbidden) Error() string

func (*DeleteFlowForbidden) IsClientError added in v1.19.1 

func (o *DeleteFlowForbidden) IsClientError() bool

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

func (*DeleteFlowForbidden) IsCode added in v1.19.1 

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

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

func (*DeleteFlowForbidden) IsRedirect added in v1.19.1 

func (o *DeleteFlowForbidden) IsRedirect() bool

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

func (*DeleteFlowForbidden) IsServerError added in v1.19.1 

func (o *DeleteFlowForbidden) IsServerError() bool

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

func (*DeleteFlowForbidden) IsSuccess added in v1.19.1 

func (o *DeleteFlowForbidden) IsSuccess() bool

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

func (*DeleteFlowForbidden) String added in v1.19.1 

func (o *DeleteFlowForbidden) String() string

type DeleteFlowNotFound 

type DeleteFlowNotFound struct {
}

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

The specified resource could not be found.

func NewDeleteFlowNotFound 

func NewDeleteFlowNotFound() *DeleteFlowNotFound

NewDeleteFlowNotFound creates a DeleteFlowNotFound with default headers values

func (*DeleteFlowNotFound) Error 

func (o *DeleteFlowNotFound) Error() string

func (*DeleteFlowNotFound) IsClientError added in v1.19.1 

func (o *DeleteFlowNotFound) IsClientError() bool

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

func (*DeleteFlowNotFound) IsCode added in v1.19.1 

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

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

func (*DeleteFlowNotFound) IsRedirect added in v1.19.1 

func (o *DeleteFlowNotFound) IsRedirect() bool

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

func (*DeleteFlowNotFound) IsServerError added in v1.19.1 

func (o *DeleteFlowNotFound) IsServerError() bool

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

func (*DeleteFlowNotFound) IsSuccess added in v1.19.1 

func (o *DeleteFlowNotFound) IsSuccess() bool

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

func (*DeleteFlowNotFound) String added in v1.19.1 

func (o *DeleteFlowNotFound) String() string

type DeleteFlowOK 

type DeleteFlowOK struct {
	Payload *models.VersionedFlow
}

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

successful operation

func NewDeleteFlowOK 

func NewDeleteFlowOK() *DeleteFlowOK

NewDeleteFlowOK creates a DeleteFlowOK with default headers values

func (*DeleteFlowOK) Error 

func (o *DeleteFlowOK) Error() string

func (*DeleteFlowOK) GetPayload 

func (o *DeleteFlowOK) GetPayload() *models.VersionedFlow

func (*DeleteFlowOK) IsClientError added in v1.19.1 

func (o *DeleteFlowOK) IsClientError() bool

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

func (*DeleteFlowOK) IsCode added in v1.19.1 

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

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

func (*DeleteFlowOK) IsRedirect added in v1.19.1 

func (o *DeleteFlowOK) IsRedirect() bool

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

func (*DeleteFlowOK) IsServerError added in v1.19.1 

func (o *DeleteFlowOK) IsServerError() bool

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

func (*DeleteFlowOK) IsSuccess added in v1.19.1 

func (o *DeleteFlowOK) IsSuccess() bool

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

func (*DeleteFlowOK) String added in v1.19.1 

func (o *DeleteFlowOK) String() string

type DeleteFlowParams 

type DeleteFlowParams struct {

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

	/* ClientID.

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

	/* FlowID.

	   The flow identifier
	*/
	FlowID string

	/* Version.

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

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

DeleteFlowParams contains all the parameters to send to the API endpoint 

for the delete flow operation.

Typically these are written to a http.Request.

func NewDeleteFlowParams 

func NewDeleteFlowParams() *DeleteFlowParams

NewDeleteFlowParams creates a new DeleteFlowParams 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 NewDeleteFlowParamsWithContext 

func NewDeleteFlowParamsWithContext(ctx context.Context) *DeleteFlowParams

NewDeleteFlowParamsWithContext creates a new DeleteFlowParams object with the ability to set a context for a request.

func NewDeleteFlowParamsWithHTTPClient 

func NewDeleteFlowParamsWithHTTPClient(client *http.Client) *DeleteFlowParams

NewDeleteFlowParamsWithHTTPClient creates a new DeleteFlowParams object with the ability to set a custom HTTPClient for a request.

func NewDeleteFlowParamsWithTimeout 

func NewDeleteFlowParamsWithTimeout(timeout time.Duration) *DeleteFlowParams

NewDeleteFlowParamsWithTimeout creates a new DeleteFlowParams object with the ability to set a timeout on a request.

func (*DeleteFlowParams) SetBucketID 

func (o *DeleteFlowParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the delete flow params

func (*DeleteFlowParams) SetClientID 

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

SetClientID adds the clientId to the delete flow params

func (*DeleteFlowParams) SetContext 

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

SetContext adds the context to the delete flow params

func (*DeleteFlowParams) SetDefaults 

func (o *DeleteFlowParams) SetDefaults()

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

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

func (*DeleteFlowParams) SetFlowID 

func (o *DeleteFlowParams) SetFlowID(flowID string)

SetFlowID adds the flowId to the delete flow params

func (*DeleteFlowParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the delete flow params

func (*DeleteFlowParams) SetTimeout 

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

SetTimeout adds the timeout to the delete flow params

func (*DeleteFlowParams) SetVersion 

func (o *DeleteFlowParams) SetVersion(version string)

SetVersion adds the version to the delete flow params

func (*DeleteFlowParams) WithBucketID 

func (o *DeleteFlowParams) WithBucketID(bucketID string) *DeleteFlowParams

WithBucketID adds the bucketID to the delete flow params

func (*DeleteFlowParams) WithClientID 

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

WithClientID adds the clientID to the delete flow params

func (*DeleteFlowParams) WithContext 

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

WithContext adds the context to the delete flow params

func (*DeleteFlowParams) WithDefaults 

func (o *DeleteFlowParams) WithDefaults() *DeleteFlowParams

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

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

func (*DeleteFlowParams) WithFlowID 

func (o *DeleteFlowParams) WithFlowID(flowID string) *DeleteFlowParams

WithFlowID adds the flowID to the delete flow params

func (*DeleteFlowParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the delete flow params

func (*DeleteFlowParams) WithTimeout 

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

WithTimeout adds the timeout to the delete flow params

func (*DeleteFlowParams) WithVersion 

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

WithVersion adds the version to the delete flow params

func (*DeleteFlowParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type DeleteFlowReader 

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

DeleteFlowReader is a Reader for the DeleteFlow structure.

func (*DeleteFlowReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type DeleteFlowUnauthorized 

type DeleteFlowUnauthorized struct {
}

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

Client could not be authenticated.

func NewDeleteFlowUnauthorized 

func NewDeleteFlowUnauthorized() *DeleteFlowUnauthorized

NewDeleteFlowUnauthorized creates a DeleteFlowUnauthorized with default headers values

func (*DeleteFlowUnauthorized) Error 

func (o *DeleteFlowUnauthorized) Error() string

func (*DeleteFlowUnauthorized) IsClientError added in v1.19.1 

func (o *DeleteFlowUnauthorized) IsClientError() bool

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

func (*DeleteFlowUnauthorized) IsCode added in v1.19.1 

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

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

func (*DeleteFlowUnauthorized) IsRedirect added in v1.19.1 

func (o *DeleteFlowUnauthorized) IsRedirect() bool

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

func (*DeleteFlowUnauthorized) IsServerError added in v1.19.1 

func (o *DeleteFlowUnauthorized) IsServerError() bool

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

func (*DeleteFlowUnauthorized) IsSuccess added in v1.19.1 

func (o *DeleteFlowUnauthorized) IsSuccess() bool

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

func (*DeleteFlowUnauthorized) String added in v1.19.1 

func (o *DeleteFlowUnauthorized) String() string

type ExportVersionedFlowConflict 

type ExportVersionedFlowConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewExportVersionedFlowConflict 

func NewExportVersionedFlowConflict() *ExportVersionedFlowConflict

NewExportVersionedFlowConflict creates a ExportVersionedFlowConflict with default headers values

func (*ExportVersionedFlowConflict) Error 

func (o *ExportVersionedFlowConflict) Error() string

func (*ExportVersionedFlowConflict) IsClientError added in v1.19.1 

func (o *ExportVersionedFlowConflict) IsClientError() bool

IsClientError returns true when this export versioned flow conflict response has a 4xx status code

func (*ExportVersionedFlowConflict) IsCode added in v1.19.1 

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

IsCode returns true when this export versioned flow conflict response a status code equal to that given

func (*ExportVersionedFlowConflict) IsRedirect added in v1.19.1 

func (o *ExportVersionedFlowConflict) IsRedirect() bool

IsRedirect returns true when this export versioned flow conflict response has a 3xx status code

func (*ExportVersionedFlowConflict) IsServerError added in v1.19.1 

func (o *ExportVersionedFlowConflict) IsServerError() bool

IsServerError returns true when this export versioned flow conflict response has a 5xx status code

func (*ExportVersionedFlowConflict) IsSuccess added in v1.19.1 

func (o *ExportVersionedFlowConflict) IsSuccess() bool

IsSuccess returns true when this export versioned flow conflict response has a 2xx status code

func (*ExportVersionedFlowConflict) String added in v1.19.1 

func (o *ExportVersionedFlowConflict) String() string

type ExportVersionedFlowForbidden 

type ExportVersionedFlowForbidden struct {
}

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

Client is not authorized to make this request.

func NewExportVersionedFlowForbidden 

func NewExportVersionedFlowForbidden() *ExportVersionedFlowForbidden

NewExportVersionedFlowForbidden creates a ExportVersionedFlowForbidden with default headers values

func (*ExportVersionedFlowForbidden) Error 

func (o *ExportVersionedFlowForbidden) Error() string

func (*ExportVersionedFlowForbidden) IsClientError added in v1.19.1 

func (o *ExportVersionedFlowForbidden) IsClientError() bool

IsClientError returns true when this export versioned flow forbidden response has a 4xx status code

func (*ExportVersionedFlowForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this export versioned flow forbidden response a status code equal to that given

func (*ExportVersionedFlowForbidden) IsRedirect added in v1.19.1 

func (o *ExportVersionedFlowForbidden) IsRedirect() bool

IsRedirect returns true when this export versioned flow forbidden response has a 3xx status code

func (*ExportVersionedFlowForbidden) IsServerError added in v1.19.1 

func (o *ExportVersionedFlowForbidden) IsServerError() bool

IsServerError returns true when this export versioned flow forbidden response has a 5xx status code

func (*ExportVersionedFlowForbidden) IsSuccess added in v1.19.1 

func (o *ExportVersionedFlowForbidden) IsSuccess() bool

IsSuccess returns true when this export versioned flow forbidden response has a 2xx status code

func (*ExportVersionedFlowForbidden) String added in v1.19.1 

func (o *ExportVersionedFlowForbidden) String() string

type ExportVersionedFlowNotFound 

type ExportVersionedFlowNotFound struct {
}

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

The specified resource could not be found.

func NewExportVersionedFlowNotFound 

func NewExportVersionedFlowNotFound() *ExportVersionedFlowNotFound

NewExportVersionedFlowNotFound creates a ExportVersionedFlowNotFound with default headers values

func (*ExportVersionedFlowNotFound) Error 

func (o *ExportVersionedFlowNotFound) Error() string

func (*ExportVersionedFlowNotFound) IsClientError added in v1.19.1 

func (o *ExportVersionedFlowNotFound) IsClientError() bool

IsClientError returns true when this export versioned flow not found response has a 4xx status code

func (*ExportVersionedFlowNotFound) IsCode added in v1.19.1 

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

IsCode returns true when this export versioned flow not found response a status code equal to that given

func (*ExportVersionedFlowNotFound) IsRedirect added in v1.19.1 

func (o *ExportVersionedFlowNotFound) IsRedirect() bool

IsRedirect returns true when this export versioned flow not found response has a 3xx status code

func (*ExportVersionedFlowNotFound) IsServerError added in v1.19.1 

func (o *ExportVersionedFlowNotFound) IsServerError() bool

IsServerError returns true when this export versioned flow not found response has a 5xx status code

func (*ExportVersionedFlowNotFound) IsSuccess added in v1.19.1 

func (o *ExportVersionedFlowNotFound) IsSuccess() bool

IsSuccess returns true when this export versioned flow not found response has a 2xx status code

func (*ExportVersionedFlowNotFound) String added in v1.19.1 

func (o *ExportVersionedFlowNotFound) String() string

type ExportVersionedFlowOK 

type ExportVersionedFlowOK struct {
	Payload *models.VersionedFlowSnapshot
}

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

successful operation

func NewExportVersionedFlowOK 

func NewExportVersionedFlowOK() *ExportVersionedFlowOK

NewExportVersionedFlowOK creates a ExportVersionedFlowOK with default headers values

func (*ExportVersionedFlowOK) Error 

func (o *ExportVersionedFlowOK) Error() string

func (*ExportVersionedFlowOK) GetPayload 

func (o *ExportVersionedFlowOK) GetPayload() *models.VersionedFlowSnapshot

func (*ExportVersionedFlowOK) IsClientError added in v1.19.1 

func (o *ExportVersionedFlowOK) IsClientError() bool

IsClientError returns true when this export versioned flow o k response has a 4xx status code

func (*ExportVersionedFlowOK) IsCode added in v1.19.1 

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

IsCode returns true when this export versioned flow o k response a status code equal to that given

func (*ExportVersionedFlowOK) IsRedirect added in v1.19.1 

func (o *ExportVersionedFlowOK) IsRedirect() bool

IsRedirect returns true when this export versioned flow o k response has a 3xx status code

func (*ExportVersionedFlowOK) IsServerError added in v1.19.1 

func (o *ExportVersionedFlowOK) IsServerError() bool

IsServerError returns true when this export versioned flow o k response has a 5xx status code

func (*ExportVersionedFlowOK) IsSuccess added in v1.19.1 

func (o *ExportVersionedFlowOK) IsSuccess() bool

IsSuccess returns true when this export versioned flow o k response has a 2xx status code

func (*ExportVersionedFlowOK) String added in v1.19.1 

func (o *ExportVersionedFlowOK) String() string

type ExportVersionedFlowParams 

type ExportVersionedFlowParams struct {

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

	/* FlowID.

	   The flow identifier
	*/
	FlowID string

	/* VersionNumber.

	   The version number

	   Format: int32
	*/
	VersionNumber int32

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

ExportVersionedFlowParams contains all the parameters to send to the API endpoint 

for the export versioned flow operation.

Typically these are written to a http.Request.

func NewExportVersionedFlowParams 

func NewExportVersionedFlowParams() *ExportVersionedFlowParams

NewExportVersionedFlowParams creates a new ExportVersionedFlowParams 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 NewExportVersionedFlowParamsWithContext 

func NewExportVersionedFlowParamsWithContext(ctx context.Context) *ExportVersionedFlowParams

NewExportVersionedFlowParamsWithContext creates a new ExportVersionedFlowParams object with the ability to set a context for a request.

func NewExportVersionedFlowParamsWithHTTPClient 

func NewExportVersionedFlowParamsWithHTTPClient(client *http.Client) *ExportVersionedFlowParams

NewExportVersionedFlowParamsWithHTTPClient creates a new ExportVersionedFlowParams object with the ability to set a custom HTTPClient for a request.

func NewExportVersionedFlowParamsWithTimeout 

func NewExportVersionedFlowParamsWithTimeout(timeout time.Duration) *ExportVersionedFlowParams

NewExportVersionedFlowParamsWithTimeout creates a new ExportVersionedFlowParams object with the ability to set a timeout on a request.

func (*ExportVersionedFlowParams) SetBucketID 

func (o *ExportVersionedFlowParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the export versioned flow params

func (*ExportVersionedFlowParams) SetContext 

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

SetContext adds the context to the export versioned flow params

func (*ExportVersionedFlowParams) SetDefaults 

func (o *ExportVersionedFlowParams) SetDefaults()

SetDefaults hydrates default values in the export versioned flow params (not the query body).

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

func (*ExportVersionedFlowParams) SetFlowID 

func (o *ExportVersionedFlowParams) SetFlowID(flowID string)

SetFlowID adds the flowId to the export versioned flow params

func (*ExportVersionedFlowParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the export versioned flow params

func (*ExportVersionedFlowParams) SetTimeout 

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

SetTimeout adds the timeout to the export versioned flow params

func (*ExportVersionedFlowParams) SetVersionNumber 

func (o *ExportVersionedFlowParams) SetVersionNumber(versionNumber int32)

SetVersionNumber adds the versionNumber to the export versioned flow params

func (*ExportVersionedFlowParams) WithBucketID 

func (o *ExportVersionedFlowParams) WithBucketID(bucketID string) *ExportVersionedFlowParams

WithBucketID adds the bucketID to the export versioned flow params

func (*ExportVersionedFlowParams) WithContext 

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

WithContext adds the context to the export versioned flow params

func (*ExportVersionedFlowParams) WithDefaults 

func (o *ExportVersionedFlowParams) WithDefaults() *ExportVersionedFlowParams

WithDefaults hydrates default values in the export versioned flow params (not the query body).

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

func (*ExportVersionedFlowParams) WithFlowID 

func (o *ExportVersionedFlowParams) WithFlowID(flowID string) *ExportVersionedFlowParams

WithFlowID adds the flowID to the export versioned flow params

func (*ExportVersionedFlowParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the export versioned flow params

func (*ExportVersionedFlowParams) WithTimeout 

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

WithTimeout adds the timeout to the export versioned flow params

func (*ExportVersionedFlowParams) WithVersionNumber 

func (o *ExportVersionedFlowParams) WithVersionNumber(versionNumber int32) *ExportVersionedFlowParams

WithVersionNumber adds the versionNumber to the export versioned flow params

func (*ExportVersionedFlowParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ExportVersionedFlowReader 

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

ExportVersionedFlowReader is a Reader for the ExportVersionedFlow structure.

func (*ExportVersionedFlowReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ExportVersionedFlowUnauthorized 

type ExportVersionedFlowUnauthorized struct {
}

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

Client could not be authenticated.

func NewExportVersionedFlowUnauthorized 

func NewExportVersionedFlowUnauthorized() *ExportVersionedFlowUnauthorized

NewExportVersionedFlowUnauthorized creates a ExportVersionedFlowUnauthorized with default headers values

func (*ExportVersionedFlowUnauthorized) Error 

func (o *ExportVersionedFlowUnauthorized) Error() string

func (*ExportVersionedFlowUnauthorized) IsClientError added in v1.19.1 

func (o *ExportVersionedFlowUnauthorized) IsClientError() bool

IsClientError returns true when this export versioned flow unauthorized response has a 4xx status code

func (*ExportVersionedFlowUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this export versioned flow unauthorized response a status code equal to that given

func (*ExportVersionedFlowUnauthorized) IsRedirect added in v1.19.1 

func (o *ExportVersionedFlowUnauthorized) IsRedirect() bool

IsRedirect returns true when this export versioned flow unauthorized response has a 3xx status code

func (*ExportVersionedFlowUnauthorized) IsServerError added in v1.19.1 

func (o *ExportVersionedFlowUnauthorized) IsServerError() bool

IsServerError returns true when this export versioned flow unauthorized response has a 5xx status code

func (*ExportVersionedFlowUnauthorized) IsSuccess added in v1.19.1 

func (o *ExportVersionedFlowUnauthorized) IsSuccess() bool

IsSuccess returns true when this export versioned flow unauthorized response has a 2xx status code

func (*ExportVersionedFlowUnauthorized) String added in v1.19.1 

func (o *ExportVersionedFlowUnauthorized) String() string

type GetFlowBadRequest 

type GetFlowBadRequest struct {
}

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

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

func NewGetFlowBadRequest 

func NewGetFlowBadRequest() *GetFlowBadRequest

NewGetFlowBadRequest creates a GetFlowBadRequest with default headers values

func (*GetFlowBadRequest) Error 

func (o *GetFlowBadRequest) Error() string

func (*GetFlowBadRequest) IsClientError added in v1.19.1 

func (o *GetFlowBadRequest) IsClientError() bool

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

func (*GetFlowBadRequest) IsCode added in v1.19.1 

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

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

func (*GetFlowBadRequest) IsRedirect added in v1.19.1 

func (o *GetFlowBadRequest) IsRedirect() bool

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

func (*GetFlowBadRequest) IsServerError added in v1.19.1 

func (o *GetFlowBadRequest) IsServerError() bool

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

func (*GetFlowBadRequest) IsSuccess added in v1.19.1 

func (o *GetFlowBadRequest) IsSuccess() bool

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

func (*GetFlowBadRequest) String added in v1.19.1 

func (o *GetFlowBadRequest) String() string

type GetFlowConflict 

type GetFlowConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewGetFlowConflict 

func NewGetFlowConflict() *GetFlowConflict

NewGetFlowConflict creates a GetFlowConflict with default headers values

func (*GetFlowConflict) Error 

func (o *GetFlowConflict) Error() string

func (*GetFlowConflict) IsClientError added in v1.19.1 

func (o *GetFlowConflict) IsClientError() bool

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

func (*GetFlowConflict) IsCode added in v1.19.1 

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

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

func (*GetFlowConflict) IsRedirect added in v1.19.1 

func (o *GetFlowConflict) IsRedirect() bool

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

func (*GetFlowConflict) IsServerError added in v1.19.1 

func (o *GetFlowConflict) IsServerError() bool

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

func (*GetFlowConflict) IsSuccess added in v1.19.1 

func (o *GetFlowConflict) IsSuccess() bool

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

func (*GetFlowConflict) String added in v1.19.1 

func (o *GetFlowConflict) String() string

type GetFlowDiffBadRequest 

type GetFlowDiffBadRequest struct {
}

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

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

func NewGetFlowDiffBadRequest 

func NewGetFlowDiffBadRequest() *GetFlowDiffBadRequest

NewGetFlowDiffBadRequest creates a GetFlowDiffBadRequest with default headers values

func (*GetFlowDiffBadRequest) Error 

func (o *GetFlowDiffBadRequest) Error() string

func (*GetFlowDiffBadRequest) IsClientError added in v1.19.1 

func (o *GetFlowDiffBadRequest) IsClientError() bool

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

func (*GetFlowDiffBadRequest) IsCode added in v1.19.1 

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

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

func (*GetFlowDiffBadRequest) IsRedirect added in v1.19.1 

func (o *GetFlowDiffBadRequest) IsRedirect() bool

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

func (*GetFlowDiffBadRequest) IsServerError added in v1.19.1 

func (o *GetFlowDiffBadRequest) IsServerError() bool

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

func (*GetFlowDiffBadRequest) IsSuccess added in v1.19.1 

func (o *GetFlowDiffBadRequest) IsSuccess() bool

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

func (*GetFlowDiffBadRequest) String added in v1.19.1 

func (o *GetFlowDiffBadRequest) String() string

type GetFlowDiffConflict 

type GetFlowDiffConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewGetFlowDiffConflict 

func NewGetFlowDiffConflict() *GetFlowDiffConflict

NewGetFlowDiffConflict creates a GetFlowDiffConflict with default headers values

func (*GetFlowDiffConflict) Error 

func (o *GetFlowDiffConflict) Error() string

func (*GetFlowDiffConflict) IsClientError added in v1.19.1 

func (o *GetFlowDiffConflict) IsClientError() bool

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

func (*GetFlowDiffConflict) IsCode added in v1.19.1 

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

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

func (*GetFlowDiffConflict) IsRedirect added in v1.19.1 

func (o *GetFlowDiffConflict) IsRedirect() bool

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

func (*GetFlowDiffConflict) IsServerError added in v1.19.1 

func (o *GetFlowDiffConflict) IsServerError() bool

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

func (*GetFlowDiffConflict) IsSuccess added in v1.19.1 

func (o *GetFlowDiffConflict) IsSuccess() bool

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

func (*GetFlowDiffConflict) String added in v1.19.1 

func (o *GetFlowDiffConflict) String() string

type GetFlowDiffForbidden 

type GetFlowDiffForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetFlowDiffForbidden 

func NewGetFlowDiffForbidden() *GetFlowDiffForbidden

NewGetFlowDiffForbidden creates a GetFlowDiffForbidden with default headers values

func (*GetFlowDiffForbidden) Error 

func (o *GetFlowDiffForbidden) Error() string

func (*GetFlowDiffForbidden) IsClientError added in v1.19.1 

func (o *GetFlowDiffForbidden) IsClientError() bool

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

func (*GetFlowDiffForbidden) IsCode added in v1.19.1 

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

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

func (*GetFlowDiffForbidden) IsRedirect added in v1.19.1 

func (o *GetFlowDiffForbidden) IsRedirect() bool

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

func (*GetFlowDiffForbidden) IsServerError added in v1.19.1 

func (o *GetFlowDiffForbidden) IsServerError() bool

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

func (*GetFlowDiffForbidden) IsSuccess added in v1.19.1 

func (o *GetFlowDiffForbidden) IsSuccess() bool

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

func (*GetFlowDiffForbidden) String added in v1.19.1 

func (o *GetFlowDiffForbidden) String() string

type GetFlowDiffNotFound 

type GetFlowDiffNotFound struct {
}

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

The specified resource could not be found.

func NewGetFlowDiffNotFound 

func NewGetFlowDiffNotFound() *GetFlowDiffNotFound

NewGetFlowDiffNotFound creates a GetFlowDiffNotFound with default headers values

func (*GetFlowDiffNotFound) Error 

func (o *GetFlowDiffNotFound) Error() string

func (*GetFlowDiffNotFound) IsClientError added in v1.19.1 

func (o *GetFlowDiffNotFound) IsClientError() bool

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

func (*GetFlowDiffNotFound) IsCode added in v1.19.1 

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

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

func (*GetFlowDiffNotFound) IsRedirect added in v1.19.1 

func (o *GetFlowDiffNotFound) IsRedirect() bool

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

func (*GetFlowDiffNotFound) IsServerError added in v1.19.1 

func (o *GetFlowDiffNotFound) IsServerError() bool

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

func (*GetFlowDiffNotFound) IsSuccess added in v1.19.1 

func (o *GetFlowDiffNotFound) IsSuccess() bool

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

func (*GetFlowDiffNotFound) String added in v1.19.1 

func (o *GetFlowDiffNotFound) String() string

type GetFlowDiffOK 

type GetFlowDiffOK struct {
	Payload *models.VersionedFlowDifference
}

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

successful operation

func NewGetFlowDiffOK 

func NewGetFlowDiffOK() *GetFlowDiffOK

NewGetFlowDiffOK creates a GetFlowDiffOK with default headers values

func (*GetFlowDiffOK) Error 

func (o *GetFlowDiffOK) Error() string

func (*GetFlowDiffOK) GetPayload 

func (o *GetFlowDiffOK) GetPayload() *models.VersionedFlowDifference

func (*GetFlowDiffOK) IsClientError added in v1.19.1 

func (o *GetFlowDiffOK) IsClientError() bool

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

func (*GetFlowDiffOK) IsCode added in v1.19.1 

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

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

func (*GetFlowDiffOK) IsRedirect added in v1.19.1 

func (o *GetFlowDiffOK) IsRedirect() bool

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

func (*GetFlowDiffOK) IsServerError added in v1.19.1 

func (o *GetFlowDiffOK) IsServerError() bool

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

func (*GetFlowDiffOK) IsSuccess added in v1.19.1 

func (o *GetFlowDiffOK) IsSuccess() bool

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

func (*GetFlowDiffOK) String added in v1.19.1 

func (o *GetFlowDiffOK) String() string

type GetFlowDiffParams 

type GetFlowDiffParams struct {

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

	/* FlowID.

	   The flow identifier
	*/
	FlowID string

	/* VersionA.

	   The first version number

	   Format: int32
	*/
	VersionA int32

	/* VersionB.

	   The second version number

	   Format: int32
	*/
	VersionB int32

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

GetFlowDiffParams contains all the parameters to send to the API endpoint 

for the get flow diff operation.

Typically these are written to a http.Request.

func NewGetFlowDiffParams 

func NewGetFlowDiffParams() *GetFlowDiffParams

NewGetFlowDiffParams creates a new GetFlowDiffParams 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 NewGetFlowDiffParamsWithContext 

func NewGetFlowDiffParamsWithContext(ctx context.Context) *GetFlowDiffParams

NewGetFlowDiffParamsWithContext creates a new GetFlowDiffParams object with the ability to set a context for a request.

func NewGetFlowDiffParamsWithHTTPClient 

func NewGetFlowDiffParamsWithHTTPClient(client *http.Client) *GetFlowDiffParams

NewGetFlowDiffParamsWithHTTPClient creates a new GetFlowDiffParams object with the ability to set a custom HTTPClient for a request.

func NewGetFlowDiffParamsWithTimeout 

func NewGetFlowDiffParamsWithTimeout(timeout time.Duration) *GetFlowDiffParams

NewGetFlowDiffParamsWithTimeout creates a new GetFlowDiffParams object with the ability to set a timeout on a request.

func (*GetFlowDiffParams) SetBucketID 

func (o *GetFlowDiffParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the get flow diff params

func (*GetFlowDiffParams) SetContext 

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

SetContext adds the context to the get flow diff params

func (*GetFlowDiffParams) SetDefaults 

func (o *GetFlowDiffParams) SetDefaults()

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

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

func (*GetFlowDiffParams) SetFlowID 

func (o *GetFlowDiffParams) SetFlowID(flowID string)

SetFlowID adds the flowId to the get flow diff params

func (*GetFlowDiffParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get flow diff params

func (*GetFlowDiffParams) SetTimeout 

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

SetTimeout adds the timeout to the get flow diff params

func (*GetFlowDiffParams) SetVersionA 

func (o *GetFlowDiffParams) SetVersionA(versionA int32)

SetVersionA adds the versionA to the get flow diff params

func (*GetFlowDiffParams) SetVersionB 

func (o *GetFlowDiffParams) SetVersionB(versionB int32)

SetVersionB adds the versionB to the get flow diff params

func (*GetFlowDiffParams) WithBucketID 

func (o *GetFlowDiffParams) WithBucketID(bucketID string) *GetFlowDiffParams

WithBucketID adds the bucketID to the get flow diff params

func (*GetFlowDiffParams) WithContext 

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

WithContext adds the context to the get flow diff params

func (*GetFlowDiffParams) WithDefaults 

func (o *GetFlowDiffParams) WithDefaults() *GetFlowDiffParams

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

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

func (*GetFlowDiffParams) WithFlowID 

func (o *GetFlowDiffParams) WithFlowID(flowID string) *GetFlowDiffParams

WithFlowID adds the flowID to the get flow diff params

func (*GetFlowDiffParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get flow diff params

func (*GetFlowDiffParams) WithTimeout 

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

WithTimeout adds the timeout to the get flow diff params

func (*GetFlowDiffParams) WithVersionA 

func (o *GetFlowDiffParams) WithVersionA(versionA int32) *GetFlowDiffParams

WithVersionA adds the versionA to the get flow diff params

func (*GetFlowDiffParams) WithVersionB 

func (o *GetFlowDiffParams) WithVersionB(versionB int32) *GetFlowDiffParams

WithVersionB adds the versionB to the get flow diff params

func (*GetFlowDiffParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetFlowDiffReader 

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

GetFlowDiffReader is a Reader for the GetFlowDiff structure.

func (*GetFlowDiffReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetFlowDiffUnauthorized 

type GetFlowDiffUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetFlowDiffUnauthorized 

func NewGetFlowDiffUnauthorized() *GetFlowDiffUnauthorized

NewGetFlowDiffUnauthorized creates a GetFlowDiffUnauthorized with default headers values

func (*GetFlowDiffUnauthorized) Error 

func (o *GetFlowDiffUnauthorized) Error() string

func (*GetFlowDiffUnauthorized) IsClientError added in v1.19.1 

func (o *GetFlowDiffUnauthorized) IsClientError() bool

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

func (*GetFlowDiffUnauthorized) IsCode added in v1.19.1 

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

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

func (*GetFlowDiffUnauthorized) IsRedirect added in v1.19.1 

func (o *GetFlowDiffUnauthorized) IsRedirect() bool

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

func (*GetFlowDiffUnauthorized) IsServerError added in v1.19.1 

func (o *GetFlowDiffUnauthorized) IsServerError() bool

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

func (*GetFlowDiffUnauthorized) IsSuccess added in v1.19.1 

func (o *GetFlowDiffUnauthorized) IsSuccess() bool

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

func (*GetFlowDiffUnauthorized) String added in v1.19.1 

func (o *GetFlowDiffUnauthorized) String() string

type GetFlowForbidden 

type GetFlowForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetFlowForbidden 

func NewGetFlowForbidden() *GetFlowForbidden

NewGetFlowForbidden creates a GetFlowForbidden with default headers values

func (*GetFlowForbidden) Error 

func (o *GetFlowForbidden) Error() string

func (*GetFlowForbidden) IsClientError added in v1.19.1 

func (o *GetFlowForbidden) IsClientError() bool

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

func (*GetFlowForbidden) IsCode added in v1.19.1 

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

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

func (*GetFlowForbidden) IsRedirect added in v1.19.1 

func (o *GetFlowForbidden) IsRedirect() bool

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

func (*GetFlowForbidden) IsServerError added in v1.19.1 

func (o *GetFlowForbidden) IsServerError() bool

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

func (*GetFlowForbidden) IsSuccess added in v1.19.1 

func (o *GetFlowForbidden) IsSuccess() bool

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

func (*GetFlowForbidden) String added in v1.19.1 

func (o *GetFlowForbidden) String() string

type GetFlowNotFound 

type GetFlowNotFound struct {
}

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

The specified resource could not be found.

func NewGetFlowNotFound 

func NewGetFlowNotFound() *GetFlowNotFound

NewGetFlowNotFound creates a GetFlowNotFound with default headers values

func (*GetFlowNotFound) Error 

func (o *GetFlowNotFound) Error() string

func (*GetFlowNotFound) IsClientError added in v1.19.1 

func (o *GetFlowNotFound) IsClientError() bool

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

func (*GetFlowNotFound) IsCode added in v1.19.1 

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

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

func (*GetFlowNotFound) IsRedirect added in v1.19.1 

func (o *GetFlowNotFound) IsRedirect() bool

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

func (*GetFlowNotFound) IsServerError added in v1.19.1 

func (o *GetFlowNotFound) IsServerError() bool

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

func (*GetFlowNotFound) IsSuccess added in v1.19.1 

func (o *GetFlowNotFound) IsSuccess() bool

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

func (*GetFlowNotFound) String added in v1.19.1 

func (o *GetFlowNotFound) String() string

type GetFlowOK 

type GetFlowOK struct {
	Payload *models.VersionedFlow
}

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

successful operation

func NewGetFlowOK 

func NewGetFlowOK() *GetFlowOK

NewGetFlowOK creates a GetFlowOK with default headers values

func (*GetFlowOK) Error 

func (o *GetFlowOK) Error() string

func (*GetFlowOK) GetPayload 

func (o *GetFlowOK) GetPayload() *models.VersionedFlow

func (*GetFlowOK) IsClientError added in v1.19.1 

func (o *GetFlowOK) IsClientError() bool

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

func (*GetFlowOK) IsCode added in v1.19.1 

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

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

func (*GetFlowOK) IsRedirect added in v1.19.1 

func (o *GetFlowOK) IsRedirect() bool

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

func (*GetFlowOK) IsServerError added in v1.19.1 

func (o *GetFlowOK) IsServerError() bool

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

func (*GetFlowOK) IsSuccess added in v1.19.1 

func (o *GetFlowOK) IsSuccess() bool

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

func (*GetFlowOK) String added in v1.19.1 

func (o *GetFlowOK) String() string

type GetFlowParams 

type GetFlowParams struct {

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

	/* FlowID.

	   The flow identifier
	*/
	FlowID string

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

GetFlowParams contains all the parameters to send to the API endpoint 

for the get flow operation.

Typically these are written to a http.Request.

func NewGetFlowParams 

func NewGetFlowParams() *GetFlowParams

NewGetFlowParams creates a new GetFlowParams 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 NewGetFlowParamsWithContext 

func NewGetFlowParamsWithContext(ctx context.Context) *GetFlowParams

NewGetFlowParamsWithContext creates a new GetFlowParams object with the ability to set a context for a request.

func NewGetFlowParamsWithHTTPClient 

func NewGetFlowParamsWithHTTPClient(client *http.Client) *GetFlowParams

NewGetFlowParamsWithHTTPClient creates a new GetFlowParams object with the ability to set a custom HTTPClient for a request.

func NewGetFlowParamsWithTimeout 

func NewGetFlowParamsWithTimeout(timeout time.Duration) *GetFlowParams

NewGetFlowParamsWithTimeout creates a new GetFlowParams object with the ability to set a timeout on a request.

func (*GetFlowParams) SetBucketID 

func (o *GetFlowParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the get flow params

func (*GetFlowParams) SetContext 

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

SetContext adds the context to the get flow params

func (*GetFlowParams) SetDefaults 

func (o *GetFlowParams) SetDefaults()

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

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

func (*GetFlowParams) SetFlowID 

func (o *GetFlowParams) SetFlowID(flowID string)

SetFlowID adds the flowId to the get flow params

func (*GetFlowParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get flow params

func (*GetFlowParams) SetTimeout 

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

SetTimeout adds the timeout to the get flow params

func (*GetFlowParams) WithBucketID 

func (o *GetFlowParams) WithBucketID(bucketID string) *GetFlowParams

WithBucketID adds the bucketID to the get flow params

func (*GetFlowParams) WithContext 

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

WithContext adds the context to the get flow params

func (*GetFlowParams) WithDefaults 

func (o *GetFlowParams) WithDefaults() *GetFlowParams

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

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

func (*GetFlowParams) WithFlowID 

func (o *GetFlowParams) WithFlowID(flowID string) *GetFlowParams

WithFlowID adds the flowID to the get flow params

func (*GetFlowParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get flow params

func (*GetFlowParams) WithTimeout 

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

WithTimeout adds the timeout to the get flow params

func (*GetFlowParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetFlowReader 

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

GetFlowReader is a Reader for the GetFlow structure.

func (*GetFlowReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetFlowUnauthorized 

type GetFlowUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetFlowUnauthorized 

func NewGetFlowUnauthorized() *GetFlowUnauthorized

NewGetFlowUnauthorized creates a GetFlowUnauthorized with default headers values

func (*GetFlowUnauthorized) Error 

func (o *GetFlowUnauthorized) Error() string

func (*GetFlowUnauthorized) IsClientError added in v1.19.1 

func (o *GetFlowUnauthorized) IsClientError() bool

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

func (*GetFlowUnauthorized) IsCode added in v1.19.1 

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

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

func (*GetFlowUnauthorized) IsRedirect added in v1.19.1 

func (o *GetFlowUnauthorized) IsRedirect() bool

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

func (*GetFlowUnauthorized) IsServerError added in v1.19.1 

func (o *GetFlowUnauthorized) IsServerError() bool

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

func (*GetFlowUnauthorized) IsSuccess added in v1.19.1 

func (o *GetFlowUnauthorized) IsSuccess() bool

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

func (*GetFlowUnauthorized) String added in v1.19.1 

func (o *GetFlowUnauthorized) String() string

type GetFlowVersionBadRequest 

type GetFlowVersionBadRequest struct {
}

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

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

func NewGetFlowVersionBadRequest 

func NewGetFlowVersionBadRequest() *GetFlowVersionBadRequest

NewGetFlowVersionBadRequest creates a GetFlowVersionBadRequest with default headers values

func (*GetFlowVersionBadRequest) Error 

func (o *GetFlowVersionBadRequest) Error() string

func (*GetFlowVersionBadRequest) IsClientError added in v1.19.1 

func (o *GetFlowVersionBadRequest) IsClientError() bool

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

func (*GetFlowVersionBadRequest) IsCode added in v1.19.1 

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

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

func (*GetFlowVersionBadRequest) IsRedirect added in v1.19.1 

func (o *GetFlowVersionBadRequest) IsRedirect() bool

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

func (*GetFlowVersionBadRequest) IsServerError added in v1.19.1 

func (o *GetFlowVersionBadRequest) IsServerError() bool

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

func (*GetFlowVersionBadRequest) IsSuccess added in v1.19.1 

func (o *GetFlowVersionBadRequest) IsSuccess() bool

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

func (*GetFlowVersionBadRequest) String added in v1.19.1 

func (o *GetFlowVersionBadRequest) String() string

type GetFlowVersionConflict 

type GetFlowVersionConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewGetFlowVersionConflict 

func NewGetFlowVersionConflict() *GetFlowVersionConflict

NewGetFlowVersionConflict creates a GetFlowVersionConflict with default headers values

func (*GetFlowVersionConflict) Error 

func (o *GetFlowVersionConflict) Error() string

func (*GetFlowVersionConflict) IsClientError added in v1.19.1 

func (o *GetFlowVersionConflict) IsClientError() bool

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

func (*GetFlowVersionConflict) IsCode added in v1.19.1 

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

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

func (*GetFlowVersionConflict) IsRedirect added in v1.19.1 

func (o *GetFlowVersionConflict) IsRedirect() bool

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

func (*GetFlowVersionConflict) IsServerError added in v1.19.1 

func (o *GetFlowVersionConflict) IsServerError() bool

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

func (*GetFlowVersionConflict) IsSuccess added in v1.19.1 

func (o *GetFlowVersionConflict) IsSuccess() bool

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

func (*GetFlowVersionConflict) String added in v1.19.1 

func (o *GetFlowVersionConflict) String() string

type GetFlowVersionForbidden 

type GetFlowVersionForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetFlowVersionForbidden 

func NewGetFlowVersionForbidden() *GetFlowVersionForbidden

NewGetFlowVersionForbidden creates a GetFlowVersionForbidden with default headers values

func (*GetFlowVersionForbidden) Error 

func (o *GetFlowVersionForbidden) Error() string

func (*GetFlowVersionForbidden) IsClientError added in v1.19.1 

func (o *GetFlowVersionForbidden) IsClientError() bool

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

func (*GetFlowVersionForbidden) IsCode added in v1.19.1 

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

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

func (*GetFlowVersionForbidden) IsRedirect added in v1.19.1 

func (o *GetFlowVersionForbidden) IsRedirect() bool

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

func (*GetFlowVersionForbidden) IsServerError added in v1.19.1 

func (o *GetFlowVersionForbidden) IsServerError() bool

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

func (*GetFlowVersionForbidden) IsSuccess added in v1.19.1 

func (o *GetFlowVersionForbidden) IsSuccess() bool

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

func (*GetFlowVersionForbidden) String added in v1.19.1 

func (o *GetFlowVersionForbidden) String() string

type GetFlowVersionNotFound 

type GetFlowVersionNotFound struct {
}

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

The specified resource could not be found.

func NewGetFlowVersionNotFound 

func NewGetFlowVersionNotFound() *GetFlowVersionNotFound

NewGetFlowVersionNotFound creates a GetFlowVersionNotFound with default headers values

func (*GetFlowVersionNotFound) Error 

func (o *GetFlowVersionNotFound) Error() string

func (*GetFlowVersionNotFound) IsClientError added in v1.19.1 

func (o *GetFlowVersionNotFound) IsClientError() bool

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

func (*GetFlowVersionNotFound) IsCode added in v1.19.1 

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

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

func (*GetFlowVersionNotFound) IsRedirect added in v1.19.1 

func (o *GetFlowVersionNotFound) IsRedirect() bool

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

func (*GetFlowVersionNotFound) IsServerError added in v1.19.1 

func (o *GetFlowVersionNotFound) IsServerError() bool

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

func (*GetFlowVersionNotFound) IsSuccess added in v1.19.1 

func (o *GetFlowVersionNotFound) IsSuccess() bool

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

func (*GetFlowVersionNotFound) String added in v1.19.1 

func (o *GetFlowVersionNotFound) String() string

type GetFlowVersionOK 

type GetFlowVersionOK struct {
	Payload *models.VersionedFlowSnapshot
}

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

successful operation

func NewGetFlowVersionOK 

func NewGetFlowVersionOK() *GetFlowVersionOK

NewGetFlowVersionOK creates a GetFlowVersionOK with default headers values

func (*GetFlowVersionOK) Error 

func (o *GetFlowVersionOK) Error() string

func (*GetFlowVersionOK) GetPayload 

func (o *GetFlowVersionOK) GetPayload() *models.VersionedFlowSnapshot

func (*GetFlowVersionOK) IsClientError added in v1.19.1 

func (o *GetFlowVersionOK) IsClientError() bool

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

func (*GetFlowVersionOK) IsCode added in v1.19.1 

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

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

func (*GetFlowVersionOK) IsRedirect added in v1.19.1 

func (o *GetFlowVersionOK) IsRedirect() bool

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

func (*GetFlowVersionOK) IsServerError added in v1.19.1 

func (o *GetFlowVersionOK) IsServerError() bool

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

func (*GetFlowVersionOK) IsSuccess added in v1.19.1 

func (o *GetFlowVersionOK) IsSuccess() bool

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

func (*GetFlowVersionOK) String added in v1.19.1 

func (o *GetFlowVersionOK) String() string

type GetFlowVersionParams 

type GetFlowVersionParams struct {

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

	/* FlowID.

	   The flow identifier
	*/
	FlowID string

	/* VersionNumber.

	   The version number

	   Format: int32
	*/
	VersionNumber int32

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

GetFlowVersionParams contains all the parameters to send to the API endpoint 

for the get flow version operation.

Typically these are written to a http.Request.

func NewGetFlowVersionParams 

func NewGetFlowVersionParams() *GetFlowVersionParams

NewGetFlowVersionParams creates a new GetFlowVersionParams 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 NewGetFlowVersionParamsWithContext 

func NewGetFlowVersionParamsWithContext(ctx context.Context) *GetFlowVersionParams

NewGetFlowVersionParamsWithContext creates a new GetFlowVersionParams object with the ability to set a context for a request.

func NewGetFlowVersionParamsWithHTTPClient 

func NewGetFlowVersionParamsWithHTTPClient(client *http.Client) *GetFlowVersionParams

NewGetFlowVersionParamsWithHTTPClient creates a new GetFlowVersionParams object with the ability to set a custom HTTPClient for a request.

func NewGetFlowVersionParamsWithTimeout 

func NewGetFlowVersionParamsWithTimeout(timeout time.Duration) *GetFlowVersionParams

NewGetFlowVersionParamsWithTimeout creates a new GetFlowVersionParams object with the ability to set a timeout on a request.

func (*GetFlowVersionParams) SetBucketID 

func (o *GetFlowVersionParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the get flow version params

func (*GetFlowVersionParams) SetContext 

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

SetContext adds the context to the get flow version params

func (*GetFlowVersionParams) SetDefaults 

func (o *GetFlowVersionParams) SetDefaults()

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

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

func (*GetFlowVersionParams) SetFlowID 

func (o *GetFlowVersionParams) SetFlowID(flowID string)

SetFlowID adds the flowId to the get flow version params

func (*GetFlowVersionParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get flow version params

func (*GetFlowVersionParams) SetTimeout 

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

SetTimeout adds the timeout to the get flow version params

func (*GetFlowVersionParams) SetVersionNumber 

func (o *GetFlowVersionParams) SetVersionNumber(versionNumber int32)

SetVersionNumber adds the versionNumber to the get flow version params

func (*GetFlowVersionParams) WithBucketID 

func (o *GetFlowVersionParams) WithBucketID(bucketID string) *GetFlowVersionParams

WithBucketID adds the bucketID to the get flow version params

func (*GetFlowVersionParams) WithContext 

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

WithContext adds the context to the get flow version params

func (*GetFlowVersionParams) WithDefaults 

func (o *GetFlowVersionParams) WithDefaults() *GetFlowVersionParams

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

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

func (*GetFlowVersionParams) WithFlowID 

func (o *GetFlowVersionParams) WithFlowID(flowID string) *GetFlowVersionParams

WithFlowID adds the flowID to the get flow version params

func (*GetFlowVersionParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get flow version params

func (*GetFlowVersionParams) WithTimeout 

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

WithTimeout adds the timeout to the get flow version params

func (*GetFlowVersionParams) WithVersionNumber 

func (o *GetFlowVersionParams) WithVersionNumber(versionNumber int32) *GetFlowVersionParams

WithVersionNumber adds the versionNumber to the get flow version params

func (*GetFlowVersionParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetFlowVersionReader 

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

GetFlowVersionReader is a Reader for the GetFlowVersion structure.

func (*GetFlowVersionReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetFlowVersionUnauthorized 

type GetFlowVersionUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetFlowVersionUnauthorized 

func NewGetFlowVersionUnauthorized() *GetFlowVersionUnauthorized

NewGetFlowVersionUnauthorized creates a GetFlowVersionUnauthorized with default headers values

func (*GetFlowVersionUnauthorized) Error 

func (o *GetFlowVersionUnauthorized) Error() string

func (*GetFlowVersionUnauthorized) IsClientError added in v1.19.1 

func (o *GetFlowVersionUnauthorized) IsClientError() bool

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

func (*GetFlowVersionUnauthorized) IsCode added in v1.19.1 

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

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

func (*GetFlowVersionUnauthorized) IsRedirect added in v1.19.1 

func (o *GetFlowVersionUnauthorized) IsRedirect() bool

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

func (*GetFlowVersionUnauthorized) IsServerError added in v1.19.1 

func (o *GetFlowVersionUnauthorized) IsServerError() bool

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

func (*GetFlowVersionUnauthorized) IsSuccess added in v1.19.1 

func (o *GetFlowVersionUnauthorized) IsSuccess() bool

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

func (*GetFlowVersionUnauthorized) String added in v1.19.1 

func (o *GetFlowVersionUnauthorized) String() string

type GetFlowVersionsConflict 

type GetFlowVersionsConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewGetFlowVersionsConflict 

func NewGetFlowVersionsConflict() *GetFlowVersionsConflict

NewGetFlowVersionsConflict creates a GetFlowVersionsConflict with default headers values

func (*GetFlowVersionsConflict) Error 

func (o *GetFlowVersionsConflict) Error() string

func (*GetFlowVersionsConflict) IsClientError added in v1.19.1 

func (o *GetFlowVersionsConflict) IsClientError() bool

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

func (*GetFlowVersionsConflict) IsCode added in v1.19.1 

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

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

func (*GetFlowVersionsConflict) IsRedirect added in v1.19.1 

func (o *GetFlowVersionsConflict) IsRedirect() bool

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

func (*GetFlowVersionsConflict) IsServerError added in v1.19.1 

func (o *GetFlowVersionsConflict) IsServerError() bool

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

func (*GetFlowVersionsConflict) IsSuccess added in v1.19.1 

func (o *GetFlowVersionsConflict) IsSuccess() bool

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

func (*GetFlowVersionsConflict) String added in v1.19.1 

func (o *GetFlowVersionsConflict) String() string

type GetFlowVersionsForbidden 

type GetFlowVersionsForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetFlowVersionsForbidden 

func NewGetFlowVersionsForbidden() *GetFlowVersionsForbidden

NewGetFlowVersionsForbidden creates a GetFlowVersionsForbidden with default headers values

func (*GetFlowVersionsForbidden) Error 

func (o *GetFlowVersionsForbidden) Error() string

func (*GetFlowVersionsForbidden) IsClientError added in v1.19.1 

func (o *GetFlowVersionsForbidden) IsClientError() bool

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

func (*GetFlowVersionsForbidden) IsCode added in v1.19.1 

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

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

func (*GetFlowVersionsForbidden) IsRedirect added in v1.19.1 

func (o *GetFlowVersionsForbidden) IsRedirect() bool

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

func (*GetFlowVersionsForbidden) IsServerError added in v1.19.1 

func (o *GetFlowVersionsForbidden) IsServerError() bool

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

func (*GetFlowVersionsForbidden) IsSuccess added in v1.19.1 

func (o *GetFlowVersionsForbidden) IsSuccess() bool

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

func (*GetFlowVersionsForbidden) String added in v1.19.1 

func (o *GetFlowVersionsForbidden) String() string

type GetFlowVersionsNotFound 

type GetFlowVersionsNotFound struct {
}

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

The specified resource could not be found.

func NewGetFlowVersionsNotFound 

func NewGetFlowVersionsNotFound() *GetFlowVersionsNotFound

NewGetFlowVersionsNotFound creates a GetFlowVersionsNotFound with default headers values

func (*GetFlowVersionsNotFound) Error 

func (o *GetFlowVersionsNotFound) Error() string

func (*GetFlowVersionsNotFound) IsClientError added in v1.19.1 

func (o *GetFlowVersionsNotFound) IsClientError() bool

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

func (*GetFlowVersionsNotFound) IsCode added in v1.19.1 

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

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

func (*GetFlowVersionsNotFound) IsRedirect added in v1.19.1 

func (o *GetFlowVersionsNotFound) IsRedirect() bool

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

func (*GetFlowVersionsNotFound) IsServerError added in v1.19.1 

func (o *GetFlowVersionsNotFound) IsServerError() bool

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

func (*GetFlowVersionsNotFound) IsSuccess added in v1.19.1 

func (o *GetFlowVersionsNotFound) IsSuccess() bool

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

func (*GetFlowVersionsNotFound) String added in v1.19.1 

func (o *GetFlowVersionsNotFound) String() string

type GetFlowVersionsOK 

type GetFlowVersionsOK struct {
	Payload []*models.VersionedFlowSnapshotMetadata
}

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

successful operation

func NewGetFlowVersionsOK 

func NewGetFlowVersionsOK() *GetFlowVersionsOK

NewGetFlowVersionsOK creates a GetFlowVersionsOK with default headers values

func (*GetFlowVersionsOK) Error 

func (o *GetFlowVersionsOK) Error() string

func (*GetFlowVersionsOK) GetPayload 

func (o *GetFlowVersionsOK) GetPayload() []*models.VersionedFlowSnapshotMetadata

func (*GetFlowVersionsOK) IsClientError added in v1.19.1 

func (o *GetFlowVersionsOK) IsClientError() bool

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

func (*GetFlowVersionsOK) IsCode added in v1.19.1 

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

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

func (*GetFlowVersionsOK) IsRedirect added in v1.19.1 

func (o *GetFlowVersionsOK) IsRedirect() bool

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

func (*GetFlowVersionsOK) IsServerError added in v1.19.1 

func (o *GetFlowVersionsOK) IsServerError() bool

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

func (*GetFlowVersionsOK) IsSuccess added in v1.19.1 

func (o *GetFlowVersionsOK) IsSuccess() bool

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

func (*GetFlowVersionsOK) String added in v1.19.1 

func (o *GetFlowVersionsOK) String() string

type GetFlowVersionsParams 

type GetFlowVersionsParams struct {

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

	/* FlowID.

	   The flow identifier
	*/
	FlowID string

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

GetFlowVersionsParams contains all the parameters to send to the API endpoint 

for the get flow versions operation.

Typically these are written to a http.Request.

func NewGetFlowVersionsParams 

func NewGetFlowVersionsParams() *GetFlowVersionsParams

NewGetFlowVersionsParams creates a new GetFlowVersionsParams 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 NewGetFlowVersionsParamsWithContext 

func NewGetFlowVersionsParamsWithContext(ctx context.Context) *GetFlowVersionsParams

NewGetFlowVersionsParamsWithContext creates a new GetFlowVersionsParams object with the ability to set a context for a request.

func NewGetFlowVersionsParamsWithHTTPClient 

func NewGetFlowVersionsParamsWithHTTPClient(client *http.Client) *GetFlowVersionsParams

NewGetFlowVersionsParamsWithHTTPClient creates a new GetFlowVersionsParams object with the ability to set a custom HTTPClient for a request.

func NewGetFlowVersionsParamsWithTimeout 

func NewGetFlowVersionsParamsWithTimeout(timeout time.Duration) *GetFlowVersionsParams

NewGetFlowVersionsParamsWithTimeout creates a new GetFlowVersionsParams object with the ability to set a timeout on a request.

func (*GetFlowVersionsParams) SetBucketID 

func (o *GetFlowVersionsParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the get flow versions params

func (*GetFlowVersionsParams) SetContext 

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

SetContext adds the context to the get flow versions params

func (*GetFlowVersionsParams) SetDefaults 

func (o *GetFlowVersionsParams) SetDefaults()

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

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

func (*GetFlowVersionsParams) SetFlowID 

func (o *GetFlowVersionsParams) SetFlowID(flowID string)

SetFlowID adds the flowId to the get flow versions params

func (*GetFlowVersionsParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get flow versions params

func (*GetFlowVersionsParams) SetTimeout 

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

SetTimeout adds the timeout to the get flow versions params

func (*GetFlowVersionsParams) WithBucketID 

func (o *GetFlowVersionsParams) WithBucketID(bucketID string) *GetFlowVersionsParams

WithBucketID adds the bucketID to the get flow versions params

func (*GetFlowVersionsParams) WithContext 

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

WithContext adds the context to the get flow versions params

func (*GetFlowVersionsParams) WithDefaults 

func (o *GetFlowVersionsParams) WithDefaults() *GetFlowVersionsParams

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

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

func (*GetFlowVersionsParams) WithFlowID 

func (o *GetFlowVersionsParams) WithFlowID(flowID string) *GetFlowVersionsParams

WithFlowID adds the flowID to the get flow versions params

func (*GetFlowVersionsParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get flow versions params

func (*GetFlowVersionsParams) WithTimeout 

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

WithTimeout adds the timeout to the get flow versions params

func (*GetFlowVersionsParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetFlowVersionsReader 

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

GetFlowVersionsReader is a Reader for the GetFlowVersions structure.

func (*GetFlowVersionsReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetFlowVersionsUnauthorized 

type GetFlowVersionsUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetFlowVersionsUnauthorized 

func NewGetFlowVersionsUnauthorized() *GetFlowVersionsUnauthorized

NewGetFlowVersionsUnauthorized creates a GetFlowVersionsUnauthorized with default headers values

func (*GetFlowVersionsUnauthorized) Error 

func (o *GetFlowVersionsUnauthorized) Error() string

func (*GetFlowVersionsUnauthorized) IsClientError added in v1.19.1 

func (o *GetFlowVersionsUnauthorized) IsClientError() bool

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

func (*GetFlowVersionsUnauthorized) IsCode added in v1.19.1 

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

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

func (*GetFlowVersionsUnauthorized) IsRedirect added in v1.19.1 

func (o *GetFlowVersionsUnauthorized) IsRedirect() bool

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

func (*GetFlowVersionsUnauthorized) IsServerError added in v1.19.1 

func (o *GetFlowVersionsUnauthorized) IsServerError() bool

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

func (*GetFlowVersionsUnauthorized) IsSuccess added in v1.19.1 

func (o *GetFlowVersionsUnauthorized) IsSuccess() bool

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

func (*GetFlowVersionsUnauthorized) String added in v1.19.1 

func (o *GetFlowVersionsUnauthorized) String() string

type GetFlowsBadRequest 

type GetFlowsBadRequest struct {
}

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

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

func NewGetFlowsBadRequest 

func NewGetFlowsBadRequest() *GetFlowsBadRequest

NewGetFlowsBadRequest creates a GetFlowsBadRequest with default headers values

func (*GetFlowsBadRequest) Error 

func (o *GetFlowsBadRequest) Error() string

func (*GetFlowsBadRequest) IsClientError added in v1.19.1 

func (o *GetFlowsBadRequest) IsClientError() bool

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

func (*GetFlowsBadRequest) IsCode added in v1.19.1 

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

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

func (*GetFlowsBadRequest) IsRedirect added in v1.19.1 

func (o *GetFlowsBadRequest) IsRedirect() bool

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

func (*GetFlowsBadRequest) IsServerError added in v1.19.1 

func (o *GetFlowsBadRequest) IsServerError() bool

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

func (*GetFlowsBadRequest) IsSuccess added in v1.19.1 

func (o *GetFlowsBadRequest) IsSuccess() bool

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

func (*GetFlowsBadRequest) String added in v1.19.1 

func (o *GetFlowsBadRequest) String() string

type GetFlowsConflict 

type GetFlowsConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewGetFlowsConflict 

func NewGetFlowsConflict() *GetFlowsConflict

NewGetFlowsConflict creates a GetFlowsConflict with default headers values

func (*GetFlowsConflict) Error 

func (o *GetFlowsConflict) Error() string

func (*GetFlowsConflict) IsClientError added in v1.19.1 

func (o *GetFlowsConflict) IsClientError() bool

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

func (*GetFlowsConflict) IsCode added in v1.19.1 

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

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

func (*GetFlowsConflict) IsRedirect added in v1.19.1 

func (o *GetFlowsConflict) IsRedirect() bool

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

func (*GetFlowsConflict) IsServerError added in v1.19.1 

func (o *GetFlowsConflict) IsServerError() bool

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

func (*GetFlowsConflict) IsSuccess added in v1.19.1 

func (o *GetFlowsConflict) IsSuccess() bool

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

func (*GetFlowsConflict) String added in v1.19.1 

func (o *GetFlowsConflict) String() string

type GetFlowsForbidden 

type GetFlowsForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetFlowsForbidden 

func NewGetFlowsForbidden() *GetFlowsForbidden

NewGetFlowsForbidden creates a GetFlowsForbidden with default headers values

func (*GetFlowsForbidden) Error 

func (o *GetFlowsForbidden) Error() string

func (*GetFlowsForbidden) IsClientError added in v1.19.1 

func (o *GetFlowsForbidden) IsClientError() bool

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

func (*GetFlowsForbidden) IsCode added in v1.19.1 

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

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

func (*GetFlowsForbidden) IsRedirect added in v1.19.1 

func (o *GetFlowsForbidden) IsRedirect() bool

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

func (*GetFlowsForbidden) IsServerError added in v1.19.1 

func (o *GetFlowsForbidden) IsServerError() bool

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

func (*GetFlowsForbidden) IsSuccess added in v1.19.1 

func (o *GetFlowsForbidden) IsSuccess() bool

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

func (*GetFlowsForbidden) String added in v1.19.1 

func (o *GetFlowsForbidden) String() string

type GetFlowsNotFound 

type GetFlowsNotFound struct {
}

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

The specified resource could not be found.

func NewGetFlowsNotFound 

func NewGetFlowsNotFound() *GetFlowsNotFound

NewGetFlowsNotFound creates a GetFlowsNotFound with default headers values

func (*GetFlowsNotFound) Error 

func (o *GetFlowsNotFound) Error() string

func (*GetFlowsNotFound) IsClientError added in v1.19.1 

func (o *GetFlowsNotFound) IsClientError() bool

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

func (*GetFlowsNotFound) IsCode added in v1.19.1 

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

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

func (*GetFlowsNotFound) IsRedirect added in v1.19.1 

func (o *GetFlowsNotFound) IsRedirect() bool

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

func (*GetFlowsNotFound) IsServerError added in v1.19.1 

func (o *GetFlowsNotFound) IsServerError() bool

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

func (*GetFlowsNotFound) IsSuccess added in v1.19.1 

func (o *GetFlowsNotFound) IsSuccess() bool

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

func (*GetFlowsNotFound) String added in v1.19.1 

func (o *GetFlowsNotFound) String() string

type GetFlowsOK 

type GetFlowsOK struct {
	Payload []*models.VersionedFlow
}

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

successful operation

func NewGetFlowsOK 

func NewGetFlowsOK() *GetFlowsOK

NewGetFlowsOK creates a GetFlowsOK with default headers values

func (*GetFlowsOK) Error 

func (o *GetFlowsOK) Error() string

func (*GetFlowsOK) GetPayload 

func (o *GetFlowsOK) GetPayload() []*models.VersionedFlow

func (*GetFlowsOK) IsClientError added in v1.19.1 

func (o *GetFlowsOK) IsClientError() bool

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

func (*GetFlowsOK) IsCode added in v1.19.1 

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

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

func (*GetFlowsOK) IsRedirect added in v1.19.1 

func (o *GetFlowsOK) IsRedirect() bool

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

func (*GetFlowsOK) IsServerError added in v1.19.1 

func (o *GetFlowsOK) IsServerError() bool

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

func (*GetFlowsOK) IsSuccess added in v1.19.1 

func (o *GetFlowsOK) IsSuccess() bool

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

func (*GetFlowsOK) String added in v1.19.1 

func (o *GetFlowsOK) String() string

type GetFlowsParams 

type GetFlowsParams struct {

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

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

GetFlowsParams contains all the parameters to send to the API endpoint 

for the get flows operation.

Typically these are written to a http.Request.

func NewGetFlowsParams 

func NewGetFlowsParams() *GetFlowsParams

NewGetFlowsParams creates a new GetFlowsParams 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 NewGetFlowsParamsWithContext 

func NewGetFlowsParamsWithContext(ctx context.Context) *GetFlowsParams

NewGetFlowsParamsWithContext creates a new GetFlowsParams object with the ability to set a context for a request.

func NewGetFlowsParamsWithHTTPClient 

func NewGetFlowsParamsWithHTTPClient(client *http.Client) *GetFlowsParams

NewGetFlowsParamsWithHTTPClient creates a new GetFlowsParams object with the ability to set a custom HTTPClient for a request.

func NewGetFlowsParamsWithTimeout 

func NewGetFlowsParamsWithTimeout(timeout time.Duration) *GetFlowsParams

NewGetFlowsParamsWithTimeout creates a new GetFlowsParams object with the ability to set a timeout on a request.

func (*GetFlowsParams) SetBucketID 

func (o *GetFlowsParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the get flows params

func (*GetFlowsParams) SetContext 

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

SetContext adds the context to the get flows params

func (*GetFlowsParams) SetDefaults 

func (o *GetFlowsParams) SetDefaults()

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

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

func (*GetFlowsParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get flows params

func (*GetFlowsParams) SetTimeout 

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

SetTimeout adds the timeout to the get flows params

func (*GetFlowsParams) WithBucketID 

func (o *GetFlowsParams) WithBucketID(bucketID string) *GetFlowsParams

WithBucketID adds the bucketID to the get flows params

func (*GetFlowsParams) WithContext 

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

WithContext adds the context to the get flows params

func (*GetFlowsParams) WithDefaults 

func (o *GetFlowsParams) WithDefaults() *GetFlowsParams

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

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

func (*GetFlowsParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get flows params

func (*GetFlowsParams) WithTimeout 

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

WithTimeout adds the timeout to the get flows params

func (*GetFlowsParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetFlowsReader 

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

GetFlowsReader is a Reader for the GetFlows structure.

func (*GetFlowsReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetFlowsUnauthorized 

type GetFlowsUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetFlowsUnauthorized 

func NewGetFlowsUnauthorized() *GetFlowsUnauthorized

NewGetFlowsUnauthorized creates a GetFlowsUnauthorized with default headers values

func (*GetFlowsUnauthorized) Error 

func (o *GetFlowsUnauthorized) Error() string

func (*GetFlowsUnauthorized) IsClientError added in v1.19.1 

func (o *GetFlowsUnauthorized) IsClientError() bool

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

func (*GetFlowsUnauthorized) IsCode added in v1.19.1 

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

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

func (*GetFlowsUnauthorized) IsRedirect added in v1.19.1 

func (o *GetFlowsUnauthorized) IsRedirect() bool

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

func (*GetFlowsUnauthorized) IsServerError added in v1.19.1 

func (o *GetFlowsUnauthorized) IsServerError() bool

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

func (*GetFlowsUnauthorized) IsSuccess added in v1.19.1 

func (o *GetFlowsUnauthorized) IsSuccess() bool

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

func (*GetFlowsUnauthorized) String added in v1.19.1 

func (o *GetFlowsUnauthorized) String() string

type GetLatestFlowVersionConflict 

type GetLatestFlowVersionConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewGetLatestFlowVersionConflict 

func NewGetLatestFlowVersionConflict() *GetLatestFlowVersionConflict

NewGetLatestFlowVersionConflict creates a GetLatestFlowVersionConflict with default headers values

func (*GetLatestFlowVersionConflict) Error 

func (o *GetLatestFlowVersionConflict) Error() string

func (*GetLatestFlowVersionConflict) IsClientError added in v1.19.1 

func (o *GetLatestFlowVersionConflict) IsClientError() bool

IsClientError returns true when this get latest flow version conflict response has a 4xx status code

func (*GetLatestFlowVersionConflict) IsCode added in v1.19.1 

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

IsCode returns true when this get latest flow version conflict response a status code equal to that given

func (*GetLatestFlowVersionConflict) IsRedirect added in v1.19.1 

func (o *GetLatestFlowVersionConflict) IsRedirect() bool

IsRedirect returns true when this get latest flow version conflict response has a 3xx status code

func (*GetLatestFlowVersionConflict) IsServerError added in v1.19.1 

func (o *GetLatestFlowVersionConflict) IsServerError() bool

IsServerError returns true when this get latest flow version conflict response has a 5xx status code

func (*GetLatestFlowVersionConflict) IsSuccess added in v1.19.1 

func (o *GetLatestFlowVersionConflict) IsSuccess() bool

IsSuccess returns true when this get latest flow version conflict response has a 2xx status code

func (*GetLatestFlowVersionConflict) String added in v1.19.1 

func (o *GetLatestFlowVersionConflict) String() string

type GetLatestFlowVersionForbidden 

type GetLatestFlowVersionForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetLatestFlowVersionForbidden 

func NewGetLatestFlowVersionForbidden() *GetLatestFlowVersionForbidden

NewGetLatestFlowVersionForbidden creates a GetLatestFlowVersionForbidden with default headers values

func (*GetLatestFlowVersionForbidden) Error 

func (o *GetLatestFlowVersionForbidden) Error() string

func (*GetLatestFlowVersionForbidden) IsClientError added in v1.19.1 

func (o *GetLatestFlowVersionForbidden) IsClientError() bool

IsClientError returns true when this get latest flow version forbidden response has a 4xx status code

func (*GetLatestFlowVersionForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this get latest flow version forbidden response a status code equal to that given

func (*GetLatestFlowVersionForbidden) IsRedirect added in v1.19.1 

func (o *GetLatestFlowVersionForbidden) IsRedirect() bool

IsRedirect returns true when this get latest flow version forbidden response has a 3xx status code

func (*GetLatestFlowVersionForbidden) IsServerError added in v1.19.1 

func (o *GetLatestFlowVersionForbidden) IsServerError() bool

IsServerError returns true when this get latest flow version forbidden response has a 5xx status code

func (*GetLatestFlowVersionForbidden) IsSuccess added in v1.19.1 

func (o *GetLatestFlowVersionForbidden) IsSuccess() bool

IsSuccess returns true when this get latest flow version forbidden response has a 2xx status code

func (*GetLatestFlowVersionForbidden) String added in v1.19.1 

func (o *GetLatestFlowVersionForbidden) String() string

type GetLatestFlowVersionMetadataConflict 

type GetLatestFlowVersionMetadataConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewGetLatestFlowVersionMetadataConflict 

func NewGetLatestFlowVersionMetadataConflict() *GetLatestFlowVersionMetadataConflict

NewGetLatestFlowVersionMetadataConflict creates a GetLatestFlowVersionMetadataConflict with default headers values

func (*GetLatestFlowVersionMetadataConflict) Error 

func (o *GetLatestFlowVersionMetadataConflict) Error() string

func (*GetLatestFlowVersionMetadataConflict) IsClientError added in v1.19.1 

func (o *GetLatestFlowVersionMetadataConflict) IsClientError() bool

IsClientError returns true when this get latest flow version metadata conflict response has a 4xx status code

func (*GetLatestFlowVersionMetadataConflict) IsCode added in v1.19.1 

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

IsCode returns true when this get latest flow version metadata conflict response a status code equal to that given

func (*GetLatestFlowVersionMetadataConflict) IsRedirect added in v1.19.1 

func (o *GetLatestFlowVersionMetadataConflict) IsRedirect() bool

IsRedirect returns true when this get latest flow version metadata conflict response has a 3xx status code

func (*GetLatestFlowVersionMetadataConflict) IsServerError added in v1.19.1 

func (o *GetLatestFlowVersionMetadataConflict) IsServerError() bool

IsServerError returns true when this get latest flow version metadata conflict response has a 5xx status code

func (*GetLatestFlowVersionMetadataConflict) IsSuccess added in v1.19.1 

func (o *GetLatestFlowVersionMetadataConflict) IsSuccess() bool

IsSuccess returns true when this get latest flow version metadata conflict response has a 2xx status code

func (*GetLatestFlowVersionMetadataConflict) String added in v1.19.1 

func (o *GetLatestFlowVersionMetadataConflict) String() string

type GetLatestFlowVersionMetadataForbidden 

type GetLatestFlowVersionMetadataForbidden struct {
}

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

Client is not authorized to make this request.

func NewGetLatestFlowVersionMetadataForbidden 

func NewGetLatestFlowVersionMetadataForbidden() *GetLatestFlowVersionMetadataForbidden

NewGetLatestFlowVersionMetadataForbidden creates a GetLatestFlowVersionMetadataForbidden with default headers values

func (*GetLatestFlowVersionMetadataForbidden) Error 

func (o *GetLatestFlowVersionMetadataForbidden) Error() string

func (*GetLatestFlowVersionMetadataForbidden) IsClientError added in v1.19.1 

func (o *GetLatestFlowVersionMetadataForbidden) IsClientError() bool

IsClientError returns true when this get latest flow version metadata forbidden response has a 4xx status code

func (*GetLatestFlowVersionMetadataForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this get latest flow version metadata forbidden response a status code equal to that given

func (*GetLatestFlowVersionMetadataForbidden) IsRedirect added in v1.19.1 

func (o *GetLatestFlowVersionMetadataForbidden) IsRedirect() bool

IsRedirect returns true when this get latest flow version metadata forbidden response has a 3xx status code

func (*GetLatestFlowVersionMetadataForbidden) IsServerError added in v1.19.1 

func (o *GetLatestFlowVersionMetadataForbidden) IsServerError() bool

IsServerError returns true when this get latest flow version metadata forbidden response has a 5xx status code

func (*GetLatestFlowVersionMetadataForbidden) IsSuccess added in v1.19.1 

func (o *GetLatestFlowVersionMetadataForbidden) IsSuccess() bool

IsSuccess returns true when this get latest flow version metadata forbidden response has a 2xx status code

func (*GetLatestFlowVersionMetadataForbidden) String added in v1.19.1 

func (o *GetLatestFlowVersionMetadataForbidden) String() string

type GetLatestFlowVersionMetadataNotFound 

type GetLatestFlowVersionMetadataNotFound struct {
}

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

The specified resource could not be found.

func NewGetLatestFlowVersionMetadataNotFound 

func NewGetLatestFlowVersionMetadataNotFound() *GetLatestFlowVersionMetadataNotFound

NewGetLatestFlowVersionMetadataNotFound creates a GetLatestFlowVersionMetadataNotFound with default headers values

func (*GetLatestFlowVersionMetadataNotFound) Error 

func (o *GetLatestFlowVersionMetadataNotFound) Error() string

func (*GetLatestFlowVersionMetadataNotFound) IsClientError added in v1.19.1 

func (o *GetLatestFlowVersionMetadataNotFound) IsClientError() bool

IsClientError returns true when this get latest flow version metadata not found response has a 4xx status code

func (*GetLatestFlowVersionMetadataNotFound) IsCode added in v1.19.1 

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

IsCode returns true when this get latest flow version metadata not found response a status code equal to that given

func (*GetLatestFlowVersionMetadataNotFound) IsRedirect added in v1.19.1 

func (o *GetLatestFlowVersionMetadataNotFound) IsRedirect() bool

IsRedirect returns true when this get latest flow version metadata not found response has a 3xx status code

func (*GetLatestFlowVersionMetadataNotFound) IsServerError added in v1.19.1 

func (o *GetLatestFlowVersionMetadataNotFound) IsServerError() bool

IsServerError returns true when this get latest flow version metadata not found response has a 5xx status code

func (*GetLatestFlowVersionMetadataNotFound) IsSuccess added in v1.19.1 

func (o *GetLatestFlowVersionMetadataNotFound) IsSuccess() bool

IsSuccess returns true when this get latest flow version metadata not found response has a 2xx status code

func (*GetLatestFlowVersionMetadataNotFound) String added in v1.19.1 

func (o *GetLatestFlowVersionMetadataNotFound) String() string

type GetLatestFlowVersionMetadataOK 

type GetLatestFlowVersionMetadataOK struct {
	Payload *models.VersionedFlowSnapshotMetadata
}

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

successful operation

func NewGetLatestFlowVersionMetadataOK 

func NewGetLatestFlowVersionMetadataOK() *GetLatestFlowVersionMetadataOK

NewGetLatestFlowVersionMetadataOK creates a GetLatestFlowVersionMetadataOK with default headers values

func (*GetLatestFlowVersionMetadataOK) Error 

func (o *GetLatestFlowVersionMetadataOK) Error() string

func (*GetLatestFlowVersionMetadataOK) GetPayload 

func (o *GetLatestFlowVersionMetadataOK) GetPayload() *models.VersionedFlowSnapshotMetadata

func (*GetLatestFlowVersionMetadataOK) IsClientError added in v1.19.1 

func (o *GetLatestFlowVersionMetadataOK) IsClientError() bool

IsClientError returns true when this get latest flow version metadata o k response has a 4xx status code

func (*GetLatestFlowVersionMetadataOK) IsCode added in v1.19.1 

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

IsCode returns true when this get latest flow version metadata o k response a status code equal to that given

func (*GetLatestFlowVersionMetadataOK) IsRedirect added in v1.19.1 

func (o *GetLatestFlowVersionMetadataOK) IsRedirect() bool

IsRedirect returns true when this get latest flow version metadata o k response has a 3xx status code

func (*GetLatestFlowVersionMetadataOK) IsServerError added in v1.19.1 

func (o *GetLatestFlowVersionMetadataOK) IsServerError() bool

IsServerError returns true when this get latest flow version metadata o k response has a 5xx status code

func (*GetLatestFlowVersionMetadataOK) IsSuccess added in v1.19.1 

func (o *GetLatestFlowVersionMetadataOK) IsSuccess() bool

IsSuccess returns true when this get latest flow version metadata o k response has a 2xx status code

func (*GetLatestFlowVersionMetadataOK) String added in v1.19.1 

func (o *GetLatestFlowVersionMetadataOK) String() string

type GetLatestFlowVersionMetadataParams 

type GetLatestFlowVersionMetadataParams struct {

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

	/* FlowID.

	   The flow identifier
	*/
	FlowID string

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

GetLatestFlowVersionMetadataParams contains all the parameters to send to the API endpoint 

for the get latest flow version metadata operation.

Typically these are written to a http.Request.

func NewGetLatestFlowVersionMetadataParams 

func NewGetLatestFlowVersionMetadataParams() *GetLatestFlowVersionMetadataParams

NewGetLatestFlowVersionMetadataParams creates a new GetLatestFlowVersionMetadataParams 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 NewGetLatestFlowVersionMetadataParamsWithContext 

func NewGetLatestFlowVersionMetadataParamsWithContext(ctx context.Context) *GetLatestFlowVersionMetadataParams

NewGetLatestFlowVersionMetadataParamsWithContext creates a new GetLatestFlowVersionMetadataParams object with the ability to set a context for a request.

func NewGetLatestFlowVersionMetadataParamsWithHTTPClient 

func NewGetLatestFlowVersionMetadataParamsWithHTTPClient(client *http.Client) *GetLatestFlowVersionMetadataParams

NewGetLatestFlowVersionMetadataParamsWithHTTPClient creates a new GetLatestFlowVersionMetadataParams object with the ability to set a custom HTTPClient for a request.

func NewGetLatestFlowVersionMetadataParamsWithTimeout 

func NewGetLatestFlowVersionMetadataParamsWithTimeout(timeout time.Duration) *GetLatestFlowVersionMetadataParams

NewGetLatestFlowVersionMetadataParamsWithTimeout creates a new GetLatestFlowVersionMetadataParams object with the ability to set a timeout on a request.

func (*GetLatestFlowVersionMetadataParams) SetBucketID 

func (o *GetLatestFlowVersionMetadataParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the get latest flow version metadata params

func (*GetLatestFlowVersionMetadataParams) SetContext 

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

SetContext adds the context to the get latest flow version metadata params

func (*GetLatestFlowVersionMetadataParams) SetDefaults 

func (o *GetLatestFlowVersionMetadataParams) SetDefaults()

SetDefaults hydrates default values in the get latest flow version metadata params (not the query body).

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

func (*GetLatestFlowVersionMetadataParams) SetFlowID 

func (o *GetLatestFlowVersionMetadataParams) SetFlowID(flowID string)

SetFlowID adds the flowId to the get latest flow version metadata params

func (*GetLatestFlowVersionMetadataParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get latest flow version metadata params

func (*GetLatestFlowVersionMetadataParams) SetTimeout 

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

SetTimeout adds the timeout to the get latest flow version metadata params

func (*GetLatestFlowVersionMetadataParams) WithBucketID 

func (o *GetLatestFlowVersionMetadataParams) WithBucketID(bucketID string) *GetLatestFlowVersionMetadataParams

WithBucketID adds the bucketID to the get latest flow version metadata params

func (*GetLatestFlowVersionMetadataParams) WithContext 

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

WithContext adds the context to the get latest flow version metadata params

func (*GetLatestFlowVersionMetadataParams) WithDefaults 

func (o *GetLatestFlowVersionMetadataParams) WithDefaults() *GetLatestFlowVersionMetadataParams

WithDefaults hydrates default values in the get latest flow version metadata params (not the query body).

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

func (*GetLatestFlowVersionMetadataParams) WithFlowID 

func (o *GetLatestFlowVersionMetadataParams) WithFlowID(flowID string) *GetLatestFlowVersionMetadataParams

WithFlowID adds the flowID to the get latest flow version metadata params

func (*GetLatestFlowVersionMetadataParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get latest flow version metadata params

func (*GetLatestFlowVersionMetadataParams) WithTimeout 

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

WithTimeout adds the timeout to the get latest flow version metadata params

func (*GetLatestFlowVersionMetadataParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetLatestFlowVersionMetadataReader 

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

GetLatestFlowVersionMetadataReader is a Reader for the GetLatestFlowVersionMetadata structure.

func (*GetLatestFlowVersionMetadataReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetLatestFlowVersionMetadataUnauthorized 

type GetLatestFlowVersionMetadataUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetLatestFlowVersionMetadataUnauthorized 

func NewGetLatestFlowVersionMetadataUnauthorized() *GetLatestFlowVersionMetadataUnauthorized

NewGetLatestFlowVersionMetadataUnauthorized creates a GetLatestFlowVersionMetadataUnauthorized with default headers values

func (*GetLatestFlowVersionMetadataUnauthorized) Error 

func (o *GetLatestFlowVersionMetadataUnauthorized) Error() string

func (*GetLatestFlowVersionMetadataUnauthorized) IsClientError added in v1.19.1 

func (o *GetLatestFlowVersionMetadataUnauthorized) IsClientError() bool

IsClientError returns true when this get latest flow version metadata unauthorized response has a 4xx status code

func (*GetLatestFlowVersionMetadataUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this get latest flow version metadata unauthorized response a status code equal to that given

func (*GetLatestFlowVersionMetadataUnauthorized) IsRedirect added in v1.19.1 

func (o *GetLatestFlowVersionMetadataUnauthorized) IsRedirect() bool

IsRedirect returns true when this get latest flow version metadata unauthorized response has a 3xx status code

func (*GetLatestFlowVersionMetadataUnauthorized) IsServerError added in v1.19.1 

func (o *GetLatestFlowVersionMetadataUnauthorized) IsServerError() bool

IsServerError returns true when this get latest flow version metadata unauthorized response has a 5xx status code

func (*GetLatestFlowVersionMetadataUnauthorized) IsSuccess added in v1.19.1 

func (o *GetLatestFlowVersionMetadataUnauthorized) IsSuccess() bool

IsSuccess returns true when this get latest flow version metadata unauthorized response has a 2xx status code

func (*GetLatestFlowVersionMetadataUnauthorized) String added in v1.19.1 

func (o *GetLatestFlowVersionMetadataUnauthorized) String() string

type GetLatestFlowVersionNotFound 

type GetLatestFlowVersionNotFound struct {
}

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

The specified resource could not be found.

func NewGetLatestFlowVersionNotFound 

func NewGetLatestFlowVersionNotFound() *GetLatestFlowVersionNotFound

NewGetLatestFlowVersionNotFound creates a GetLatestFlowVersionNotFound with default headers values

func (*GetLatestFlowVersionNotFound) Error 

func (o *GetLatestFlowVersionNotFound) Error() string

func (*GetLatestFlowVersionNotFound) IsClientError added in v1.19.1 

func (o *GetLatestFlowVersionNotFound) IsClientError() bool

IsClientError returns true when this get latest flow version not found response has a 4xx status code

func (*GetLatestFlowVersionNotFound) IsCode added in v1.19.1 

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

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

func (*GetLatestFlowVersionNotFound) IsRedirect added in v1.19.1 

func (o *GetLatestFlowVersionNotFound) IsRedirect() bool

IsRedirect returns true when this get latest flow version not found response has a 3xx status code

func (*GetLatestFlowVersionNotFound) IsServerError added in v1.19.1 

func (o *GetLatestFlowVersionNotFound) IsServerError() bool

IsServerError returns true when this get latest flow version not found response has a 5xx status code

func (*GetLatestFlowVersionNotFound) IsSuccess added in v1.19.1 

func (o *GetLatestFlowVersionNotFound) IsSuccess() bool

IsSuccess returns true when this get latest flow version not found response has a 2xx status code

func (*GetLatestFlowVersionNotFound) String added in v1.19.1 

func (o *GetLatestFlowVersionNotFound) String() string

type GetLatestFlowVersionOK 

type GetLatestFlowVersionOK struct {
	Payload *models.VersionedFlowSnapshot
}

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

successful operation

func NewGetLatestFlowVersionOK 

func NewGetLatestFlowVersionOK() *GetLatestFlowVersionOK

NewGetLatestFlowVersionOK creates a GetLatestFlowVersionOK with default headers values

func (*GetLatestFlowVersionOK) Error 

func (o *GetLatestFlowVersionOK) Error() string

func (*GetLatestFlowVersionOK) GetPayload 

func (o *GetLatestFlowVersionOK) GetPayload() *models.VersionedFlowSnapshot

func (*GetLatestFlowVersionOK) IsClientError added in v1.19.1 

func (o *GetLatestFlowVersionOK) IsClientError() bool

IsClientError returns true when this get latest flow version o k response has a 4xx status code

func (*GetLatestFlowVersionOK) IsCode added in v1.19.1 

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

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

func (*GetLatestFlowVersionOK) IsRedirect added in v1.19.1 

func (o *GetLatestFlowVersionOK) IsRedirect() bool

IsRedirect returns true when this get latest flow version o k response has a 3xx status code

func (*GetLatestFlowVersionOK) IsServerError added in v1.19.1 

func (o *GetLatestFlowVersionOK) IsServerError() bool

IsServerError returns true when this get latest flow version o k response has a 5xx status code

func (*GetLatestFlowVersionOK) IsSuccess added in v1.19.1 

func (o *GetLatestFlowVersionOK) IsSuccess() bool

IsSuccess returns true when this get latest flow version o k response has a 2xx status code

func (*GetLatestFlowVersionOK) String added in v1.19.1 

func (o *GetLatestFlowVersionOK) String() string

type GetLatestFlowVersionParams 

type GetLatestFlowVersionParams struct {

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

	/* FlowID.

	   The flow identifier
	*/
	FlowID string

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

GetLatestFlowVersionParams contains all the parameters to send to the API endpoint 

for the get latest flow version operation.

Typically these are written to a http.Request.

func NewGetLatestFlowVersionParams 

func NewGetLatestFlowVersionParams() *GetLatestFlowVersionParams

NewGetLatestFlowVersionParams creates a new GetLatestFlowVersionParams 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 NewGetLatestFlowVersionParamsWithContext 

func NewGetLatestFlowVersionParamsWithContext(ctx context.Context) *GetLatestFlowVersionParams

NewGetLatestFlowVersionParamsWithContext creates a new GetLatestFlowVersionParams object with the ability to set a context for a request.

func NewGetLatestFlowVersionParamsWithHTTPClient 

func NewGetLatestFlowVersionParamsWithHTTPClient(client *http.Client) *GetLatestFlowVersionParams

NewGetLatestFlowVersionParamsWithHTTPClient creates a new GetLatestFlowVersionParams object with the ability to set a custom HTTPClient for a request.

func NewGetLatestFlowVersionParamsWithTimeout 

func NewGetLatestFlowVersionParamsWithTimeout(timeout time.Duration) *GetLatestFlowVersionParams

NewGetLatestFlowVersionParamsWithTimeout creates a new GetLatestFlowVersionParams object with the ability to set a timeout on a request.

func (*GetLatestFlowVersionParams) SetBucketID 

func (o *GetLatestFlowVersionParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the get latest flow version params

func (*GetLatestFlowVersionParams) SetContext 

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

SetContext adds the context to the get latest flow version params

func (*GetLatestFlowVersionParams) SetDefaults 

func (o *GetLatestFlowVersionParams) SetDefaults()

SetDefaults hydrates default values in the get latest flow version params (not the query body).

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

func (*GetLatestFlowVersionParams) SetFlowID 

func (o *GetLatestFlowVersionParams) SetFlowID(flowID string)

SetFlowID adds the flowId to the get latest flow version params

func (*GetLatestFlowVersionParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get latest flow version params

func (*GetLatestFlowVersionParams) SetTimeout 

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

SetTimeout adds the timeout to the get latest flow version params

func (*GetLatestFlowVersionParams) WithBucketID 

func (o *GetLatestFlowVersionParams) WithBucketID(bucketID string) *GetLatestFlowVersionParams

WithBucketID adds the bucketID to the get latest flow version params

func (*GetLatestFlowVersionParams) WithContext 

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

WithContext adds the context to the get latest flow version params

func (*GetLatestFlowVersionParams) WithDefaults 

func (o *GetLatestFlowVersionParams) WithDefaults() *GetLatestFlowVersionParams

WithDefaults hydrates default values in the get latest flow version params (not the query body).

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

func (*GetLatestFlowVersionParams) WithFlowID 

func (o *GetLatestFlowVersionParams) WithFlowID(flowID string) *GetLatestFlowVersionParams

WithFlowID adds the flowID to the get latest flow version params

func (*GetLatestFlowVersionParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get latest flow version params

func (*GetLatestFlowVersionParams) WithTimeout 

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

WithTimeout adds the timeout to the get latest flow version params

func (*GetLatestFlowVersionParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetLatestFlowVersionReader 

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

GetLatestFlowVersionReader is a Reader for the GetLatestFlowVersion structure.

func (*GetLatestFlowVersionReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetLatestFlowVersionUnauthorized 

type GetLatestFlowVersionUnauthorized struct {
}

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

Client could not be authenticated.

func NewGetLatestFlowVersionUnauthorized 

func NewGetLatestFlowVersionUnauthorized() *GetLatestFlowVersionUnauthorized

NewGetLatestFlowVersionUnauthorized creates a GetLatestFlowVersionUnauthorized with default headers values

func (*GetLatestFlowVersionUnauthorized) Error 

func (o *GetLatestFlowVersionUnauthorized) Error() string

func (*GetLatestFlowVersionUnauthorized) IsClientError added in v1.19.1 

func (o *GetLatestFlowVersionUnauthorized) IsClientError() bool

IsClientError returns true when this get latest flow version unauthorized response has a 4xx status code

func (*GetLatestFlowVersionUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this get latest flow version unauthorized response a status code equal to that given

func (*GetLatestFlowVersionUnauthorized) IsRedirect added in v1.19.1 

func (o *GetLatestFlowVersionUnauthorized) IsRedirect() bool

IsRedirect returns true when this get latest flow version unauthorized response has a 3xx status code

func (*GetLatestFlowVersionUnauthorized) IsServerError added in v1.19.1 

func (o *GetLatestFlowVersionUnauthorized) IsServerError() bool

IsServerError returns true when this get latest flow version unauthorized response has a 5xx status code

func (*GetLatestFlowVersionUnauthorized) IsSuccess added in v1.19.1 

func (o *GetLatestFlowVersionUnauthorized) IsSuccess() bool

IsSuccess returns true when this get latest flow version unauthorized response has a 2xx status code

func (*GetLatestFlowVersionUnauthorized) String added in v1.19.1 

func (o *GetLatestFlowVersionUnauthorized) String() string

type ImportVersionedFlowBadRequest 

type ImportVersionedFlowBadRequest struct {
}

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

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

func NewImportVersionedFlowBadRequest 

func NewImportVersionedFlowBadRequest() *ImportVersionedFlowBadRequest

NewImportVersionedFlowBadRequest creates a ImportVersionedFlowBadRequest with default headers values

func (*ImportVersionedFlowBadRequest) Error 

func (o *ImportVersionedFlowBadRequest) Error() string

func (*ImportVersionedFlowBadRequest) IsClientError added in v1.19.1 

func (o *ImportVersionedFlowBadRequest) IsClientError() bool

IsClientError returns true when this import versioned flow bad request response has a 4xx status code

func (*ImportVersionedFlowBadRequest) IsCode added in v1.19.1 

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

IsCode returns true when this import versioned flow bad request response a status code equal to that given

func (*ImportVersionedFlowBadRequest) IsRedirect added in v1.19.1 

func (o *ImportVersionedFlowBadRequest) IsRedirect() bool

IsRedirect returns true when this import versioned flow bad request response has a 3xx status code

func (*ImportVersionedFlowBadRequest) IsServerError added in v1.19.1 

func (o *ImportVersionedFlowBadRequest) IsServerError() bool

IsServerError returns true when this import versioned flow bad request response has a 5xx status code

func (*ImportVersionedFlowBadRequest) IsSuccess added in v1.19.1 

func (o *ImportVersionedFlowBadRequest) IsSuccess() bool

IsSuccess returns true when this import versioned flow bad request response has a 2xx status code

func (*ImportVersionedFlowBadRequest) String added in v1.19.1 

func (o *ImportVersionedFlowBadRequest) String() string

type ImportVersionedFlowConflict 

type ImportVersionedFlowConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewImportVersionedFlowConflict 

func NewImportVersionedFlowConflict() *ImportVersionedFlowConflict

NewImportVersionedFlowConflict creates a ImportVersionedFlowConflict with default headers values

func (*ImportVersionedFlowConflict) Error 

func (o *ImportVersionedFlowConflict) Error() string

func (*ImportVersionedFlowConflict) IsClientError added in v1.19.1 

func (o *ImportVersionedFlowConflict) IsClientError() bool

IsClientError returns true when this import versioned flow conflict response has a 4xx status code

func (*ImportVersionedFlowConflict) IsCode added in v1.19.1 

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

IsCode returns true when this import versioned flow conflict response a status code equal to that given

func (*ImportVersionedFlowConflict) IsRedirect added in v1.19.1 

func (o *ImportVersionedFlowConflict) IsRedirect() bool

IsRedirect returns true when this import versioned flow conflict response has a 3xx status code

func (*ImportVersionedFlowConflict) IsServerError added in v1.19.1 

func (o *ImportVersionedFlowConflict) IsServerError() bool

IsServerError returns true when this import versioned flow conflict response has a 5xx status code

func (*ImportVersionedFlowConflict) IsSuccess added in v1.19.1 

func (o *ImportVersionedFlowConflict) IsSuccess() bool

IsSuccess returns true when this import versioned flow conflict response has a 2xx status code

func (*ImportVersionedFlowConflict) String added in v1.19.1 

func (o *ImportVersionedFlowConflict) String() string

type ImportVersionedFlowCreated 

type ImportVersionedFlowCreated struct {
}

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

The resource has been successfully created.

func NewImportVersionedFlowCreated 

func NewImportVersionedFlowCreated() *ImportVersionedFlowCreated

NewImportVersionedFlowCreated creates a ImportVersionedFlowCreated with default headers values

func (*ImportVersionedFlowCreated) Error 

func (o *ImportVersionedFlowCreated) Error() string

func (*ImportVersionedFlowCreated) IsClientError added in v1.19.1 

func (o *ImportVersionedFlowCreated) IsClientError() bool

IsClientError returns true when this import versioned flow created response has a 4xx status code

func (*ImportVersionedFlowCreated) IsCode added in v1.19.1 

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

IsCode returns true when this import versioned flow created response a status code equal to that given

func (*ImportVersionedFlowCreated) IsRedirect added in v1.19.1 

func (o *ImportVersionedFlowCreated) IsRedirect() bool

IsRedirect returns true when this import versioned flow created response has a 3xx status code

func (*ImportVersionedFlowCreated) IsServerError added in v1.19.1 

func (o *ImportVersionedFlowCreated) IsServerError() bool

IsServerError returns true when this import versioned flow created response has a 5xx status code

func (*ImportVersionedFlowCreated) IsSuccess added in v1.19.1 

func (o *ImportVersionedFlowCreated) IsSuccess() bool

IsSuccess returns true when this import versioned flow created response has a 2xx status code

func (*ImportVersionedFlowCreated) String added in v1.19.1 

func (o *ImportVersionedFlowCreated) String() string

type ImportVersionedFlowForbidden 

type ImportVersionedFlowForbidden struct {
}

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

Client is not authorized to make this request.

func NewImportVersionedFlowForbidden 

func NewImportVersionedFlowForbidden() *ImportVersionedFlowForbidden

NewImportVersionedFlowForbidden creates a ImportVersionedFlowForbidden with default headers values

func (*ImportVersionedFlowForbidden) Error 

func (o *ImportVersionedFlowForbidden) Error() string

func (*ImportVersionedFlowForbidden) IsClientError added in v1.19.1 

func (o *ImportVersionedFlowForbidden) IsClientError() bool

IsClientError returns true when this import versioned flow forbidden response has a 4xx status code

func (*ImportVersionedFlowForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this import versioned flow forbidden response a status code equal to that given

func (*ImportVersionedFlowForbidden) IsRedirect added in v1.19.1 

func (o *ImportVersionedFlowForbidden) IsRedirect() bool

IsRedirect returns true when this import versioned flow forbidden response has a 3xx status code

func (*ImportVersionedFlowForbidden) IsServerError added in v1.19.1 

func (o *ImportVersionedFlowForbidden) IsServerError() bool

IsServerError returns true when this import versioned flow forbidden response has a 5xx status code

func (*ImportVersionedFlowForbidden) IsSuccess added in v1.19.1 

func (o *ImportVersionedFlowForbidden) IsSuccess() bool

IsSuccess returns true when this import versioned flow forbidden response has a 2xx status code

func (*ImportVersionedFlowForbidden) String added in v1.19.1 

func (o *ImportVersionedFlowForbidden) String() string

type ImportVersionedFlowNotFound 

type ImportVersionedFlowNotFound struct {
}

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

The specified resource could not be found.

func NewImportVersionedFlowNotFound 

func NewImportVersionedFlowNotFound() *ImportVersionedFlowNotFound

NewImportVersionedFlowNotFound creates a ImportVersionedFlowNotFound with default headers values

func (*ImportVersionedFlowNotFound) Error 

func (o *ImportVersionedFlowNotFound) Error() string

func (*ImportVersionedFlowNotFound) IsClientError added in v1.19.1 

func (o *ImportVersionedFlowNotFound) IsClientError() bool

IsClientError returns true when this import versioned flow not found response has a 4xx status code

func (*ImportVersionedFlowNotFound) IsCode added in v1.19.1 

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

IsCode returns true when this import versioned flow not found response a status code equal to that given

func (*ImportVersionedFlowNotFound) IsRedirect added in v1.19.1 

func (o *ImportVersionedFlowNotFound) IsRedirect() bool

IsRedirect returns true when this import versioned flow not found response has a 3xx status code

func (*ImportVersionedFlowNotFound) IsServerError added in v1.19.1 

func (o *ImportVersionedFlowNotFound) IsServerError() bool

IsServerError returns true when this import versioned flow not found response has a 5xx status code

func (*ImportVersionedFlowNotFound) IsSuccess added in v1.19.1 

func (o *ImportVersionedFlowNotFound) IsSuccess() bool

IsSuccess returns true when this import versioned flow not found response has a 2xx status code

func (*ImportVersionedFlowNotFound) String added in v1.19.1 

func (o *ImportVersionedFlowNotFound) String() string

type ImportVersionedFlowOK 

type ImportVersionedFlowOK struct {
	Payload *models.VersionedFlowSnapshot
}

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

successful operation

func NewImportVersionedFlowOK 

func NewImportVersionedFlowOK() *ImportVersionedFlowOK

NewImportVersionedFlowOK creates a ImportVersionedFlowOK with default headers values

func (*ImportVersionedFlowOK) Error 

func (o *ImportVersionedFlowOK) Error() string

func (*ImportVersionedFlowOK) GetPayload 

func (o *ImportVersionedFlowOK) GetPayload() *models.VersionedFlowSnapshot

func (*ImportVersionedFlowOK) IsClientError added in v1.19.1 

func (o *ImportVersionedFlowOK) IsClientError() bool

IsClientError returns true when this import versioned flow o k response has a 4xx status code

func (*ImportVersionedFlowOK) IsCode added in v1.19.1 

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

IsCode returns true when this import versioned flow o k response a status code equal to that given

func (*ImportVersionedFlowOK) IsRedirect added in v1.19.1 

func (o *ImportVersionedFlowOK) IsRedirect() bool

IsRedirect returns true when this import versioned flow o k response has a 3xx status code

func (*ImportVersionedFlowOK) IsServerError added in v1.19.1 

func (o *ImportVersionedFlowOK) IsServerError() bool

IsServerError returns true when this import versioned flow o k response has a 5xx status code

func (*ImportVersionedFlowOK) IsSuccess added in v1.19.1 

func (o *ImportVersionedFlowOK) IsSuccess() bool

IsSuccess returns true when this import versioned flow o k response has a 2xx status code

func (*ImportVersionedFlowOK) String added in v1.19.1 

func (o *ImportVersionedFlowOK) String() string

type ImportVersionedFlowParams 

type ImportVersionedFlowParams struct {

	// Comments.
	Comments *string

	/* Body.

	   file
	*/
	Body *models.VersionedFlowSnapshot

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

	/* FlowID.

	   The flow identifier
	*/
	FlowID string

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

ImportVersionedFlowParams contains all the parameters to send to the API endpoint 

for the import versioned flow operation.

Typically these are written to a http.Request.

func NewImportVersionedFlowParams 

func NewImportVersionedFlowParams() *ImportVersionedFlowParams

NewImportVersionedFlowParams creates a new ImportVersionedFlowParams 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 NewImportVersionedFlowParamsWithContext 

func NewImportVersionedFlowParamsWithContext(ctx context.Context) *ImportVersionedFlowParams

NewImportVersionedFlowParamsWithContext creates a new ImportVersionedFlowParams object with the ability to set a context for a request.

func NewImportVersionedFlowParamsWithHTTPClient 

func NewImportVersionedFlowParamsWithHTTPClient(client *http.Client) *ImportVersionedFlowParams

NewImportVersionedFlowParamsWithHTTPClient creates a new ImportVersionedFlowParams object with the ability to set a custom HTTPClient for a request.

func NewImportVersionedFlowParamsWithTimeout 

func NewImportVersionedFlowParamsWithTimeout(timeout time.Duration) *ImportVersionedFlowParams

NewImportVersionedFlowParamsWithTimeout creates a new ImportVersionedFlowParams object with the ability to set a timeout on a request.

func (*ImportVersionedFlowParams) SetBody 

func (o *ImportVersionedFlowParams) SetBody(body *models.VersionedFlowSnapshot)

SetBody adds the body to the import versioned flow params

func (*ImportVersionedFlowParams) SetBucketID 

func (o *ImportVersionedFlowParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the import versioned flow params

func (*ImportVersionedFlowParams) SetComments 

func (o *ImportVersionedFlowParams) SetComments(comments *string)

SetComments adds the comments to the import versioned flow params

func (*ImportVersionedFlowParams) SetContext 

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

SetContext adds the context to the import versioned flow params

func (*ImportVersionedFlowParams) SetDefaults 

func (o *ImportVersionedFlowParams) SetDefaults()

SetDefaults hydrates default values in the import versioned flow params (not the query body).

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

func (*ImportVersionedFlowParams) SetFlowID 

func (o *ImportVersionedFlowParams) SetFlowID(flowID string)

SetFlowID adds the flowId to the import versioned flow params

func (*ImportVersionedFlowParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the import versioned flow params

func (*ImportVersionedFlowParams) SetTimeout 

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

SetTimeout adds the timeout to the import versioned flow params

func (*ImportVersionedFlowParams) WithBody 

func (o *ImportVersionedFlowParams) WithBody(body *models.VersionedFlowSnapshot) *ImportVersionedFlowParams

WithBody adds the body to the import versioned flow params

func (*ImportVersionedFlowParams) WithBucketID 

func (o *ImportVersionedFlowParams) WithBucketID(bucketID string) *ImportVersionedFlowParams

WithBucketID adds the bucketID to the import versioned flow params

func (*ImportVersionedFlowParams) WithComments 

func (o *ImportVersionedFlowParams) WithComments(comments *string) *ImportVersionedFlowParams

WithComments adds the comments to the import versioned flow params

func (*ImportVersionedFlowParams) WithContext 

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

WithContext adds the context to the import versioned flow params

func (*ImportVersionedFlowParams) WithDefaults 

func (o *ImportVersionedFlowParams) WithDefaults() *ImportVersionedFlowParams

WithDefaults hydrates default values in the import versioned flow params (not the query body).

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

func (*ImportVersionedFlowParams) WithFlowID 

func (o *ImportVersionedFlowParams) WithFlowID(flowID string) *ImportVersionedFlowParams

WithFlowID adds the flowID to the import versioned flow params

func (*ImportVersionedFlowParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the import versioned flow params

func (*ImportVersionedFlowParams) WithTimeout 

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

WithTimeout adds the timeout to the import versioned flow params

func (*ImportVersionedFlowParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ImportVersionedFlowReader 

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

ImportVersionedFlowReader is a Reader for the ImportVersionedFlow structure.

func (*ImportVersionedFlowReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ImportVersionedFlowUnauthorized 

type ImportVersionedFlowUnauthorized struct {
}

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

Client could not be authenticated.

func NewImportVersionedFlowUnauthorized 

func NewImportVersionedFlowUnauthorized() *ImportVersionedFlowUnauthorized

NewImportVersionedFlowUnauthorized creates a ImportVersionedFlowUnauthorized with default headers values

func (*ImportVersionedFlowUnauthorized) Error 

func (o *ImportVersionedFlowUnauthorized) Error() string

func (*ImportVersionedFlowUnauthorized) IsClientError added in v1.19.1 

func (o *ImportVersionedFlowUnauthorized) IsClientError() bool

IsClientError returns true when this import versioned flow unauthorized response has a 4xx status code

func (*ImportVersionedFlowUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this import versioned flow unauthorized response a status code equal to that given

func (*ImportVersionedFlowUnauthorized) IsRedirect added in v1.19.1 

func (o *ImportVersionedFlowUnauthorized) IsRedirect() bool

IsRedirect returns true when this import versioned flow unauthorized response has a 3xx status code

func (*ImportVersionedFlowUnauthorized) IsServerError added in v1.19.1 

func (o *ImportVersionedFlowUnauthorized) IsServerError() bool

IsServerError returns true when this import versioned flow unauthorized response has a 5xx status code

func (*ImportVersionedFlowUnauthorized) IsSuccess added in v1.19.1 

func (o *ImportVersionedFlowUnauthorized) IsSuccess() bool

IsSuccess returns true when this import versioned flow unauthorized response has a 2xx status code

func (*ImportVersionedFlowUnauthorized) String added in v1.19.1 

func (o *ImportVersionedFlowUnauthorized) String() string

type UpdateFlowBadRequest 

type UpdateFlowBadRequest struct {
}

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

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

func NewUpdateFlowBadRequest 

func NewUpdateFlowBadRequest() *UpdateFlowBadRequest

NewUpdateFlowBadRequest creates a UpdateFlowBadRequest with default headers values

func (*UpdateFlowBadRequest) Error 

func (o *UpdateFlowBadRequest) Error() string

func (*UpdateFlowBadRequest) IsClientError added in v1.19.1 

func (o *UpdateFlowBadRequest) IsClientError() bool

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

func (*UpdateFlowBadRequest) IsCode added in v1.19.1 

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

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

func (*UpdateFlowBadRequest) IsRedirect added in v1.19.1 

func (o *UpdateFlowBadRequest) IsRedirect() bool

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

func (*UpdateFlowBadRequest) IsServerError added in v1.19.1 

func (o *UpdateFlowBadRequest) IsServerError() bool

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

func (*UpdateFlowBadRequest) IsSuccess added in v1.19.1 

func (o *UpdateFlowBadRequest) IsSuccess() bool

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

func (*UpdateFlowBadRequest) String added in v1.19.1 

func (o *UpdateFlowBadRequest) String() string

type UpdateFlowConflict 

type UpdateFlowConflict struct {
}

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

NiFi Registry was unable to complete the request because it assumes a server state that is not valid.

func NewUpdateFlowConflict 

func NewUpdateFlowConflict() *UpdateFlowConflict

NewUpdateFlowConflict creates a UpdateFlowConflict with default headers values

func (*UpdateFlowConflict) Error 

func (o *UpdateFlowConflict) Error() string

func (*UpdateFlowConflict) IsClientError added in v1.19.1 

func (o *UpdateFlowConflict) IsClientError() bool

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

func (*UpdateFlowConflict) IsCode added in v1.19.1 

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

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

func (*UpdateFlowConflict) IsRedirect added in v1.19.1 

func (o *UpdateFlowConflict) IsRedirect() bool

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

func (*UpdateFlowConflict) IsServerError added in v1.19.1 

func (o *UpdateFlowConflict) IsServerError() bool

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

func (*UpdateFlowConflict) IsSuccess added in v1.19.1 

func (o *UpdateFlowConflict) IsSuccess() bool

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

func (*UpdateFlowConflict) String added in v1.19.1 

func (o *UpdateFlowConflict) String() string

type UpdateFlowForbidden 

type UpdateFlowForbidden struct {
}

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

Client is not authorized to make this request.

func NewUpdateFlowForbidden 

func NewUpdateFlowForbidden() *UpdateFlowForbidden

NewUpdateFlowForbidden creates a UpdateFlowForbidden with default headers values

func (*UpdateFlowForbidden) Error 

func (o *UpdateFlowForbidden) Error() string

func (*UpdateFlowForbidden) IsClientError added in v1.19.1 

func (o *UpdateFlowForbidden) IsClientError() bool

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

func (*UpdateFlowForbidden) IsCode added in v1.19.1 

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

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

func (*UpdateFlowForbidden) IsRedirect added in v1.19.1 

func (o *UpdateFlowForbidden) IsRedirect() bool

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

func (*UpdateFlowForbidden) IsServerError added in v1.19.1 

func (o *UpdateFlowForbidden) IsServerError() bool

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

func (*UpdateFlowForbidden) IsSuccess added in v1.19.1 

func (o *UpdateFlowForbidden) IsSuccess() bool

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

func (*UpdateFlowForbidden) String added in v1.19.1 

func (o *UpdateFlowForbidden) String() string

type UpdateFlowNotFound 

type UpdateFlowNotFound struct {
}

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

The specified resource could not be found.

func NewUpdateFlowNotFound 

func NewUpdateFlowNotFound() *UpdateFlowNotFound

NewUpdateFlowNotFound creates a UpdateFlowNotFound with default headers values

func (*UpdateFlowNotFound) Error 

func (o *UpdateFlowNotFound) Error() string

func (*UpdateFlowNotFound) IsClientError added in v1.19.1 

func (o *UpdateFlowNotFound) IsClientError() bool

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

func (*UpdateFlowNotFound) IsCode added in v1.19.1 

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

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

func (*UpdateFlowNotFound) IsRedirect added in v1.19.1 

func (o *UpdateFlowNotFound) IsRedirect() bool

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

func (*UpdateFlowNotFound) IsServerError added in v1.19.1 

func (o *UpdateFlowNotFound) IsServerError() bool

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

func (*UpdateFlowNotFound) IsSuccess added in v1.19.1 

func (o *UpdateFlowNotFound) IsSuccess() bool

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

func (*UpdateFlowNotFound) String added in v1.19.1 

func (o *UpdateFlowNotFound) String() string

type UpdateFlowOK 

type UpdateFlowOK struct {
	Payload *models.VersionedFlow
}

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

successful operation

func NewUpdateFlowOK 

func NewUpdateFlowOK() *UpdateFlowOK

NewUpdateFlowOK creates a UpdateFlowOK with default headers values

func (*UpdateFlowOK) Error 

func (o *UpdateFlowOK) Error() string

func (*UpdateFlowOK) GetPayload 

func (o *UpdateFlowOK) GetPayload() *models.VersionedFlow

func (*UpdateFlowOK) IsClientError added in v1.19.1 

func (o *UpdateFlowOK) IsClientError() bool

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

func (*UpdateFlowOK) IsCode added in v1.19.1 

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

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

func (*UpdateFlowOK) IsRedirect added in v1.19.1 

func (o *UpdateFlowOK) IsRedirect() bool

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

func (*UpdateFlowOK) IsServerError added in v1.19.1 

func (o *UpdateFlowOK) IsServerError() bool

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

func (*UpdateFlowOK) IsSuccess added in v1.19.1 

func (o *UpdateFlowOK) IsSuccess() bool

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

func (*UpdateFlowOK) String added in v1.19.1 

func (o *UpdateFlowOK) String() string

type UpdateFlowParams 

type UpdateFlowParams struct {

	/* Body.

	   The updated flow
	*/
	Body *models.VersionedFlow

	/* BucketID.

	   The bucket identifier
	*/
	BucketID string

	/* FlowID.

	   The flow identifier
	*/
	FlowID string

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

UpdateFlowParams contains all the parameters to send to the API endpoint 

for the update flow operation.

Typically these are written to a http.Request.

func NewUpdateFlowParams 

func NewUpdateFlowParams() *UpdateFlowParams

NewUpdateFlowParams creates a new UpdateFlowParams 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 NewUpdateFlowParamsWithContext 

func NewUpdateFlowParamsWithContext(ctx context.Context) *UpdateFlowParams

NewUpdateFlowParamsWithContext creates a new UpdateFlowParams object with the ability to set a context for a request.

func NewUpdateFlowParamsWithHTTPClient 

func NewUpdateFlowParamsWithHTTPClient(client *http.Client) *UpdateFlowParams

NewUpdateFlowParamsWithHTTPClient creates a new UpdateFlowParams object with the ability to set a custom HTTPClient for a request.

func NewUpdateFlowParamsWithTimeout 

func NewUpdateFlowParamsWithTimeout(timeout time.Duration) *UpdateFlowParams

NewUpdateFlowParamsWithTimeout creates a new UpdateFlowParams object with the ability to set a timeout on a request.

func (*UpdateFlowParams) SetBody 

func (o *UpdateFlowParams) SetBody(body *models.VersionedFlow)

SetBody adds the body to the update flow params

func (*UpdateFlowParams) SetBucketID 

func (o *UpdateFlowParams) SetBucketID(bucketID string)

SetBucketID adds the bucketId to the update flow params

func (*UpdateFlowParams) SetContext 

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

SetContext adds the context to the update flow params

func (*UpdateFlowParams) SetDefaults 

func (o *UpdateFlowParams) SetDefaults()

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

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

func (*UpdateFlowParams) SetFlowID 

func (o *UpdateFlowParams) SetFlowID(flowID string)

SetFlowID adds the flowId to the update flow params

func (*UpdateFlowParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the update flow params

func (*UpdateFlowParams) SetTimeout 

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

SetTimeout adds the timeout to the update flow params

func (*UpdateFlowParams) WithBody 

func (o *UpdateFlowParams) WithBody(body *models.VersionedFlow) *UpdateFlowParams

WithBody adds the body to the update flow params

func (*UpdateFlowParams) WithBucketID 

func (o *UpdateFlowParams) WithBucketID(bucketID string) *UpdateFlowParams

WithBucketID adds the bucketID to the update flow params

func (*UpdateFlowParams) WithContext 

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

WithContext adds the context to the update flow params

func (*UpdateFlowParams) WithDefaults 

func (o *UpdateFlowParams) WithDefaults() *UpdateFlowParams

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

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

func (*UpdateFlowParams) WithFlowID 

func (o *UpdateFlowParams) WithFlowID(flowID string) *UpdateFlowParams

WithFlowID adds the flowID to the update flow params

func (*UpdateFlowParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the update flow params

func (*UpdateFlowParams) WithTimeout 

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

WithTimeout adds the timeout to the update flow params

func (*UpdateFlowParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type UpdateFlowReader 

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

UpdateFlowReader is a Reader for the UpdateFlow structure.

func (*UpdateFlowReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type UpdateFlowUnauthorized 

type UpdateFlowUnauthorized struct {
}

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

Client could not be authenticated.

func NewUpdateFlowUnauthorized 

func NewUpdateFlowUnauthorized() *UpdateFlowUnauthorized

NewUpdateFlowUnauthorized creates a UpdateFlowUnauthorized with default headers values

func (*UpdateFlowUnauthorized) Error 

func (o *UpdateFlowUnauthorized) Error() string

func (*UpdateFlowUnauthorized) IsClientError added in v1.19.1 

func (o *UpdateFlowUnauthorized) IsClientError() bool

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

func (*UpdateFlowUnauthorized) IsCode added in v1.19.1 

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

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

func (*UpdateFlowUnauthorized) IsRedirect added in v1.19.1 

func (o *UpdateFlowUnauthorized) IsRedirect() bool

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

func (*UpdateFlowUnauthorized) IsServerError added in v1.19.1 

func (o *UpdateFlowUnauthorized) IsServerError() bool

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

func (*UpdateFlowUnauthorized) IsSuccess added in v1.19.1 

func (o *UpdateFlowUnauthorized) IsSuccess() bool

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

func (*UpdateFlowUnauthorized) String added in v1.19.1 

func (o *UpdateFlowUnauthorized) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.