Documentation
¶
Index ¶
- type Client
- func (a *Client) PauseProcessing(params *PauseProcessingParams, authInfo runtime.ClientAuthInfoWriter) (*PauseProcessingOK, error)
- func (a *Client) ResumeProcessing(params *ResumeProcessingParams, authInfo runtime.ClientAuthInfoWriter) (*ResumeProcessingOK, error)
- func (a *Client) SetTransport(transport runtime.ClientTransport)
- type PauseProcessingOK
- type PauseProcessingParams
- func NewPauseProcessingParams() *PauseProcessingParams
- func NewPauseProcessingParamsWithContext(ctx context.Context) *PauseProcessingParams
- func NewPauseProcessingParamsWithHTTPClient(client *http.Client) *PauseProcessingParams
- func NewPauseProcessingParamsWithTimeout(timeout time.Duration) *PauseProcessingParams
- func (o *PauseProcessingParams) SetContext(ctx context.Context)
- func (o *PauseProcessingParams) SetHTTPClient(client *http.Client)
- func (o *PauseProcessingParams) SetTimeout(timeout time.Duration)
- func (o *PauseProcessingParams) WithContext(ctx context.Context) *PauseProcessingParams
- func (o *PauseProcessingParams) WithHTTPClient(client *http.Client) *PauseProcessingParams
- func (o *PauseProcessingParams) WithTimeout(timeout time.Duration) *PauseProcessingParams
- func (o *PauseProcessingParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type PauseProcessingReader
- type ResumeProcessingOK
- type ResumeProcessingParams
- func NewResumeProcessingParams() *ResumeProcessingParams
- func NewResumeProcessingParamsWithContext(ctx context.Context) *ResumeProcessingParams
- func NewResumeProcessingParamsWithHTTPClient(client *http.Client) *ResumeProcessingParams
- func NewResumeProcessingParamsWithTimeout(timeout time.Duration) *ResumeProcessingParams
- func (o *ResumeProcessingParams) SetContext(ctx context.Context)
- func (o *ResumeProcessingParams) SetHTTPClient(client *http.Client)
- func (o *ResumeProcessingParams) SetTimeout(timeout time.Duration)
- func (o *ResumeProcessingParams) WithContext(ctx context.Context) *ResumeProcessingParams
- func (o *ResumeProcessingParams) WithHTTPClient(client *http.Client) *ResumeProcessingParams
- func (o *ResumeProcessingParams) WithTimeout(timeout time.Duration) *ResumeProcessingParams
- func (o *ResumeProcessingParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type ResumeProcessingReader
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 system service manager API
func New ¶
func New(transport runtime.ClientTransport, formats strfmt.Registry) *Client
New creates a new system service manager API client.
func (*Client) PauseProcessing ¶
func (a *Client) PauseProcessing(params *PauseProcessingParams, authInfo runtime.ClientAuthInfoWriter) (*PauseProcessingOK, error)
PauseProcessing pauses message processing
If the message journal is enabled, incoming messages will be spooled on disk, if it is disabled, you might lose messages from inputs which cannot buffer themselves, like AMQP or Kafka-based inputs.
func (*Client) ResumeProcessing ¶
func (a *Client) ResumeProcessing(params *ResumeProcessingParams, authInfo runtime.ClientAuthInfoWriter) (*ResumeProcessingOK, error)
ResumeProcessing resumes message processing
func (*Client) SetTransport ¶
func (a *Client) SetTransport(transport runtime.ClientTransport)
SetTransport changes the transport on the client
type PauseProcessingOK ¶
type PauseProcessingOK struct {
}
PauseProcessingOK handles this case with default header values.
No response was specified
func NewPauseProcessingOK ¶
func NewPauseProcessingOK() *PauseProcessingOK
NewPauseProcessingOK creates a PauseProcessingOK with default headers values
func (*PauseProcessingOK) Error ¶
func (o *PauseProcessingOK) Error() string
type PauseProcessingParams ¶
type PauseProcessingParams struct {
Context context.Context
HTTPClient *http.Client
// contains filtered or unexported fields
}
PauseProcessingParams contains all the parameters to send to the API endpoint for the pause processing operation typically these are written to a http.Request
func NewPauseProcessingParams ¶
func NewPauseProcessingParams() *PauseProcessingParams
NewPauseProcessingParams creates a new PauseProcessingParams object with the default values initialized.
func NewPauseProcessingParamsWithContext ¶
func NewPauseProcessingParamsWithContext(ctx context.Context) *PauseProcessingParams
NewPauseProcessingParamsWithContext creates a new PauseProcessingParams object with the default values initialized, and the ability to set a context for a request
func NewPauseProcessingParamsWithHTTPClient ¶
func NewPauseProcessingParamsWithHTTPClient(client *http.Client) *PauseProcessingParams
NewPauseProcessingParamsWithHTTPClient creates a new PauseProcessingParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewPauseProcessingParamsWithTimeout ¶
func NewPauseProcessingParamsWithTimeout(timeout time.Duration) *PauseProcessingParams
NewPauseProcessingParamsWithTimeout creates a new PauseProcessingParams object with the default values initialized, and the ability to set a timeout on a request
func (*PauseProcessingParams) SetContext ¶
func (o *PauseProcessingParams) SetContext(ctx context.Context)
SetContext adds the context to the pause processing params
func (*PauseProcessingParams) SetHTTPClient ¶
func (o *PauseProcessingParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the pause processing params
func (*PauseProcessingParams) SetTimeout ¶
func (o *PauseProcessingParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the pause processing params
func (*PauseProcessingParams) WithContext ¶
func (o *PauseProcessingParams) WithContext(ctx context.Context) *PauseProcessingParams
WithContext adds the context to the pause processing params
func (*PauseProcessingParams) WithHTTPClient ¶
func (o *PauseProcessingParams) WithHTTPClient(client *http.Client) *PauseProcessingParams
WithHTTPClient adds the HTTPClient to the pause processing params
func (*PauseProcessingParams) WithTimeout ¶
func (o *PauseProcessingParams) WithTimeout(timeout time.Duration) *PauseProcessingParams
WithTimeout adds the timeout to the pause processing params
func (*PauseProcessingParams) WriteToRequest ¶
func (o *PauseProcessingParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type PauseProcessingReader ¶
type PauseProcessingReader struct {
// contains filtered or unexported fields
}
PauseProcessingReader is a Reader for the PauseProcessing structure.
func (*PauseProcessingReader) ReadResponse ¶
func (o *PauseProcessingReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type ResumeProcessingOK ¶
type ResumeProcessingOK struct {
}
ResumeProcessingOK handles this case with default header values.
No response was specified
func NewResumeProcessingOK ¶
func NewResumeProcessingOK() *ResumeProcessingOK
NewResumeProcessingOK creates a ResumeProcessingOK with default headers values
func (*ResumeProcessingOK) Error ¶
func (o *ResumeProcessingOK) Error() string
type ResumeProcessingParams ¶
type ResumeProcessingParams struct {
Context context.Context
HTTPClient *http.Client
// contains filtered or unexported fields
}
ResumeProcessingParams contains all the parameters to send to the API endpoint for the resume processing operation typically these are written to a http.Request
func NewResumeProcessingParams ¶
func NewResumeProcessingParams() *ResumeProcessingParams
NewResumeProcessingParams creates a new ResumeProcessingParams object with the default values initialized.
func NewResumeProcessingParamsWithContext ¶
func NewResumeProcessingParamsWithContext(ctx context.Context) *ResumeProcessingParams
NewResumeProcessingParamsWithContext creates a new ResumeProcessingParams object with the default values initialized, and the ability to set a context for a request
func NewResumeProcessingParamsWithHTTPClient ¶
func NewResumeProcessingParamsWithHTTPClient(client *http.Client) *ResumeProcessingParams
NewResumeProcessingParamsWithHTTPClient creates a new ResumeProcessingParams object with the default values initialized, and the ability to set a custom HTTPClient for a request
func NewResumeProcessingParamsWithTimeout ¶
func NewResumeProcessingParamsWithTimeout(timeout time.Duration) *ResumeProcessingParams
NewResumeProcessingParamsWithTimeout creates a new ResumeProcessingParams object with the default values initialized, and the ability to set a timeout on a request
func (*ResumeProcessingParams) SetContext ¶
func (o *ResumeProcessingParams) SetContext(ctx context.Context)
SetContext adds the context to the resume processing params
func (*ResumeProcessingParams) SetHTTPClient ¶
func (o *ResumeProcessingParams) SetHTTPClient(client *http.Client)
SetHTTPClient adds the HTTPClient to the resume processing params
func (*ResumeProcessingParams) SetTimeout ¶
func (o *ResumeProcessingParams) SetTimeout(timeout time.Duration)
SetTimeout adds the timeout to the resume processing params
func (*ResumeProcessingParams) WithContext ¶
func (o *ResumeProcessingParams) WithContext(ctx context.Context) *ResumeProcessingParams
WithContext adds the context to the resume processing params
func (*ResumeProcessingParams) WithHTTPClient ¶
func (o *ResumeProcessingParams) WithHTTPClient(client *http.Client) *ResumeProcessingParams
WithHTTPClient adds the HTTPClient to the resume processing params
func (*ResumeProcessingParams) WithTimeout ¶
func (o *ResumeProcessingParams) WithTimeout(timeout time.Duration) *ResumeProcessingParams
WithTimeout adds the timeout to the resume processing params
func (*ResumeProcessingParams) WriteToRequest ¶
func (o *ResumeProcessingParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type ResumeProcessingReader ¶
type ResumeProcessingReader struct {
// contains filtered or unexported fields
}
ResumeProcessingReader is a Reader for the ResumeProcessing structure.
func (*ResumeProcessingReader) ReadResponse ¶
func (o *ResumeProcessingReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
Source Files