data_transfer

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 data transfer API

func (*Client) CommitInputPortTransaction 

func (a *Client) CommitInputPortTransaction(params *CommitInputPortTransactionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CommitInputPortTransactionOK, error)

CommitInputPortTransaction commits or cancel the specified transaction

func (*Client) CommitOutputPortTransaction 

func (a *Client) CommitOutputPortTransaction(params *CommitOutputPortTransactionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CommitOutputPortTransactionOK, error)

CommitOutputPortTransaction commits or cancel the specified transaction

func (*Client) CreatePortTransaction 

func (a *Client) CreatePortTransaction(params *CreatePortTransactionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CreatePortTransactionOK, error)

CreatePortTransaction creates a transaction to the specified output port or input port

func (*Client) ExtendInputPortTransactionTTL 

func (a *Client) ExtendInputPortTransactionTTL(params *ExtendInputPortTransactionTTLParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ExtendInputPortTransactionTTLOK, error)

ExtendInputPortTransactionTTL extends transaction TTL

func (*Client) ExtendOutputPortTransactionTTL 

func (a *Client) ExtendOutputPortTransactionTTL(params *ExtendOutputPortTransactionTTLParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ExtendOutputPortTransactionTTLOK, error)

ExtendOutputPortTransactionTTL extends transaction TTL

func (*Client) ReceiveFlowFiles 

func (a *Client) ReceiveFlowFiles(params *ReceiveFlowFilesParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ReceiveFlowFilesOK, error)

ReceiveFlowFiles transfers flow files to the input port

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

func (*Client) TransferFlowFiles 

func (a *Client) TransferFlowFiles(params *TransferFlowFilesParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*TransferFlowFilesOK, error)

TransferFlowFiles transfers flow files from the output port

type ClientOption 

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService 

