Versions in this module Expand all Collapse all v0 v0.85.0 Dec 4, 2025 Changes in this version + type Client struct + func (a *Client) CreateSubscriptionHandler(params *CreateSubscriptionHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*CreateSubscriptionHandlerOK, *CreateSubscriptionHandlerBadRequest, ...) + func (a *Client) CreateSubscriptionHandlerShort(params *CreateSubscriptionHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*CreateSubscriptionHandlerOK, error) + func (a *Client) CreateTopicHandler(params *CreateTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*CreateTopicHandlerOK, *CreateTopicHandlerBadRequest, ...) + func (a *Client) CreateTopicHandlerShort(params *CreateTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*CreateTopicHandlerOK, error) + func (a *Client) DeleteTopicHandler(params *DeleteTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteTopicHandlerOK, *DeleteTopicHandlerUnauthorized, ...) + func (a *Client) DeleteTopicHandlerShort(params *DeleteTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteTopicHandlerOK, error) + func (a *Client) ListTopicsHandler(params *ListTopicsHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*ListTopicsHandlerOK, *ListTopicsHandlerBadRequest, ...) + func (a *Client) ListTopicsHandlerShort(params *ListTopicsHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*ListTopicsHandlerOK, error) + func (a *Client) SetTransport(transport runtime.ClientTransport) + func (a *Client) UnsubscribeTopicHandler(params *UnsubscribeTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*UnsubscribeTopicHandlerOK, *UnsubscribeTopicHandlerUnauthorized, ...) + func (a *Client) UnsubscribeTopicHandlerShort(params *UnsubscribeTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*UnsubscribeTopicHandlerOK, error) + type ClientService interface + CreateSubscriptionHandler func(params *CreateSubscriptionHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*CreateSubscriptionHandlerOK, *CreateSubscriptionHandlerBadRequest, ...) + CreateSubscriptionHandlerShort func(params *CreateSubscriptionHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*CreateSubscriptionHandlerOK, error) + CreateTopicHandler func(params *CreateTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*CreateTopicHandlerOK, *CreateTopicHandlerBadRequest, ...) + CreateTopicHandlerShort func(params *CreateTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*CreateTopicHandlerOK, error) + DeleteTopicHandler func(params *DeleteTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteTopicHandlerOK, *DeleteTopicHandlerUnauthorized, ...) + DeleteTopicHandlerShort func(params *DeleteTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteTopicHandlerOK, error) + ListTopicsHandler func(params *ListTopicsHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*ListTopicsHandlerOK, *ListTopicsHandlerBadRequest, ...) + ListTopicsHandlerShort func(params *ListTopicsHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*ListTopicsHandlerOK, error) + SetTransport func(transport runtime.ClientTransport) + UnsubscribeTopicHandler func(params *UnsubscribeTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*UnsubscribeTopicHandlerOK, *UnsubscribeTopicHandlerUnauthorized, ...) + UnsubscribeTopicHandlerShort func(params *UnsubscribeTopicHandlerParams, authInfo runtime.ClientAuthInfoWriter) (*UnsubscribeTopicHandlerOK, error) + func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService + type CreateSubscriptionHandlerBadRequest struct + Payload *csmclientmodels.ResponseErrorResponse + func NewCreateSubscriptionHandlerBadRequest() *CreateSubscriptionHandlerBadRequest + func (o *CreateSubscriptionHandlerBadRequest) Error() string + func (o *CreateSubscriptionHandlerBadRequest) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *CreateSubscriptionHandlerBadRequest) ToJSONString() string + type CreateSubscriptionHandlerForbidden struct + Payload *csmclientmodels.ResponseErrorResponse + func NewCreateSubscriptionHandlerForbidden() *CreateSubscriptionHandlerForbidden + func (o *CreateSubscriptionHandlerForbidden) Error() string + func (o *CreateSubscriptionHandlerForbidden) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *CreateSubscriptionHandlerForbidden) ToJSONString() string + type CreateSubscriptionHandlerInternalServerError struct + Payload *csmclientmodels.ResponseErrorResponse + func NewCreateSubscriptionHandlerInternalServerError() *CreateSubscriptionHandlerInternalServerError + func (o *CreateSubscriptionHandlerInternalServerError) Error() string + func (o *CreateSubscriptionHandlerInternalServerError) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *CreateSubscriptionHandlerInternalServerError) ToJSONString() string + type CreateSubscriptionHandlerNotFound struct + Payload *csmclientmodels.ResponseErrorResponse + func NewCreateSubscriptionHandlerNotFound() *CreateSubscriptionHandlerNotFound + func (o *CreateSubscriptionHandlerNotFound) Error() string + func (o *CreateSubscriptionHandlerNotFound) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *CreateSubscriptionHandlerNotFound) ToJSONString() string + type CreateSubscriptionHandlerOK struct + Payload *csmclientmodels.ApimodelCreateSubscriptionResponse + func NewCreateSubscriptionHandlerOK() *CreateSubscriptionHandlerOK + func (o *CreateSubscriptionHandlerOK) Error() string + func (o *CreateSubscriptionHandlerOK) GetPayload() *csmclientmodels.ApimodelCreateSubscriptionResponse + func (o *CreateSubscriptionHandlerOK) ToJSONString() string + type CreateSubscriptionHandlerParams struct + App string + AuthInfoWriter runtime.ClientAuthInfoWriter + Body *csmclientmodels.ApimodelCreateSubscriptionRequest + Context context.Context + HTTPClient *http.Client + Namespace string + RetryPolicy *utils.Retry + XFlightId *string + func NewCreateSubscriptionHandlerParams() *CreateSubscriptionHandlerParams + func NewCreateSubscriptionHandlerParamsWithContext(ctx context.Context) *CreateSubscriptionHandlerParams + func NewCreateSubscriptionHandlerParamsWithHTTPClient(client *http.Client) *CreateSubscriptionHandlerParams + func NewCreateSubscriptionHandlerParamsWithTimeout(timeout time.Duration) *CreateSubscriptionHandlerParams + func (o *CreateSubscriptionHandlerParams) SetApp(app string) + func (o *CreateSubscriptionHandlerParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter) + func (o *CreateSubscriptionHandlerParams) SetBody(body *csmclientmodels.ApimodelCreateSubscriptionRequest) + func (o *CreateSubscriptionHandlerParams) SetContext(ctx context.Context) + func (o *CreateSubscriptionHandlerParams) SetFlightId(flightId string) + func (o *CreateSubscriptionHandlerParams) SetHTTPClient(client *http.Client) + func (o *CreateSubscriptionHandlerParams) SetHTTPClientTransport(roundTripper http.RoundTripper) + func (o *CreateSubscriptionHandlerParams) SetNamespace(namespace string) + func (o *CreateSubscriptionHandlerParams) SetTimeout(timeout time.Duration) + func (o *CreateSubscriptionHandlerParams) WithApp(app string) *CreateSubscriptionHandlerParams + func (o *CreateSubscriptionHandlerParams) WithBody(body *csmclientmodels.ApimodelCreateSubscriptionRequest) *CreateSubscriptionHandlerParams + func (o *CreateSubscriptionHandlerParams) WithContext(ctx context.Context) *CreateSubscriptionHandlerParams + func (o *CreateSubscriptionHandlerParams) WithHTTPClient(client *http.Client) *CreateSubscriptionHandlerParams + func (o *CreateSubscriptionHandlerParams) WithNamespace(namespace string) *CreateSubscriptionHandlerParams + func (o *CreateSubscriptionHandlerParams) WithTimeout(timeout time.Duration) *CreateSubscriptionHandlerParams + func (o *CreateSubscriptionHandlerParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error + type CreateSubscriptionHandlerReader struct + func (o *CreateSubscriptionHandlerReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error) + type CreateSubscriptionHandlerUnauthorized struct + Payload *csmclientmodels.ResponseErrorResponse + func NewCreateSubscriptionHandlerUnauthorized() *CreateSubscriptionHandlerUnauthorized + func (o *CreateSubscriptionHandlerUnauthorized) Error() string + func (o *CreateSubscriptionHandlerUnauthorized) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *CreateSubscriptionHandlerUnauthorized) ToJSONString() string + type CreateTopicHandlerBadRequest struct + Payload *csmclientmodels.ResponseErrorResponse + func NewCreateTopicHandlerBadRequest() *CreateTopicHandlerBadRequest + func (o *CreateTopicHandlerBadRequest) Error() string + func (o *CreateTopicHandlerBadRequest) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *CreateTopicHandlerBadRequest) ToJSONString() string + type CreateTopicHandlerConflict struct + Payload *csmclientmodels.ResponseErrorResponse + func NewCreateTopicHandlerConflict() *CreateTopicHandlerConflict + func (o *CreateTopicHandlerConflict) Error() string + func (o *CreateTopicHandlerConflict) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *CreateTopicHandlerConflict) ToJSONString() string + type CreateTopicHandlerForbidden struct + Payload *csmclientmodels.ResponseErrorResponse + func NewCreateTopicHandlerForbidden() *CreateTopicHandlerForbidden + func (o *CreateTopicHandlerForbidden) Error() string + func (o *CreateTopicHandlerForbidden) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *CreateTopicHandlerForbidden) ToJSONString() string + type CreateTopicHandlerInternalServerError struct + Payload *csmclientmodels.ResponseErrorResponse + func NewCreateTopicHandlerInternalServerError() *CreateTopicHandlerInternalServerError + func (o *CreateTopicHandlerInternalServerError) Error() string + func (o *CreateTopicHandlerInternalServerError) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *CreateTopicHandlerInternalServerError) ToJSONString() string + type CreateTopicHandlerOK struct + Payload *csmclientmodels.ApimodelTopicResponse + func NewCreateTopicHandlerOK() *CreateTopicHandlerOK + func (o *CreateTopicHandlerOK) Error() string + func (o *CreateTopicHandlerOK) GetPayload() *csmclientmodels.ApimodelTopicResponse + func (o *CreateTopicHandlerOK) ToJSONString() string + type CreateTopicHandlerParams struct + AuthInfoWriter runtime.ClientAuthInfoWriter + Body *csmclientmodels.ApimodelCreateTopicRequest + Context context.Context + HTTPClient *http.Client + Namespace string + RetryPolicy *utils.Retry + XFlightId *string + func NewCreateTopicHandlerParams() *CreateTopicHandlerParams + func NewCreateTopicHandlerParamsWithContext(ctx context.Context) *CreateTopicHandlerParams + func NewCreateTopicHandlerParamsWithHTTPClient(client *http.Client) *CreateTopicHandlerParams + func NewCreateTopicHandlerParamsWithTimeout(timeout time.Duration) *CreateTopicHandlerParams + func (o *CreateTopicHandlerParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter) + func (o *CreateTopicHandlerParams) SetBody(body *csmclientmodels.ApimodelCreateTopicRequest) + func (o *CreateTopicHandlerParams) SetContext(ctx context.Context) + func (o *CreateTopicHandlerParams) SetFlightId(flightId string) + func (o *CreateTopicHandlerParams) SetHTTPClient(client *http.Client) + func (o *CreateTopicHandlerParams) SetHTTPClientTransport(roundTripper http.RoundTripper) + func (o *CreateTopicHandlerParams) SetNamespace(namespace string) + func (o *CreateTopicHandlerParams) SetTimeout(timeout time.Duration) + func (o *CreateTopicHandlerParams) WithBody(body *csmclientmodels.ApimodelCreateTopicRequest) *CreateTopicHandlerParams + func (o *CreateTopicHandlerParams) WithContext(ctx context.Context) *CreateTopicHandlerParams + func (o *CreateTopicHandlerParams) WithHTTPClient(client *http.Client) *CreateTopicHandlerParams + func (o *CreateTopicHandlerParams) WithNamespace(namespace string) *CreateTopicHandlerParams + func (o *CreateTopicHandlerParams) WithTimeout(timeout time.Duration) *CreateTopicHandlerParams + func (o *CreateTopicHandlerParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error + type CreateTopicHandlerReader struct + func (o *CreateTopicHandlerReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error) + type CreateTopicHandlerUnauthorized struct + Payload *csmclientmodels.ResponseErrorResponse + func NewCreateTopicHandlerUnauthorized() *CreateTopicHandlerUnauthorized + func (o *CreateTopicHandlerUnauthorized) Error() string + func (o *CreateTopicHandlerUnauthorized) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *CreateTopicHandlerUnauthorized) ToJSONString() string + type DeleteTopicHandlerForbidden struct + Payload *csmclientmodels.ResponseErrorResponse + func NewDeleteTopicHandlerForbidden() *DeleteTopicHandlerForbidden + func (o *DeleteTopicHandlerForbidden) Error() string + func (o *DeleteTopicHandlerForbidden) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *DeleteTopicHandlerForbidden) ToJSONString() string + type DeleteTopicHandlerInternalServerError struct + Payload *csmclientmodels.ResponseErrorResponse + func NewDeleteTopicHandlerInternalServerError() *DeleteTopicHandlerInternalServerError + func (o *DeleteTopicHandlerInternalServerError) Error() string + func (o *DeleteTopicHandlerInternalServerError) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *DeleteTopicHandlerInternalServerError) ToJSONString() string + type DeleteTopicHandlerNotFound struct + Payload *csmclientmodels.ResponseErrorResponse + func NewDeleteTopicHandlerNotFound() *DeleteTopicHandlerNotFound + func (o *DeleteTopicHandlerNotFound) Error() string + func (o *DeleteTopicHandlerNotFound) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *DeleteTopicHandlerNotFound) ToJSONString() string + type DeleteTopicHandlerOK struct + Payload *csmclientmodels.ApimodelTopicResponse + func NewDeleteTopicHandlerOK() *DeleteTopicHandlerOK + func (o *DeleteTopicHandlerOK) Error() string + func (o *DeleteTopicHandlerOK) GetPayload() *csmclientmodels.ApimodelTopicResponse + func (o *DeleteTopicHandlerOK) ToJSONString() string + type DeleteTopicHandlerParams struct + AuthInfoWriter runtime.ClientAuthInfoWriter + Context context.Context + HTTPClient *http.Client + Namespace string + RetryPolicy *utils.Retry + TopicName string + XFlightId *string + func NewDeleteTopicHandlerParams() *DeleteTopicHandlerParams + func NewDeleteTopicHandlerParamsWithContext(ctx context.Context) *DeleteTopicHandlerParams + func NewDeleteTopicHandlerParamsWithHTTPClient(client *http.Client) *DeleteTopicHandlerParams + func NewDeleteTopicHandlerParamsWithTimeout(timeout time.Duration) *DeleteTopicHandlerParams + func (o *DeleteTopicHandlerParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter) + func (o *DeleteTopicHandlerParams) SetContext(ctx context.Context) + func (o *DeleteTopicHandlerParams) SetFlightId(flightId string) + func (o *DeleteTopicHandlerParams) SetHTTPClient(client *http.Client) + func (o *DeleteTopicHandlerParams) SetHTTPClientTransport(roundTripper http.RoundTripper) + func (o *DeleteTopicHandlerParams) SetNamespace(namespace string) + func (o *DeleteTopicHandlerParams) SetTimeout(timeout time.Duration) + func (o *DeleteTopicHandlerParams) SetTopicName(topicName string) + func (o *DeleteTopicHandlerParams) WithContext(ctx context.Context) *DeleteTopicHandlerParams + func (o *DeleteTopicHandlerParams) WithHTTPClient(client *http.Client) *DeleteTopicHandlerParams + func (o *DeleteTopicHandlerParams) WithNamespace(namespace string) *DeleteTopicHandlerParams + func (o *DeleteTopicHandlerParams) WithTimeout(timeout time.Duration) *DeleteTopicHandlerParams + func (o *DeleteTopicHandlerParams) WithTopicName(topicName string) *DeleteTopicHandlerParams + func (o *DeleteTopicHandlerParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error + type DeleteTopicHandlerReader struct + func (o *DeleteTopicHandlerReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error) + type DeleteTopicHandlerUnauthorized struct + Payload *csmclientmodels.ResponseErrorResponse + func NewDeleteTopicHandlerUnauthorized() *DeleteTopicHandlerUnauthorized + func (o *DeleteTopicHandlerUnauthorized) Error() string + func (o *DeleteTopicHandlerUnauthorized) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *DeleteTopicHandlerUnauthorized) ToJSONString() string + type ListTopicsHandlerBadRequest struct + Payload *csmclientmodels.ResponseErrorResponse + func NewListTopicsHandlerBadRequest() *ListTopicsHandlerBadRequest + func (o *ListTopicsHandlerBadRequest) Error() string + func (o *ListTopicsHandlerBadRequest) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *ListTopicsHandlerBadRequest) ToJSONString() string + type ListTopicsHandlerForbidden struct + Payload *csmclientmodels.ResponseErrorResponse + func NewListTopicsHandlerForbidden() *ListTopicsHandlerForbidden + func (o *ListTopicsHandlerForbidden) Error() string + func (o *ListTopicsHandlerForbidden) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *ListTopicsHandlerForbidden) ToJSONString() string + type ListTopicsHandlerInternalServerError struct + Payload *csmclientmodels.ResponseErrorResponse + func NewListTopicsHandlerInternalServerError() *ListTopicsHandlerInternalServerError + func (o *ListTopicsHandlerInternalServerError) Error() string + func (o *ListTopicsHandlerInternalServerError) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *ListTopicsHandlerInternalServerError) ToJSONString() string + type ListTopicsHandlerOK struct + Payload *csmclientmodels.ApimodelListTopicsResponse + func NewListTopicsHandlerOK() *ListTopicsHandlerOK + func (o *ListTopicsHandlerOK) Error() string + func (o *ListTopicsHandlerOK) GetPayload() *csmclientmodels.ApimodelListTopicsResponse + func (o *ListTopicsHandlerOK) ToJSONString() string + type ListTopicsHandlerParams struct + AuthInfoWriter runtime.ClientAuthInfoWriter + Context context.Context + FuzzyTopicName *string + HTTPClient *http.Client + IsSubscribedByAppName *string + IsUnsubscribedByAppName *string + Limit *int64 + Namespace string + Offset *int64 + RetryPolicy *utils.Retry + XFlightId *string + func NewListTopicsHandlerParams() *ListTopicsHandlerParams + func NewListTopicsHandlerParamsWithContext(ctx context.Context) *ListTopicsHandlerParams + func NewListTopicsHandlerParamsWithHTTPClient(client *http.Client) *ListTopicsHandlerParams + func NewListTopicsHandlerParamsWithTimeout(timeout time.Duration) *ListTopicsHandlerParams + func (o *ListTopicsHandlerParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter) + func (o *ListTopicsHandlerParams) SetContext(ctx context.Context) + func (o *ListTopicsHandlerParams) SetFlightId(flightId string) + func (o *ListTopicsHandlerParams) SetFuzzyTopicName(fuzzyTopicName *string) + func (o *ListTopicsHandlerParams) SetHTTPClient(client *http.Client) + func (o *ListTopicsHandlerParams) SetHTTPClientTransport(roundTripper http.RoundTripper) + func (o *ListTopicsHandlerParams) SetIsSubscribedByAppName(isSubscribedByAppName *string) + func (o *ListTopicsHandlerParams) SetIsUnsubscribedByAppName(isUnsubscribedByAppName *string) + func (o *ListTopicsHandlerParams) SetLimit(limit *int64) + func (o *ListTopicsHandlerParams) SetNamespace(namespace string) + func (o *ListTopicsHandlerParams) SetOffset(offset *int64) + func (o *ListTopicsHandlerParams) SetTimeout(timeout time.Duration) + func (o *ListTopicsHandlerParams) WithContext(ctx context.Context) *ListTopicsHandlerParams + func (o *ListTopicsHandlerParams) WithFuzzyTopicName(fuzzyTopicName *string) *ListTopicsHandlerParams + func (o *ListTopicsHandlerParams) WithHTTPClient(client *http.Client) *ListTopicsHandlerParams + func (o *ListTopicsHandlerParams) WithIsSubscribedByAppName(isSubscribedByAppName *string) *ListTopicsHandlerParams + func (o *ListTopicsHandlerParams) WithIsUnsubscribedByAppName(isUnsubscribedByAppName *string) *ListTopicsHandlerParams + func (o *ListTopicsHandlerParams) WithLimit(limit *int64) *ListTopicsHandlerParams + func (o *ListTopicsHandlerParams) WithNamespace(namespace string) *ListTopicsHandlerParams + func (o *ListTopicsHandlerParams) WithOffset(offset *int64) *ListTopicsHandlerParams + func (o *ListTopicsHandlerParams) WithTimeout(timeout time.Duration) *ListTopicsHandlerParams + func (o *ListTopicsHandlerParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error + type ListTopicsHandlerReader struct + func (o *ListTopicsHandlerReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error) + type ListTopicsHandlerUnauthorized struct + Payload *csmclientmodels.ResponseErrorResponse + func NewListTopicsHandlerUnauthorized() *ListTopicsHandlerUnauthorized + func (o *ListTopicsHandlerUnauthorized) Error() string + func (o *ListTopicsHandlerUnauthorized) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *ListTopicsHandlerUnauthorized) ToJSONString() string + type UnsubscribeTopicHandlerForbidden struct + Payload *csmclientmodels.ResponseErrorResponse + func NewUnsubscribeTopicHandlerForbidden() *UnsubscribeTopicHandlerForbidden + func (o *UnsubscribeTopicHandlerForbidden) Error() string + func (o *UnsubscribeTopicHandlerForbidden) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *UnsubscribeTopicHandlerForbidden) ToJSONString() string + type UnsubscribeTopicHandlerInternalServerError struct + Payload *csmclientmodels.ResponseErrorResponse + func NewUnsubscribeTopicHandlerInternalServerError() *UnsubscribeTopicHandlerInternalServerError + func (o *UnsubscribeTopicHandlerInternalServerError) Error() string + func (o *UnsubscribeTopicHandlerInternalServerError) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *UnsubscribeTopicHandlerInternalServerError) ToJSONString() string + type UnsubscribeTopicHandlerNotFound struct + Payload *csmclientmodels.ResponseErrorResponse + func NewUnsubscribeTopicHandlerNotFound() *UnsubscribeTopicHandlerNotFound + func (o *UnsubscribeTopicHandlerNotFound) Error() string + func (o *UnsubscribeTopicHandlerNotFound) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *UnsubscribeTopicHandlerNotFound) ToJSONString() string + type UnsubscribeTopicHandlerOK struct + Payload *csmclientmodels.ApimodelTopicSubscription + func NewUnsubscribeTopicHandlerOK() *UnsubscribeTopicHandlerOK + func (o *UnsubscribeTopicHandlerOK) Error() string + func (o *UnsubscribeTopicHandlerOK) GetPayload() *csmclientmodels.ApimodelTopicSubscription + func (o *UnsubscribeTopicHandlerOK) ToJSONString() string + type UnsubscribeTopicHandlerParams struct + App string + AuthInfoWriter runtime.ClientAuthInfoWriter + Context context.Context + HTTPClient *http.Client + Namespace string + RetryPolicy *utils.Retry + TopicName string + XFlightId *string + func NewUnsubscribeTopicHandlerParams() *UnsubscribeTopicHandlerParams + func NewUnsubscribeTopicHandlerParamsWithContext(ctx context.Context) *UnsubscribeTopicHandlerParams + func NewUnsubscribeTopicHandlerParamsWithHTTPClient(client *http.Client) *UnsubscribeTopicHandlerParams + func NewUnsubscribeTopicHandlerParamsWithTimeout(timeout time.Duration) *UnsubscribeTopicHandlerParams + func (o *UnsubscribeTopicHandlerParams) SetApp(app string) + func (o *UnsubscribeTopicHandlerParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter) + func (o *UnsubscribeTopicHandlerParams) SetContext(ctx context.Context) + func (o *UnsubscribeTopicHandlerParams) SetFlightId(flightId string) + func (o *UnsubscribeTopicHandlerParams) SetHTTPClient(client *http.Client) + func (o *UnsubscribeTopicHandlerParams) SetHTTPClientTransport(roundTripper http.RoundTripper) + func (o *UnsubscribeTopicHandlerParams) SetNamespace(namespace string) + func (o *UnsubscribeTopicHandlerParams) SetTimeout(timeout time.Duration) + func (o *UnsubscribeTopicHandlerParams) SetTopicName(topicName string) + func (o *UnsubscribeTopicHandlerParams) WithApp(app string) *UnsubscribeTopicHandlerParams + func (o *UnsubscribeTopicHandlerParams) WithContext(ctx context.Context) *UnsubscribeTopicHandlerParams + func (o *UnsubscribeTopicHandlerParams) WithHTTPClient(client *http.Client) *UnsubscribeTopicHandlerParams + func (o *UnsubscribeTopicHandlerParams) WithNamespace(namespace string) *UnsubscribeTopicHandlerParams + func (o *UnsubscribeTopicHandlerParams) WithTimeout(timeout time.Duration) *UnsubscribeTopicHandlerParams + func (o *UnsubscribeTopicHandlerParams) WithTopicName(topicName string) *UnsubscribeTopicHandlerParams + func (o *UnsubscribeTopicHandlerParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error + type UnsubscribeTopicHandlerReader struct + func (o *UnsubscribeTopicHandlerReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error) + type UnsubscribeTopicHandlerUnauthorized struct + Payload *csmclientmodels.ResponseErrorResponse + func NewUnsubscribeTopicHandlerUnauthorized() *UnsubscribeTopicHandlerUnauthorized + func (o *UnsubscribeTopicHandlerUnauthorized) Error() string + func (o *UnsubscribeTopicHandlerUnauthorized) GetPayload() *csmclientmodels.ResponseErrorResponse + func (o *UnsubscribeTopicHandlerUnauthorized) ToJSONString() string
Go to main page