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.

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.