event_streams

package
v0.2.35 Latest Latest
Warning

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

 Go to latest Published: May 3, 2023 License: MIT 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 event streams API

func (*Client) ListAvailableStreamsOAuth2 

func (a *Client) ListAvailableStreamsOAuth2(params *ListAvailableStreamsOAuth2Params, opts ...ClientOption) (*ListAvailableStreamsOAuth2OK, error)

ListAvailableStreamsOAuth2 discovers all event streams in your environment

func (*Client) RefreshActiveStreamSession 

func (a *Client) RefreshActiveStreamSession(params *RefreshActiveStreamSessionParams, opts ...ClientOption) (*RefreshActiveStreamSessionOK, error)

RefreshActiveStreamSession refreshes an active event stream use the URL shown in a g e t sensors entities datafeed v2 response

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

type ClientOption 

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService 

type ClientService interface {
	ListAvailableStreamsOAuth2(params *ListAvailableStreamsOAuth2Params, opts ...ClientOption) (*ListAvailableStreamsOAuth2OK, error)

	RefreshActiveStreamSession(params *RefreshActiveStreamSessionParams, opts ...ClientOption) (*RefreshActiveStreamSessionOK, 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 event streams API client.

type ListAvailableStreamsOAuth2BadRequest 

type ListAvailableStreamsOAuth2BadRequest struct {

	/* Request limit per minute.
	 */
	XRateLimitLimit int64

	/* The number of requests remaining for the sliding one minute window.
	 */
	XRateLimitRemaining int64

	Payload *models.MainDiscoveryResponseV2
}

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

Bad Request

func NewListAvailableStreamsOAuth2BadRequest 

func NewListAvailableStreamsOAuth2BadRequest() *ListAvailableStreamsOAuth2BadRequest

NewListAvailableStreamsOAuth2BadRequest creates a ListAvailableStreamsOAuth2BadRequest with default headers values

func (*ListAvailableStreamsOAuth2BadRequest) Code added in v0.2.33 

func (o *ListAvailableStreamsOAuth2BadRequest) Code() int

Code gets the status code for the list available streams o auth2 bad request response

func (*ListAvailableStreamsOAuth2BadRequest) Error 

func (o *ListAvailableStreamsOAuth2BadRequest) Error() string

func (*ListAvailableStreamsOAuth2BadRequest) GetPayload 

func (o *ListAvailableStreamsOAuth2BadRequest) GetPayload() *models.MainDiscoveryResponseV2

func (*ListAvailableStreamsOAuth2BadRequest) IsClientError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2BadRequest) IsClientError() bool

IsClientError returns true when this list available streams o auth2 bad request response has a 4xx status code

func (*ListAvailableStreamsOAuth2BadRequest) IsCode added in v0.2.27 

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

IsCode returns true when this list available streams o auth2 bad request response a status code equal to that given

func (*ListAvailableStreamsOAuth2BadRequest) IsRedirect added in v0.2.27 

func (o *ListAvailableStreamsOAuth2BadRequest) IsRedirect() bool

IsRedirect returns true when this list available streams o auth2 bad request response has a 3xx status code

func (*ListAvailableStreamsOAuth2BadRequest) IsServerError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2BadRequest) IsServerError() bool

IsServerError returns true when this list available streams o auth2 bad request response has a 5xx status code

func (*ListAvailableStreamsOAuth2BadRequest) IsSuccess added in v0.2.27 

func (o *ListAvailableStreamsOAuth2BadRequest) IsSuccess() bool

IsSuccess returns true when this list available streams o auth2 bad request response has a 2xx status code

func (*ListAvailableStreamsOAuth2BadRequest) String added in v0.2.27 

func (o *ListAvailableStreamsOAuth2BadRequest) String() string

type ListAvailableStreamsOAuth2Default 

type ListAvailableStreamsOAuth2Default struct {
	Payload *models.MainDiscoveryResponseV2
	// contains filtered or unexported fields
}

ListAvailableStreamsOAuth2Default describes a response with status code -1, with default header values.

OK

func NewListAvailableStreamsOAuth2Default 

func NewListAvailableStreamsOAuth2Default(code int) *ListAvailableStreamsOAuth2Default

NewListAvailableStreamsOAuth2Default creates a ListAvailableStreamsOAuth2Default with default headers values

func (*ListAvailableStreamsOAuth2Default) Code 

func (o *ListAvailableStreamsOAuth2Default) Code() int

Code gets the status code for the list available streams o auth2 default response

func (*ListAvailableStreamsOAuth2Default) Error 

func (o *ListAvailableStreamsOAuth2Default) Error() string

func (*ListAvailableStreamsOAuth2Default) GetPayload 

func (o *ListAvailableStreamsOAuth2Default) GetPayload() *models.MainDiscoveryResponseV2

func (*ListAvailableStreamsOAuth2Default) IsClientError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2Default) IsClientError() bool

