plugins_system_pipelines_pipeline

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 28, 2018 License: BSD-3-Clause Imports: 10 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 plugins org graylog plugins pipelineprocessor system pipelines pipeline API

func New 

func New(transport runtime.ClientTransport, formats strfmt.Registry) *Client

New creates a new plugins org graylog plugins pipelineprocessor system pipelines pipeline API client.

func (*Client) ConnectPipelines 

func (a *Client) ConnectPipelines(params *ConnectPipelinesParams, authInfo runtime.ClientAuthInfoWriter) (*ConnectPipelinesOK, error)

ConnectPipelines connects processing pipelines to a stream

func (*Client) ConnectStreams 

func (a *Client) ConnectStreams(params *ConnectStreamsParams, authInfo runtime.ClientAuthInfoWriter) (*ConnectStreamsOK, error)

ConnectStreams connects streams to a processing pipeline

func (*Client) GetPipelinesForStream 

func (a *Client) GetPipelinesForStream(params *GetPipelinesForStreamParams, authInfo runtime.ClientAuthInfoWriter) (*GetPipelinesForStreamOK, error)

GetPipelinesForStream gets pipeline connections for the given stream

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

type ConnectPipelinesOK 

type ConnectPipelinesOK struct {
	Payload *models.PipelineConnections
}

ConnectPipelinesOK handles this case with default header values.

No response was specified

func NewConnectPipelinesOK 

func NewConnectPipelinesOK() *ConnectPipelinesOK

NewConnectPipelinesOK creates a ConnectPipelinesOK with default headers values

func (*ConnectPipelinesOK) Error 

func (o *ConnectPipelinesOK) Error() string

type ConnectPipelinesParams 