type ClientService interface {
	CommitInputPortTransaction(params *CommitInputPortTransactionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CommitInputPortTransactionOK, error)

	CommitOutputPortTransaction(params *CommitOutputPortTransactionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CommitOutputPortTransactionOK, error)

	CreatePortTransaction(params *CreatePortTransactionParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CreatePortTransactionOK, error)

	ExtendInputPortTransactionTTL(params *ExtendInputPortTransactionTTLParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ExtendInputPortTransactionTTLOK, error)

	ExtendOutputPortTransactionTTL(params *ExtendOutputPortTransactionTTLParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ExtendOutputPortTransactionTTLOK, error)

	ReceiveFlowFiles(params *ReceiveFlowFilesParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ReceiveFlowFilesOK, error)

	TransferFlowFiles(params *TransferFlowFilesParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*TransferFlowFilesOK, 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 data transfer API client.

type CommitInputPortTransactionBadRequest 

type CommitInputPortTransactionBadRequest struct {
}

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

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

func NewCommitInputPortTransactionBadRequest 

func NewCommitInputPortTransactionBadRequest() *CommitInputPortTransactionBadRequest

NewCommitInputPortTransactionBadRequest creates a CommitInputPortTransactionBadRequest with default headers values

func (*CommitInputPortTransactionBadRequest) Error 

func (o *CommitInputPortTransactionBadRequest) Error() string

func (*CommitInputPortTransactionBadRequest) IsClientError added in v1.19.1 

func (o *CommitInputPortTransactionBadRequest) IsClientError() bool

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

func (*CommitInputPortTransactionBadRequest) IsCode added in v1.19.1 

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

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

func (*CommitInputPortTransactionBadRequest) IsRedirect added in v1.19.1 

func (o *CommitInputPortTransactionBadRequest) IsRedirect() bool

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

func (*CommitInputPortTransactionBadRequest) IsServerError added in v1.19.1 

func (o *CommitInputPortTransactionBadRequest) IsServerError() bool

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

func (*CommitInputPortTransactionBadRequest) IsSuccess added in v1.19.1 

func (o *CommitInputPortTransactionBadRequest) IsSuccess() bool

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

func (*CommitInputPortTransactionBadRequest) String added in v1.19.1 

func (o *CommitInputPortTransactionBadRequest) String() string

type CommitInputPortTransactionConflict 

type CommitInputPortTransactionConflict struct {
}

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

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

func NewCommitInputPortTransactionConflict 

func NewCommitInputPortTransactionConflict() *CommitInputPortTransactionConflict

NewCommitInputPortTransactionConflict creates a CommitInputPortTransactionConflict with default headers values

func (*CommitInputPortTransactionConflict) Error 

func (o *CommitInputPortTransactionConflict) Error() string

func (*CommitInputPortTransactionConflict) IsClientError added in v1.19.1 

func (o *CommitInputPortTransactionConflict) IsClientError() bool

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

func (*CommitInputPortTransactionConflict) IsCode added in v1.19.1 

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

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

func (*CommitInputPortTransactionConflict) IsRedirect added in v1.19.1 

func (o *CommitInputPortTransactionConflict) IsRedirect() bool

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

func (*CommitInputPortTransactionConflict) IsServerError added in v1.19.1 

func (o *CommitInputPortTransactionConflict) IsServerError() bool

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

func (*CommitInputPortTransactionConflict) IsSuccess added in v1.19.1 

func (o *CommitInputPortTransactionConflict) IsSuccess() bool

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

func (*CommitInputPortTransactionConflict) String added in v1.19.1 

func (o *CommitInputPortTransactionConflict) String() string

type CommitInputPortTransactionForbidden 

type CommitInputPortTransactionForbidden struct {
}

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

Client is not authorized to make this request.

func NewCommitInputPortTransactionForbidden 

func NewCommitInputPortTransactionForbidden() *CommitInputPortTransactionForbidden

NewCommitInputPortTransactionForbidden creates a CommitInputPortTransactionForbidden with default headers values

func (*CommitInputPortTransactionForbidden) Error 

func (o *CommitInputPortTransactionForbidden) Error() string

func (*CommitInputPortTransactionForbidden) IsClientError added in v1.19.1 

func (o *CommitInputPortTransactionForbidden) IsClientError() bool

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

func (*CommitInputPortTransactionForbidden) IsCode added in v1.19.1 

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

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

func (*CommitInputPortTransactionForbidden) IsRedirect added in v1.19.1 

func (o *CommitInputPortTransactionForbidden) IsRedirect() bool

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

func (*CommitInputPortTransactionForbidden) IsServerError added in v1.19.1 

func (o *CommitInputPortTransactionForbidden) IsServerError() bool

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

func (*CommitInputPortTransactionForbidden) IsSuccess added in v1.19.1 

func (o *CommitInputPortTransactionForbidden) IsSuccess() bool

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

func (*CommitInputPortTransactionForbidden) String added in v1.19.1 

func (o *CommitInputPortTransactionForbidden) String() string

type CommitInputPortTransactionNotFound 

type CommitInputPortTransactionNotFound struct {
}

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

The specified resource could not be found.

func NewCommitInputPortTransactionNotFound 

func NewCommitInputPortTransactionNotFound() *CommitInputPortTransactionNotFound

NewCommitInputPortTransactionNotFound creates a CommitInputPortTransactionNotFound with default headers values

func (*CommitInputPortTransactionNotFound) Error 

func (o *CommitInputPortTransactionNotFound) Error() string

func (*CommitInputPortTransactionNotFound) IsClientError added in v1.19.1 

func (o *CommitInputPortTransactionNotFound) IsClientError() bool

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

func (*CommitInputPortTransactionNotFound) IsCode added in v1.19.1 

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

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

func (*CommitInputPortTransactionNotFound) IsRedirect added in v1.19.1 

func (o *CommitInputPortTransactionNotFound) IsRedirect() bool

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

func (*CommitInputPortTransactionNotFound) IsServerError added in v1.19.1 

func (o *CommitInputPortTransactionNotFound) IsServerError() bool

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

func (*CommitInputPortTransactionNotFound) IsSuccess added in v1.19.1 

func (o *CommitInputPortTransactionNotFound) IsSuccess() bool

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

func (*CommitInputPortTransactionNotFound) String added in v1.19.1 

func (o *CommitInputPortTransactionNotFound) String() string

type CommitInputPortTransactionOK 

type CommitInputPortTransactionOK struct {
	Payload *models.TransactionResultEntity
}

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

successful operation

func NewCommitInputPortTransactionOK 

func NewCommitInputPortTransactionOK() *CommitInputPortTransactionOK

NewCommitInputPortTransactionOK creates a CommitInputPortTransactionOK with default headers values

func (*CommitInputPortTransactionOK) Error 

func (o *CommitInputPortTransactionOK) Error() string

func (*CommitInputPortTransactionOK) GetPayload 

func (o *CommitInputPortTransactionOK) GetPayload() *models.TransactionResultEntity

func (*CommitInputPortTransactionOK) IsClientError added in v1.19.1 

func (o *CommitInputPortTransactionOK) IsClientError() bool

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

func (*CommitInputPortTransactionOK) IsCode added in v1.19.1 

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

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

func (*CommitInputPortTransactionOK) IsRedirect added in v1.19.1 

func (o *CommitInputPortTransactionOK) IsRedirect() bool

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

func (*CommitInputPortTransactionOK) IsServerError added in v1.19.1 

func (o *CommitInputPortTransactionOK) IsServerError() bool

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

func (*CommitInputPortTransactionOK) IsSuccess added in v1.19.1 

func (o *CommitInputPortTransactionOK) IsSuccess() bool

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

func (*CommitInputPortTransactionOK) String added in v1.19.1 

func (o *CommitInputPortTransactionOK) String() string

type CommitInputPortTransactionParams 

type CommitInputPortTransactionParams struct {

	/* PortID.

	   The input port id.
	*/
	PortID string

	/* ResponseCode.

	   The response code. Available values are BAD_CHECKSUM(19), CONFIRM_TRANSACTION(12) or CANCEL_TRANSACTION(15).

	   Format: int32
	*/
	ResponseCode int32

	/* TransactionID.

	   The transaction id.
	*/
	TransactionID string

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

CommitInputPortTransactionParams contains all the parameters to send to the API endpoint 

for the commit input port transaction operation.

Typically these are written to a http.Request.

func NewCommitInputPortTransactionParams 

func NewCommitInputPortTransactionParams() *CommitInputPortTransactionParams

NewCommitInputPortTransactionParams creates a new CommitInputPortTransactionParams 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 NewCommitInputPortTransactionParamsWithContext 

func NewCommitInputPortTransactionParamsWithContext(ctx context.Context) *CommitInputPortTransactionParams

NewCommitInputPortTransactionParamsWithContext creates a new CommitInputPortTransactionParams object with the ability to set a context for a request.

func NewCommitInputPortTransactionParamsWithHTTPClient 

func NewCommitInputPortTransactionParamsWithHTTPClient(client *http.Client) *CommitInputPortTransactionParams

NewCommitInputPortTransactionParamsWithHTTPClient creates a new CommitInputPortTransactionParams object with the ability to set a custom HTTPClient for a request.

func NewCommitInputPortTransactionParamsWithTimeout 

func NewCommitInputPortTransactionParamsWithTimeout(timeout time.Duration) *CommitInputPortTransactionParams

NewCommitInputPortTransactionParamsWithTimeout creates a new CommitInputPortTransactionParams object with the ability to set a timeout on a request.

func (*CommitInputPortTransactionParams) SetContext 

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

SetContext adds the context to the commit input port transaction params

func (*CommitInputPortTransactionParams) SetDefaults 

func (o *CommitInputPortTransactionParams) SetDefaults()

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

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

func (*CommitInputPortTransactionParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the commit input port transaction params

func (*CommitInputPortTransactionParams) SetPortID 

func (o *CommitInputPortTransactionParams) SetPortID(portID string)

SetPortID adds the portId to the commit input port transaction params

func (*CommitInputPortTransactionParams) SetResponseCode 

func (o *CommitInputPortTransactionParams) SetResponseCode(responseCode int32)

SetResponseCode adds the responseCode to the commit input port transaction params

func (*CommitInputPortTransactionParams) SetTimeout 

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

SetTimeout adds the timeout to the commit input port transaction params

func (*CommitInputPortTransactionParams) SetTransactionID 

func (o *CommitInputPortTransactionParams) SetTransactionID(transactionID string)

SetTransactionID adds the transactionId to the commit input port transaction params

func (*CommitInputPortTransactionParams) WithContext 

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

WithContext adds the context to the commit input port transaction params

func (*CommitInputPortTransactionParams) WithDefaults 

func (o *CommitInputPortTransactionParams) WithDefaults() *CommitInputPortTransactionParams

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

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

func (*CommitInputPortTransactionParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the commit input port transaction params

func (*CommitInputPortTransactionParams) WithPortID 

func (o *CommitInputPortTransactionParams) WithPortID(portID string) *CommitInputPortTransactionParams

WithPortID adds the portID to the commit input port transaction params

func (*CommitInputPortTransactionParams) WithResponseCode 

func (o *CommitInputPortTransactionParams) WithResponseCode(responseCode int32) *CommitInputPortTransactionParams

WithResponseCode adds the responseCode to the commit input port transaction params

func (*CommitInputPortTransactionParams) WithTimeout 

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

WithTimeout adds the timeout to the commit input port transaction params

func (*CommitInputPortTransactionParams) WithTransactionID 

func (o *CommitInputPortTransactionParams) WithTransactionID(transactionID string) *CommitInputPortTransactionParams

WithTransactionID adds the transactionID to the commit input port transaction params

func (*CommitInputPortTransactionParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type CommitInputPortTransactionReader 

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

CommitInputPortTransactionReader is a Reader for the CommitInputPortTransaction structure.

func (*CommitInputPortTransactionReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type CommitInputPortTransactionServiceUnavailable 

type CommitInputPortTransactionServiceUnavailable struct {
}

CommitInputPortTransactionServiceUnavailable describes a response with status code 503, with default header values.

NiFi instance is not ready for serving request, or temporarily overloaded. Retrying the same request later may be successful

func NewCommitInputPortTransactionServiceUnavailable 

func NewCommitInputPortTransactionServiceUnavailable() *CommitInputPortTransactionServiceUnavailable

NewCommitInputPortTransactionServiceUnavailable creates a CommitInputPortTransactionServiceUnavailable with default headers values

func (*CommitInputPortTransactionServiceUnavailable) Error 

func (o *CommitInputPortTransactionServiceUnavailable) Error() string

func (*CommitInputPortTransactionServiceUnavailable) IsClientError added in v1.19.1 

func (o *CommitInputPortTransactionServiceUnavailable) IsClientError() bool

IsClientError returns true when this commit input port transaction service unavailable response has a 4xx status code

func (*CommitInputPortTransactionServiceUnavailable) IsCode added in v1.19.1 

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

IsCode returns true when this commit input port transaction service unavailable response a status code equal to that given

func (*CommitInputPortTransactionServiceUnavailable) IsRedirect added in v1.19.1 

func (o *CommitInputPortTransactionServiceUnavailable) IsRedirect() bool

IsRedirect returns true when this commit input port transaction service unavailable response has a 3xx status code

func (*CommitInputPortTransactionServiceUnavailable) IsServerError added in v1.19.1 

func (o *CommitInputPortTransactionServiceUnavailable) IsServerError() bool

IsServerError returns true when this commit input port transaction service unavailable response has a 5xx status code

func (*CommitInputPortTransactionServiceUnavailable) IsSuccess added in v1.19.1 

func (o *CommitInputPortTransactionServiceUnavailable) IsSuccess() bool

IsSuccess returns true when this commit input port transaction service unavailable response has a 2xx status code

func (*CommitInputPortTransactionServiceUnavailable) String added in v1.19.1 

func (o *CommitInputPortTransactionServiceUnavailable) String() string

type CommitInputPortTransactionUnauthorized 

type CommitInputPortTransactionUnauthorized struct {
}

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

Client could not be authenticated.

func NewCommitInputPortTransactionUnauthorized 

func NewCommitInputPortTransactionUnauthorized() *CommitInputPortTransactionUnauthorized

NewCommitInputPortTransactionUnauthorized creates a CommitInputPortTransactionUnauthorized with default headers values

func (*CommitInputPortTransactionUnauthorized) Error 

func (o *CommitInputPortTransactionUnauthorized) Error() string

func (*CommitInputPortTransactionUnauthorized) IsClientError added in v1.19.1 

func (o *CommitInputPortTransactionUnauthorized) IsClientError() bool

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

func (*CommitInputPortTransactionUnauthorized) IsCode added in v1.19.1 

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

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

func (*CommitInputPortTransactionUnauthorized) IsRedirect added in v1.19.1 

func (o *CommitInputPortTransactionUnauthorized) IsRedirect() bool

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

func (*CommitInputPortTransactionUnauthorized) IsServerError added in v1.19.1 

func (o *CommitInputPortTransactionUnauthorized) IsServerError() bool

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

func (*CommitInputPortTransactionUnauthorized) IsSuccess added in v1.19.1 

func (o *CommitInputPortTransactionUnauthorized) IsSuccess() bool

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

func (*CommitInputPortTransactionUnauthorized) String added in v1.19.1 

func (o *CommitInputPortTransactionUnauthorized) String() string

type CommitOutputPortTransactionBadRequest 

type CommitOutputPortTransactionBadRequest struct {
}

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

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

func NewCommitOutputPortTransactionBadRequest 

func NewCommitOutputPortTransactionBadRequest() *CommitOutputPortTransactionBadRequest

NewCommitOutputPortTransactionBadRequest creates a CommitOutputPortTransactionBadRequest with default headers values

func (*CommitOutputPortTransactionBadRequest) Error 

func (o *CommitOutputPortTransactionBadRequest) Error() string

func (*CommitOutputPortTransactionBadRequest) IsClientError added in v1.19.1 

func (o *CommitOutputPortTransactionBadRequest) IsClientError() bool

IsClientError returns true when this commit output port transaction bad request response has a 4xx status code

func (*CommitOutputPortTransactionBadRequest) IsCode added in v1.19.1 

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

IsCode returns true when this commit output port transaction bad request response a status code equal to that given

func (*CommitOutputPortTransactionBadRequest) IsRedirect added in v1.19.1 

func (o *CommitOutputPortTransactionBadRequest) IsRedirect() bool

IsRedirect returns true when this commit output port transaction bad request response has a 3xx status code

func (*CommitOutputPortTransactionBadRequest) IsServerError added in v1.19.1 

func (o *CommitOutputPortTransactionBadRequest) IsServerError() bool

IsServerError returns true when this commit output port transaction bad request response has a 5xx status code

func (*CommitOutputPortTransactionBadRequest) IsSuccess added in v1.19.1 

func (o *CommitOutputPortTransactionBadRequest) IsSuccess() bool

IsSuccess returns true when this commit output port transaction bad request response has a 2xx status code

func (*CommitOutputPortTransactionBadRequest) String added in v1.19.1 

func (o *CommitOutputPortTransactionBadRequest) String() string

type CommitOutputPortTransactionConflict 

type CommitOutputPortTransactionConflict struct {
}

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

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

func NewCommitOutputPortTransactionConflict 

func NewCommitOutputPortTransactionConflict() *CommitOutputPortTransactionConflict

NewCommitOutputPortTransactionConflict creates a CommitOutputPortTransactionConflict with default headers values

func (*CommitOutputPortTransactionConflict) Error 

func (o *CommitOutputPortTransactionConflict) Error() string

func (*CommitOutputPortTransactionConflict) IsClientError added in v1.19.1 

func (o *CommitOutputPortTransactionConflict) IsClientError() bool

IsClientError returns true when this commit output port transaction conflict response has a 4xx status code

func (*CommitOutputPortTransactionConflict) IsCode added in v1.19.1 

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

IsCode returns true when this commit output port transaction conflict response a status code equal to that given

func (*CommitOutputPortTransactionConflict) IsRedirect added in v1.19.1 

func (o *CommitOutputPortTransactionConflict) IsRedirect() bool

IsRedirect returns true when this commit output port transaction conflict response has a 3xx status code

func (*CommitOutputPortTransactionConflict) IsServerError added in v1.19.1 

func (o *CommitOutputPortTransactionConflict) IsServerError() bool

IsServerError returns true when this commit output port transaction conflict response has a 5xx status code

func (*CommitOutputPortTransactionConflict) IsSuccess added in v1.19.1 

func (o *CommitOutputPortTransactionConflict) IsSuccess() bool

IsSuccess returns true when this commit output port transaction conflict response has a 2xx status code

func (*CommitOutputPortTransactionConflict) String added in v1.19.1 

func (o *CommitOutputPortTransactionConflict) String() string

type CommitOutputPortTransactionForbidden 

type CommitOutputPortTransactionForbidden struct {
}

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

Client is not authorized to make this request.

func NewCommitOutputPortTransactionForbidden 

func NewCommitOutputPortTransactionForbidden() *CommitOutputPortTransactionForbidden

NewCommitOutputPortTransactionForbidden creates a CommitOutputPortTransactionForbidden with default headers values

func (*CommitOutputPortTransactionForbidden) Error 

func (o *CommitOutputPortTransactionForbidden) Error() string

func (*CommitOutputPortTransactionForbidden) IsClientError added in v1.19.1 

func (o *CommitOutputPortTransactionForbidden) IsClientError() bool

IsClientError returns true when this commit output port transaction forbidden response has a 4xx status code

func (*CommitOutputPortTransactionForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this commit output port transaction forbidden response a status code equal to that given

func (*CommitOutputPortTransactionForbidden) IsRedirect added in v1.19.1 

func (o *CommitOutputPortTransactionForbidden) IsRedirect() bool

IsRedirect returns true when this commit output port transaction forbidden response has a 3xx status code

func (*CommitOutputPortTransactionForbidden) IsServerError added in v1.19.1 

func (o *CommitOutputPortTransactionForbidden) IsServerError() bool

IsServerError returns true when this commit output port transaction forbidden response has a 5xx status code

func (*CommitOutputPortTransactionForbidden) IsSuccess added in v1.19.1 

func (o *CommitOutputPortTransactionForbidden) IsSuccess() bool

IsSuccess returns true when this commit output port transaction forbidden response has a 2xx status code

func (*CommitOutputPortTransactionForbidden) String added in v1.19.1 

func (o *CommitOutputPortTransactionForbidden) String() string

type CommitOutputPortTransactionNotFound 

type CommitOutputPortTransactionNotFound struct {
}

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

The specified resource could not be found.

func NewCommitOutputPortTransactionNotFound 

func NewCommitOutputPortTransactionNotFound() *CommitOutputPortTransactionNotFound

NewCommitOutputPortTransactionNotFound creates a CommitOutputPortTransactionNotFound with default headers values

func (*CommitOutputPortTransactionNotFound) Error 

func (o *CommitOutputPortTransactionNotFound) Error() string

func (*CommitOutputPortTransactionNotFound) IsClientError added in v1.19.1 

func (o *CommitOutputPortTransactionNotFound) IsClientError() bool

IsClientError returns true when this commit output port transaction not found response has a 4xx status code

func (*CommitOutputPortTransactionNotFound) IsCode added in v1.19.1 

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

IsCode returns true when this commit output port transaction not found response a status code equal to that given

func (*CommitOutputPortTransactionNotFound) IsRedirect added in v1.19.1 

func (o *CommitOutputPortTransactionNotFound) IsRedirect() bool

IsRedirect returns true when this commit output port transaction not found response has a 3xx status code

func (*CommitOutputPortTransactionNotFound) IsServerError added in v1.19.1 

func (o *CommitOutputPortTransactionNotFound) IsServerError() bool

IsServerError returns true when this commit output port transaction not found response has a 5xx status code

func (*CommitOutputPortTransactionNotFound) IsSuccess added in v1.19.1 

func (o *CommitOutputPortTransactionNotFound) IsSuccess() bool

IsSuccess returns true when this commit output port transaction not found response has a 2xx status code

func (*CommitOutputPortTransactionNotFound) String added in v1.19.1 

func (o *CommitOutputPortTransactionNotFound) String() string

type CommitOutputPortTransactionOK 

type CommitOutputPortTransactionOK struct {
	Payload *models.TransactionResultEntity
}

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

successful operation

func NewCommitOutputPortTransactionOK 

func NewCommitOutputPortTransactionOK() *CommitOutputPortTransactionOK

NewCommitOutputPortTransactionOK creates a CommitOutputPortTransactionOK with default headers values

func (*CommitOutputPortTransactionOK) Error 

func (o *CommitOutputPortTransactionOK) Error() string

func (*CommitOutputPortTransactionOK) GetPayload 

func (o *CommitOutputPortTransactionOK) GetPayload() *models.TransactionResultEntity

func (*CommitOutputPortTransactionOK) IsClientError added in v1.19.1 

func (o *CommitOutputPortTransactionOK) IsClientError() bool

IsClientError returns true when this commit output port transaction o k response has a 4xx status code

func (*CommitOutputPortTransactionOK) IsCode added in v1.19.1 

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

IsCode returns true when this commit output port transaction o k response a status code equal to that given

func (*CommitOutputPortTransactionOK) IsRedirect added in v1.19.1 

func (o *CommitOutputPortTransactionOK) IsRedirect() bool

IsRedirect returns true when this commit output port transaction o k response has a 3xx status code

func (*CommitOutputPortTransactionOK) IsServerError added in v1.19.1 

func (o *CommitOutputPortTransactionOK) IsServerError() bool

IsServerError returns true when this commit output port transaction o k response has a 5xx status code

func (*CommitOutputPortTransactionOK) IsSuccess added in v1.19.1 

func (o *CommitOutputPortTransactionOK) IsSuccess() bool

IsSuccess returns true when this commit output port transaction o k response has a 2xx status code

func (*CommitOutputPortTransactionOK) String added in v1.19.1 

func (o *CommitOutputPortTransactionOK) String() string

type CommitOutputPortTransactionParams 

type CommitOutputPortTransactionParams struct {

	/* Checksum.

	   A checksum calculated at client side using CRC32 to check flow file content integrity. It must match with the value calculated at server side.
	*/
	Checksum string

	/* PortID.

	   The output port id.
	*/
	PortID string

	/* ResponseCode.

	   The response code. Available values are CONFIRM_TRANSACTION(12) or CANCEL_TRANSACTION(15).

	   Format: int32
	*/
	ResponseCode int32

	/* TransactionID.

	   The transaction id.
	*/
	TransactionID string

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

CommitOutputPortTransactionParams contains all the parameters to send to the API endpoint 

for the commit output port transaction operation.

Typically these are written to a http.Request.

func NewCommitOutputPortTransactionParams 

func NewCommitOutputPortTransactionParams() *CommitOutputPortTransactionParams

NewCommitOutputPortTransactionParams creates a new CommitOutputPortTransactionParams 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 NewCommitOutputPortTransactionParamsWithContext 

func NewCommitOutputPortTransactionParamsWithContext(ctx context.Context) *CommitOutputPortTransactionParams

NewCommitOutputPortTransactionParamsWithContext creates a new CommitOutputPortTransactionParams object with the ability to set a context for a request.

func NewCommitOutputPortTransactionParamsWithHTTPClient 

func NewCommitOutputPortTransactionParamsWithHTTPClient(client *http.Client) *CommitOutputPortTransactionParams

NewCommitOutputPortTransactionParamsWithHTTPClient creates a new CommitOutputPortTransactionParams object with the ability to set a custom HTTPClient for a request.

func NewCommitOutputPortTransactionParamsWithTimeout 

func NewCommitOutputPortTransactionParamsWithTimeout(timeout time.Duration) *CommitOutputPortTransactionParams

NewCommitOutputPortTransactionParamsWithTimeout creates a new CommitOutputPortTransactionParams object with the ability to set a timeout on a request.

func (*CommitOutputPortTransactionParams) SetChecksum 

func (o *CommitOutputPortTransactionParams) SetChecksum(checksum string)

SetChecksum adds the checksum to the commit output port transaction params

func (*CommitOutputPortTransactionParams) SetContext 

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

SetContext adds the context to the commit output port transaction params

func (*CommitOutputPortTransactionParams) SetDefaults 

func (o *CommitOutputPortTransactionParams) SetDefaults()

SetDefaults hydrates default values in the commit output port transaction params (not the query body).

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

func (*CommitOutputPortTransactionParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the commit output port transaction params

func (*CommitOutputPortTransactionParams) SetPortID 

func (o *CommitOutputPortTransactionParams) SetPortID(portID string)

SetPortID adds the portId to the commit output port transaction params

func (*CommitOutputPortTransactionParams) SetResponseCode 

func (o *CommitOutputPortTransactionParams) SetResponseCode(responseCode int32)

SetResponseCode adds the responseCode to the commit output port transaction params

func (*CommitOutputPortTransactionParams) SetTimeout 

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

SetTimeout adds the timeout to the commit output port transaction params

func (*CommitOutputPortTransactionParams) SetTransactionID 

func (o *CommitOutputPortTransactionParams) SetTransactionID(transactionID string)

SetTransactionID adds the transactionId to the commit output port transaction params

func (*CommitOutputPortTransactionParams) WithChecksum 

func (o *CommitOutputPortTransactionParams) WithChecksum(checksum string) *CommitOutputPortTransactionParams

WithChecksum adds the checksum to the commit output port transaction params

func (*CommitOutputPortTransactionParams) WithContext 

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

WithContext adds the context to the commit output port transaction params

func (*CommitOutputPortTransactionParams) WithDefaults 

func (o *CommitOutputPortTransactionParams) WithDefaults() *CommitOutputPortTransactionParams

WithDefaults hydrates default values in the commit output port transaction params (not the query body).

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

func (*CommitOutputPortTransactionParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the commit output port transaction params

func (*CommitOutputPortTransactionParams) WithPortID 

func (o *CommitOutputPortTransactionParams) WithPortID(portID string) *CommitOutputPortTransactionParams

WithPortID adds the portID to the commit output port transaction params

func (*CommitOutputPortTransactionParams) WithResponseCode 

func (o *CommitOutputPortTransactionParams) WithResponseCode(responseCode int32) *CommitOutputPortTransactionParams

WithResponseCode adds the responseCode to the commit output port transaction params

func (*CommitOutputPortTransactionParams) WithTimeout 

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

WithTimeout adds the timeout to the commit output port transaction params

func (*CommitOutputPortTransactionParams) WithTransactionID 

func (o *CommitOutputPortTransactionParams) WithTransactionID(transactionID string) *CommitOutputPortTransactionParams

WithTransactionID adds the transactionID to the commit output port transaction params

func (*CommitOutputPortTransactionParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type CommitOutputPortTransactionReader 

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

CommitOutputPortTransactionReader is a Reader for the CommitOutputPortTransaction structure.

func (*CommitOutputPortTransactionReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type CommitOutputPortTransactionServiceUnavailable 

type CommitOutputPortTransactionServiceUnavailable struct {
}

CommitOutputPortTransactionServiceUnavailable describes a response with status code 503, with default header values.

NiFi instance is not ready for serving request, or temporarily overloaded. Retrying the same request later may be successful

func NewCommitOutputPortTransactionServiceUnavailable 

func NewCommitOutputPortTransactionServiceUnavailable() *CommitOutputPortTransactionServiceUnavailable

NewCommitOutputPortTransactionServiceUnavailable creates a CommitOutputPortTransactionServiceUnavailable with default headers values

func (*CommitOutputPortTransactionServiceUnavailable) Error 

func (o *CommitOutputPortTransactionServiceUnavailable) Error() string

func (*CommitOutputPortTransactionServiceUnavailable) IsClientError added in v1.19.1 

func (o *CommitOutputPortTransactionServiceUnavailable) IsClientError() bool

IsClientError returns true when this commit output port transaction service unavailable response has a 4xx status code

func (*CommitOutputPortTransactionServiceUnavailable) IsCode added in v1.19.1 

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

IsCode returns true when this commit output port transaction service unavailable response a status code equal to that given

func (*CommitOutputPortTransactionServiceUnavailable) IsRedirect added in v1.19.1 

func (o *CommitOutputPortTransactionServiceUnavailable) IsRedirect() bool

IsRedirect returns true when this commit output port transaction service unavailable response has a 3xx status code

func (*CommitOutputPortTransactionServiceUnavailable) IsServerError added in v1.19.1 

func (o *CommitOutputPortTransactionServiceUnavailable) IsServerError() bool

IsServerError returns true when this commit output port transaction service unavailable response has a 5xx status code

func (*CommitOutputPortTransactionServiceUnavailable) IsSuccess added in v1.19.1 

func (o *CommitOutputPortTransactionServiceUnavailable) IsSuccess() bool

IsSuccess returns true when this commit output port transaction service unavailable response has a 2xx status code

func (*CommitOutputPortTransactionServiceUnavailable) String added in v1.19.1 

func (o *CommitOutputPortTransactionServiceUnavailable) String() string

type CommitOutputPortTransactionUnauthorized 

type CommitOutputPortTransactionUnauthorized struct {
}

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

Client could not be authenticated.

func NewCommitOutputPortTransactionUnauthorized 

func NewCommitOutputPortTransactionUnauthorized() *CommitOutputPortTransactionUnauthorized

NewCommitOutputPortTransactionUnauthorized creates a CommitOutputPortTransactionUnauthorized with default headers values

func (*CommitOutputPortTransactionUnauthorized) Error 

func (o *CommitOutputPortTransactionUnauthorized) Error() string

func (*CommitOutputPortTransactionUnauthorized) IsClientError added in v1.19.1 

func (o *CommitOutputPortTransactionUnauthorized) IsClientError() bool

IsClientError returns true when this commit output port transaction unauthorized response has a 4xx status code

func (*CommitOutputPortTransactionUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this commit output port transaction unauthorized response a status code equal to that given

func (*CommitOutputPortTransactionUnauthorized) IsRedirect added in v1.19.1 

func (o *CommitOutputPortTransactionUnauthorized) IsRedirect() bool

IsRedirect returns true when this commit output port transaction unauthorized response has a 3xx status code

func (*CommitOutputPortTransactionUnauthorized) IsServerError added in v1.19.1 

func (o *CommitOutputPortTransactionUnauthorized) IsServerError() bool

IsServerError returns true when this commit output port transaction unauthorized response has a 5xx status code

func (*CommitOutputPortTransactionUnauthorized) IsSuccess added in v1.19.1 

func (o *CommitOutputPortTransactionUnauthorized) IsSuccess() bool

IsSuccess returns true when this commit output port transaction unauthorized response has a 2xx status code

func (*CommitOutputPortTransactionUnauthorized) String added in v1.19.1 

func (o *CommitOutputPortTransactionUnauthorized) String() string

type CreatePortTransactionBadRequest 

type CreatePortTransactionBadRequest struct {
}

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

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

func NewCreatePortTransactionBadRequest 

func NewCreatePortTransactionBadRequest() *CreatePortTransactionBadRequest

NewCreatePortTransactionBadRequest creates a CreatePortTransactionBadRequest with default headers values

func (*CreatePortTransactionBadRequest) Error 

func (o *CreatePortTransactionBadRequest) Error() string

func (*CreatePortTransactionBadRequest) IsClientError added in v1.19.1 

func (o *CreatePortTransactionBadRequest) IsClientError() bool

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

func (*CreatePortTransactionBadRequest) IsCode added in v1.19.1 

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

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

func (*CreatePortTransactionBadRequest) IsRedirect added in v1.19.1 

func (o *CreatePortTransactionBadRequest) IsRedirect() bool

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

func (*CreatePortTransactionBadRequest) IsServerError added in v1.19.1 

func (o *CreatePortTransactionBadRequest) IsServerError() bool

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

func (*CreatePortTransactionBadRequest) IsSuccess added in v1.19.1 

func (o *CreatePortTransactionBadRequest) IsSuccess() bool

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

func (*CreatePortTransactionBadRequest) String added in v1.19.1 

func (o *CreatePortTransactionBadRequest) String() string

type CreatePortTransactionConflict 

type CreatePortTransactionConflict struct {
}

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

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

func NewCreatePortTransactionConflict 

func NewCreatePortTransactionConflict() *CreatePortTransactionConflict

NewCreatePortTransactionConflict creates a CreatePortTransactionConflict with default headers values

func (*CreatePortTransactionConflict) Error 

func (o *CreatePortTransactionConflict) Error() string

func (*CreatePortTransactionConflict) IsClientError added in v1.19.1 

func (o *CreatePortTransactionConflict) IsClientError() bool

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

func (*CreatePortTransactionConflict) IsCode added in v1.19.1 

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

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

func (*CreatePortTransactionConflict) IsRedirect added in v1.19.1 

func (o *CreatePortTransactionConflict) IsRedirect() bool

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

func (*CreatePortTransactionConflict) IsServerError added in v1.19.1 

func (o *CreatePortTransactionConflict) IsServerError() bool

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

func (*CreatePortTransactionConflict) IsSuccess added in v1.19.1 

func (o *CreatePortTransactionConflict) IsSuccess() bool

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

func (*CreatePortTransactionConflict) String added in v1.19.1 

func (o *CreatePortTransactionConflict) String() string

type CreatePortTransactionForbidden 

type CreatePortTransactionForbidden struct {
}

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

Client is not authorized to make this request.

func NewCreatePortTransactionForbidden 

func NewCreatePortTransactionForbidden() *CreatePortTransactionForbidden

NewCreatePortTransactionForbidden creates a CreatePortTransactionForbidden with default headers values

func (*CreatePortTransactionForbidden) Error 

func (o *CreatePortTransactionForbidden) Error() string

func (*CreatePortTransactionForbidden) IsClientError added in v1.19.1 

func (o *CreatePortTransactionForbidden) IsClientError() bool

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

func (*CreatePortTransactionForbidden) IsCode added in v1.19.1 

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

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

func (*CreatePortTransactionForbidden) IsRedirect added in v1.19.1 

func (o *CreatePortTransactionForbidden) IsRedirect() bool

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

func (*CreatePortTransactionForbidden) IsServerError added in v1.19.1 

func (o *CreatePortTransactionForbidden) IsServerError() bool

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

func (*CreatePortTransactionForbidden) IsSuccess added in v1.19.1 

func (o *CreatePortTransactionForbidden) IsSuccess() bool

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

func (*CreatePortTransactionForbidden) String added in v1.19.1 

func (o *CreatePortTransactionForbidden) String() string

type CreatePortTransactionNotFound 

type CreatePortTransactionNotFound struct {
}

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

The specified resource could not be found.

func NewCreatePortTransactionNotFound 

func NewCreatePortTransactionNotFound() *CreatePortTransactionNotFound

NewCreatePortTransactionNotFound creates a CreatePortTransactionNotFound with default headers values

func (*CreatePortTransactionNotFound) Error 

func (o *CreatePortTransactionNotFound) Error() string

func (*CreatePortTransactionNotFound) IsClientError added in v1.19.1 

func (o *CreatePortTransactionNotFound) IsClientError() bool

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

func (*CreatePortTransactionNotFound) IsCode added in v1.19.1 

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

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

func (*CreatePortTransactionNotFound) IsRedirect added in v1.19.1 

func (o *CreatePortTransactionNotFound) IsRedirect() bool

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

func (*CreatePortTransactionNotFound) IsServerError added in v1.19.1 

func (o *CreatePortTransactionNotFound) IsServerError() bool

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

func (*CreatePortTransactionNotFound) IsSuccess added in v1.19.1 

func (o *CreatePortTransactionNotFound) IsSuccess() bool

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

func (*CreatePortTransactionNotFound) String added in v1.19.1 

func (o *CreatePortTransactionNotFound) String() string

type CreatePortTransactionOK 

type CreatePortTransactionOK struct {
	Payload *models.TransactionResultEntity
}

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

successful operation

func NewCreatePortTransactionOK 

func NewCreatePortTransactionOK() *CreatePortTransactionOK

NewCreatePortTransactionOK creates a CreatePortTransactionOK with default headers values

func (*CreatePortTransactionOK) Error 

func (o *CreatePortTransactionOK) Error() string

func (*CreatePortTransactionOK) GetPayload 

func (o *CreatePortTransactionOK) GetPayload() *models.TransactionResultEntity

func (*CreatePortTransactionOK) IsClientError added in v1.19.1 

func (o *CreatePortTransactionOK) IsClientError() bool

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

func (*CreatePortTransactionOK) IsCode added in v1.19.1 

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

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

func (*CreatePortTransactionOK) IsRedirect added in v1.19.1 

func (o *CreatePortTransactionOK) IsRedirect() bool

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

func (*CreatePortTransactionOK) IsServerError added in v1.19.1 

func (o *CreatePortTransactionOK) IsServerError() bool

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

func (*CreatePortTransactionOK) IsSuccess added in v1.19.1 

func (o *CreatePortTransactionOK) IsSuccess() bool

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

func (*CreatePortTransactionOK) String added in v1.19.1 

func (o *CreatePortTransactionOK) String() string

type CreatePortTransactionParams 

type CreatePortTransactionParams struct {

	// PortID.
	PortID string

	/* PortType.

	   The port type.
	*/
	PortType string

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

CreatePortTransactionParams contains all the parameters to send to the API endpoint 

for the create port transaction operation.

Typically these are written to a http.Request.

func NewCreatePortTransactionParams 

func NewCreatePortTransactionParams() *CreatePortTransactionParams

NewCreatePortTransactionParams creates a new CreatePortTransactionParams 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 NewCreatePortTransactionParamsWithContext 

func NewCreatePortTransactionParamsWithContext(ctx context.Context) *CreatePortTransactionParams

NewCreatePortTransactionParamsWithContext creates a new CreatePortTransactionParams object with the ability to set a context for a request.

func NewCreatePortTransactionParamsWithHTTPClient 

func NewCreatePortTransactionParamsWithHTTPClient(client *http.Client) *CreatePortTransactionParams

NewCreatePortTransactionParamsWithHTTPClient creates a new CreatePortTransactionParams object with the ability to set a custom HTTPClient for a request.

func NewCreatePortTransactionParamsWithTimeout 

func NewCreatePortTransactionParamsWithTimeout(timeout time.Duration) *CreatePortTransactionParams

NewCreatePortTransactionParamsWithTimeout creates a new CreatePortTransactionParams object with the ability to set a timeout on a request.

func (*CreatePortTransactionParams) SetContext 

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

SetContext adds the context to the create port transaction params

func (*CreatePortTransactionParams) SetDefaults 

func (o *CreatePortTransactionParams) SetDefaults()

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

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

func (*CreatePortTransactionParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the create port transaction params

func (*CreatePortTransactionParams) SetPortID 

func (o *CreatePortTransactionParams) SetPortID(portID string)

SetPortID adds the portId to the create port transaction params

func (*CreatePortTransactionParams) SetPortType 

func (o *CreatePortTransactionParams) SetPortType(portType string)

SetPortType adds the portType to the create port transaction params

func (*CreatePortTransactionParams) SetTimeout 

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

SetTimeout adds the timeout to the create port transaction params

func (*CreatePortTransactionParams) WithContext 

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

WithContext adds the context to the create port transaction params

func (*CreatePortTransactionParams) WithDefaults 

func (o *CreatePortTransactionParams) WithDefaults() *CreatePortTransactionParams

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

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

func (*CreatePortTransactionParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the create port transaction params

func (*CreatePortTransactionParams) WithPortID 

func (o *CreatePortTransactionParams) WithPortID(portID string) *CreatePortTransactionParams

WithPortID adds the portID to the create port transaction params

func (*CreatePortTransactionParams) WithPortType 

func (o *CreatePortTransactionParams) WithPortType(portType string) *CreatePortTransactionParams

WithPortType adds the portType to the create port transaction params

func (*CreatePortTransactionParams) WithTimeout 

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

WithTimeout adds the timeout to the create port transaction params

func (*CreatePortTransactionParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type CreatePortTransactionReader 

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

CreatePortTransactionReader is a Reader for the CreatePortTransaction structure.

func (*CreatePortTransactionReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type CreatePortTransactionServiceUnavailable 

type CreatePortTransactionServiceUnavailable struct {
}

CreatePortTransactionServiceUnavailable describes a response with status code 503, with default header values.

NiFi instance is not ready for serving request, or temporarily overloaded. Retrying the same request later may be successful

func NewCreatePortTransactionServiceUnavailable 

func NewCreatePortTransactionServiceUnavailable() *CreatePortTransactionServiceUnavailable

NewCreatePortTransactionServiceUnavailable creates a CreatePortTransactionServiceUnavailable with default headers values

func (*CreatePortTransactionServiceUnavailable) Error 

func (o *CreatePortTransactionServiceUnavailable) Error() string

func (*CreatePortTransactionServiceUnavailable) IsClientError added in v1.19.1 

func (o *CreatePortTransactionServiceUnavailable) IsClientError() bool

IsClientError returns true when this create port transaction service unavailable response has a 4xx status code

func (*CreatePortTransactionServiceUnavailable) IsCode added in v1.19.1 

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

IsCode returns true when this create port transaction service unavailable response a status code equal to that given

func (*CreatePortTransactionServiceUnavailable) IsRedirect added in v1.19.1 

func (o *CreatePortTransactionServiceUnavailable) IsRedirect() bool

IsRedirect returns true when this create port transaction service unavailable response has a 3xx status code

func (*CreatePortTransactionServiceUnavailable) IsServerError added in v1.19.1 

func (o *CreatePortTransactionServiceUnavailable) IsServerError() bool

IsServerError returns true when this create port transaction service unavailable response has a 5xx status code

func (*CreatePortTransactionServiceUnavailable) IsSuccess added in v1.19.1 

func (o *CreatePortTransactionServiceUnavailable) IsSuccess() bool

IsSuccess returns true when this create port transaction service unavailable response has a 2xx status code

func (*CreatePortTransactionServiceUnavailable) String added in v1.19.1 

func (o *CreatePortTransactionServiceUnavailable) String() string

type CreatePortTransactionUnauthorized 

type CreatePortTransactionUnauthorized struct {
}

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

Client could not be authenticated.

func NewCreatePortTransactionUnauthorized 

func NewCreatePortTransactionUnauthorized() *CreatePortTransactionUnauthorized

NewCreatePortTransactionUnauthorized creates a CreatePortTransactionUnauthorized with default headers values

func (*CreatePortTransactionUnauthorized) Error 

func (o *CreatePortTransactionUnauthorized) Error() string

func (*CreatePortTransactionUnauthorized) IsClientError added in v1.19.1 

func (o *CreatePortTransactionUnauthorized) IsClientError() bool

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

func (*CreatePortTransactionUnauthorized) IsCode added in v1.19.1 

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

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

func (*CreatePortTransactionUnauthorized) IsRedirect added in v1.19.1 

func (o *CreatePortTransactionUnauthorized) IsRedirect() bool

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

func (*CreatePortTransactionUnauthorized) IsServerError added in v1.19.1 

func (o *CreatePortTransactionUnauthorized) IsServerError() bool

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

func (*CreatePortTransactionUnauthorized) IsSuccess added in v1.19.1 

func (o *CreatePortTransactionUnauthorized) IsSuccess() bool

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

func (*CreatePortTransactionUnauthorized) String added in v1.19.1 

func (o *CreatePortTransactionUnauthorized) String() string

type ExtendInputPortTransactionTTLBadRequest 

type ExtendInputPortTransactionTTLBadRequest struct {
}

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

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

func NewExtendInputPortTransactionTTLBadRequest 

func NewExtendInputPortTransactionTTLBadRequest() *ExtendInputPortTransactionTTLBadRequest

NewExtendInputPortTransactionTTLBadRequest creates a ExtendInputPortTransactionTTLBadRequest with default headers values

func (*ExtendInputPortTransactionTTLBadRequest) Error 

func (o *ExtendInputPortTransactionTTLBadRequest) Error() string

func (*ExtendInputPortTransactionTTLBadRequest) IsClientError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLBadRequest) IsClientError() bool

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

func (*ExtendInputPortTransactionTTLBadRequest) IsCode added in v1.19.1 

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

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

func (*ExtendInputPortTransactionTTLBadRequest) IsRedirect added in v1.19.1 

func (o *ExtendInputPortTransactionTTLBadRequest) IsRedirect() bool

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

func (*ExtendInputPortTransactionTTLBadRequest) IsServerError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLBadRequest) IsServerError() bool

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

func (*ExtendInputPortTransactionTTLBadRequest) IsSuccess added in v1.19.1 

func (o *ExtendInputPortTransactionTTLBadRequest) IsSuccess() bool

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

func (*ExtendInputPortTransactionTTLBadRequest) String added in v1.19.1 

func (o *ExtendInputPortTransactionTTLBadRequest) String() string

type ExtendInputPortTransactionTTLConflict 

type ExtendInputPortTransactionTTLConflict struct {
}

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

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

func NewExtendInputPortTransactionTTLConflict 

func NewExtendInputPortTransactionTTLConflict() *ExtendInputPortTransactionTTLConflict

NewExtendInputPortTransactionTTLConflict creates a ExtendInputPortTransactionTTLConflict with default headers values

func (*ExtendInputPortTransactionTTLConflict) Error 

func (o *ExtendInputPortTransactionTTLConflict) Error() string

func (*ExtendInputPortTransactionTTLConflict) IsClientError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLConflict) IsClientError() bool

IsClientError returns true when this extend input port transaction Ttl conflict response has a 4xx status code

func (*ExtendInputPortTransactionTTLConflict) IsCode added in v1.19.1 

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

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

func (*ExtendInputPortTransactionTTLConflict) IsRedirect added in v1.19.1 

func (o *ExtendInputPortTransactionTTLConflict) IsRedirect() bool

IsRedirect returns true when this extend input port transaction Ttl conflict response has a 3xx status code

func (*ExtendInputPortTransactionTTLConflict) IsServerError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLConflict) IsServerError() bool

IsServerError returns true when this extend input port transaction Ttl conflict response has a 5xx status code

func (*ExtendInputPortTransactionTTLConflict) IsSuccess added in v1.19.1 

func (o *ExtendInputPortTransactionTTLConflict) IsSuccess() bool

IsSuccess returns true when this extend input port transaction Ttl conflict response has a 2xx status code

func (*ExtendInputPortTransactionTTLConflict) String added in v1.19.1 

func (o *ExtendInputPortTransactionTTLConflict) String() string

type ExtendInputPortTransactionTTLForbidden 

type ExtendInputPortTransactionTTLForbidden struct {
}

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

Client is not authorized to make this request.

func NewExtendInputPortTransactionTTLForbidden 

func NewExtendInputPortTransactionTTLForbidden() *ExtendInputPortTransactionTTLForbidden

NewExtendInputPortTransactionTTLForbidden creates a ExtendInputPortTransactionTTLForbidden with default headers values

func (*ExtendInputPortTransactionTTLForbidden) Error 

func (o *ExtendInputPortTransactionTTLForbidden) Error() string

func (*ExtendInputPortTransactionTTLForbidden) IsClientError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLForbidden) IsClientError() bool

IsClientError returns true when this extend input port transaction Ttl forbidden response has a 4xx status code

func (*ExtendInputPortTransactionTTLForbidden) IsCode added in v1.19.1 

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

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

func (*ExtendInputPortTransactionTTLForbidden) IsRedirect added in v1.19.1 

func (o *ExtendInputPortTransactionTTLForbidden) IsRedirect() bool

IsRedirect returns true when this extend input port transaction Ttl forbidden response has a 3xx status code

func (*ExtendInputPortTransactionTTLForbidden) IsServerError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLForbidden) IsServerError() bool

IsServerError returns true when this extend input port transaction Ttl forbidden response has a 5xx status code

func (*ExtendInputPortTransactionTTLForbidden) IsSuccess added in v1.19.1 

func (o *ExtendInputPortTransactionTTLForbidden) IsSuccess() bool

IsSuccess returns true when this extend input port transaction Ttl forbidden response has a 2xx status code

func (*ExtendInputPortTransactionTTLForbidden) String added in v1.19.1 

func (o *ExtendInputPortTransactionTTLForbidden) String() string

type ExtendInputPortTransactionTTLNotFound 

type ExtendInputPortTransactionTTLNotFound struct {
}

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

The specified resource could not be found.

func NewExtendInputPortTransactionTTLNotFound 

func NewExtendInputPortTransactionTTLNotFound() *ExtendInputPortTransactionTTLNotFound

NewExtendInputPortTransactionTTLNotFound creates a ExtendInputPortTransactionTTLNotFound with default headers values

func (*ExtendInputPortTransactionTTLNotFound) Error 

func (o *ExtendInputPortTransactionTTLNotFound) Error() string

func (*ExtendInputPortTransactionTTLNotFound) IsClientError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLNotFound) IsClientError() bool

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

func (*ExtendInputPortTransactionTTLNotFound) IsCode added in v1.19.1 

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

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

func (*ExtendInputPortTransactionTTLNotFound) IsRedirect added in v1.19.1 

func (o *ExtendInputPortTransactionTTLNotFound) IsRedirect() bool

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

func (*ExtendInputPortTransactionTTLNotFound) IsServerError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLNotFound) IsServerError() bool

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

func (*ExtendInputPortTransactionTTLNotFound) IsSuccess added in v1.19.1 

func (o *ExtendInputPortTransactionTTLNotFound) IsSuccess() bool

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

func (*ExtendInputPortTransactionTTLNotFound) String added in v1.19.1 

func (o *ExtendInputPortTransactionTTLNotFound) String() string

type ExtendInputPortTransactionTTLOK 

type ExtendInputPortTransactionTTLOK struct {
	Payload *models.TransactionResultEntity
}

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

successful operation

func NewExtendInputPortTransactionTTLOK 

func NewExtendInputPortTransactionTTLOK() *ExtendInputPortTransactionTTLOK

NewExtendInputPortTransactionTTLOK creates a ExtendInputPortTransactionTTLOK with default headers values

func (*ExtendInputPortTransactionTTLOK) Error 

func (o *ExtendInputPortTransactionTTLOK) Error() string

func (*ExtendInputPortTransactionTTLOK) GetPayload 

func (o *ExtendInputPortTransactionTTLOK) GetPayload() *models.TransactionResultEntity

func (*ExtendInputPortTransactionTTLOK) IsClientError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLOK) IsClientError() bool

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

func (*ExtendInputPortTransactionTTLOK) IsCode added in v1.19.1 

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

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

func (*ExtendInputPortTransactionTTLOK) IsRedirect added in v1.19.1 

func (o *ExtendInputPortTransactionTTLOK) IsRedirect() bool

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

func (*ExtendInputPortTransactionTTLOK) IsServerError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLOK) IsServerError() bool

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

func (*ExtendInputPortTransactionTTLOK) IsSuccess added in v1.19.1 

func (o *ExtendInputPortTransactionTTLOK) IsSuccess() bool

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

func (*ExtendInputPortTransactionTTLOK) String added in v1.19.1 

func (o *ExtendInputPortTransactionTTLOK) String() string

type ExtendInputPortTransactionTTLParams 

type ExtendInputPortTransactionTTLParams struct {

	// PortID.
	PortID string

	// TransactionID.
	TransactionID string

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

ExtendInputPortTransactionTTLParams contains all the parameters to send to the API endpoint 

for the extend input port transaction TTL operation.

Typically these are written to a http.Request.

func NewExtendInputPortTransactionTTLParams 

func NewExtendInputPortTransactionTTLParams() *ExtendInputPortTransactionTTLParams

NewExtendInputPortTransactionTTLParams creates a new ExtendInputPortTransactionTTLParams 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 NewExtendInputPortTransactionTTLParamsWithContext 

func NewExtendInputPortTransactionTTLParamsWithContext(ctx context.Context) *ExtendInputPortTransactionTTLParams

NewExtendInputPortTransactionTTLParamsWithContext creates a new ExtendInputPortTransactionTTLParams object with the ability to set a context for a request.

func NewExtendInputPortTransactionTTLParamsWithHTTPClient 

func NewExtendInputPortTransactionTTLParamsWithHTTPClient(client *http.Client) *ExtendInputPortTransactionTTLParams

NewExtendInputPortTransactionTTLParamsWithHTTPClient creates a new ExtendInputPortTransactionTTLParams object with the ability to set a custom HTTPClient for a request.

func NewExtendInputPortTransactionTTLParamsWithTimeout 

func NewExtendInputPortTransactionTTLParamsWithTimeout(timeout time.Duration) *ExtendInputPortTransactionTTLParams

NewExtendInputPortTransactionTTLParamsWithTimeout creates a new ExtendInputPortTransactionTTLParams object with the ability to set a timeout on a request.

func (*ExtendInputPortTransactionTTLParams) SetContext 

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

SetContext adds the context to the extend input port transaction TTL params

func (*ExtendInputPortTransactionTTLParams) SetDefaults 

func (o *ExtendInputPortTransactionTTLParams) SetDefaults()

SetDefaults hydrates default values in the extend input port transaction TTL params (not the query body).

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

func (*ExtendInputPortTransactionTTLParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the extend input port transaction TTL params

func (*ExtendInputPortTransactionTTLParams) SetPortID 

func (o *ExtendInputPortTransactionTTLParams) SetPortID(portID string)

SetPortID adds the portId to the extend input port transaction TTL params

func (*ExtendInputPortTransactionTTLParams) SetTimeout 

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

SetTimeout adds the timeout to the extend input port transaction TTL params

func (*ExtendInputPortTransactionTTLParams) SetTransactionID 

func (o *ExtendInputPortTransactionTTLParams) SetTransactionID(transactionID string)

SetTransactionID adds the transactionId to the extend input port transaction TTL params

func (*ExtendInputPortTransactionTTLParams) WithContext 

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

WithContext adds the context to the extend input port transaction TTL params

func (*ExtendInputPortTransactionTTLParams) WithDefaults 

func (o *ExtendInputPortTransactionTTLParams) WithDefaults() *ExtendInputPortTransactionTTLParams

WithDefaults hydrates default values in the extend input port transaction TTL params (not the query body).

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

func (*ExtendInputPortTransactionTTLParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the extend input port transaction TTL params

func (*ExtendInputPortTransactionTTLParams) WithPortID 

func (o *ExtendInputPortTransactionTTLParams) WithPortID(portID string) *ExtendInputPortTransactionTTLParams

WithPortID adds the portID to the extend input port transaction TTL params

func (*ExtendInputPortTransactionTTLParams) WithTimeout 

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

WithTimeout adds the timeout to the extend input port transaction TTL params

func (*ExtendInputPortTransactionTTLParams) WithTransactionID 

func (o *ExtendInputPortTransactionTTLParams) WithTransactionID(transactionID string) *ExtendInputPortTransactionTTLParams

WithTransactionID adds the transactionID to the extend input port transaction TTL params

func (*ExtendInputPortTransactionTTLParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ExtendInputPortTransactionTTLReader 

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

ExtendInputPortTransactionTTLReader is a Reader for the ExtendInputPortTransactionTTL structure.

func (*ExtendInputPortTransactionTTLReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ExtendInputPortTransactionTTLUnauthorized 

type ExtendInputPortTransactionTTLUnauthorized struct {
}

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

Client could not be authenticated.

func NewExtendInputPortTransactionTTLUnauthorized 

func NewExtendInputPortTransactionTTLUnauthorized() *ExtendInputPortTransactionTTLUnauthorized

NewExtendInputPortTransactionTTLUnauthorized creates a ExtendInputPortTransactionTTLUnauthorized with default headers values

func (*ExtendInputPortTransactionTTLUnauthorized) Error 

func (o *ExtendInputPortTransactionTTLUnauthorized) Error() string

func (*ExtendInputPortTransactionTTLUnauthorized) IsClientError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLUnauthorized) IsClientError() bool

IsClientError returns true when this extend input port transaction Ttl unauthorized response has a 4xx status code

func (*ExtendInputPortTransactionTTLUnauthorized) IsCode added in v1.19.1 

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

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

func (*ExtendInputPortTransactionTTLUnauthorized) IsRedirect added in v1.19.1 

func (o *ExtendInputPortTransactionTTLUnauthorized) IsRedirect() bool

IsRedirect returns true when this extend input port transaction Ttl unauthorized response has a 3xx status code

func (*ExtendInputPortTransactionTTLUnauthorized) IsServerError added in v1.19.1 

func (o *ExtendInputPortTransactionTTLUnauthorized) IsServerError() bool

IsServerError returns true when this extend input port transaction Ttl unauthorized response has a 5xx status code

func (*ExtendInputPortTransactionTTLUnauthorized) IsSuccess added in v1.19.1 

func (o *ExtendInputPortTransactionTTLUnauthorized) IsSuccess() bool

IsSuccess returns true when this extend input port transaction Ttl unauthorized response has a 2xx status code

func (*ExtendInputPortTransactionTTLUnauthorized) String added in v1.19.1 

func (o *ExtendInputPortTransactionTTLUnauthorized) String() string

type ExtendOutputPortTransactionTTLBadRequest 

type ExtendOutputPortTransactionTTLBadRequest struct {
}

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

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

func NewExtendOutputPortTransactionTTLBadRequest 

func NewExtendOutputPortTransactionTTLBadRequest() *ExtendOutputPortTransactionTTLBadRequest

NewExtendOutputPortTransactionTTLBadRequest creates a ExtendOutputPortTransactionTTLBadRequest with default headers values

func (*ExtendOutputPortTransactionTTLBadRequest) Error 

func (o *ExtendOutputPortTransactionTTLBadRequest) Error() string

func (*ExtendOutputPortTransactionTTLBadRequest) IsClientError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLBadRequest) IsClientError() bool

IsClientError returns true when this extend output port transaction Ttl bad request response has a 4xx status code

func (*ExtendOutputPortTransactionTTLBadRequest) IsCode added in v1.19.1 

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

IsCode returns true when this extend output port transaction Ttl bad request response a status code equal to that given

func (*ExtendOutputPortTransactionTTLBadRequest) IsRedirect added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLBadRequest) IsRedirect() bool

IsRedirect returns true when this extend output port transaction Ttl bad request response has a 3xx status code

func (*ExtendOutputPortTransactionTTLBadRequest) IsServerError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLBadRequest) IsServerError() bool

IsServerError returns true when this extend output port transaction Ttl bad request response has a 5xx status code

func (*ExtendOutputPortTransactionTTLBadRequest) IsSuccess added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLBadRequest) IsSuccess() bool

IsSuccess returns true when this extend output port transaction Ttl bad request response has a 2xx status code

func (*ExtendOutputPortTransactionTTLBadRequest) String added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLBadRequest) String() string

type ExtendOutputPortTransactionTTLConflict 

type ExtendOutputPortTransactionTTLConflict struct {
}

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

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

func NewExtendOutputPortTransactionTTLConflict 

func NewExtendOutputPortTransactionTTLConflict() *ExtendOutputPortTransactionTTLConflict

NewExtendOutputPortTransactionTTLConflict creates a ExtendOutputPortTransactionTTLConflict with default headers values

func (*ExtendOutputPortTransactionTTLConflict) Error 

func (o *ExtendOutputPortTransactionTTLConflict) Error() string

func (*ExtendOutputPortTransactionTTLConflict) IsClientError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLConflict) IsClientError() bool

IsClientError returns true when this extend output port transaction Ttl conflict response has a 4xx status code

func (*ExtendOutputPortTransactionTTLConflict) IsCode added in v1.19.1 

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

IsCode returns true when this extend output port transaction Ttl conflict response a status code equal to that given

func (*ExtendOutputPortTransactionTTLConflict) IsRedirect added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLConflict) IsRedirect() bool

IsRedirect returns true when this extend output port transaction Ttl conflict response has a 3xx status code

func (*ExtendOutputPortTransactionTTLConflict) IsServerError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLConflict) IsServerError() bool

IsServerError returns true when this extend output port transaction Ttl conflict response has a 5xx status code

func (*ExtendOutputPortTransactionTTLConflict) IsSuccess added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLConflict) IsSuccess() bool

IsSuccess returns true when this extend output port transaction Ttl conflict response has a 2xx status code

func (*ExtendOutputPortTransactionTTLConflict) String added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLConflict) String() string

type ExtendOutputPortTransactionTTLForbidden 

type ExtendOutputPortTransactionTTLForbidden struct {
}

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

Client is not authorized to make this request.

func NewExtendOutputPortTransactionTTLForbidden 

func NewExtendOutputPortTransactionTTLForbidden() *ExtendOutputPortTransactionTTLForbidden

NewExtendOutputPortTransactionTTLForbidden creates a ExtendOutputPortTransactionTTLForbidden with default headers values

func (*ExtendOutputPortTransactionTTLForbidden) Error 

func (o *ExtendOutputPortTransactionTTLForbidden) Error() string

func (*ExtendOutputPortTransactionTTLForbidden) IsClientError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLForbidden) IsClientError() bool

IsClientError returns true when this extend output port transaction Ttl forbidden response has a 4xx status code

func (*ExtendOutputPortTransactionTTLForbidden) IsCode added in v1.19.1 

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

IsCode returns true when this extend output port transaction Ttl forbidden response a status code equal to that given

func (*ExtendOutputPortTransactionTTLForbidden) IsRedirect added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLForbidden) IsRedirect() bool

IsRedirect returns true when this extend output port transaction Ttl forbidden response has a 3xx status code

func (*ExtendOutputPortTransactionTTLForbidden) IsServerError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLForbidden) IsServerError() bool