IsClientError returns true when this list available streams o auth2 default response has a 4xx status code

func (*ListAvailableStreamsOAuth2Default) IsCode added in v0.2.27 

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

IsCode returns true when this list available streams o auth2 default response a status code equal to that given

func (*ListAvailableStreamsOAuth2Default) IsRedirect added in v0.2.27 

func (o *ListAvailableStreamsOAuth2Default) IsRedirect() bool

IsRedirect returns true when this list available streams o auth2 default response has a 3xx status code

func (*ListAvailableStreamsOAuth2Default) IsServerError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2Default) IsServerError() bool

IsServerError returns true when this list available streams o auth2 default response has a 5xx status code

func (*ListAvailableStreamsOAuth2Default) IsSuccess added in v0.2.27 

func (o *ListAvailableStreamsOAuth2Default) IsSuccess() bool

IsSuccess returns true when this list available streams o auth2 default response has a 2xx status code

func (*ListAvailableStreamsOAuth2Default) String added in v0.2.27 

func (o *ListAvailableStreamsOAuth2Default) String() string

type ListAvailableStreamsOAuth2Forbidden 

type ListAvailableStreamsOAuth2Forbidden struct {

	/* Request limit per minute.
	 */
	XRateLimitLimit int64

	/* The number of requests remaining for the sliding one minute window.
	 */
	XRateLimitRemaining int64

	Payload *models.MsaReplyMetaOnly
}

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

Forbidden

func NewListAvailableStreamsOAuth2Forbidden 

func NewListAvailableStreamsOAuth2Forbidden() *ListAvailableStreamsOAuth2Forbidden

NewListAvailableStreamsOAuth2Forbidden creates a ListAvailableStreamsOAuth2Forbidden with default headers values

func (*ListAvailableStreamsOAuth2Forbidden) Code added in v0.2.33 

func (o *ListAvailableStreamsOAuth2Forbidden) Code() int

Code gets the status code for the list available streams o auth2 forbidden response

func (*ListAvailableStreamsOAuth2Forbidden) Error 

func (o *ListAvailableStreamsOAuth2Forbidden) Error() string

func (*ListAvailableStreamsOAuth2Forbidden) GetPayload 

func (o *ListAvailableStreamsOAuth2Forbidden) GetPayload() *models.MsaReplyMetaOnly

func (*ListAvailableStreamsOAuth2Forbidden) IsClientError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2Forbidden) IsClientError() bool

IsClientError returns true when this list available streams o auth2 forbidden response has a 4xx status code

func (*ListAvailableStreamsOAuth2Forbidden) IsCode added in v0.2.27 

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

IsCode returns true when this list available streams o auth2 forbidden response a status code equal to that given

func (*ListAvailableStreamsOAuth2Forbidden) IsRedirect added in v0.2.27 

func (o *ListAvailableStreamsOAuth2Forbidden) IsRedirect() bool

IsRedirect returns true when this list available streams o auth2 forbidden response has a 3xx status code

func (*ListAvailableStreamsOAuth2Forbidden) IsServerError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2Forbidden) IsServerError() bool

IsServerError returns true when this list available streams o auth2 forbidden response has a 5xx status code

func (*ListAvailableStreamsOAuth2Forbidden) IsSuccess added in v0.2.27 

func (o *ListAvailableStreamsOAuth2Forbidden) IsSuccess() bool

IsSuccess returns true when this list available streams o auth2 forbidden response has a 2xx status code

func (*ListAvailableStreamsOAuth2Forbidden) String added in v0.2.27 

func (o *ListAvailableStreamsOAuth2Forbidden) String() string

type ListAvailableStreamsOAuth2InternalServerError 

type ListAvailableStreamsOAuth2InternalServerError struct {

	/* Request limit per minute.
	 */
	XRateLimitLimit int64

	/* The number of requests remaining for the sliding one minute window.
	 */
	XRateLimitRemaining int64

	Payload *models.MainDiscoveryResponseV2
}

ListAvailableStreamsOAuth2InternalServerError describes a response with status code 500, with default header values.

Internal Server Error

func NewListAvailableStreamsOAuth2InternalServerError 

func NewListAvailableStreamsOAuth2InternalServerError() *ListAvailableStreamsOAuth2InternalServerError

NewListAvailableStreamsOAuth2InternalServerError creates a ListAvailableStreamsOAuth2InternalServerError with default headers values

func (*ListAvailableStreamsOAuth2InternalServerError) Code added in v0.2.33 

func (o *ListAvailableStreamsOAuth2InternalServerError) Code() int

Code gets the status code for the list available streams o auth2 internal server error response

func (*ListAvailableStreamsOAuth2InternalServerError) Error 

func (o *ListAvailableStreamsOAuth2InternalServerError) Error() string

func (*ListAvailableStreamsOAuth2InternalServerError) GetPayload 

func (o *ListAvailableStreamsOAuth2InternalServerError) GetPayload() *models.MainDiscoveryResponseV2

