system

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

func New

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

New creates a new system API client.

func (*Client) CloneStream

func (a *Client) CloneStream(params *CloneStreamParams, authInfo runtime.ClientAuthInfoWriter) (*CloneStreamOK, error)

CloneStream clones a stream

func (*Client) GetEnabled

func (a *Client) GetEnabled(params *GetEnabledParams, authInfo runtime.ClientAuthInfoWriter) (*GetEnabledOK, error)

GetEnabled gets a list of all enabled streams

func (*Client) Pause

func (a *Client) Pause(params *PauseParams, authInfo runtime.ClientAuthInfoWriter) (*PauseOK, error)

Pause pauses a stream

func (*Client) Resume

func (a *Client) Resume(params *ResumeParams, authInfo runtime.ClientAuthInfoWriter) (*ResumeOK, error)

Resume resumes a stream

func (*Client) SetTransport

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

SetTransport changes the transport on the client

func (*Client) TestMatch

func (a *Client) TestMatch(params *TestMatchParams, authInfo runtime.ClientAuthInfoWriter) (*TestMatchOK, error)

TestMatch tests matching of a stream against a supplied message

type CloneStreamBadRequest

type CloneStreamBadRequest struct {
}

CloneStreamBadRequest handles this case with default header values.

Invalid or missing Stream id.

func NewCloneStreamBadRequest

func NewCloneStreamBadRequest() *CloneStreamBadRequest

NewCloneStreamBadRequest creates a CloneStreamBadRequest with default headers values

func (*CloneStreamBadRequest) Error

func (o *CloneStreamBadRequest) Error() string

type CloneStreamNotFound

type CloneStreamNotFound struct {
}

CloneStreamNotFound handles this case with default header values.

Stream not found.

func NewCloneStreamNotFound

func NewCloneStreamNotFound() *CloneStreamNotFound

NewCloneStreamNotFound creates a CloneStreamNotFound with default headers values

func (*CloneStreamNotFound) Error

func (o *CloneStreamNotFound) Error() string

type CloneStreamOK

type CloneStreamOK struct {
}

CloneStreamOK handles this case with default header values.

No response was specified

func NewCloneStreamOK

func NewCloneStreamOK() *CloneStreamOK

NewCloneStreamOK creates a CloneStreamOK with default headers values

func (*CloneStreamOK) Error

func (o *CloneStreamOK) Error() string

type CloneStreamParams

