event_streams

package
v0.6.0 Latest Latest
Warning

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

Go to latest
Published: Feb 27, 2024 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 {

	/* Trace-ID: submit to support if resolving an issue
	 */
	XCSTRACEID string

	/* 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

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

func (*ListAvailableStreamsOAuth2BadRequest) Error

func (*ListAvailableStreamsOAuth2BadRequest) GetPayload

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

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

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

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

type ListAvailableStreamsOAuth2Forbidden

type ListAvailableStreamsOAuth2Forbidden struct {

	/* Trace-ID: submit to support if resolving an issue
	 */
	XCSTRACEID string

	/* 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

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

func (*ListAvailableStreamsOAuth2Forbidden) Error

func (*ListAvailableStreamsOAuth2Forbidden) GetPayload

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

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

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

type ListAvailableStreamsOAuth2InternalServerError

type ListAvailableStreamsOAuth2InternalServerError struct {

	/* Trace-ID: submit to support if resolving an issue
	 */
	XCSTRACEID string

	/* 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

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

func (*ListAvailableStreamsOAuth2InternalServerError) Error

func (*ListAvailableStreamsOAuth2InternalServerError) GetPayload

func (*ListAvailableStreamsOAuth2InternalServerError) IsClientError added in v0.2.27

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

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

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

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

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

type ListAvailableStreamsOAuth2OK

type ListAvailableStreamsOAuth2OK struct {

	/* Trace-ID: submit to support if resolving an issue
	 */
	XCSTRACEID string

	/* 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

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

func (*ListAvailableStreamsOAuth2OK) Error

func (*ListAvailableStreamsOAuth2OK) GetPayload

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

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

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

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

func (*ListAvailableStreamsOAuth2Params) WithContext

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

func (*ListAvailableStreamsOAuth2Params) WithDefaults

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

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

func (*ListAvailableStreamsOAuth2Params) WithHTTPClient

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

func (*ListAvailableStreamsOAuth2Params) WithTimeout

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

func (*ListAvailableStreamsOAuth2Params) WriteToRequest

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 {

	/* Trace-ID: submit to support if resolving an issue
	 */
	XCSTRACEID string

	/* 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

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

func (*ListAvailableStreamsOAuth2TooManyRequests) Error

func (*ListAvailableStreamsOAuth2TooManyRequests) GetPayload

func (*ListAvailableStreamsOAuth2TooManyRequests) IsClientError added in v0.2.27

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

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

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

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

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

type RefreshActiveStreamSessionBadRequest

type RefreshActiveStreamSessionBadRequest struct {

	/* Trace-ID: submit to support if resolving an issue
	 */
	XCSTRACEID string

	/* 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

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

func (*RefreshActiveStreamSessionBadRequest) Error

func (*RefreshActiveStreamSessionBadRequest) GetPayload

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

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

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

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

type RefreshActiveStreamSessionForbidden

type RefreshActiveStreamSessionForbidden struct {

	/* Trace-ID: submit to support if resolving an issue
	 */
	XCSTRACEID string

	/* 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

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

func (*RefreshActiveStreamSessionForbidden) Error

func (*RefreshActiveStreamSessionForbidden) GetPayload

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

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

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

func (*RefreshActiveStreamSessionForbidden) String added in v0.2.27

type RefreshActiveStreamSessionInternalServerError

type RefreshActiveStreamSessionInternalServerError struct {

	/* Trace-ID: submit to support if resolving an issue
	 */
	XCSTRACEID string

	/* 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

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

func (*RefreshActiveStreamSessionInternalServerError) Error

func (*RefreshActiveStreamSessionInternalServerError) GetPayload

func (*RefreshActiveStreamSessionInternalServerError) IsClientError added in v0.2.27

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

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

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

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

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

type RefreshActiveStreamSessionOK

type RefreshActiveStreamSessionOK struct {

	/* Trace-ID: submit to support if resolving an issue
	 */
	XCSTRACEID string

	/* 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

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

func (*RefreshActiveStreamSessionOK) Error

func (*RefreshActiveStreamSessionOK) GetPayload

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

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

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

WithActionName adds the actionName to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WithAppID

WithAppID adds the appID to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WithContext

WithContext adds the context to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WithDefaults

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

WithHTTPClient adds the HTTPClient to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WithPartition

WithPartition adds the partition to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WithTimeout

WithTimeout adds the timeout to the refresh active stream session params

func (*RefreshActiveStreamSessionParams) WriteToRequest

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 {

	/* Trace-ID: submit to support if resolving an issue
	 */
	XCSTRACEID string

	/* 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

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

func (*RefreshActiveStreamSessionTooManyRequests) Error

func (*RefreshActiveStreamSessionTooManyRequests) GetPayload

func (*RefreshActiveStreamSessionTooManyRequests) IsClientError added in v0.2.27

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

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

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

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

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

Jump to

Keyboard shortcuts

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