IsServerError returns true when this extend output port transaction Ttl forbidden response has a 5xx status code

func (*ExtendOutputPortTransactionTTLForbidden) IsSuccess added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLForbidden) IsSuccess() bool

IsSuccess returns true when this extend output port transaction Ttl forbidden response has a 2xx status code

func (*ExtendOutputPortTransactionTTLForbidden) String added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLForbidden) String() string

type ExtendOutputPortTransactionTTLNotFound 

type ExtendOutputPortTransactionTTLNotFound struct {
}

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

The specified resource could not be found.

func NewExtendOutputPortTransactionTTLNotFound 

func NewExtendOutputPortTransactionTTLNotFound() *ExtendOutputPortTransactionTTLNotFound

NewExtendOutputPortTransactionTTLNotFound creates a ExtendOutputPortTransactionTTLNotFound with default headers values

func (*ExtendOutputPortTransactionTTLNotFound) Error 

func (o *ExtendOutputPortTransactionTTLNotFound) Error() string

func (*ExtendOutputPortTransactionTTLNotFound) IsClientError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLNotFound) IsClientError() bool

IsClientError returns true when this extend output port transaction Ttl not found response has a 4xx status code

func (*ExtendOutputPortTransactionTTLNotFound) IsCode added in v1.19.1 

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

