cluster

package
v0.25.2 Latest Latest
Warning

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

 Go to latest Published: Apr 5, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package cluster provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen version v1.16.2 DO NOT EDIT.

Package cluster is an API client for the cluster service

Package cluster provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen version v1.16.2 DO NOT EDIT.

Package cluster provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen version v1.16.2 DO NOT EDIT.

Index

Constants

View Source 
const (
	BearerAuthScopes = "bearerAuth.Scopes"
)

Variables

This section is empty.

Functions

func Handler 

func Handler(si ServerInterface) http.Handler

Handler creates http.Handler with routing matching OpenAPI spec.

func HandlerFromMux 

func HandlerFromMux(si ServerInterface, r chi.Router) http.Handler

HandlerFromMux creates http.Handler with routing matching OpenAPI spec based on the provided mux.

func HandlerFromMuxWithBaseURL 

func HandlerFromMuxWithBaseURL(si ServerInterface, r chi.Router, baseURL string) http.Handler

func HandlerWithOptions 

func HandlerWithOptions(si ServerInterface, options ChiServerOptions) http.Handler

HandlerWithOptions creates http.Handler with additional options

func NewDownloadClusterResourceBundleRequest 

func NewDownloadClusterResourceBundleRequest(server string, bundleId BundleId) (*http.Request, error)

NewDownloadClusterResourceBundleRequest generates requests for DownloadClusterResourceBundle

func NewExchangeClusterIdentityTokenRequest 

func NewExchangeClusterIdentityTokenRequest(server string, body ExchangeClusterIdentityTokenJSONRequestBody) (*http.Request, error)

NewExchangeClusterIdentityTokenRequest calls the generic ExchangeClusterIdentityToken builder with application/json body

func NewExchangeClusterIdentityTokenRequestWithBody 

func NewExchangeClusterIdentityTokenRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewExchangeClusterIdentityTokenRequestWithBody generates requests for ExchangeClusterIdentityToken with any type of body

func NewGetClusterBootstrapConfigRequest 

func NewGetClusterBootstrapConfigRequest(server string) (*http.Request, error)

NewGetClusterBootstrapConfigRequest generates requests for GetClusterBootstrapConfig

func NewGetClusterResourceBundlesRequest 

func NewGetClusterResourceBundlesRequest(server string) (*http.Request, error)

NewGetClusterResourceBundlesRequest generates requests for GetClusterResourceBundles

func NewReportClusterResourceBundleStatusRequest 

func NewReportClusterResourceBundleStatusRequest(server string, bundleId BundleId, body ReportClusterResourceBundleStatusJSONRequestBody) (*http.Request, error)

NewReportClusterResourceBundleStatusRequest calls the generic ReportClusterResourceBundleStatus builder with application/json body

func NewReportClusterResourceBundleStatusRequestWithBody 

func NewReportClusterResourceBundleStatusRequestWithBody(server string, bundleId BundleId, contentType string, body io.Reader) (*http.Request, error)

NewReportClusterResourceBundleStatusRequestWithBody generates requests for ReportClusterResourceBundleStatus with any type of body

func NewTokenFetcher 

func NewTokenFetcher(endpoint string, opts ...ClientOption) (token.Fetcher, error)

NewTokenFetcher creates a new authorization token fetcher

Types

type BootstrapConfig 

type BootstrapConfig struct {
	// DatabrokerStorageConnection databroker storage connection string
	DatabrokerStorageConnection *string `json:"databrokerStorageConnection,omitempty"`
}

BootstrapConfig defines model for BootstrapConfig.

type Bundle 

type Bundle struct {
	// Id bundle id
	Id string `json:"id"`
}

Bundle defines model for Bundle.

type BundleId 

type BundleId = string

BundleId defines model for bundleId.

type BundleStatus 

type BundleStatus struct {
	Failure *BundleStatusFailure `json:"failure,omitempty"`
	Success *BundleStatusSuccess `json:"success,omitempty"`
}

BundleStatus defines model for BundleStatus.

type BundleStatusFailure 

type BundleStatusFailure struct {
	Message string `json:"message"`

	// Source source of the failure
	Source BundleStatusFailureSource `json:"source"`
}

BundleStatusFailure defines model for BundleStatusFailure.

type BundleStatusFailureSource 

type BundleStatusFailureSource string

BundleStatusFailureSource source of the failure 

const (
	DatabrokerError BundleStatusFailureSource = "databroker_error"
	DownloadError   BundleStatusFailureSource = "download_error"
	InvalidBundle   BundleStatusFailureSource = "invalid_bundle"
	IoError         BundleStatusFailureSource = "io_error"
	UnknownError    BundleStatusFailureSource = "unknown_error"
)

Defines values for BundleStatusFailureSource.

type BundleStatusSuccess 

type BundleStatusSuccess struct {
	// Metadata bundle metadata
	Metadata map[string]string `json:"metadata"`
}

BundleStatusSuccess defines model for BundleStatusSuccess.