func (*ListAvailableStreamsOAuth2InternalServerError) IsClientError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2InternalServerError) IsClientError() bool

IsClientError returns true when this list available streams o auth2 internal server error response has a 4xx status code

func (*ListAvailableStreamsOAuth2InternalServerError) IsCode added in v0.2.27 

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

IsCode returns true when this list available streams o auth2 internal server error response a status code equal to that given

func (*ListAvailableStreamsOAuth2InternalServerError) IsRedirect added in v0.2.27 

func (o *ListAvailableStreamsOAuth2InternalServerError) IsRedirect() bool

IsRedirect returns true when this list available streams o auth2 internal server error response has a 3xx status code

func (*ListAvailableStreamsOAuth2InternalServerError) IsServerError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2InternalServerError) IsServerError() bool

IsServerError returns true when this list available streams o auth2 internal server error response has a 5xx status code

func (*ListAvailableStreamsOAuth2InternalServerError) IsSuccess added in v0.2.27 

func (o *ListAvailableStreamsOAuth2InternalServerError) IsSuccess() bool

IsSuccess returns true when this list available streams o auth2 internal server error response has a 2xx status code

func (*ListAvailableStreamsOAuth2InternalServerError) String added in v0.2.27 

func (o *ListAvailableStreamsOAuth2InternalServerError) String() string

type ListAvailableStreamsOAuth2OK 

type ListAvailableStreamsOAuth2OK struct {

	/* Request limit per minute.
	 */
	XRateLimitLimit int64

	/* The number of requests remaining for the sliding one minute window.
	 */
	XRateLimitRemaining int64

	Payload *models.MainDiscoveryResponseV2
}

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

OK

func NewListAvailableStreamsOAuth2OK 

func NewListAvailableStreamsOAuth2OK() *ListAvailableStreamsOAuth2OK

NewListAvailableStreamsOAuth2OK creates a ListAvailableStreamsOAuth2OK with default headers values

func (*ListAvailableStreamsOAuth2OK) Code added in v0.2.33 

func (o *ListAvailableStreamsOAuth2OK) Code() int

Code gets the status code for the list available streams o auth2 o k response

func (*ListAvailableStreamsOAuth2OK) Error 

func (o *ListAvailableStreamsOAuth2OK) Error() string

func (*ListAvailableStreamsOAuth2OK) GetPayload 

func (o *ListAvailableStreamsOAuth2OK) GetPayload() *models.MainDiscoveryResponseV2

func (*ListAvailableStreamsOAuth2OK) IsClientError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2OK) IsClientError() bool

IsClientError returns true when this list available streams o auth2 o k response has a 4xx status code

func (*ListAvailableStreamsOAuth2OK) IsCode added in v0.2.27 

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

IsCode returns true when this list available streams o auth2 o k response a status code equal to that given

func (*ListAvailableStreamsOAuth2OK) IsRedirect added in v0.2.27 

func (o *ListAvailableStreamsOAuth2OK) IsRedirect() bool

IsRedirect returns true when this list available streams o auth2 o k response has a 3xx status code

func (*ListAvailableStreamsOAuth2OK) IsServerError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2OK) IsServerError() bool

IsServerError returns true when this list available streams o auth2 o k response has a 5xx status code

func (*ListAvailableStreamsOAuth2OK) IsSuccess added in v0.2.27 

func (o *ListAvailableStreamsOAuth2OK) IsSuccess() bool

IsSuccess returns true when this list available streams o auth2 o k response has a 2xx status code

func (*ListAvailableStreamsOAuth2OK) String added in v0.2.27 

func (o *ListAvailableStreamsOAuth2OK) String() string

type ListAvailableStreamsOAuth2Params 