IsCode returns true when this extend output port transaction Ttl not found response a status code equal to that given

func (*ExtendOutputPortTransactionTTLNotFound) IsRedirect added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLNotFound) IsRedirect() bool

IsRedirect returns true when this extend output port transaction Ttl not found response has a 3xx status code

func (*ExtendOutputPortTransactionTTLNotFound) IsServerError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLNotFound) IsServerError() bool

IsServerError returns true when this extend output port transaction Ttl not found response has a 5xx status code

func (*ExtendOutputPortTransactionTTLNotFound) IsSuccess added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLNotFound) IsSuccess() bool

IsSuccess returns true when this extend output port transaction Ttl not found response has a 2xx status code

func (*ExtendOutputPortTransactionTTLNotFound) String added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLNotFound) String() string

type ExtendOutputPortTransactionTTLOK 

type ExtendOutputPortTransactionTTLOK struct {
	Payload *models.TransactionResultEntity
}

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

successful operation

func NewExtendOutputPortTransactionTTLOK 

func NewExtendOutputPortTransactionTTLOK() *ExtendOutputPortTransactionTTLOK

NewExtendOutputPortTransactionTTLOK creates a ExtendOutputPortTransactionTTLOK with default headers values

func (*ExtendOutputPortTransactionTTLOK) Error 