type CloneStreamParams struct {

	/*JSONBody*/
	JSONBody *models.CloneStreamRequest
	/*StreamID*/
	StreamID string

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

CloneStreamParams contains all the parameters to send to the API endpoint for the clone stream operation typically these are written to a http.Request

func NewCloneStreamParams

func NewCloneStreamParams() *CloneStreamParams

NewCloneStreamParams creates a new CloneStreamParams object with the default values initialized.

func NewCloneStreamParamsWithContext

func NewCloneStreamParamsWithContext(ctx context.Context) *CloneStreamParams

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

func NewCloneStreamParamsWithHTTPClient

func NewCloneStreamParamsWithHTTPClient(client *http.Client) *CloneStreamParams

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

func NewCloneStreamParamsWithTimeout

func NewCloneStreamParamsWithTimeout(timeout time.Duration) *CloneStreamParams

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

func (*CloneStreamParams) SetContext

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

SetContext adds the context to the clone stream params

func (*CloneStreamParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the clone stream params

func (*CloneStreamParams) SetJSONBody

func (o *CloneStreamParams) SetJSONBody(jSONBody *models.CloneStreamRequest)

SetJSONBody adds the jsonBody to the clone stream params

func (*CloneStreamParams) SetStreamID

func (o *CloneStreamParams) SetStreamID(streamID string)

SetStreamID adds the streamId to the clone stream params

func (*CloneStreamParams) SetTimeout

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

SetTimeout adds the timeout to the clone stream params

func (*CloneStreamParams) WithContext

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

WithContext adds the context to the clone stream params

func (*CloneStreamParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the clone stream params

func (*CloneStreamParams) WithJSONBody

func (o *CloneStreamParams) WithJSONBody(jSONBody *models.CloneStreamRequest) *CloneStreamParams

WithJSONBody adds the jSONBody to the clone stream params

func (*CloneStreamParams) WithStreamID

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

WithStreamID adds the streamID to the clone stream params

func (*CloneStreamParams) WithTimeout

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

WithTimeout adds the timeout to the clone stream params

func (*CloneStreamParams) WriteToRequest

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

WriteToRequest writes these params to a swagger request

type CloneStreamReader

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

CloneStreamReader is a Reader for the CloneStream structure.

func (*CloneStreamReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type GetEnabledOK

type GetEnabledOK struct {
	Payload *models.StreamListResponse
}

GetEnabledOK handles this case with default header values.

No response was specified

func NewGetEnabledOK

func NewGetEnabledOK() *GetEnabledOK

NewGetEnabledOK creates a GetEnabledOK with default headers values

func (*GetEnabledOK) Error

func (o *GetEnabledOK) Error() string

type GetEnabledParams

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

GetEnabledParams contains all the parameters to send to the API endpoint for the get enabled operation typically these are written to a http.Request

func NewGetEnabledParams

func NewGetEnabledParams() *GetEnabledParams

NewGetEnabledParams creates a new GetEnabledParams object with the default values initialized.

func NewGetEnabledParamsWithContext

func NewGetEnabledParamsWithContext(ctx context.Context) *GetEnabledParams

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

func NewGetEnabledParamsWithHTTPClient

func NewGetEnabledParamsWithHTTPClient(client *http.Client) *GetEnabledParams

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

func NewGetEnabledParamsWithTimeout

func NewGetEnabledParamsWithTimeout(timeout time.Duration) *GetEnabledParams

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

func (*GetEnabledParams) SetContext

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

SetContext adds the context to the get enabled params

func (*GetEnabledParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the get enabled params

func (*GetEnabledParams) SetTimeout

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

SetTimeout adds the timeout to the get enabled params

func (*GetEnabledParams) WithContext

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

WithContext adds the context to the get enabled params

func (*GetEnabledParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the get enabled params

func (*GetEnabledParams) WithTimeout

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

WithTimeout adds the timeout to the get enabled params

func (*GetEnabledParams) WriteToRequest

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

WriteToRequest writes these params to a swagger request

type GetEnabledReader

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

GetEnabledReader is a Reader for the GetEnabled structure.

func (*GetEnabledReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type PauseBadRequest

type PauseBadRequest struct {
}

PauseBadRequest handles this case with default header values.

Invalid or missing Stream id.

func NewPauseBadRequest

func NewPauseBadRequest() *PauseBadRequest

NewPauseBadRequest creates a PauseBadRequest with default headers values

func (*PauseBadRequest) Error

func (o *PauseBadRequest) Error() string

type PauseNotFound

type PauseNotFound struct {
}

PauseNotFound handles this case with default header values.

Stream not found.

func NewPauseNotFound

func NewPauseNotFound() *PauseNotFound

NewPauseNotFound creates a PauseNotFound with default headers values

func (*PauseNotFound) Error

func (o *PauseNotFound) Error() string

type PauseOK

type PauseOK struct {
}

PauseOK handles this case with default header values.

No response was specified

func NewPauseOK

func NewPauseOK() *PauseOK

NewPauseOK creates a PauseOK with default headers values

func (*PauseOK) Error

func (o *PauseOK) Error() string

type PauseParams

type PauseParams struct {

	/*StreamID*/
	StreamID string

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

PauseParams contains all the parameters to send to the API endpoint for the pause operation typically these are written to a http.Request

func NewPauseParams

func NewPauseParams() *PauseParams

NewPauseParams creates a new PauseParams object with the default values initialized.

func NewPauseParamsWithContext

func NewPauseParamsWithContext(ctx context.Context) *PauseParams

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

func NewPauseParamsWithHTTPClient

func NewPauseParamsWithHTTPClient(client *http.Client) *PauseParams

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

func NewPauseParamsWithTimeout

func NewPauseParamsWithTimeout(timeout time.Duration) *PauseParams

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

func (*PauseParams) SetContext

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

SetContext adds the context to the pause params

func (*PauseParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the pause params

func (*PauseParams) SetStreamID

func (o *PauseParams) SetStreamID(streamID string)

SetStreamID adds the streamId to the pause params

func (*PauseParams) SetTimeout

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

SetTimeout adds the timeout to the pause params

func (*PauseParams) WithContext

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

WithContext adds the context to the pause params

func (*PauseParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the pause params

func (*PauseParams) WithStreamID

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

WithStreamID adds the streamID to the pause params

func (*PauseParams) WithTimeout

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

WithTimeout adds the timeout to the pause params

func (*PauseParams) WriteToRequest

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

WriteToRequest writes these params to a swagger request

type PauseReader

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

PauseReader is a Reader for the Pause structure.

func (*PauseReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type ResumeBadRequest

type ResumeBadRequest struct {
}

ResumeBadRequest handles this case with default header values.

Invalid or missing Stream id.

func NewResumeBadRequest

func NewResumeBadRequest() *ResumeBadRequest

NewResumeBadRequest creates a ResumeBadRequest with default headers values

func (*ResumeBadRequest) Error

func (o *ResumeBadRequest) Error() string

type ResumeNotFound

type ResumeNotFound struct {
}

ResumeNotFound handles this case with default header values.

Stream not found.

func NewResumeNotFound

func NewResumeNotFound() *ResumeNotFound

NewResumeNotFound creates a ResumeNotFound with default headers values

func (*ResumeNotFound) Error

func (o *ResumeNotFound) Error() string

type ResumeOK

type ResumeOK struct {
}

ResumeOK handles this case with default header values.

No response was specified

func NewResumeOK

func NewResumeOK() *ResumeOK

NewResumeOK creates a ResumeOK with default headers values

func (*ResumeOK) Error

func (o *ResumeOK) Error() string

type ResumeParams

type ResumeParams struct {

	/*StreamID*/
	StreamID string

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

ResumeParams contains all the parameters to send to the API endpoint for the resume operation typically these are written to a http.Request

func NewResumeParams

func NewResumeParams() *ResumeParams

NewResumeParams creates a new ResumeParams object with the default values initialized.

func NewResumeParamsWithContext

func NewResumeParamsWithContext(ctx context.Context) *ResumeParams

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

func NewResumeParamsWithHTTPClient

func NewResumeParamsWithHTTPClient(client *http.Client) *ResumeParams

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

func NewResumeParamsWithTimeout

func NewResumeParamsWithTimeout(timeout time.Duration) *ResumeParams

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

func (*ResumeParams) SetContext

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

SetContext adds the context to the resume params

func (*ResumeParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the resume params

func (*ResumeParams) SetStreamID

func (o *ResumeParams) SetStreamID(streamID string)

SetStreamID adds the streamId to the resume params

func (*ResumeParams) SetTimeout

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

SetTimeout adds the timeout to the resume params

func (*ResumeParams) WithContext

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

WithContext adds the context to the resume params

func (*ResumeParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the resume params

func (*ResumeParams) WithStreamID

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

WithStreamID adds the streamID to the resume params

func (*ResumeParams) WithTimeout

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

WithTimeout adds the timeout to the resume params

func (*ResumeParams) WriteToRequest

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

WriteToRequest writes these params to a swagger request

type ResumeReader

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

ResumeReader is a Reader for the Resume structure.

func (*ResumeReader) ReadResponse

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

ReadResponse reads a server response into the received o.

type TestMatchBadRequest

type TestMatchBadRequest struct {
}

TestMatchBadRequest handles this case with default header values.

Invalid or missing Stream id.

func NewTestMatchBadRequest

func NewTestMatchBadRequest() *TestMatchBadRequest

NewTestMatchBadRequest creates a TestMatchBadRequest with default headers values

func (*TestMatchBadRequest) Error

func (o *TestMatchBadRequest) Error() string

type TestMatchNotFound

type TestMatchNotFound struct {
}

TestMatchNotFound handles this case with default header values.

Stream not found.

func NewTestMatchNotFound

func NewTestMatchNotFound() *TestMatchNotFound

NewTestMatchNotFound creates a TestMatchNotFound with default headers values

func (*TestMatchNotFound) Error

func (o *TestMatchNotFound) Error() string

type TestMatchOK

type TestMatchOK struct {
	Payload *models.TestMatchResponse
}

TestMatchOK handles this case with default header values.

No response was specified

func NewTestMatchOK

func NewTestMatchOK() *TestMatchOK

NewTestMatchOK creates a TestMatchOK with default headers values

func (*TestMatchOK) Error

func (o *TestMatchOK) Error() string

type TestMatchParams

type TestMatchParams struct {

	/*JSONBody*/
	JSONBody interface{}
	/*StreamID*/
	StreamID string

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

TestMatchParams contains all the parameters to send to the API endpoint for the test match operation typically these are written to a http.Request

func NewTestMatchParams

func NewTestMatchParams() *TestMatchParams

NewTestMatchParams creates a new TestMatchParams object with the default values initialized.

func NewTestMatchParamsWithContext

func NewTestMatchParamsWithContext(ctx context.Context) *TestMatchParams

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

func NewTestMatchParamsWithHTTPClient

func NewTestMatchParamsWithHTTPClient(client *http.Client) *TestMatchParams

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

func NewTestMatchParamsWithTimeout

func NewTestMatchParamsWithTimeout(timeout time.Duration) *TestMatchParams

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

func (*TestMatchParams) SetContext

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

SetContext adds the context to the test match params

func (*TestMatchParams) SetHTTPClient

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

SetHTTPClient adds the HTTPClient to the test match params

func (*TestMatchParams) SetJSONBody

func (o *TestMatchParams) SetJSONBody(jSONBody interface{})

SetJSONBody adds the jsonBody to the test match params

func (*TestMatchParams) SetStreamID

func (o *TestMatchParams) SetStreamID(streamID string)

SetStreamID adds the streamId to the test match params

func (*TestMatchParams) SetTimeout

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

SetTimeout adds the timeout to the test match params

func (*TestMatchParams) WithContext

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

WithContext adds the context to the test match params

func (*TestMatchParams) WithHTTPClient

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

WithHTTPClient adds the HTTPClient to the test match params

func (*TestMatchParams) WithJSONBody

func (o *TestMatchParams) WithJSONBody(jSONBody interface{}) *TestMatchParams

WithJSONBody adds the jSONBody to the test match params

func (*TestMatchParams) WithStreamID

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

WithStreamID adds the streamID to the test match params

func (*TestMatchParams) WithTimeout

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

WithTimeout adds the timeout to the test match params

func (*TestMatchParams) WriteToRequest

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

WriteToRequest writes these params to a swagger request

type TestMatchReader

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

TestMatchReader is a Reader for the TestMatch structure.

func (*TestMatchReader) ReadResponse

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

ReadResponse reads a server response into the received o.

Jump to

Keyboard shortcuts

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