type ListAvailableStreamsOAuth2Params struct {

	/* AppID.

	   Label that identifies your connection. Max: 32 alphanumeric characters (a-z, A-Z, 0-9).
	*/
	AppID string

	/* Format.

	   Format for streaming events. Valid values: json, flatjson
	*/
	Format *string

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

ListAvailableStreamsOAuth2Params contains all the parameters to send to the API endpoint 

for the list available streams o auth2 operation.

Typically these are written to a http.Request.

func NewListAvailableStreamsOAuth2Params 

func NewListAvailableStreamsOAuth2Params() *ListAvailableStreamsOAuth2Params

NewListAvailableStreamsOAuth2Params creates a new ListAvailableStreamsOAuth2Params 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 NewListAvailableStreamsOAuth2ParamsWithContext 

func NewListAvailableStreamsOAuth2ParamsWithContext(ctx context.Context) *ListAvailableStreamsOAuth2Params

NewListAvailableStreamsOAuth2ParamsWithContext creates a new ListAvailableStreamsOAuth2Params object with the ability to set a context for a request.

func NewListAvailableStreamsOAuth2ParamsWithHTTPClient 

func NewListAvailableStreamsOAuth2ParamsWithHTTPClient(client *http.Client) *ListAvailableStreamsOAuth2Params

NewListAvailableStreamsOAuth2ParamsWithHTTPClient creates a new ListAvailableStreamsOAuth2Params object with the ability to set a custom HTTPClient for a request.

func NewListAvailableStreamsOAuth2ParamsWithTimeout 

func NewListAvailableStreamsOAuth2ParamsWithTimeout(timeout time.Duration) *ListAvailableStreamsOAuth2Params

NewListAvailableStreamsOAuth2ParamsWithTimeout creates a new ListAvailableStreamsOAuth2Params object with the ability to set a timeout on a request.

func (*ListAvailableStreamsOAuth2Params) SetAppID 

func (o *ListAvailableStreamsOAuth2Params) SetAppID(appID string)

SetAppID adds the appId to the list available streams o auth2 params

func (*ListAvailableStreamsOAuth2Params) SetContext 

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

SetContext adds the context to the list available streams o auth2 params

func (*ListAvailableStreamsOAuth2Params) SetDefaults 

func (o *ListAvailableStreamsOAuth2Params) SetDefaults()

SetDefaults hydrates default values in the list available streams o auth2 params (not the query body).

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

func (*ListAvailableStreamsOAuth2Params) SetFormat 

func (o *ListAvailableStreamsOAuth2Params) SetFormat(format *string)

SetFormat adds the format to the list available streams o auth2 params

func (*ListAvailableStreamsOAuth2Params) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the list available streams o auth2 params

func (*ListAvailableStreamsOAuth2Params) SetTimeout 

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

SetTimeout adds the timeout to the list available streams o auth2 params

func (*ListAvailableStreamsOAuth2Params) WithAppID 

func (o *ListAvailableStreamsOAuth2Params) WithAppID(appID string) *ListAvailableStreamsOAuth2Params

WithAppID adds the appID to the list available streams o auth2 params

func (*ListAvailableStreamsOAuth2Params) WithContext 

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

WithContext adds the context to the list available streams o auth2 params

func (*ListAvailableStreamsOAuth2Params) WithDefaults 

func (o *ListAvailableStreamsOAuth2Params) WithDefaults() *ListAvailableStreamsOAuth2Params

WithDefaults hydrates default values in the list available streams o auth2 params (not the query body).

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

func (*ListAvailableStreamsOAuth2Params) WithFormat 

func (o *ListAvailableStreamsOAuth2Params) WithFormat(format *string) *ListAvailableStreamsOAuth2Params

WithFormat adds the format to the list available streams o auth2 params

func (*ListAvailableStreamsOAuth2Params) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the list available streams o auth2 params

func (*ListAvailableStreamsOAuth2Params) WithTimeout 

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

WithTimeout adds the timeout to the list available streams o auth2 params

func (*ListAvailableStreamsOAuth2Params) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ListAvailableStreamsOAuth2Reader 

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

ListAvailableStreamsOAuth2Reader is a Reader for the ListAvailableStreamsOAuth2 structure.

func (*ListAvailableStreamsOAuth2Reader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ListAvailableStreamsOAuth2TooManyRequests 

type ListAvailableStreamsOAuth2TooManyRequests struct {

	/* Request limit per minute.
	 */
	XRateLimitLimit int64

	/* The number of requests remaining for the sliding one minute window.
	 */
	XRateLimitRemaining int64

	/* Too many requests, retry after this time (as milliseconds since epoch)
	 */
	XRateLimitRetryAfter int64

	Payload *models.MsaReplyMetaOnly
}

ListAvailableStreamsOAuth2TooManyRequests describes a response with status code 429, with default header values.

Too Many Requests

func NewListAvailableStreamsOAuth2TooManyRequests 

func NewListAvailableStreamsOAuth2TooManyRequests() *ListAvailableStreamsOAuth2TooManyRequests

NewListAvailableStreamsOAuth2TooManyRequests creates a ListAvailableStreamsOAuth2TooManyRequests with default headers values

func (*ListAvailableStreamsOAuth2TooManyRequests) Code added in v0.2.33 

func (o *ListAvailableStreamsOAuth2TooManyRequests) Code() int

Code gets the status code for the list available streams o auth2 too many requests response

func (*ListAvailableStreamsOAuth2TooManyRequests) Error 

func (o *ListAvailableStreamsOAuth2TooManyRequests) Error() string

func (*ListAvailableStreamsOAuth2TooManyRequests) GetPayload 

func (o *ListAvailableStreamsOAuth2TooManyRequests) GetPayload() *models.MsaReplyMetaOnly

func (*ListAvailableStreamsOAuth2TooManyRequests) IsClientError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2TooManyRequests) IsClientError() bool

IsClientError returns true when this list available streams o auth2 too many requests response has a 4xx status code

func (*ListAvailableStreamsOAuth2TooManyRequests) IsCode added in v0.2.27 

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

IsCode returns true when this list available streams o auth2 too many requests response a status code equal to that given

func (*ListAvailableStreamsOAuth2TooManyRequests) IsRedirect added in v0.2.27 

func (o *ListAvailableStreamsOAuth2TooManyRequests) IsRedirect() bool

IsRedirect returns true when this list available streams o auth2 too many requests response has a 3xx status code

func (*ListAvailableStreamsOAuth2TooManyRequests) IsServerError added in v0.2.27 

func (o *ListAvailableStreamsOAuth2TooManyRequests) IsServerError() bool

IsServerError returns true when this list available streams o auth2 too many requests response has a 5xx status code

func (*ListAvailableStreamsOAuth2TooManyRequests) IsSuccess added in v0.2.27 

func (o *ListAvailableStreamsOAuth2TooManyRequests) IsSuccess() bool

IsSuccess returns true when this list available streams o auth2 too many requests response has a 2xx status code

func (*ListAvailableStreamsOAuth2TooManyRequests) String added in v0.2.27 

func (o *ListAvailableStreamsOAuth2TooManyRequests) String() string

type RefreshActiveStreamSessionBadRequest 

type RefreshActiveStreamSessionBadRequest struct {

	/* Request limit per minute.
	 */
	XRateLimitLimit int64

	/* The number of requests remaining for the sliding one minute window.
	 */
	XRateLimitRemaining int64

	Payload *models.MsaReplyMetaOnly
}

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

Bad Request

func NewRefreshActiveStreamSessionBadRequest 

func NewRefreshActiveStreamSessionBadRequest() *RefreshActiveStreamSessionBadRequest

NewRefreshActiveStreamSessionBadRequest creates a RefreshActiveStreamSessionBadRequest with default headers values

func (*RefreshActiveStreamSessionBadRequest) Code added in v0.2.33 

func (o *RefreshActiveStreamSessionBadRequest) Code() int

Code gets the status code for the refresh active stream session bad request response

func (*RefreshActiveStreamSessionBadRequest) Error 

func (o *RefreshActiveStreamSessionBadRequest) Error() string

func (*RefreshActiveStreamSessionBadRequest) GetPayload 

func (o *RefreshActiveStreamSessionBadRequest) GetPayload() *models.MsaReplyMetaOnly

func (*RefreshActiveStreamSessionBadRequest) IsClientError added in v0.2.27 

func (o *RefreshActiveStreamSessionBadRequest) IsClientError() bool

IsClientError returns true when this refresh active stream session bad request response has a 4xx status code

func (*RefreshActiveStreamSessionBadRequest) IsCode added in v0.2.27 

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

IsCode returns true when this refresh active stream session bad request response a status code equal to that given

func (*RefreshActiveStreamSessionBadRequest) IsRedirect added in v0.2.27 

func (o *RefreshActiveStreamSessionBadRequest) IsRedirect() bool

IsRedirect returns true when this refresh active stream session bad request response has a 3xx status code

func (*RefreshActiveStreamSessionBadRequest) IsServerError added in v0.2.27 

func (o *RefreshActiveStreamSessionBadRequest) IsServerError() bool

IsServerError returns true when this refresh active stream session bad request response has a 5xx status code

func (*RefreshActiveStreamSessionBadRequest) IsSuccess added in v0.2.27 

func (o *RefreshActiveStreamSessionBadRequest) IsSuccess() bool

IsSuccess returns true when this refresh active stream session bad request response has a 2xx status code

func (*RefreshActiveStreamSessionBadRequest) String added in v0.2.27 

func (o *RefreshActiveStreamSessionBadRequest) String() string

type RefreshActiveStreamSessionDefault 

type RefreshActiveStreamSessionDefault struct {
	Payload *models.MsaReplyMetaOnly
	// contains filtered or unexported fields
}

RefreshActiveStreamSessionDefault describes a response with status code -1, with default header values.

OK

func NewRefreshActiveStreamSessionDefault 

func NewRefreshActiveStreamSessionDefault(code int) *RefreshActiveStreamSessionDefault

NewRefreshActiveStreamSessionDefault creates a RefreshActiveStreamSessionDefault with default headers values

func (*RefreshActiveStreamSessionDefault) Code 

func (o *RefreshActiveStreamSessionDefault) Code() int

Code gets the status code for the refresh active stream session default response

func (*RefreshActiveStreamSessionDefault) Error 

func (o *RefreshActiveStreamSessionDefault) Error() string

func (*RefreshActiveStreamSessionDefault) GetPayload 

func (o *RefreshActiveStreamSessionDefault) GetPayload() *models.MsaReplyMetaOnly

func (*RefreshActiveStreamSessionDefault) IsClientError added in v0.2.27 

func (o *RefreshActiveStreamSessionDefault) IsClientError() bool

IsClientError returns true when this refresh active stream session default response has a 4xx status code

func (*RefreshActiveStreamSessionDefault) IsCode added in v0.2.27 

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

IsCode returns true when this refresh active stream session default response a status code equal to that given

func (*RefreshActiveStreamSessionDefault) IsRedirect added in v0.2.27 

func (o *RefreshActiveStreamSessionDefault) IsRedirect() bool

IsRedirect returns true when this refresh active stream session default response has a 3xx status code

func (*RefreshActiveStreamSessionDefault) IsServerError added in v0.2.27 

func (o *RefreshActiveStreamSessionDefault) IsServerError() bool

IsServerError returns true when this refresh active stream session default response has a 5xx status code

func (*RefreshActiveStreamSessionDefault) IsSuccess added in v0.2.27 

func (o *RefreshActiveStreamSessionDefault) IsSuccess() bool

IsSuccess returns true when this refresh active stream session default response has a 2xx status code

func (*RefreshActiveStreamSessionDefault) String added in v0.2.27 

func (o *RefreshActiveStreamSessionDefault) String() string

type RefreshActiveStreamSessionForbidden 

type RefreshActiveStreamSessionForbidden struct {

	/* Request limit per minute.
	 */
	XRateLimitLimit int64

	/* The number of requests remaining for the sliding one minute window.
	 */
	XRateLimitRemaining int64

	Payload *models.MsaReplyMetaOnly
}

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

Forbidden

func NewRefreshActiveStreamSessionForbidden 

func NewRefreshActiveStreamSessionForbidden() *RefreshActiveStreamSessionForbidden

NewRefreshActiveStreamSessionForbidden creates a RefreshActiveStreamSessionForbidden with default headers values

func (*RefreshActiveStreamSessionForbidden) Code added in v0.2.33 

func (o *RefreshActiveStreamSessionForbidden) Code() int

Code gets the status code for the refresh active stream session forbidden response

func (*RefreshActiveStreamSessionForbidden) Error 

func (o *RefreshActiveStreamSessionForbidden) Error() string

func (*RefreshActiveStreamSessionForbidden) GetPayload 

func (o *RefreshActiveStreamSessionForbidden) GetPayload() *models.MsaReplyMetaOnly

func (*RefreshActiveStreamSessionForbidden) IsClientError added in v0.2.27 

func (o *RefreshActiveStreamSessionForbidden) IsClientError() bool

IsClientError returns true when this refresh active stream session forbidden response has a 4xx status code

func (*RefreshActiveStreamSessionForbidden) IsCode added in v0.2.27 

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

IsCode returns true when this refresh active stream session forbidden response a status code equal to that given

func (*RefreshActiveStreamSessionForbidden) IsRedirect added in v0.2.27 

func (o *RefreshActiveStreamSessionForbidden) IsRedirect() bool

IsRedirect returns true when this refresh active stream session forbidden response has a 3xx status code

func (*RefreshActiveStreamSessionForbidden) IsServerError added in v0.2.27 

func (o *RefreshActiveStreamSessionForbidden) IsServerError() bool

IsServerError returns true when this refresh active stream session forbidden response has a 5xx status code

func (*RefreshActiveStreamSessionForbidden) IsSuccess added in v0.2.27 

func (o *RefreshActiveStreamSessionForbidden) IsSuccess() bool

IsSuccess returns true when this refresh active stream session forbidden response has a 2xx status code

func (*RefreshActiveStreamSessionForbidden) String added in v0.2.27 

func (o *RefreshActiveStreamSessionForbidden) String() string

type RefreshActiveStreamSessionInternalServerError 

type RefreshActiveStreamSessionInternalServerError struct {

	/* Request limit per minute.
	 */
	XRateLimitLimit int64

	/* The number of requests remaining for the sliding one minute window.
	 */
	XRateLimitRemaining int64

	Payload *models.MsaReplyMetaOnly
}

RefreshActiveStreamSessionInternalServerError describes a response with status code 500, with default header values.

Internal Server Error

func NewRefreshActiveStreamSessionInternalServerError 

func NewRefreshActiveStreamSessionInternalServerError() *RefreshActiveStreamSessionInternalServerError

NewRefreshActiveStreamSessionInternalServerError creates a RefreshActiveStreamSessionInternalServerError with default headers values

func (*RefreshActiveStreamSessionInternalServerError) Code added in v0.2.33 

func (o *RefreshActiveStreamSessionInternalServerError) Code() int

Code gets the status code for the refresh active stream session internal server error response

func (*RefreshActiveStreamSessionInternalServerError) Error 

func (o *RefreshActiveStreamSessionInternalServerError) Error() string

func (*RefreshActiveStreamSessionInternalServerError) GetPayload 

func (o *RefreshActiveStreamSessionInternalServerError) GetPayload() *models.MsaReplyMetaOnly

func (*RefreshActiveStreamSessionInternalServerError) IsClientError added in v0.2.27 

func (o *RefreshActiveStreamSessionInternalServerError) IsClientError() bool

IsClientError returns true when this refresh active stream session internal server error response has a 4xx status code

func (*RefreshActiveStreamSessionInternalServerError) IsCode added in v0.2.27 

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

IsCode returns true when this refresh active stream session internal server error response a status code equal to that given

func (*RefreshActiveStreamSessionInternalServerError) IsRedirect added in v0.2.27 

func (o *RefreshActiveStreamSessionInternalServerError) IsRedirect() bool

IsRedirect returns true when this refresh active stream session internal server error response has a 3xx status code

func (*RefreshActiveStreamSessionInternalServerError) IsServerError added in v0.2.27 

func (o *RefreshActiveStreamSessionInternalServerError) IsServerError() bool

IsServerError returns true when this refresh active stream session internal server error response has a 5xx status code

func (*RefreshActiveStreamSessionInternalServerError) IsSuccess added in v0.2.27 

func (o *RefreshActiveStreamSessionInternalServerError) IsSuccess() bool

IsSuccess returns true when this refresh active stream session internal server error response has a 2xx status code

func (*RefreshActiveStreamSessionInternalServerError) String added in v0.2.27 

func (o *RefreshActiveStreamSessionInternalServerError) String() string

type RefreshActiveStreamSessionOK 

type RefreshActiveStreamSessionOK struct {

	/* Request limit per minute.
	 */
	XRateLimitLimit int64

	/* The number of requests remaining for the sliding one minute window.
	 */
	XRateLimitRemaining int64

	Payload *models.MsaReplyMetaOnly
}

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

OK

func NewRefreshActiveStreamSessionOK 

func NewRefreshActiveStreamSessionOK() *RefreshActiveStreamSessionOK

NewRefreshActiveStreamSessionOK creates a RefreshActiveStreamSessionOK with default headers values

func (*RefreshActiveStreamSessionOK) Code added in v0.2.33 

func (o *RefreshActiveStreamSessionOK) Code() int

Code gets the status code for the refresh active stream session o k response

func (*RefreshActiveStreamSessionOK) Error 

func (o *RefreshActiveStreamSessionOK) Error() string

func (*RefreshActiveStreamSessionOK) GetPayload 

func (o *RefreshActiveStreamSessionOK) GetPayload() *models.MsaReplyMetaOnly

func (*RefreshActiveStreamSessionOK) IsClientError added in v0.2.27 

func (o *RefreshActiveStreamSessionOK) IsClientError() bool

IsClientError returns true when this refresh active stream session o k response has a 4xx status code

func (*RefreshActiveStreamSessionOK) IsCode added in v0.2.27 

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

IsCode returns true when this refresh active stream session o k response a status code equal to that given

func (*RefreshActiveStreamSessionOK) IsRedirect added in v0.2.27 

func (o *RefreshActiveStreamSessionOK) IsRedirect() bool

IsRedirect returns true when this refresh active stream session o k response has a 3xx status code

func (*RefreshActiveStreamSessionOK) IsServerError added in v0.2.27 

func (o *RefreshActiveStreamSessionOK) IsServerError() bool

IsServerError returns true when this refresh active stream session o k response has a 5xx status code

func (*RefreshActiveStreamSessionOK) IsSuccess added in v0.2.27 

func (o *RefreshActiveStreamSessionOK) IsSuccess() bool

IsSuccess returns true when this refresh active stream session o k response has a 2xx status code

func (*RefreshActiveStreamSessionOK) String added in v0.2.27 

func (o *RefreshActiveStreamSessionOK) String() string

type RefreshActiveStreamSessionParams 

type RefreshActiveStreamSessionParams struct {

	/* ActionName.

	   Action name. Allowed value is refresh_active_stream_session.
	*/
	ActionName string

	/* AppID.

	   Label that identifies your connection. Max: 32 alphanumeric characters (a-z, A-Z, 0-9).
	*/
	AppID string

	/* Partition.

	   Partition to request data for.
	*/
	Partition int64

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

RefreshActiveStreamSessionParams contains all the parameters to send to the API endpoint 

for the refresh active stream session operation.

Typically these are written to a http.Request.

func NewRefreshActiveStreamSessionParams 

func NewRefreshActiveStreamSessionParams() *RefreshActiveStreamSessionParams

NewRefreshActiveStreamSessionParams creates a new RefreshActiveStreamSessionParams 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 NewRefreshActiveStreamSessionParamsWithContext 

func NewRefreshActiveStreamSessionParamsWithContext(ctx context.Context) *RefreshActiveStreamSessionParams

NewRefreshActiveStreamSessionParamsWithContext creates a new RefreshActiveStreamSessionParams object with the ability to set a context for a request.

func NewRefreshActiveStreamSessionParamsWithHTTPClient 

func NewRefreshActiveStreamSessionParamsWithHTTPClient(client *http.Client) *RefreshActiveStreamSessionParams

NewRefreshActiveStreamSessionParamsWithHTTPClient creates a new RefreshActiveStreamSessionParams object with the ability to set a custom HTTPClient for a request.

func NewRefreshActiveStreamSessionParamsWithTimeout 

func NewRefreshActiveStreamSessionParamsWithTimeout(timeout time.Duration) *RefreshActiveStreamSessionParams

NewRefreshActiveStreamSessionParamsWithTimeout creates a new RefreshActiveStreamSessionParams object with the ability to set a timeout on a request.

func (*RefreshActiveStreamSessionParams) SetActionName 

func (o *RefreshActiveStreamSessionParams) SetActionName(actionName string)

SetActionName adds the actionName to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) SetAppID 

func (o *RefreshActiveStreamSessionParams) SetAppID(appID string)

SetAppID adds the appId to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) SetContext 

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