type ChiServerOptions 

type ChiServerOptions struct {
	BaseURL          string
	BaseRouter       chi.Router
	Middlewares      []MiddlewareFunc
	ErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)
}

type Client 

type Client struct {
	// The endpoint of the server conforming to this interface, with scheme,
	// https://api.deepmap.com for example. This can contain a path relative
	// to the server, such as https://api.deepmap.com/dev-test, and all the
	// paths in the swagger spec will be appended to the server.
	Server string

	// Doer for performing requests, typically a *http.Client with any
	// customized settings, such as certificate chains.
	Client HttpRequestDoer

	// A list of callbacks for modifying requests which are generated before sending over
	// the network.
	RequestEditors []RequestEditorFn
}

Client which conforms to the OpenAPI3 specification for this service.

func NewClient 

func NewClient(server string, opts ...ClientOption) (*Client, error)

Creates a new Client, with reasonable defaults

func (*Client) DownloadClusterResourceBundle 

func (c *Client) DownloadClusterResourceBundle(ctx context.Context, bundleId BundleId, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ExchangeClusterIdentityToken 

func (c *Client) ExchangeClusterIdentityToken(ctx context.Context, body ExchangeClusterIdentityTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ExchangeClusterIdentityTokenWithBody 

func (c *Client) ExchangeClusterIdentityTokenWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetClusterBootstrapConfig 

func (c *Client) GetClusterBootstrapConfig(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetClusterResourceBundles 

func (c *Client) GetClusterResourceBundles(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ReportClusterResourceBundleStatus 

func (c *Client) ReportClusterResourceBundleStatus(ctx context.Context, bundleId BundleId, body ReportClusterResourceBundleStatusJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ReportClusterResourceBundleStatusWithBody 

func (c *Client) ReportClusterResourceBundleStatusWithBody(ctx context.Context, bundleId BundleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

type ClientInterface 

type ClientInterface interface {
	// GetClusterBootstrapConfig request
	GetClusterBootstrapConfig(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetClusterResourceBundles request
	GetClusterResourceBundles(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DownloadClusterResourceBundle request
	DownloadClusterResourceBundle(ctx context.Context, bundleId BundleId, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ReportClusterResourceBundleStatusWithBody request with any body
	ReportClusterResourceBundleStatusWithBody(ctx context.Context, bundleId BundleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	ReportClusterResourceBundleStatus(ctx context.Context, bundleId BundleId, body ReportClusterResourceBundleStatusJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ExchangeClusterIdentityTokenWithBody request with any body
	ExchangeClusterIdentityTokenWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	ExchangeClusterIdentityToken(ctx context.Context, body ExchangeClusterIdentityTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
}

The interface specification for the client above.

type ClientOption 

type ClientOption func(*Client) error

ClientOption allows setting custom parameters during construction

func WithBaseURL 

func WithBaseURL(baseURL string) ClientOption

WithBaseURL overrides the baseURL.

func WithHTTPClient 

func WithHTTPClient(doer HttpRequestDoer) ClientOption

WithHTTPClient allows overriding the default Doer, which is automatically created using http.Client. This is useful for tests.

func WithRequestEditorFn 

func WithRequestEditorFn(fn RequestEditorFn) ClientOption

WithRequestEditorFn allows setting up a callback function, which will be called right before sending the request. This can be used to mutate the request.

type ClientWithResponses 

type ClientWithResponses struct {
	ClientInterface
}

ClientWithResponses builds on ClientInterface to offer response payloads

func NewClientWithResponses 

func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)

NewClientWithResponses creates a new ClientWithResponses, which wraps Client with return type handling

func (*ClientWithResponses) DownloadClusterResourceBundleWithResponse 

func (c *ClientWithResponses) DownloadClusterResourceBundleWithResponse(ctx context.Context, bundleId BundleId, reqEditors ...RequestEditorFn) (*DownloadClusterResourceBundleResp, error)

DownloadClusterResourceBundleWithResponse request returning *DownloadClusterResourceBundleResp

func (*ClientWithResponses) ExchangeClusterIdentityTokenWithBodyWithResponse 

func (c *ClientWithResponses) ExchangeClusterIdentityTokenWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ExchangeClusterIdentityTokenResp, error)

ExchangeClusterIdentityTokenWithBodyWithResponse request with arbitrary body returning *ExchangeClusterIdentityTokenResp

func (*ClientWithResponses) ExchangeClusterIdentityTokenWithResponse 

func (c *ClientWithResponses) ExchangeClusterIdentityTokenWithResponse(ctx context.Context, body ExchangeClusterIdentityTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*ExchangeClusterIdentityTokenResp, error)

func (*ClientWithResponses) GetClusterBootstrapConfigWithResponse 

func (c *ClientWithResponses) GetClusterBootstrapConfigWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetClusterBootstrapConfigResp, error)

GetClusterBootstrapConfigWithResponse request returning *GetClusterBootstrapConfigResp

func (*ClientWithResponses) GetClusterResourceBundlesWithResponse 

func (c *ClientWithResponses) GetClusterResourceBundlesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetClusterResourceBundlesResp, error)

GetClusterResourceBundlesWithResponse request returning *GetClusterResourceBundlesResp

func (*ClientWithResponses) ReportClusterResourceBundleStatusWithBodyWithResponse 

func (c *ClientWithResponses) ReportClusterResourceBundleStatusWithBodyWithResponse(ctx context.Context, bundleId BundleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ReportClusterResourceBundleStatusResp, error)

ReportClusterResourceBundleStatusWithBodyWithResponse request with arbitrary body returning *ReportClusterResourceBundleStatusResp

func (*ClientWithResponses) ReportClusterResourceBundleStatusWithResponse 

func (c *ClientWithResponses) ReportClusterResourceBundleStatusWithResponse(ctx context.Context, bundleId BundleId, body ReportClusterResourceBundleStatusJSONRequestBody, reqEditors ...RequestEditorFn) (*ReportClusterResourceBundleStatusResp, error)

type ClientWithResponsesInterface 

type ClientWithResponsesInterface interface {
	// GetClusterBootstrapConfigWithResponse request
	GetClusterBootstrapConfigWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetClusterBootstrapConfigResp, error)

	// GetClusterResourceBundlesWithResponse request
	GetClusterResourceBundlesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetClusterResourceBundlesResp, error)

	// DownloadClusterResourceBundleWithResponse request
	DownloadClusterResourceBundleWithResponse(ctx context.Context, bundleId BundleId, reqEditors ...RequestEditorFn) (*DownloadClusterResourceBundleResp, error)

	// ReportClusterResourceBundleStatusWithBodyWithResponse request with any body
	ReportClusterResourceBundleStatusWithBodyWithResponse(ctx context.Context, bundleId BundleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ReportClusterResourceBundleStatusResp, error)

	ReportClusterResourceBundleStatusWithResponse(ctx context.Context, bundleId BundleId, body ReportClusterResourceBundleStatusJSONRequestBody, reqEditors ...RequestEditorFn) (*ReportClusterResourceBundleStatusResp, error)

	// ExchangeClusterIdentityTokenWithBodyWithResponse request with any body
	ExchangeClusterIdentityTokenWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ExchangeClusterIdentityTokenResp, error)

	ExchangeClusterIdentityTokenWithResponse(ctx context.Context, body ExchangeClusterIdentityTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*ExchangeClusterIdentityTokenResp, error)
}

ClientWithResponsesInterface is the interface specification for the client with responses above.

func NewAuthorizedClient 

func NewAuthorizedClient(
	endpoint string,
	tokenProvider TokenProviderFn,
	httpClient *http.Client,
) (ClientWithResponsesInterface, error)

NewAuthorizedClient creates a new HTTP client that will automatically add an authorization header

type DownloadBundleResponse 

type DownloadBundleResponse struct {
	// CaptureMetadataHeaders bundle metadata that need be picked up by the client from the download URL
	CaptureMetadataHeaders []string `json:"captureMetadataHeaders"`
	ExpiresInSeconds       string   `json:"expiresInSeconds"`

	// Url download URL
	Url string `json:"url"`
}

DownloadBundleResponse defines model for DownloadBundleResponse.

type DownloadCacheEntry 

type DownloadCacheEntry struct {
	// URL is the URL to download the bundle from.
	URL url.URL
	// ExpiresAt is the time at which the URL expires.
	ExpiresAt time.Time
	// CaptureHeaders is a list of headers to capture from the response.
	CaptureHeaders []string
}

DownloadCacheEntry is a cache entry for a URL to download a bundle from.

type DownloadClusterResourceBundle200JSONResponse 

type DownloadClusterResourceBundle200JSONResponse DownloadBundleResponse

func (DownloadClusterResourceBundle200JSONResponse) VisitDownloadClusterResourceBundleResponse 

func (response DownloadClusterResourceBundle200JSONResponse) VisitDownloadClusterResourceBundleResponse(w http.ResponseWriter) error

type DownloadClusterResourceBundle400JSONResponse 

type DownloadClusterResourceBundle400JSONResponse ErrorResponse

func (DownloadClusterResourceBundle400JSONResponse) VisitDownloadClusterResourceBundleResponse 

func (response DownloadClusterResourceBundle400JSONResponse) VisitDownloadClusterResourceBundleResponse(w http.ResponseWriter) error

type DownloadClusterResourceBundle404JSONResponse 

type DownloadClusterResourceBundle404JSONResponse ErrorResponse

func (DownloadClusterResourceBundle404JSONResponse) VisitDownloadClusterResourceBundleResponse 

func (response DownloadClusterResourceBundle404JSONResponse) VisitDownloadClusterResourceBundleResponse(w http.ResponseWriter) error

type DownloadClusterResourceBundle500JSONResponse 

type DownloadClusterResourceBundle500JSONResponse ErrorResponse

func (DownloadClusterResourceBundle500JSONResponse) VisitDownloadClusterResourceBundleResponse 

func (response DownloadClusterResourceBundle500JSONResponse) VisitDownloadClusterResourceBundleResponse(w http.ResponseWriter) error

type DownloadClusterResourceBundleRequestObject 

type DownloadClusterResourceBundleRequestObject struct {
	BundleId BundleId `json:"bundleId"`
}

type DownloadClusterResourceBundleResp 

type DownloadClusterResourceBundleResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *DownloadBundleResponse
	JSON400      *ErrorResponse
	JSON404      *ErrorResponse
	JSON500      *ErrorResponse
}

func ParseDownloadClusterResourceBundleResp 

func ParseDownloadClusterResourceBundleResp(rsp *http.Response) (*DownloadClusterResourceBundleResp, error)

ParseDownloadClusterResourceBundleResp parses an HTTP response from a DownloadClusterResourceBundleWithResponse call

func (*DownloadClusterResourceBundleResp) GetBadRequestError 

func (r *DownloadClusterResourceBundleResp) GetBadRequestError() (string, bool)

GetBadRequestError implements apierror.APIResponse

func (*DownloadClusterResourceBundleResp) GetHTTPResponse 

func (r *DownloadClusterResourceBundleResp) GetHTTPResponse() *http.Response

GetHTTPResponse implements apierror.APIResponse

func (*DownloadClusterResourceBundleResp) GetInternalServerError 

func (r *DownloadClusterResourceBundleResp) GetInternalServerError() (string, bool)

GetInternalServerError implements apierror.APIResponse

func (*DownloadClusterResourceBundleResp) GetValue 

func (r *DownloadClusterResourceBundleResp) GetValue() *DownloadBundleResponse

GetValue implements apierror.APIResponse

func (DownloadClusterResourceBundleResp) Status 

func (r DownloadClusterResourceBundleResp) Status() string

Status returns HTTPResponse.Status

func (DownloadClusterResourceBundleResp) StatusCode 

func (r DownloadClusterResourceBundleResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DownloadClusterResourceBundleResponseObject 

type DownloadClusterResourceBundleResponseObject interface {
	VisitDownloadClusterResourceBundleResponse(w http.ResponseWriter) error
}

type EmptyResponse 

type EmptyResponse struct{}

EmptyResponse is an empty response

type ErrorResponse 

type ErrorResponse struct {
	// Error Error message
	Error string `json:"error"`
}

ErrorResponse defines model for ErrorResponse.

type ExchangeClusterIdentityToken200JSONResponse 

type ExchangeClusterIdentityToken200JSONResponse ExchangeTokenResponse

func (ExchangeClusterIdentityToken200JSONResponse) VisitExchangeClusterIdentityTokenResponse 

func (response ExchangeClusterIdentityToken200JSONResponse) VisitExchangeClusterIdentityTokenResponse(w http.ResponseWriter) error

type ExchangeClusterIdentityToken400JSONResponse 

type ExchangeClusterIdentityToken400JSONResponse ErrorResponse

func (ExchangeClusterIdentityToken400JSONResponse) VisitExchangeClusterIdentityTokenResponse 

func (response ExchangeClusterIdentityToken400JSONResponse) VisitExchangeClusterIdentityTokenResponse(w http.ResponseWriter) error

type ExchangeClusterIdentityToken500JSONResponse 

type ExchangeClusterIdentityToken500JSONResponse ErrorResponse

func (ExchangeClusterIdentityToken500JSONResponse) VisitExchangeClusterIdentityTokenResponse 

func (response ExchangeClusterIdentityToken500JSONResponse) VisitExchangeClusterIdentityTokenResponse(w http.ResponseWriter) error

type ExchangeClusterIdentityTokenJSONRequestBody 

type ExchangeClusterIdentityTokenJSONRequestBody = ExchangeTokenRequest

ExchangeClusterIdentityTokenJSONRequestBody defines body for ExchangeClusterIdentityToken for application/json ContentType.

type ExchangeClusterIdentityTokenRequestObject 

type ExchangeClusterIdentityTokenRequestObject struct {
	Body *ExchangeClusterIdentityTokenJSONRequestBody
}

type ExchangeClusterIdentityTokenResp 

type ExchangeClusterIdentityTokenResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ExchangeTokenResponse
	JSON400      *ErrorResponse
	JSON500      *ErrorResponse
}

func ParseExchangeClusterIdentityTokenResp 

func ParseExchangeClusterIdentityTokenResp(rsp *http.Response) (*ExchangeClusterIdentityTokenResp, error)

ParseExchangeClusterIdentityTokenResp parses an HTTP response from a ExchangeClusterIdentityTokenWithResponse call

func (*ExchangeClusterIdentityTokenResp) GetBadRequestError 

func (r *ExchangeClusterIdentityTokenResp) GetBadRequestError() (string, bool)

GetBadRequestError implements apierror.APIResponse

func (*ExchangeClusterIdentityTokenResp) GetHTTPResponse 

func (r *ExchangeClusterIdentityTokenResp) GetHTTPResponse() *http.Response

GetHTTPResponse implements apierror.APIResponse

func (*ExchangeClusterIdentityTokenResp) GetInternalServerError 

func (r *ExchangeClusterIdentityTokenResp) GetInternalServerError() (string, bool)

GetInternalServerError implements apierror.APIResponse

func (*ExchangeClusterIdentityTokenResp) GetValue 

func (r *ExchangeClusterIdentityTokenResp) GetValue() *ExchangeTokenResponse

GetValue implements apierror.APIResponse

func (ExchangeClusterIdentityTokenResp) Status 

func (r ExchangeClusterIdentityTokenResp) Status() string

Status returns HTTPResponse.Status

func (ExchangeClusterIdentityTokenResp) StatusCode 

func (r ExchangeClusterIdentityTokenResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ExchangeClusterIdentityTokenResponseObject 

type ExchangeClusterIdentityTokenResponseObject interface {
	VisitExchangeClusterIdentityTokenResponse(w http.ResponseWriter) error
}

type ExchangeTokenRequest 

type ExchangeTokenRequest struct {
	// RefreshToken cluster identity token
	RefreshToken string `json:"refreshToken"`
}

ExchangeTokenRequest defines model for ExchangeTokenRequest.

type ExchangeTokenResponse 

type ExchangeTokenResponse struct {
	ExpiresInSeconds string `json:"expiresInSeconds"`

	// IdToken ID token
	IdToken string `json:"idToken"`
}

ExchangeTokenResponse defines model for ExchangeTokenResponse.

type GetBootstrapConfigResponse 

type GetBootstrapConfigResponse = BootstrapConfig

GetBootstrapConfigResponse defines model for GetBootstrapConfigResponse.

type GetBundlesResponse 

type GetBundlesResponse struct {
	Bundles []Bundle `json:"bundles"`
}

GetBundlesResponse defines model for GetBundlesResponse.

type GetClusterBootstrapConfig200JSONResponse 

type GetClusterBootstrapConfig200JSONResponse GetBootstrapConfigResponse

func (GetClusterBootstrapConfig200JSONResponse) VisitGetClusterBootstrapConfigResponse 

func (response GetClusterBootstrapConfig200JSONResponse) VisitGetClusterBootstrapConfigResponse(w http.ResponseWriter) error

type GetClusterBootstrapConfig400JSONResponse 

type GetClusterBootstrapConfig400JSONResponse ErrorResponse

func (GetClusterBootstrapConfig400JSONResponse) VisitGetClusterBootstrapConfigResponse 

func (response GetClusterBootstrapConfig400JSONResponse) VisitGetClusterBootstrapConfigResponse(w http.ResponseWriter) error

type GetClusterBootstrapConfig500JSONResponse 

type GetClusterBootstrapConfig500JSONResponse ErrorResponse

func (GetClusterBootstrapConfig500JSONResponse) VisitGetClusterBootstrapConfigResponse 

func (response GetClusterBootstrapConfig500JSONResponse) VisitGetClusterBootstrapConfigResponse(w http.ResponseWriter) error

type GetClusterBootstrapConfigRequestObject 

type GetClusterBootstrapConfigRequestObject struct {
}

type GetClusterBootstrapConfigResp 

type GetClusterBootstrapConfigResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetBootstrapConfigResponse
	JSON400      *ErrorResponse
	JSON500      *ErrorResponse
}

func ParseGetClusterBootstrapConfigResp 

func ParseGetClusterBootstrapConfigResp(rsp *http.Response) (*GetClusterBootstrapConfigResp, error)

ParseGetClusterBootstrapConfigResp parses an HTTP response from a GetClusterBootstrapConfigWithResponse call

func (*GetClusterBootstrapConfigResp) GetBadRequestError 

func (r *GetClusterBootstrapConfigResp) GetBadRequestError() (string, bool)

GetBadRequestError implements apierror.APIResponse

func (*GetClusterBootstrapConfigResp) GetHTTPResponse 

func (r *GetClusterBootstrapConfigResp) GetHTTPResponse() *http.Response

GetHTTPResponse implements apierror.APIResponse

func (*GetClusterBootstrapConfigResp) GetInternalServerError 

func (r *GetClusterBootstrapConfigResp) GetInternalServerError() (string, bool)

GetInternalServerError implements apierror.APIResponse

func (*GetClusterBootstrapConfigResp) GetValue 

func (r *GetClusterBootstrapConfigResp) GetValue() *BootstrapConfig

GetValue implements apierror.APIResponse

func (GetClusterBootstrapConfigResp) Status 

func (r GetClusterBootstrapConfigResp) Status() string

Status returns HTTPResponse.Status

func (GetClusterBootstrapConfigResp) StatusCode 

func (r GetClusterBootstrapConfigResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetClusterBootstrapConfigResponseObject 

type GetClusterBootstrapConfigResponseObject interface {
	VisitGetClusterBootstrapConfigResponse(w http.ResponseWriter) error
}

type GetClusterResourceBundles200JSONResponse 

type GetClusterResourceBundles200JSONResponse GetBundlesResponse

func (GetClusterResourceBundles200JSONResponse) VisitGetClusterResourceBundlesResponse 

func (response GetClusterResourceBundles200JSONResponse) VisitGetClusterResourceBundlesResponse(w http.ResponseWriter) error

type GetClusterResourceBundles400JSONResponse 

type GetClusterResourceBundles400JSONResponse ErrorResponse

func (GetClusterResourceBundles400JSONResponse) VisitGetClusterResourceBundlesResponse 

func (response GetClusterResourceBundles400JSONResponse) VisitGetClusterResourceBundlesResponse(w http.ResponseWriter) error

type GetClusterResourceBundles500JSONResponse 

type GetClusterResourceBundles500JSONResponse ErrorResponse

func (GetClusterResourceBundles500JSONResponse) VisitGetClusterResourceBundlesResponse 

func (response GetClusterResourceBundles500JSONResponse) VisitGetClusterResourceBundlesResponse(w http.ResponseWriter) error

type GetClusterResourceBundlesRequestObject 

type GetClusterResourceBundlesRequestObject struct {
}

type GetClusterResourceBundlesResp 

type GetClusterResourceBundlesResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetBundlesResponse
	JSON400      *ErrorResponse
	JSON500      *ErrorResponse
}

func ParseGetClusterResourceBundlesResp 

func ParseGetClusterResourceBundlesResp(rsp *http.Response) (*GetClusterResourceBundlesResp, error)

ParseGetClusterResourceBundlesResp parses an HTTP response from a GetClusterResourceBundlesWithResponse call

func (*GetClusterResourceBundlesResp) GetBadRequestError 

func (r *GetClusterResourceBundlesResp) GetBadRequestError() (string, bool)

GetBadRequestError implements apierror.APIResponse

func (*GetClusterResourceBundlesResp) GetHTTPResponse 

func (r *GetClusterResourceBundlesResp) GetHTTPResponse() *http.Response

GetHTTPResponse implements apierror.APIResponse

func (*GetClusterResourceBundlesResp) GetInternalServerError 

func (r *GetClusterResourceBundlesResp) GetInternalServerError() (string, bool)

GetInternalServerError implements apierror.APIResponse

func (*GetClusterResourceBundlesResp) GetValue 

func (r *GetClusterResourceBundlesResp) GetValue() *GetBundlesResponse

GetValue implements apierror.APIResponse

func (GetClusterResourceBundlesResp) Status 

func (r GetClusterResourceBundlesResp) Status() string

Status returns HTTPResponse.Status

func (GetClusterResourceBundlesResp) StatusCode 

func (r GetClusterResourceBundlesResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetClusterResourceBundlesResponseObject 

type GetClusterResourceBundlesResponseObject interface {
	VisitGetClusterResourceBundlesResponse(w http.ResponseWriter) error
}

type HttpRequestDoer 

type HttpRequestDoer interface {
	Do(req *http.Request) (*http.Response, error)
}

Doer performs HTTP requests.

The standard http.Client implements this interface.

type InvalidParamFormatError 

type InvalidParamFormatError struct {
	ParamName string
	Err       error
}

func (*InvalidParamFormatError) Error 

func (e *InvalidParamFormatError) Error() string

func (*InvalidParamFormatError) Unwrap 

func (e *InvalidParamFormatError) Unwrap() error

type MiddlewareFunc 

type MiddlewareFunc func(http.Handler) http.Handler

type ReportClusterResourceBundleStatus204Response 

type ReportClusterResourceBundleStatus204Response struct {
}

func (ReportClusterResourceBundleStatus204Response) VisitReportClusterResourceBundleStatusResponse 

func (response ReportClusterResourceBundleStatus204Response) VisitReportClusterResourceBundleStatusResponse(w http.ResponseWriter) error

type ReportClusterResourceBundleStatus400JSONResponse 

type ReportClusterResourceBundleStatus400JSONResponse ErrorResponse

func (ReportClusterResourceBundleStatus400JSONResponse) VisitReportClusterResourceBundleStatusResponse 

func (response ReportClusterResourceBundleStatus400JSONResponse) VisitReportClusterResourceBundleStatusResponse(w http.ResponseWriter) error

type ReportClusterResourceBundleStatus500JSONResponse 

type ReportClusterResourceBundleStatus500JSONResponse ErrorResponse

func (ReportClusterResourceBundleStatus500JSONResponse) VisitReportClusterResourceBundleStatusResponse 

func (response ReportClusterResourceBundleStatus500JSONResponse) VisitReportClusterResourceBundleStatusResponse(w http.ResponseWriter) error

type ReportClusterResourceBundleStatusJSONRequestBody 

type ReportClusterResourceBundleStatusJSONRequestBody = BundleStatus

ReportClusterResourceBundleStatusJSONRequestBody defines body for ReportClusterResourceBundleStatus for application/json ContentType.

type ReportClusterResourceBundleStatusRequestObject 

type ReportClusterResourceBundleStatusRequestObject struct {
	BundleId BundleId `json:"bundleId"`
	Body     *ReportClusterResourceBundleStatusJSONRequestBody
}

type ReportClusterResourceBundleStatusResp 

type ReportClusterResourceBundleStatusResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorResponse
	JSON500      *ErrorResponse
}

func ParseReportClusterResourceBundleStatusResp 

func ParseReportClusterResourceBundleStatusResp(rsp *http.Response) (*ReportClusterResourceBundleStatusResp, error)

ParseReportClusterResourceBundleStatusResp parses an HTTP response from a ReportClusterResourceBundleStatusWithResponse call

func (*ReportClusterResourceBundleStatusResp) GetBadRequestError 

func (r *ReportClusterResourceBundleStatusResp) GetBadRequestError() (string, bool)

GetBadRequestError implements apierror.APIResponse

func (*ReportClusterResourceBundleStatusResp) GetHTTPResponse 

func (r *ReportClusterResourceBundleStatusResp) GetHTTPResponse() *http.Response

GetHTTPResponse implements apierror.APIResponse

func (*ReportClusterResourceBundleStatusResp) GetInternalServerError 

func (r *ReportClusterResourceBundleStatusResp) GetInternalServerError() (string, bool)

GetInternalServerError implements apierror.APIResponse

func (*ReportClusterResourceBundleStatusResp) GetValue 

func (r *ReportClusterResourceBundleStatusResp) GetValue() *EmptyResponse

GetValue implements apierror.APIResponse

func (ReportClusterResourceBundleStatusResp) Status 

func (r ReportClusterResourceBundleStatusResp) Status() string

Status returns HTTPResponse.Status

func (ReportClusterResourceBundleStatusResp) StatusCode 

func (r ReportClusterResourceBundleStatusResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ReportClusterResourceBundleStatusResponseObject 

type ReportClusterResourceBundleStatusResponseObject interface {
	VisitReportClusterResourceBundleStatusResponse(w http.ResponseWriter) error
}

type RequestEditorFn 

type RequestEditorFn func(ctx context.Context, req *http.Request) error

RequestEditorFn is the function signature for the RequestEditor callback function

type RequiredHeaderError 

type RequiredHeaderError struct {
	ParamName string
	Err       error
}

func (*RequiredHeaderError) Error 

func (e *RequiredHeaderError) Error() string

func (*RequiredHeaderError) Unwrap 

func (e *RequiredHeaderError) Unwrap() error

type RequiredParamError 

type RequiredParamError struct {
	ParamName string
}

func (*RequiredParamError) Error 

func (e *RequiredParamError) Error() string

type ServerInterface 

type ServerInterface interface {

	// (GET /bootstrap)
	GetClusterBootstrapConfig(w http.ResponseWriter, r *http.Request)

	// (GET /bundles)
	GetClusterResourceBundles(w http.ResponseWriter, r *http.Request)

	// (GET /bundles/{bundleId}/download)
	DownloadClusterResourceBundle(w http.ResponseWriter, r *http.Request, bundleId BundleId)

	// (POST /bundles/{bundleId}/status)
	ReportClusterResourceBundleStatus(w http.ResponseWriter, r *http.Request, bundleId BundleId)

	// (POST /exchangeToken)
	ExchangeClusterIdentityToken(w http.ResponseWriter, r *http.Request)
}

ServerInterface represents all server handlers.

func NewStrictHandler 

func NewStrictHandler(ssi StrictServerInterface, middlewares []StrictMiddlewareFunc) ServerInterface

func NewStrictHandlerWithOptions 

func NewStrictHandlerWithOptions(ssi StrictServerInterface, middlewares []StrictMiddlewareFunc, options StrictHTTPServerOptions) ServerInterface

type ServerInterfaceWrapper 

type ServerInterfaceWrapper struct {
	Handler            ServerInterface
	HandlerMiddlewares []MiddlewareFunc
	ErrorHandlerFunc   func(w http.ResponseWriter, r *http.Request, err error)
}

ServerInterfaceWrapper converts contexts to parameters.

func (*ServerInterfaceWrapper) DownloadClusterResourceBundle 

func (siw *ServerInterfaceWrapper) DownloadClusterResourceBundle(w http.ResponseWriter, r *http.Request)

DownloadClusterResourceBundle operation middleware

func (*ServerInterfaceWrapper) ExchangeClusterIdentityToken 

func (siw *ServerInterfaceWrapper) ExchangeClusterIdentityToken(w http.ResponseWriter, r *http.Request)

ExchangeClusterIdentityToken operation middleware

func (*ServerInterfaceWrapper) GetClusterBootstrapConfig 

func (siw *ServerInterfaceWrapper) GetClusterBootstrapConfig(w http.ResponseWriter, r *http.Request)

GetClusterBootstrapConfig operation middleware

func (*ServerInterfaceWrapper) GetClusterResourceBundles 

func (siw *ServerInterfaceWrapper) GetClusterResourceBundles(w http.ResponseWriter, r *http.Request)

GetClusterResourceBundles operation middleware

func (*ServerInterfaceWrapper) ReportClusterResourceBundleStatus 

func (siw *ServerInterfaceWrapper) ReportClusterResourceBundleStatus(w http.ResponseWriter, r *http.Request)

ReportClusterResourceBundleStatus operation middleware

type StrictHTTPServerOptions 

type StrictHTTPServerOptions struct {
	RequestErrorHandlerFunc  func(w http.ResponseWriter, r *http.Request, err error)
	ResponseErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)
}

type StrictHandlerFunc 

type StrictHandlerFunc = strictnethttp.StrictHttpHandlerFunc

type StrictMiddlewareFunc 

type StrictMiddlewareFunc = strictnethttp.StrictHttpMiddlewareFunc

type StrictServerInterface 

type StrictServerInterface interface {

	// (GET /bootstrap)
	GetClusterBootstrapConfig(ctx context.Context, request GetClusterBootstrapConfigRequestObject) (GetClusterBootstrapConfigResponseObject, error)

	// (GET /bundles)
	GetClusterResourceBundles(ctx context.Context, request GetClusterResourceBundlesRequestObject) (GetClusterResourceBundlesResponseObject, error)

	// (GET /bundles/{bundleId}/download)
	DownloadClusterResourceBundle(ctx context.Context, request DownloadClusterResourceBundleRequestObject) (DownloadClusterResourceBundleResponseObject, error)

	// (POST /bundles/{bundleId}/status)
	ReportClusterResourceBundleStatus(ctx context.Context, request ReportClusterResourceBundleStatusRequestObject) (ReportClusterResourceBundleStatusResponseObject, error)

	// (POST /exchangeToken)
	ExchangeClusterIdentityToken(ctx context.Context, request ExchangeClusterIdentityTokenRequestObject) (ExchangeClusterIdentityTokenResponseObject, error)
}

StrictServerInterface represents all server handlers.

type TokenProviderFn 

type TokenProviderFn func(ctx context.Context, minTTL time.Duration) (string, error)

TokenProviderFn is a function that returns a token that is expected to be valid for at least minTTL

type TooManyValuesForParamError 

type TooManyValuesForParamError struct {
	ParamName string
	Count     int
}

func (*TooManyValuesForParamError) Error 

func (e *TooManyValuesForParamError) Error() string

type URLCache 

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

URLCache is a cache of URLs to download bundles from.

func NewURLCache 

func NewURLCache() *URLCache

NewURLCache creates a new URL cache.

func (*URLCache) Get 

func (c *URLCache) Get(key string, minTTL time.Duration) (*DownloadCacheEntry, bool)

Get gets the cache entry for the given key, if it exists and has not expired.

func (*URLCache) Set 

func (c *URLCache) Set(key string, entry DownloadCacheEntry)

Set sets the cache entry for the given key.

type UnescapedCookieParamError 

type UnescapedCookieParamError struct {
	ParamName string
	Err       error
}

func (*UnescapedCookieParamError) Error 

func (e *UnescapedCookieParamError) Error() string

func (*UnescapedCookieParamError) Unwrap 

func (e *UnescapedCookieParamError) Unwrap() error

type Unimplemented 

type Unimplemented struct{}

func (Unimplemented) DownloadClusterResourceBundle 

func (_ Unimplemented) DownloadClusterResourceBundle(w http.ResponseWriter, r *http.Request, bundleId BundleId)

(GET /bundles/{bundleId}/download)

func (Unimplemented) ExchangeClusterIdentityToken 

func (_ Unimplemented) ExchangeClusterIdentityToken(w http.ResponseWriter, r *http.Request)

(POST /exchangeToken)

func (Unimplemented) GetClusterBootstrapConfig 

func (_ Unimplemented) GetClusterBootstrapConfig(w http.ResponseWriter, r *http.Request)

(GET /bootstrap)

func (Unimplemented) GetClusterResourceBundles 

func (_ Unimplemented) GetClusterResourceBundles(w http.ResponseWriter, r *http.Request)

(GET /bundles)

func (Unimplemented) ReportClusterResourceBundleStatus 

func (_ Unimplemented) ReportClusterResourceBundleStatus(w http.ResponseWriter, r *http.Request, bundleId BundleId)

(POST /bundles/{bundleId}/status)

type UnmarshalingParamError 

type UnmarshalingParamError struct {
	ParamName string
	Err       error
}

func (*UnmarshalingParamError) Error 

func (e *UnmarshalingParamError) Error() string

func (*UnmarshalingParamError) Unwrap 

func (e *UnmarshalingParamError) Unwrap() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.