Documentation ¶
Index ¶
- type Client
- func (a *Client) ListAvailableStreamsOAuth2(params *ListAvailableStreamsOAuth2Params, opts ...ClientOption) (*ListAvailableStreamsOAuth2OK, error)
- func (a *Client) RefreshActiveStreamSession(params *RefreshActiveStreamSessionParams, opts ...ClientOption) (*RefreshActiveStreamSessionOK, error)
- func (a *Client) SetTransport(transport runtime.ClientTransport)
- type ClientOption
- type ClientService
- type ListAvailableStreamsOAuth2BadRequest
- func (o *ListAvailableStreamsOAuth2BadRequest) Code() int
- func (o *ListAvailableStreamsOAuth2BadRequest) Error() string
- func (o *ListAvailableStreamsOAuth2BadRequest) GetPayload() *models.MainDiscoveryResponseV2
- func (o *ListAvailableStreamsOAuth2BadRequest) IsClientError() bool
- func (o *ListAvailableStreamsOAuth2BadRequest) IsCode(code int) bool
- func (o *ListAvailableStreamsOAuth2BadRequest) IsRedirect() bool
- func (o *ListAvailableStreamsOAuth2BadRequest) IsServerError() bool
- func (o *ListAvailableStreamsOAuth2BadRequest) IsSuccess() bool
- func (o *ListAvailableStreamsOAuth2BadRequest) String() string
- type ListAvailableStreamsOAuth2Forbidden
- func (o *ListAvailableStreamsOAuth2Forbidden) Code() int
- func (o *ListAvailableStreamsOAuth2Forbidden) Error() string
- func (o *ListAvailableStreamsOAuth2Forbidden) GetPayload() *models.MsaReplyMetaOnly
- func (o *ListAvailableStreamsOAuth2Forbidden) IsClientError() bool
- func (o *ListAvailableStreamsOAuth2Forbidden) IsCode(code int) bool
- func (o *ListAvailableStreamsOAuth2Forbidden) IsRedirect() bool
- func (o *ListAvailableStreamsOAuth2Forbidden) IsServerError() bool
- func (o *ListAvailableStreamsOAuth2Forbidden) IsSuccess() bool
- func (o *ListAvailableStreamsOAuth2Forbidden) String() string
- type ListAvailableStreamsOAuth2InternalServerError
- func (o *ListAvailableStreamsOAuth2InternalServerError) Code() int
- func (o *ListAvailableStreamsOAuth2InternalServerError) Error() string
- func (o *ListAvailableStreamsOAuth2InternalServerError) GetPayload() *models.MainDiscoveryResponseV2
- func (o *ListAvailableStreamsOAuth2InternalServerError) IsClientError() bool
- func (o *ListAvailableStreamsOAuth2InternalServerError) IsCode(code int) bool
- func (o *ListAvailableStreamsOAuth2InternalServerError) IsRedirect() bool
- func (o *ListAvailableStreamsOAuth2InternalServerError) IsServerError() bool
- func (o *ListAvailableStreamsOAuth2InternalServerError) IsSuccess() bool
- func (o *ListAvailableStreamsOAuth2InternalServerError) String() string
- type ListAvailableStreamsOAuth2OK
- func (o *ListAvailableStreamsOAuth2OK) Code() int
- func (o *ListAvailableStreamsOAuth2OK) Error() string
- func (o *ListAvailableStreamsOAuth2OK) GetPayload() *models.MainDiscoveryResponseV2
- func (o *ListAvailableStreamsOAuth2OK) IsClientError() bool
- func (o *ListAvailableStreamsOAuth2OK) IsCode(code int) bool
- func (o *ListAvailableStreamsOAuth2OK) IsRedirect() bool
- func (o *ListAvailableStreamsOAuth2OK) IsServerError() bool
- func (o *ListAvailableStreamsOAuth2OK) IsSuccess() bool
- func (o *ListAvailableStreamsOAuth2OK) String() string
- type ListAvailableStreamsOAuth2Params
- func NewListAvailableStreamsOAuth2Params() *ListAvailableStreamsOAuth2Params
- func NewListAvailableStreamsOAuth2ParamsWithContext(ctx context.Context) *ListAvailableStreamsOAuth2Params
- func NewListAvailableStreamsOAuth2ParamsWithHTTPClient(client *http.Client) *ListAvailableStreamsOAuth2Params
- func NewListAvailableStreamsOAuth2ParamsWithTimeout(timeout time.Duration) *ListAvailableStreamsOAuth2Params
- func (o *ListAvailableStreamsOAuth2Params) SetAppID(appID string)
- func (o *ListAvailableStreamsOAuth2Params) SetContext(ctx context.Context)
- func (o *ListAvailableStreamsOAuth2Params) SetDefaults()
- func (o *ListAvailableStreamsOAuth2Params) SetFormat(format *string)
- func (o *ListAvailableStreamsOAuth2Params) SetHTTPClient(client *http.Client)
- func (o *ListAvailableStreamsOAuth2Params) SetTimeout(timeout time.Duration)
- func (o *ListAvailableStreamsOAuth2Params) WithAppID(appID string) *ListAvailableStreamsOAuth2Params
- func (o *ListAvailableStreamsOAuth2Params) WithContext(ctx context.Context) *ListAvailableStreamsOAuth2Params
- func (o *ListAvailableStreamsOAuth2Params) WithDefaults() *ListAvailableStreamsOAuth2Params
- func (o *ListAvailableStreamsOAuth2Params) WithFormat(format *string) *ListAvailableStreamsOAuth2Params
- func (o *ListAvailableStreamsOAuth2Params) WithHTTPClient(client *http.Client) *ListAvailableStreamsOAuth2Params
- func (o *ListAvailableStreamsOAuth2Params) WithTimeout(timeout time.Duration) *ListAvailableStreamsOAuth2Params
- func (o *ListAvailableStreamsOAuth2Params) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type ListAvailableStreamsOAuth2Reader
- type ListAvailableStreamsOAuth2TooManyRequests
- func (o *ListAvailableStreamsOAuth2TooManyRequests) Code() int
- func (o *ListAvailableStreamsOAuth2TooManyRequests) Error() string
- func (o *ListAvailableStreamsOAuth2TooManyRequests) GetPayload() *models.MsaReplyMetaOnly
- func (o *ListAvailableStreamsOAuth2TooManyRequests) IsClientError() bool
- func (o *ListAvailableStreamsOAuth2TooManyRequests) IsCode(code int) bool
- func (o *ListAvailableStreamsOAuth2TooManyRequests) IsRedirect() bool
- func (o *ListAvailableStreamsOAuth2TooManyRequests) IsServerError() bool
- func (o *ListAvailableStreamsOAuth2TooManyRequests) IsSuccess() bool
- func (o *ListAvailableStreamsOAuth2TooManyRequests) String() string
- type RefreshActiveStreamSessionBadRequest
- func (o *RefreshActiveStreamSessionBadRequest) Code() int
- func (o *RefreshActiveStreamSessionBadRequest) Error() string
- func (o *RefreshActiveStreamSessionBadRequest) GetPayload() *models.MsaReplyMetaOnly
- func (o *RefreshActiveStreamSessionBadRequest) IsClientError() bool
- func (o *RefreshActiveStreamSessionBadRequest) IsCode(code int) bool
- func (o *RefreshActiveStreamSessionBadRequest) IsRedirect() bool
- func (o *RefreshActiveStreamSessionBadRequest) IsServerError() bool
- func (o *RefreshActiveStreamSessionBadRequest) IsSuccess() bool
- func (o *RefreshActiveStreamSessionBadRequest) String() string
- type RefreshActiveStreamSessionForbidden
- func (o *RefreshActiveStreamSessionForbidden) Code() int
- func (o *RefreshActiveStreamSessionForbidden) Error() string
- func (o *RefreshActiveStreamSessionForbidden) GetPayload() *models.MsaReplyMetaOnly
- func (o *RefreshActiveStreamSessionForbidden) IsClientError() bool
- func (o *RefreshActiveStreamSessionForbidden) IsCode(code int) bool
- func (o *RefreshActiveStreamSessionForbidden) IsRedirect() bool
- func (o *RefreshActiveStreamSessionForbidden) IsServerError() bool
- func (o *RefreshActiveStreamSessionForbidden) IsSuccess() bool
- func (o *RefreshActiveStreamSessionForbidden) String() string
- type RefreshActiveStreamSessionInternalServerError
- func (o *RefreshActiveStreamSessionInternalServerError) Code() int
- func (o *RefreshActiveStreamSessionInternalServerError) Error() string
- func (o *RefreshActiveStreamSessionInternalServerError) GetPayload() *models.MsaReplyMetaOnly
- func (o *RefreshActiveStreamSessionInternalServerError) IsClientError() bool
- func (o *RefreshActiveStreamSessionInternalServerError) IsCode(code int) bool
- func (o *RefreshActiveStreamSessionInternalServerError) IsRedirect() bool
- func (o *RefreshActiveStreamSessionInternalServerError) IsServerError() bool
- func (o *RefreshActiveStreamSessionInternalServerError) IsSuccess() bool
- func (o *RefreshActiveStreamSessionInternalServerError) String() string
- type RefreshActiveStreamSessionOK
- func (o *RefreshActiveStreamSessionOK) Code() int
- func (o *RefreshActiveStreamSessionOK) Error() string
- func (o *RefreshActiveStreamSessionOK) GetPayload() *models.MsaReplyMetaOnly
- func (o *RefreshActiveStreamSessionOK) IsClientError() bool
- func (o *RefreshActiveStreamSessionOK) IsCode(code int) bool
- func (o *RefreshActiveStreamSessionOK) IsRedirect() bool
- func (o *RefreshActiveStreamSessionOK) IsServerError() bool
- func (o *RefreshActiveStreamSessionOK) IsSuccess() bool
- func (o *RefreshActiveStreamSessionOK) String() string
- type RefreshActiveStreamSessionParams
- func NewRefreshActiveStreamSessionParams() *RefreshActiveStreamSessionParams
- func NewRefreshActiveStreamSessionParamsWithContext(ctx context.Context) *RefreshActiveStreamSessionParams
- func NewRefreshActiveStreamSessionParamsWithHTTPClient(client *http.Client) *RefreshActiveStreamSessionParams
- func NewRefreshActiveStreamSessionParamsWithTimeout(timeout time.Duration) *RefreshActiveStreamSessionParams
- func (o *RefreshActiveStreamSessionParams) SetActionName(actionName string)
- func (o *RefreshActiveStreamSessionParams) SetAppID(appID string)
- func (o *RefreshActiveStreamSessionParams) SetContext(ctx context.Context)
- func (o *RefreshActiveStreamSessionParams) SetDefaults()
- func (o *RefreshActiveStreamSessionParams) SetHTTPClient(client *http.Client)
- func (o *RefreshActiveStreamSessionParams) SetPartition(partition int64)
- func (o *RefreshActiveStreamSessionParams) SetTimeout(timeout time.Duration)
- func (o *RefreshActiveStreamSessionParams) WithActionName(actionName string) *RefreshActiveStreamSessionParams
- func (o *RefreshActiveStreamSessionParams) WithAppID(appID string) *RefreshActiveStreamSessionParams
- func (o *RefreshActiveStreamSessionParams) WithContext(ctx context.Context) *RefreshActiveStreamSessionParams
- func (o *RefreshActiveStreamSessionParams) WithDefaults() *RefreshActiveStreamSessionParams
- func (o *RefreshActiveStreamSessionParams) WithHTTPClient(client *http.Client) *RefreshActiveStreamSessionParams
- func (o *RefreshActiveStreamSessionParams) WithPartition(partition int64) *RefreshActiveStreamSessionParams
- func (o *RefreshActiveStreamSessionParams) WithTimeout(timeout time.Duration) *RefreshActiveStreamSessionParams
- func (o *RefreshActiveStreamSessionParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type RefreshActiveStreamSessionReader
- type RefreshActiveStreamSessionTooManyRequests
- func (o *RefreshActiveStreamSessionTooManyRequests) Code() int
- func (o *RefreshActiveStreamSessionTooManyRequests) Error() string
- func (o *RefreshActiveStreamSessionTooManyRequests) GetPayload() *models.MsaReplyMetaOnly
- func (o *RefreshActiveStreamSessionTooManyRequests) IsClientError() bool
- func (o *RefreshActiveStreamSessionTooManyRequests) IsCode(code int) bool
- func (o *RefreshActiveStreamSessionTooManyRequests) IsRedirect() bool
- func (o *RefreshActiveStreamSessionTooManyRequests) IsServerError() bool
- func (o *RefreshActiveStreamSessionTooManyRequests) IsSuccess() bool
- func (o *RefreshActiveStreamSessionTooManyRequests) String() string
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
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 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
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 { /* 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
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 { /* 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
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 { /* 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
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 { /* 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
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 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
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 { /* 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
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 { /* 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
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 { /* 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
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