SetContext adds the context to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) SetDefaults 

func (o *RefreshActiveStreamSessionParams) SetDefaults()

SetDefaults hydrates default values in the refresh active stream session params (not the query body).

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

func (*RefreshActiveStreamSessionParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) SetPartition 

func (o *RefreshActiveStreamSessionParams) SetPartition(partition int64)

SetPartition adds the partition to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) SetTimeout 

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

SetTimeout adds the timeout to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WithActionName 

func (o *RefreshActiveStreamSessionParams) WithActionName(actionName string) *RefreshActiveStreamSessionParams

WithActionName adds the actionName to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WithAppID 

func (o *RefreshActiveStreamSessionParams) WithAppID(appID string) *RefreshActiveStreamSessionParams

WithAppID adds the appID to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WithContext 

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

WithContext adds the context to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WithDefaults 

func (o *RefreshActiveStreamSessionParams) WithDefaults() *RefreshActiveStreamSessionParams

WithDefaults hydrates default values in the refresh active stream session params (not the query body).

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

func (*RefreshActiveStreamSessionParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WithPartition 

func (o *RefreshActiveStreamSessionParams) WithPartition(partition int64) *RefreshActiveStreamSessionParams

WithPartition adds the partition to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WithTimeout 

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

WithTimeout adds the timeout to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type RefreshActiveStreamSessionReader 

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

RefreshActiveStreamSessionReader is a Reader for the RefreshActiveStreamSession structure.

func (*RefreshActiveStreamSessionReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type RefreshActiveStreamSessionTooManyRequests 

type RefreshActiveStreamSessionTooManyRequests struct {

	/* Request limit per minute.
	 */
	XRateLimitLimit int64

	/* The number of requests remaining for the sliding one minute window.
	 */
	XRateLimitRemaining int64

	/* Too many requests, retry after this time (as milliseconds since epoch)
	 */
	XRateLimitRetryAfter int64

	Payload *models.MsaReplyMetaOnly
}

RefreshActiveStreamSessionTooManyRequests describes a response with status code 429, with default header values.

Too Many Requests

func NewRefreshActiveStreamSessionTooManyRequests 

func NewRefreshActiveStreamSessionTooManyRequests() *RefreshActiveStreamSessionTooManyRequests

NewRefreshActiveStreamSessionTooManyRequests creates a RefreshActiveStreamSessionTooManyRequests with default headers values

func (*RefreshActiveStreamSessionTooManyRequests) Code added in v0.2.33 

func (o *RefreshActiveStreamSessionTooManyRequests) Code() int

Code gets the status code for the refresh active stream session too many requests response

func (*RefreshActiveStreamSessionTooManyRequests) Error 

func (o *RefreshActiveStreamSessionTooManyRequests) Error() string

func (*RefreshActiveStreamSessionTooManyRequests) GetPayload 

func (o *RefreshActiveStreamSessionTooManyRequests) GetPayload() *models.MsaReplyMetaOnly

func (*RefreshActiveStreamSessionTooManyRequests) IsClientError added in v0.2.27 

func (o *RefreshActiveStreamSessionTooManyRequests) IsClientError() bool

IsClientError returns true when this refresh active stream session too many requests response has a 4xx status code

func (*RefreshActiveStreamSessionTooManyRequests) IsCode added in v0.2.27 

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

IsCode returns true when this refresh active stream session too many requests response a status code equal to that given

func (*RefreshActiveStreamSessionTooManyRequests) IsRedirect added in v0.2.27 

func (o *RefreshActiveStreamSessionTooManyRequests) IsRedirect() bool

IsRedirect returns true when this refresh active stream session too many requests response has a 3xx status code

func (*RefreshActiveStreamSessionTooManyRequests) IsServerError added in v0.2.27 

func (o *RefreshActiveStreamSessionTooManyRequests) IsServerError() bool

IsServerError returns true when this refresh active stream session too many requests response has a 5xx status code

func (*RefreshActiveStreamSessionTooManyRequests) IsSuccess added in v0.2.27 

func (o *RefreshActiveStreamSessionTooManyRequests) IsSuccess() bool

IsSuccess returns true when this refresh active stream session too many requests response has a 2xx status code

func (*RefreshActiveStreamSessionTooManyRequests) String added in v0.2.27 

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