func (o *ExtendOutputPortTransactionTTLOK) Error() string

func (*ExtendOutputPortTransactionTTLOK) GetPayload 

func (o *ExtendOutputPortTransactionTTLOK) GetPayload() *models.TransactionResultEntity

func (*ExtendOutputPortTransactionTTLOK) IsClientError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLOK) IsClientError() bool

IsClientError returns true when this extend output port transaction Ttl o k response has a 4xx status code

func (*ExtendOutputPortTransactionTTLOK) IsCode added in v1.19.1 

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

IsCode returns true when this extend output port transaction Ttl o k response a status code equal to that given

func (*ExtendOutputPortTransactionTTLOK) IsRedirect added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLOK) IsRedirect() bool

IsRedirect returns true when this extend output port transaction Ttl o k response has a 3xx status code

func (*ExtendOutputPortTransactionTTLOK) IsServerError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLOK) IsServerError() bool

IsServerError returns true when this extend output port transaction Ttl o k response has a 5xx status code

func (*ExtendOutputPortTransactionTTLOK) IsSuccess added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLOK) IsSuccess() bool

IsSuccess returns true when this extend output port transaction Ttl o k response has a 2xx status code

func (*ExtendOutputPortTransactionTTLOK) String added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLOK) String() string

type ExtendOutputPortTransactionTTLParams 