type ConnectPipelinesParams struct {

	/*JSONBody*/
	JSONBody *models.PipelineConnections

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

ConnectPipelinesParams contains all the parameters to send to the API endpoint for the connect pipelines operation typically these are written to a http.Request

func NewConnectPipelinesParams 

func NewConnectPipelinesParams() *ConnectPipelinesParams

NewConnectPipelinesParams creates a new ConnectPipelinesParams object with the default values initialized.

func NewConnectPipelinesParamsWithContext 

func NewConnectPipelinesParamsWithContext(ctx context.Context) *ConnectPipelinesParams

NewConnectPipelinesParamsWithContext creates a new ConnectPipelinesParams object with the default values initialized, and the ability to set a context for a request

func NewConnectPipelinesParamsWithHTTPClient 

func NewConnectPipelinesParamsWithHTTPClient(client *http.Client) *ConnectPipelinesParams

NewConnectPipelinesParamsWithHTTPClient creates a new ConnectPipelinesParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewConnectPipelinesParamsWithTimeout 

func NewConnectPipelinesParamsWithTimeout(timeout time.Duration) *ConnectPipelinesParams

NewConnectPipelinesParamsWithTimeout creates a new ConnectPipelinesParams object with the default values initialized, and the ability to set a timeout on a request

func (*ConnectPipelinesParams) SetContext 

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

SetContext adds the context to the connect pipelines params

func (*ConnectPipelinesParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the connect pipelines params

func (*ConnectPipelinesParams) SetJSONBody 

func (o *ConnectPipelinesParams) SetJSONBody(jSONBody *models.PipelineConnections)

SetJSONBody adds the jsonBody to the connect pipelines params

func (*ConnectPipelinesParams) SetTimeout 

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

SetTimeout adds the timeout to the connect pipelines params

func (*ConnectPipelinesParams) WithContext 

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

WithContext adds the context to the connect pipelines params

func (*ConnectPipelinesParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the connect pipelines params

func (*ConnectPipelinesParams) WithJSONBody 

func (o *ConnectPipelinesParams) WithJSONBody(jSONBody *models.PipelineConnections) *ConnectPipelinesParams

WithJSONBody adds the jSONBody to the connect pipelines params

func (*ConnectPipelinesParams) WithTimeout 

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

WithTimeout adds the timeout to the connect pipelines params

func (*ConnectPipelinesParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ConnectPipelinesReader 

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

ConnectPipelinesReader is a Reader for the ConnectPipelines structure.

func (*ConnectPipelinesReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ConnectStreamsOK 

type ConnectStreamsOK struct {
	Payload []interface{}
}

ConnectStreamsOK handles this case with default header values.

No response was specified

func NewConnectStreamsOK 

func NewConnectStreamsOK() *ConnectStreamsOK

NewConnectStreamsOK creates a ConnectStreamsOK with default headers values

func (*ConnectStreamsOK) Error 

func (o *ConnectStreamsOK) Error() string

type ConnectStreamsParams 

type ConnectStreamsParams struct {

	/*JSONBody*/
	JSONBody *models.PipelineReverseConnections

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

ConnectStreamsParams contains all the parameters to send to the API endpoint for the connect streams operation typically these are written to a http.Request

func NewConnectStreamsParams 

func NewConnectStreamsParams() *ConnectStreamsParams

NewConnectStreamsParams creates a new ConnectStreamsParams object with the default values initialized.

func NewConnectStreamsParamsWithContext 

func NewConnectStreamsParamsWithContext(ctx context.Context) *ConnectStreamsParams

NewConnectStreamsParamsWithContext creates a new ConnectStreamsParams object with the default values initialized, and the ability to set a context for a request

func NewConnectStreamsParamsWithHTTPClient 

func NewConnectStreamsParamsWithHTTPClient(client *http.Client) *ConnectStreamsParams

NewConnectStreamsParamsWithHTTPClient creates a new ConnectStreamsParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewConnectStreamsParamsWithTimeout 

func NewConnectStreamsParamsWithTimeout(timeout time.Duration) *ConnectStreamsParams

NewConnectStreamsParamsWithTimeout creates a new ConnectStreamsParams object with the default values initialized, and the ability to set a timeout on a request

func (*ConnectStreamsParams) SetContext 

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

SetContext adds the context to the connect streams params

func (*ConnectStreamsParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the connect streams params

func (*ConnectStreamsParams) SetJSONBody 

func (o *ConnectStreamsParams) SetJSONBody(jSONBody *models.PipelineReverseConnections)

SetJSONBody adds the jsonBody to the connect streams params

func (*ConnectStreamsParams) SetTimeout 

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

SetTimeout adds the timeout to the connect streams params

func (*ConnectStreamsParams) WithContext 

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

WithContext adds the context to the connect streams params

func (*ConnectStreamsParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the connect streams params

func (*ConnectStreamsParams) WithJSONBody 

func (o *ConnectStreamsParams) WithJSONBody(jSONBody *models.PipelineReverseConnections) *ConnectStreamsParams

WithJSONBody adds the jSONBody to the connect streams params

func (*ConnectStreamsParams) WithTimeout 

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

WithTimeout adds the timeout to the connect streams params

func (*ConnectStreamsParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ConnectStreamsReader 

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

ConnectStreamsReader is a Reader for the ConnectStreams structure.

func (*ConnectStreamsReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetPipelinesForStreamOK 

type GetPipelinesForStreamOK struct {
	Payload *models.PipelineConnections
}

GetPipelinesForStreamOK handles this case with default header values.

No response was specified

func NewGetPipelinesForStreamOK 

func NewGetPipelinesForStreamOK() *GetPipelinesForStreamOK

NewGetPipelinesForStreamOK creates a GetPipelinesForStreamOK with default headers values

func (*GetPipelinesForStreamOK) Error 

func (o *GetPipelinesForStreamOK) Error() string

type GetPipelinesForStreamParams 

type GetPipelinesForStreamParams struct {

	/*StreamID*/
	StreamID string

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

GetPipelinesForStreamParams contains all the parameters to send to the API endpoint for the get pipelines for stream operation typically these are written to a http.Request

func NewGetPipelinesForStreamParams 

func NewGetPipelinesForStreamParams() *GetPipelinesForStreamParams

NewGetPipelinesForStreamParams creates a new GetPipelinesForStreamParams object with the default values initialized.

func NewGetPipelinesForStreamParamsWithContext 

func NewGetPipelinesForStreamParamsWithContext(ctx context.Context) *GetPipelinesForStreamParams

NewGetPipelinesForStreamParamsWithContext creates a new GetPipelinesForStreamParams object with the default values initialized, and the ability to set a context for a request

func NewGetPipelinesForStreamParamsWithHTTPClient 

func NewGetPipelinesForStreamParamsWithHTTPClient(client *http.Client) *GetPipelinesForStreamParams

NewGetPipelinesForStreamParamsWithHTTPClient creates a new GetPipelinesForStreamParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetPipelinesForStreamParamsWithTimeout 

func NewGetPipelinesForStreamParamsWithTimeout(timeout time.Duration) *GetPipelinesForStreamParams

NewGetPipelinesForStreamParamsWithTimeout creates a new GetPipelinesForStreamParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetPipelinesForStreamParams) SetContext 

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

SetContext adds the context to the get pipelines for stream params

func (*GetPipelinesForStreamParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get pipelines for stream params

func (*GetPipelinesForStreamParams) SetStreamID 

func (o *GetPipelinesForStreamParams) SetStreamID(streamID string)

SetStreamID adds the streamId to the get pipelines for stream params

func (*GetPipelinesForStreamParams) SetTimeout 

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

SetTimeout adds the timeout to the get pipelines for stream params

func (*GetPipelinesForStreamParams) WithContext 

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

WithContext adds the context to the get pipelines for stream params

func (*GetPipelinesForStreamParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get pipelines for stream params

func (*GetPipelinesForStreamParams) WithStreamID 

func (o *GetPipelinesForStreamParams) WithStreamID(streamID string) *GetPipelinesForStreamParams

WithStreamID adds the streamID to the get pipelines for stream params

func (*GetPipelinesForStreamParams) WithTimeout 

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

WithTimeout adds the timeout to the get pipelines for stream params

func (*GetPipelinesForStreamParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetPipelinesForStreamReader 

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

GetPipelinesForStreamReader is a Reader for the GetPipelinesForStream structure.

func (*GetPipelinesForStreamReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

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.