type ExtendOutputPortTransactionTTLParams struct {

	// PortID.
	PortID string

	// TransactionID.
	TransactionID string

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

ExtendOutputPortTransactionTTLParams contains all the parameters to send to the API endpoint 

for the extend output port transaction TTL operation.

Typically these are written to a http.Request.

func NewExtendOutputPortTransactionTTLParams 

func NewExtendOutputPortTransactionTTLParams() *ExtendOutputPortTransactionTTLParams

NewExtendOutputPortTransactionTTLParams creates a new ExtendOutputPortTransactionTTLParams 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 NewExtendOutputPortTransactionTTLParamsWithContext 

func NewExtendOutputPortTransactionTTLParamsWithContext(ctx context.Context) *ExtendOutputPortTransactionTTLParams

NewExtendOutputPortTransactionTTLParamsWithContext creates a new ExtendOutputPortTransactionTTLParams object with the ability to set a context for a request.

func NewExtendOutputPortTransactionTTLParamsWithHTTPClient 

func NewExtendOutputPortTransactionTTLParamsWithHTTPClient(client *http.Client) *ExtendOutputPortTransactionTTLParams

NewExtendOutputPortTransactionTTLParamsWithHTTPClient creates a new ExtendOutputPortTransactionTTLParams object with the ability to set a custom HTTPClient for a request.

func NewExtendOutputPortTransactionTTLParamsWithTimeout 

func NewExtendOutputPortTransactionTTLParamsWithTimeout(timeout time.Duration) *ExtendOutputPortTransactionTTLParams

NewExtendOutputPortTransactionTTLParamsWithTimeout creates a new ExtendOutputPortTransactionTTLParams object with the ability to set a timeout on a request.

func (*ExtendOutputPortTransactionTTLParams) SetContext 

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

SetContext adds the context to the extend output port transaction TTL params

func (*ExtendOutputPortTransactionTTLParams) SetDefaults 

func (o *ExtendOutputPortTransactionTTLParams) SetDefaults()

SetDefaults hydrates default values in the extend output port transaction TTL params (not the query body).

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

func (*ExtendOutputPortTransactionTTLParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the extend output port transaction TTL params

func (*ExtendOutputPortTransactionTTLParams) SetPortID 

func (o *ExtendOutputPortTransactionTTLParams) SetPortID(portID string)

SetPortID adds the portId to the extend output port transaction TTL params

func (*ExtendOutputPortTransactionTTLParams) SetTimeout 

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

SetTimeout adds the timeout to the extend output port transaction TTL params

func (*ExtendOutputPortTransactionTTLParams) SetTransactionID 

func (o *ExtendOutputPortTransactionTTLParams) SetTransactionID(transactionID string)

SetTransactionID adds the transactionId to the extend output port transaction TTL params

func (*ExtendOutputPortTransactionTTLParams) WithContext 

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

WithContext adds the context to the extend output port transaction TTL params

func (*ExtendOutputPortTransactionTTLParams) WithDefaults 

func (o *ExtendOutputPortTransactionTTLParams) WithDefaults() *ExtendOutputPortTransactionTTLParams

WithDefaults hydrates default values in the extend output port transaction TTL params (not the query body).

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

func (*ExtendOutputPortTransactionTTLParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the extend output port transaction TTL params

func (*ExtendOutputPortTransactionTTLParams) WithPortID 

func (o *ExtendOutputPortTransactionTTLParams) WithPortID(portID string) *ExtendOutputPortTransactionTTLParams

WithPortID adds the portID to the extend output port transaction TTL params

func (*ExtendOutputPortTransactionTTLParams) WithTimeout 

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

WithTimeout adds the timeout to the extend output port transaction TTL params

func (*ExtendOutputPortTransactionTTLParams) WithTransactionID 

func (o *ExtendOutputPortTransactionTTLParams) WithTransactionID(transactionID string) *ExtendOutputPortTransactionTTLParams

WithTransactionID adds the transactionID to the extend output port transaction TTL params

func (*ExtendOutputPortTransactionTTLParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ExtendOutputPortTransactionTTLReader 

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

ExtendOutputPortTransactionTTLReader is a Reader for the ExtendOutputPortTransactionTTL structure.

func (*ExtendOutputPortTransactionTTLReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ExtendOutputPortTransactionTTLServiceUnavailable 

type ExtendOutputPortTransactionTTLServiceUnavailable struct {
}

ExtendOutputPortTransactionTTLServiceUnavailable describes a response with status code 503, with default header values.

NiFi instance is not ready for serving request, or temporarily overloaded. Retrying the same request later may be successful

func NewExtendOutputPortTransactionTTLServiceUnavailable 

func NewExtendOutputPortTransactionTTLServiceUnavailable() *ExtendOutputPortTransactionTTLServiceUnavailable

NewExtendOutputPortTransactionTTLServiceUnavailable creates a ExtendOutputPortTransactionTTLServiceUnavailable with default headers values

func (*ExtendOutputPortTransactionTTLServiceUnavailable) Error 

func (o *ExtendOutputPortTransactionTTLServiceUnavailable) Error() string

func (*ExtendOutputPortTransactionTTLServiceUnavailable) IsClientError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLServiceUnavailable) IsClientError() bool

IsClientError returns true when this extend output port transaction Ttl service unavailable response has a 4xx status code

func (*ExtendOutputPortTransactionTTLServiceUnavailable) IsCode added in v1.19.1 

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

IsCode returns true when this extend output port transaction Ttl service unavailable response a status code equal to that given

func (*ExtendOutputPortTransactionTTLServiceUnavailable) IsRedirect added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLServiceUnavailable) IsRedirect() bool

IsRedirect returns true when this extend output port transaction Ttl service unavailable response has a 3xx status code

func (*ExtendOutputPortTransactionTTLServiceUnavailable) IsServerError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLServiceUnavailable) IsServerError() bool

IsServerError returns true when this extend output port transaction Ttl service unavailable response has a 5xx status code

func (*ExtendOutputPortTransactionTTLServiceUnavailable) IsSuccess added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLServiceUnavailable) IsSuccess() bool

IsSuccess returns true when this extend output port transaction Ttl service unavailable response has a 2xx status code

func (*ExtendOutputPortTransactionTTLServiceUnavailable) String added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLServiceUnavailable) String() string

type ExtendOutputPortTransactionTTLUnauthorized 

type ExtendOutputPortTransactionTTLUnauthorized struct {
}

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

Client could not be authenticated.

func NewExtendOutputPortTransactionTTLUnauthorized 

func NewExtendOutputPortTransactionTTLUnauthorized() *ExtendOutputPortTransactionTTLUnauthorized

NewExtendOutputPortTransactionTTLUnauthorized creates a ExtendOutputPortTransactionTTLUnauthorized with default headers values

func (*ExtendOutputPortTransactionTTLUnauthorized) Error 

func (o *ExtendOutputPortTransactionTTLUnauthorized) Error() string

func (*ExtendOutputPortTransactionTTLUnauthorized) IsClientError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLUnauthorized) IsClientError() bool

IsClientError returns true when this extend output port transaction Ttl unauthorized response has a 4xx status code

func (*ExtendOutputPortTransactionTTLUnauthorized) IsCode added in v1.19.1 

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

IsCode returns true when this extend output port transaction Ttl unauthorized response a status code equal to that given

func (*ExtendOutputPortTransactionTTLUnauthorized) IsRedirect added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLUnauthorized) IsRedirect() bool

IsRedirect returns true when this extend output port transaction Ttl unauthorized response has a 3xx status code

func (*ExtendOutputPortTransactionTTLUnauthorized) IsServerError added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLUnauthorized) IsServerError() bool

IsServerError returns true when this extend output port transaction Ttl unauthorized response has a 5xx status code

func (*ExtendOutputPortTransactionTTLUnauthorized) IsSuccess added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLUnauthorized) IsSuccess() bool

IsSuccess returns true when this extend output port transaction Ttl unauthorized response has a 2xx status code

func (*ExtendOutputPortTransactionTTLUnauthorized) String added in v1.19.1 

func (o *ExtendOutputPortTransactionTTLUnauthorized) String() string

type ReceiveFlowFilesBadRequest 

type ReceiveFlowFilesBadRequest struct {
}

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

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

func NewReceiveFlowFilesBadRequest 

func NewReceiveFlowFilesBadRequest() *ReceiveFlowFilesBadRequest

NewReceiveFlowFilesBadRequest creates a ReceiveFlowFilesBadRequest with default headers values

func (*ReceiveFlowFilesBadRequest) Error 

func (o *ReceiveFlowFilesBadRequest) Error() string

func (*ReceiveFlowFilesBadRequest) IsClientError added in v1.19.1 

func (o *ReceiveFlowFilesBadRequest) IsClientError() bool

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

func (*ReceiveFlowFilesBadRequest) IsCode added in v1.19.1 

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

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

func (*ReceiveFlowFilesBadRequest) IsRedirect added in v1.19.1 

func (o *ReceiveFlowFilesBadRequest) IsRedirect() bool

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

func (*ReceiveFlowFilesBadRequest) IsServerError added in v1.19.1 

func (o *ReceiveFlowFilesBadRequest) IsServerError() bool

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

func (*ReceiveFlowFilesBadRequest) IsSuccess added in v1.19.1 

func (o *ReceiveFlowFilesBadRequest) IsSuccess() bool

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

func (*ReceiveFlowFilesBadRequest) String added in v1.19.1 

func (o *ReceiveFlowFilesBadRequest) String() string

type ReceiveFlowFilesConflict 

type ReceiveFlowFilesConflict struct {
}

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

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

func NewReceiveFlowFilesConflict 

func NewReceiveFlowFilesConflict() *ReceiveFlowFilesConflict

NewReceiveFlowFilesConflict creates a ReceiveFlowFilesConflict with default headers values

func (*ReceiveFlowFilesConflict) Error 

func (o *ReceiveFlowFilesConflict) Error() string

func (*ReceiveFlowFilesConflict) IsClientError added in v1.19.1 

func (o *ReceiveFlowFilesConflict) IsClientError() bool

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

func (*ReceiveFlowFilesConflict) IsCode added in v1.19.1 

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

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

func (*ReceiveFlowFilesConflict) IsRedirect added in v1.19.1 

func (o *ReceiveFlowFilesConflict) IsRedirect() bool

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

func (*ReceiveFlowFilesConflict) IsServerError added in v1.19.1 

func (o *ReceiveFlowFilesConflict) IsServerError() bool

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

func (*ReceiveFlowFilesConflict) IsSuccess added in v1.19.1 

func (o *ReceiveFlowFilesConflict) IsSuccess() bool

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

func (*ReceiveFlowFilesConflict) String added in v1.19.1 

func (o *ReceiveFlowFilesConflict) String() string

type ReceiveFlowFilesForbidden 

type ReceiveFlowFilesForbidden struct {
}

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

Client is not authorized to make this request.

func NewReceiveFlowFilesForbidden 

func NewReceiveFlowFilesForbidden() *ReceiveFlowFilesForbidden

NewReceiveFlowFilesForbidden creates a ReceiveFlowFilesForbidden with default headers values

func (*ReceiveFlowFilesForbidden) Error 

func (o *ReceiveFlowFilesForbidden) Error() string

func (*ReceiveFlowFilesForbidden) IsClientError added in v1.19.1 

func (o *ReceiveFlowFilesForbidden) IsClientError() bool

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

func (*ReceiveFlowFilesForbidden) IsCode added in v1.19.1 

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

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

func (*ReceiveFlowFilesForbidden) IsRedirect added in v1.19.1 

func (o *ReceiveFlowFilesForbidden) IsRedirect() bool

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

func (*ReceiveFlowFilesForbidden) IsServerError added in v1.19.1 

func (o *ReceiveFlowFilesForbidden) IsServerError() bool

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

func (*ReceiveFlowFilesForbidden) IsSuccess added in v1.19.1 

func (o *ReceiveFlowFilesForbidden) IsSuccess() bool

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

func (*ReceiveFlowFilesForbidden) String added in v1.19.1 

func (o *ReceiveFlowFilesForbidden) String() string

type ReceiveFlowFilesNotFound 

type ReceiveFlowFilesNotFound struct {
}

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

The specified resource could not be found.

func NewReceiveFlowFilesNotFound 

func NewReceiveFlowFilesNotFound() *ReceiveFlowFilesNotFound

NewReceiveFlowFilesNotFound creates a ReceiveFlowFilesNotFound with default headers values

func (*ReceiveFlowFilesNotFound) Error 

func (o *ReceiveFlowFilesNotFound) Error() string

func (*ReceiveFlowFilesNotFound) IsClientError added in v1.19.1 

func (o *ReceiveFlowFilesNotFound) IsClientError() bool

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

func (*ReceiveFlowFilesNotFound) IsCode added in v1.19.1 

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

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

func (*ReceiveFlowFilesNotFound) IsRedirect added in v1.19.1 

func (o *ReceiveFlowFilesNotFound) IsRedirect() bool

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

func (*ReceiveFlowFilesNotFound) IsServerError added in v1.19.1 

func (o *ReceiveFlowFilesNotFound) IsServerError() bool

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

func (*ReceiveFlowFilesNotFound) IsSuccess added in v1.19.1 

func (o *ReceiveFlowFilesNotFound) IsSuccess() bool

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

func (*ReceiveFlowFilesNotFound) String added in v1.19.1 

func (o *ReceiveFlowFilesNotFound) String() string

type ReceiveFlowFilesOK 

type ReceiveFlowFilesOK struct {
	Payload string
}

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

successful operation

func NewReceiveFlowFilesOK 

func NewReceiveFlowFilesOK() *ReceiveFlowFilesOK

NewReceiveFlowFilesOK creates a ReceiveFlowFilesOK with default headers values

func (*ReceiveFlowFilesOK) Error 

func (o *ReceiveFlowFilesOK) Error() string

func (*ReceiveFlowFilesOK) GetPayload 

func (o *ReceiveFlowFilesOK) GetPayload() string

func (*ReceiveFlowFilesOK) IsClientError added in v1.19.1 

func (o *ReceiveFlowFilesOK) IsClientError() bool

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

func (*ReceiveFlowFilesOK) IsCode added in v1.19.1 

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

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

func (*ReceiveFlowFilesOK) IsRedirect added in v1.19.1 

func (o *ReceiveFlowFilesOK) IsRedirect() bool

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

func (*ReceiveFlowFilesOK) IsServerError added in v1.19.1 

func (o *ReceiveFlowFilesOK) IsServerError() bool

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

func (*ReceiveFlowFilesOK) IsSuccess added in v1.19.1 

func (o *ReceiveFlowFilesOK) IsSuccess() bool

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

func (*ReceiveFlowFilesOK) String added in v1.19.1 

func (o *ReceiveFlowFilesOK) String() string

type ReceiveFlowFilesParams 

type ReceiveFlowFilesParams struct {

	/* PortID.

	   The input port id.
	*/
	PortID string

	// TransactionID.
	TransactionID string

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

ReceiveFlowFilesParams contains all the parameters to send to the API endpoint 

for the receive flow files operation.

Typically these are written to a http.Request.

func NewReceiveFlowFilesParams 

func NewReceiveFlowFilesParams() *ReceiveFlowFilesParams

NewReceiveFlowFilesParams creates a new ReceiveFlowFilesParams 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 NewReceiveFlowFilesParamsWithContext 

func NewReceiveFlowFilesParamsWithContext(ctx context.Context) *ReceiveFlowFilesParams

NewReceiveFlowFilesParamsWithContext creates a new ReceiveFlowFilesParams object with the ability to set a context for a request.

func NewReceiveFlowFilesParamsWithHTTPClient 

func NewReceiveFlowFilesParamsWithHTTPClient(client *http.Client) *ReceiveFlowFilesParams

NewReceiveFlowFilesParamsWithHTTPClient creates a new ReceiveFlowFilesParams object with the ability to set a custom HTTPClient for a request.

func NewReceiveFlowFilesParamsWithTimeout 

func NewReceiveFlowFilesParamsWithTimeout(timeout time.Duration) *ReceiveFlowFilesParams

NewReceiveFlowFilesParamsWithTimeout creates a new ReceiveFlowFilesParams object with the ability to set a timeout on a request.

func (*ReceiveFlowFilesParams) SetContext 

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

SetContext adds the context to the receive flow files params

func (*ReceiveFlowFilesParams) SetDefaults 

func (o *ReceiveFlowFilesParams) SetDefaults()

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

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

func (*ReceiveFlowFilesParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the receive flow files params

func (*ReceiveFlowFilesParams) SetPortID 

func (o *ReceiveFlowFilesParams) SetPortID(portID string)

SetPortID adds the portId to the receive flow files params

func (*ReceiveFlowFilesParams) SetTimeout 

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

SetTimeout adds the timeout to the receive flow files params

func (*ReceiveFlowFilesParams) SetTransactionID 

func (o *ReceiveFlowFilesParams) SetTransactionID(transactionID string)

SetTransactionID adds the transactionId to the receive flow files params

func (*ReceiveFlowFilesParams) WithContext 

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

WithContext adds the context to the receive flow files params

func (*ReceiveFlowFilesParams) WithDefaults 

func (o *ReceiveFlowFilesParams) WithDefaults() *ReceiveFlowFilesParams

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

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

func (*ReceiveFlowFilesParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the receive flow files params

func (*ReceiveFlowFilesParams) WithPortID 

func (o *ReceiveFlowFilesParams) WithPortID(portID string) *ReceiveFlowFilesParams

WithPortID adds the portID to the receive flow files params

func (*ReceiveFlowFilesParams) WithTimeout 

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

WithTimeout adds the timeout to the receive flow files params

func (*ReceiveFlowFilesParams) WithTransactionID 

func (o *ReceiveFlowFilesParams) WithTransactionID(transactionID string) *ReceiveFlowFilesParams

WithTransactionID adds the transactionID to the receive flow files params

func (*ReceiveFlowFilesParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ReceiveFlowFilesReader 

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

ReceiveFlowFilesReader is a Reader for the ReceiveFlowFiles structure.

func (*ReceiveFlowFilesReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ReceiveFlowFilesServiceUnavailable 

type ReceiveFlowFilesServiceUnavailable struct {
}

ReceiveFlowFilesServiceUnavailable describes a response with status code 503, with default header values.

NiFi instance is not ready for serving request, or temporarily overloaded. Retrying the same request later may be successful

func NewReceiveFlowFilesServiceUnavailable 

func NewReceiveFlowFilesServiceUnavailable() *ReceiveFlowFilesServiceUnavailable

NewReceiveFlowFilesServiceUnavailable creates a ReceiveFlowFilesServiceUnavailable with default headers values

func (*ReceiveFlowFilesServiceUnavailable) Error 

func (o *ReceiveFlowFilesServiceUnavailable) Error() string

func (*ReceiveFlowFilesServiceUnavailable) IsClientError added in v1.19.1 

func (o *ReceiveFlowFilesServiceUnavailable) IsClientError() bool

IsClientError returns true when this receive flow files service unavailable response has a 4xx status code

func (*ReceiveFlowFilesServiceUnavailable) IsCode added in v1.19.1 

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

IsCode returns true when this receive flow files service unavailable response a status code equal to that given

func (*ReceiveFlowFilesServiceUnavailable) IsRedirect added in v1.19.1 

func (o *ReceiveFlowFilesServiceUnavailable) IsRedirect() bool

IsRedirect returns true when this receive flow files service unavailable response has a 3xx status code

func (*ReceiveFlowFilesServiceUnavailable) IsServerError added in v1.19.1 

func (o *ReceiveFlowFilesServiceUnavailable) IsServerError() bool

IsServerError returns true when this receive flow files service unavailable response has a 5xx status code

func (*ReceiveFlowFilesServiceUnavailable) IsSuccess added in v1.19.1 

func (o *ReceiveFlowFilesServiceUnavailable) IsSuccess() bool

IsSuccess returns true when this receive flow files service unavailable response has a 2xx status code

func (*ReceiveFlowFilesServiceUnavailable) String added in v1.19.1 

func (o *ReceiveFlowFilesServiceUnavailable) String() string

type ReceiveFlowFilesUnauthorized 

type ReceiveFlowFilesUnauthorized struct {
}

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

Client could not be authenticated.

func NewReceiveFlowFilesUnauthorized 

func NewReceiveFlowFilesUnauthorized() *ReceiveFlowFilesUnauthorized

NewReceiveFlowFilesUnauthorized creates a ReceiveFlowFilesUnauthorized with default headers values

func (*ReceiveFlowFilesUnauthorized) Error 

func (o *ReceiveFlowFilesUnauthorized) Error() string

func (*ReceiveFlowFilesUnauthorized) IsClientError added in v1.19.1 

func (o *ReceiveFlowFilesUnauthorized) IsClientError() bool

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

func (*ReceiveFlowFilesUnauthorized) IsCode added in v1.19.1 

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

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

func (*ReceiveFlowFilesUnauthorized) IsRedirect added in v1.19.1 

func (o *ReceiveFlowFilesUnauthorized) IsRedirect() bool

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

func (*ReceiveFlowFilesUnauthorized) IsServerError added in v1.19.1 

func (o *ReceiveFlowFilesUnauthorized) IsServerError() bool

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

func (*ReceiveFlowFilesUnauthorized) IsSuccess added in v1.19.1 

func (o *ReceiveFlowFilesUnauthorized) IsSuccess() bool

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

func (*ReceiveFlowFilesUnauthorized) String added in v1.19.1 

func (o *ReceiveFlowFilesUnauthorized) String() string

type TransferFlowFilesBadRequest 

type TransferFlowFilesBadRequest struct {
}

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

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

func NewTransferFlowFilesBadRequest 

func NewTransferFlowFilesBadRequest() *TransferFlowFilesBadRequest

NewTransferFlowFilesBadRequest creates a TransferFlowFilesBadRequest with default headers values

func (*TransferFlowFilesBadRequest) Error 

func (o *TransferFlowFilesBadRequest) Error() string

func (*TransferFlowFilesBadRequest) IsClientError added in v1.19.1 

func (o *TransferFlowFilesBadRequest) IsClientError() bool

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

func (*TransferFlowFilesBadRequest) IsCode added in v1.19.1 

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

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

func (*TransferFlowFilesBadRequest) IsRedirect added in v1.19.1 

func (o *TransferFlowFilesBadRequest) IsRedirect() bool

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

func (*TransferFlowFilesBadRequest) IsServerError added in v1.19.1 

func (o *TransferFlowFilesBadRequest) IsServerError() bool

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

func (*TransferFlowFilesBadRequest) IsSuccess added in v1.19.1 

func (o *TransferFlowFilesBadRequest) IsSuccess() bool

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

func (*TransferFlowFilesBadRequest) String added in v1.19.1 

func (o *TransferFlowFilesBadRequest) String() string

type TransferFlowFilesConflict 

type TransferFlowFilesConflict struct {
}

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

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

func NewTransferFlowFilesConflict 

func NewTransferFlowFilesConflict() *TransferFlowFilesConflict

NewTransferFlowFilesConflict creates a TransferFlowFilesConflict with default headers values

func (*TransferFlowFilesConflict) Error 

func (o *TransferFlowFilesConflict) Error() string

func (*TransferFlowFilesConflict) IsClientError added in v1.19.1 

func (o *TransferFlowFilesConflict) IsClientError() bool

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

func (*TransferFlowFilesConflict) IsCode added in v1.19.1 

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

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

func (*TransferFlowFilesConflict) IsRedirect added in v1.19.1 

func (o *TransferFlowFilesConflict) IsRedirect() bool

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

func (*TransferFlowFilesConflict) IsServerError added in v1.19.1 

func (o *TransferFlowFilesConflict) IsServerError() bool

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

func (*TransferFlowFilesConflict) IsSuccess added in v1.19.1 

func (o *TransferFlowFilesConflict) IsSuccess() bool

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

func (*TransferFlowFilesConflict) String added in v1.19.1 

func (o *TransferFlowFilesConflict) String() string

type TransferFlowFilesForbidden 

type TransferFlowFilesForbidden struct {
}

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

Client is not authorized to make this request.

func NewTransferFlowFilesForbidden 

func NewTransferFlowFilesForbidden() *TransferFlowFilesForbidden

NewTransferFlowFilesForbidden creates a TransferFlowFilesForbidden with default headers values

func (*TransferFlowFilesForbidden) Error 

func (o *TransferFlowFilesForbidden) Error() string

func (*TransferFlowFilesForbidden) IsClientError added in v1.19.1 

func (o *TransferFlowFilesForbidden) IsClientError() bool

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

func (*TransferFlowFilesForbidden) IsCode added in v1.19.1 

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

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

func (*TransferFlowFilesForbidden) IsRedirect added in v1.19.1 

func (o *TransferFlowFilesForbidden) IsRedirect() bool

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

func (*TransferFlowFilesForbidden) IsServerError added in v1.19.1 

func (o *TransferFlowFilesForbidden) IsServerError() bool

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

func (*TransferFlowFilesForbidden) IsSuccess added in v1.19.1 

func (o *TransferFlowFilesForbidden) IsSuccess() bool

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

func (*TransferFlowFilesForbidden) String added in v1.19.1 

func (o *TransferFlowFilesForbidden) String() string

type TransferFlowFilesNotFound 

type TransferFlowFilesNotFound struct {
}

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

The specified resource could not be found.

func NewTransferFlowFilesNotFound 

func NewTransferFlowFilesNotFound() *TransferFlowFilesNotFound

NewTransferFlowFilesNotFound creates a TransferFlowFilesNotFound with default headers values

func (*TransferFlowFilesNotFound) Error 

func (o *TransferFlowFilesNotFound) Error() string

func (*TransferFlowFilesNotFound) IsClientError added in v1.19.1 

func (o *TransferFlowFilesNotFound) IsClientError() bool

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

func (*TransferFlowFilesNotFound) IsCode added in v1.19.1 

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

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

func (*TransferFlowFilesNotFound) IsRedirect added in v1.19.1 

func (o *TransferFlowFilesNotFound) IsRedirect() bool

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

func (*TransferFlowFilesNotFound) IsServerError added in v1.19.1 

func (o *TransferFlowFilesNotFound) IsServerError() bool

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

func (*TransferFlowFilesNotFound) IsSuccess added in v1.19.1 

func (o *TransferFlowFilesNotFound) IsSuccess() bool

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

func (*TransferFlowFilesNotFound) String added in v1.19.1 

func (o *TransferFlowFilesNotFound) String() string

type TransferFlowFilesOK 

type TransferFlowFilesOK struct {
	Payload models.StreamingOutput
}

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

There is no flow file to return.

func NewTransferFlowFilesOK 

func NewTransferFlowFilesOK() *TransferFlowFilesOK

NewTransferFlowFilesOK creates a TransferFlowFilesOK with default headers values

func (*TransferFlowFilesOK) Error 

func (o *TransferFlowFilesOK) Error() string

func (*TransferFlowFilesOK) GetPayload 

func (o *TransferFlowFilesOK) GetPayload() models.StreamingOutput

func (*TransferFlowFilesOK) IsClientError added in v1.19.1 

func (o *TransferFlowFilesOK) IsClientError() bool

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

func (*TransferFlowFilesOK) IsCode added in v1.19.1 

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

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

func (*TransferFlowFilesOK) IsRedirect added in v1.19.1 

func (o *TransferFlowFilesOK) IsRedirect() bool

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

func (*TransferFlowFilesOK) IsServerError added in v1.19.1 

func (o *TransferFlowFilesOK) IsServerError() bool

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

func (*TransferFlowFilesOK) IsSuccess added in v1.19.1 

func (o *TransferFlowFilesOK) IsSuccess() bool

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

func (*TransferFlowFilesOK) String added in v1.19.1 

func (o *TransferFlowFilesOK) String() string

type TransferFlowFilesParams 

type TransferFlowFilesParams struct {

	/* PortID.

	   The output port id.
	*/
	PortID string

	// TransactionID.
	TransactionID string

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

TransferFlowFilesParams contains all the parameters to send to the API endpoint 

for the transfer flow files operation.

Typically these are written to a http.Request.

func NewTransferFlowFilesParams 

func NewTransferFlowFilesParams() *TransferFlowFilesParams

NewTransferFlowFilesParams creates a new TransferFlowFilesParams 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 NewTransferFlowFilesParamsWithContext 

func NewTransferFlowFilesParamsWithContext(ctx context.Context) *TransferFlowFilesParams

NewTransferFlowFilesParamsWithContext creates a new TransferFlowFilesParams object with the ability to set a context for a request.

func NewTransferFlowFilesParamsWithHTTPClient 

func NewTransferFlowFilesParamsWithHTTPClient(client *http.Client) *TransferFlowFilesParams

NewTransferFlowFilesParamsWithHTTPClient creates a new TransferFlowFilesParams object with the ability to set a custom HTTPClient for a request.

func NewTransferFlowFilesParamsWithTimeout 

func NewTransferFlowFilesParamsWithTimeout(timeout time.Duration) *TransferFlowFilesParams

NewTransferFlowFilesParamsWithTimeout creates a new TransferFlowFilesParams object with the ability to set a timeout on a request.

func (*TransferFlowFilesParams) SetContext 

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

SetContext adds the context to the transfer flow files params

func (*TransferFlowFilesParams) SetDefaults 

func (o *TransferFlowFilesParams) SetDefaults()

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

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

func (*TransferFlowFilesParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the transfer flow files params

func (*TransferFlowFilesParams) SetPortID 

func (o *TransferFlowFilesParams) SetPortID(portID string)

SetPortID adds the portId to the transfer flow files params

func (*TransferFlowFilesParams) SetTimeout 

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

SetTimeout adds the timeout to the transfer flow files params

func (*TransferFlowFilesParams) SetTransactionID 

func (o *TransferFlowFilesParams) SetTransactionID(transactionID string)

SetTransactionID adds the transactionId to the transfer flow files params

func (*TransferFlowFilesParams) WithContext 

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

WithContext adds the context to the transfer flow files params

func (*TransferFlowFilesParams) WithDefaults 

func (o *TransferFlowFilesParams) WithDefaults() *TransferFlowFilesParams

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

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

func (*TransferFlowFilesParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the transfer flow files params

func (*TransferFlowFilesParams) WithPortID 

func (o *TransferFlowFilesParams) WithPortID(portID string) *TransferFlowFilesParams

WithPortID adds the portID to the transfer flow files params

func (*TransferFlowFilesParams) WithTimeout 

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

WithTimeout adds the timeout to the transfer flow files params

func (*TransferFlowFilesParams) WithTransactionID 

func (o *TransferFlowFilesParams) WithTransactionID(transactionID string) *TransferFlowFilesParams

WithTransactionID adds the transactionID to the transfer flow files params

func (*TransferFlowFilesParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type TransferFlowFilesReader 

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

TransferFlowFilesReader is a Reader for the TransferFlowFiles structure.

func (*TransferFlowFilesReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type TransferFlowFilesServiceUnavailable 

type TransferFlowFilesServiceUnavailable struct {
}

TransferFlowFilesServiceUnavailable describes a response with status code 503, with default header values.

NiFi instance is not ready for serving request, or temporarily overloaded. Retrying the same request later may be successful

func NewTransferFlowFilesServiceUnavailable 

func NewTransferFlowFilesServiceUnavailable() *TransferFlowFilesServiceUnavailable

NewTransferFlowFilesServiceUnavailable creates a TransferFlowFilesServiceUnavailable with default headers values

func (*TransferFlowFilesServiceUnavailable) Error 

func (o *TransferFlowFilesServiceUnavailable) Error() string

func (*TransferFlowFilesServiceUnavailable) IsClientError added in v1.19.1 

func (o *TransferFlowFilesServiceUnavailable) IsClientError() bool

IsClientError returns true when this transfer flow files service unavailable response has a 4xx status code

func (*TransferFlowFilesServiceUnavailable) IsCode added in v1.19.1 

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

IsCode returns true when this transfer flow files service unavailable response a status code equal to that given

func (*TransferFlowFilesServiceUnavailable) IsRedirect added in v1.19.1 

func (o *TransferFlowFilesServiceUnavailable) IsRedirect() bool

IsRedirect returns true when this transfer flow files service unavailable response has a 3xx status code

func (*TransferFlowFilesServiceUnavailable) IsServerError added in v1.19.1 

func (o *TransferFlowFilesServiceUnavailable) IsServerError() bool

IsServerError returns true when this transfer flow files service unavailable response has a 5xx status code

func (*TransferFlowFilesServiceUnavailable) IsSuccess added in v1.19.1 

func (o *TransferFlowFilesServiceUnavailable) IsSuccess() bool

IsSuccess returns true when this transfer flow files service unavailable response has a 2xx status code

func (*TransferFlowFilesServiceUnavailable) String added in v1.19.1 

func (o *TransferFlowFilesServiceUnavailable) String() string

type TransferFlowFilesUnauthorized 

type TransferFlowFilesUnauthorized struct {
}

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

Client could not be authenticated.

func NewTransferFlowFilesUnauthorized 

func NewTransferFlowFilesUnauthorized() *TransferFlowFilesUnauthorized

NewTransferFlowFilesUnauthorized creates a TransferFlowFilesUnauthorized with default headers values

func (*TransferFlowFilesUnauthorized) Error 

func (o *TransferFlowFilesUnauthorized) Error() string

func (*TransferFlowFilesUnauthorized) IsClientError added in v1.19.1 

func (o *TransferFlowFilesUnauthorized) IsClientError() bool

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

func (*TransferFlowFilesUnauthorized) IsCode added in v1.19.1 

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

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

func (*TransferFlowFilesUnauthorized) IsRedirect added in v1.19.1 

func (o *TransferFlowFilesUnauthorized) IsRedirect() bool

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

func (*TransferFlowFilesUnauthorized) IsServerError added in v1.19.1 

func (o *TransferFlowFilesUnauthorized) IsServerError() bool

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

func (*TransferFlowFilesUnauthorized) IsSuccess added in v1.19.1 

func (o *TransferFlowFilesUnauthorized) IsSuccess() bool

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

func (*TransferFlowFilesUnauthorized) String added in v1.19.1 

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