handlers

Documentation

Index

• Constants
• func DecodeJSONBody(resp *http.Response, value any) error
• func ModifyJSONBody(resp *http.Response, value any, fn func() error) error
• func ResponseBuffer(resp *http.Response) (*bytes.Buffer, error)
• func ResponseReader(resp *http.Response) (io.ReadCloser, error)
• type CommonProviderHandler
  • func NewCommonProviderHandler(includes, excludes *[]string) *CommonProviderHandler
  • func (handler *CommonProviderHandler) CanHandleProvider(provider *models.Provider) bool
• type ProviderDirectHandler
  • func (handler *ProviderDirectHandler) Download(ctx echo.Context, provider *models.Provider) error
  • func (handler *ProviderDirectHandler) GetPlatform(ctx echo.Context, provider *models.Provider, ...) error
  • func (handler *ProviderDirectHandler) GetVersions(ctx echo.Context, provider *models.Provider) error
  • func (handler *ProviderDirectHandler) String() string
• type ProviderFilesystemMirrorHandler
  • func (handler *ProviderFilesystemMirrorHandler) Download(ctx echo.Context, provider *models.Provider) error
  • func (handler *ProviderFilesystemMirrorHandler) GetPlatform(ctx echo.Context, provider *models.Provider, ...) error
  • func (handler *ProviderFilesystemMirrorHandler) GetVersions(ctx echo.Context, provider *models.Provider) error
  • func (handler *ProviderFilesystemMirrorHandler) String() string
• type ProviderHandler
  • func NewProviderDirectHandler(providerService *services.ProviderService, cacheProviderHTTPStatusCode int, ...) ProviderHandler
  • func NewProviderFilesystemMirrorHandler(providerService *services.ProviderService, cacheProviderHTTPStatusCode int, ...) ProviderHandler
  • func NewProviderNetworkMirrorHandler(providerService *services.ProviderService, cacheProviderHTTPStatusCode int, ...) ProviderHandler
• type ProviderNetworkMirrorHandler
  • func (handler *ProviderNetworkMirrorHandler) Download(ctx echo.Context, provider *models.Provider) error
  • func (handler *ProviderNetworkMirrorHandler) GetPlatform(ctx echo.Context, provider *models.Provider, ...) error
  • func (handler *ProviderNetworkMirrorHandler) GetVersions(ctx echo.Context, provider *models.Provider) error
  • func (handler *ProviderNetworkMirrorHandler) String() string
• type ReverseProxy
  • func (reverseProxy *ReverseProxy) NewRequest(ctx echo.Context, targetURL *url.URL) (er error)
  • func (reverseProxy ReverseProxy) WithModifyResponse(fn func(resp *http.Response) error) *ReverseProxy
  • func (reverseProxy ReverseProxy) WithRewrite(fn func(req *httputil.ProxyRequest)) *ReverseProxy

Constants

const (
	// Provider's assets consist of three files/URLs: zipped binary, hashes and signature
	ProviderDownloadURLName         providerURLName = "download_url"
	ProviderSHASumsURLName          providerURLName = "shasums_url"
	ProviderSHASumsSignatureURLName providerURLName = "shasums_signature_url"
)

Functions

func DecodeJSONBody

func DecodeJSONBody(resp *http.Response, value any) error

func ModifyJSONBody

func ModifyJSONBody(resp *http.Response, value any, fn func() error) error

func ResponseBuffer

func ResponseBuffer(resp *http.Response) (*bytes.Buffer, error)

func ResponseReader

func ResponseReader(resp *http.Response) (io.ReadCloser, error)

Types

type CommonProviderHandler

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

func NewCommonProviderHandler

func NewCommonProviderHandler(includes, excludes *[]string) *CommonProviderHandler

func (*CommonProviderHandler) CanHandleProvider

func (handler *CommonProviderHandler) CanHandleProvider(provider *models.Provider) bool

CanHandleProvider implements ProviderHandler.CanHandleProvider

type ProviderDirectHandler

type ProviderDirectHandler struct {
	*CommonProviderHandler

	*ReverseProxy
	// contains filtered or unexported fields
}

func (*ProviderDirectHandler) Download

func (handler *ProviderDirectHandler) Download(ctx echo.Context, provider *models.Provider) error

Download implements ProviderHandler.Download

func (*ProviderDirectHandler) GetPlatform

func (handler *ProviderDirectHandler) GetPlatform(ctx echo.Context, provider *models.Provider, downloaderController router.Controller, cacheRequestID string) error

GetPlatform implements ProviderHandler.GetPlatform

func (*ProviderDirectHandler) GetVersions

func (handler *ProviderDirectHandler) GetVersions(ctx echo.Context, provider *models.Provider) error

GetVersions implements ProviderHandler.GetVersions

func (*ProviderDirectHandler) String

func (handler *ProviderDirectHandler) String() string

type ProviderFilesystemMirrorHandler

type ProviderFilesystemMirrorHandler struct {
	*CommonProviderHandler
	// contains filtered or unexported fields
}

func (*ProviderFilesystemMirrorHandler) Download

func (handler *ProviderFilesystemMirrorHandler) Download(ctx echo.Context, provider *models.Provider) error

Download implements ProviderHandler.Download

func (*ProviderFilesystemMirrorHandler) GetPlatform

func (handler *ProviderFilesystemMirrorHandler) GetPlatform(ctx echo.Context, provider *models.Provider, downloaderController router.Controller, cacheRequestID string) error

GetPlatform implements ProviderHandler.GetPlatform

func (*ProviderFilesystemMirrorHandler) GetVersions

func (handler *ProviderFilesystemMirrorHandler) GetVersions(ctx echo.Context, provider *models.Provider) error

GetVersions implements ProviderHandler.GetVersions

func (*ProviderFilesystemMirrorHandler) String

func (handler *ProviderFilesystemMirrorHandler) String() string

type ProviderHandler

type ProviderHandler interface {
	// CanHandleProvider returns true if the given provider can be handled by this handler.
	CanHandleProvider(provider *models.Provider) bool

	// GetVersions serves a request that returns all versions for a single provider.
	GetVersions(ctx echo.Context, provider *models.Provider) error

	// GetPlatform serves a request that returns a provider for a specific platform.
	GetPlatform(ctx echo.Context, provider *models.Provider, downloaderController router.Controller, cacheRequestID string) error

	// Download serves a request to download the target file.
	Download(ctx echo.Context, provider *models.Provider) error
}

func NewProviderDirectHandler

func NewProviderDirectHandler(providerService *services.ProviderService, cacheProviderHTTPStatusCode int, method *cliconfig.ProviderInstallationDirect) ProviderHandler

func NewProviderFilesystemMirrorHandler

func NewProviderFilesystemMirrorHandler(providerService *services.ProviderService, cacheProviderHTTPStatusCode int, method *cliconfig.ProviderInstallationFilesystemMirror) ProviderHandler

func NewProviderNetworkMirrorHandler

func NewProviderNetworkMirrorHandler(providerService *services.ProviderService, cacheProviderHTTPStatusCode int, networkMirror *cliconfig.ProviderInstallationNetworkMirror) ProviderHandler

type ProviderNetworkMirrorHandler

type ProviderNetworkMirrorHandler struct {
	*CommonProviderHandler

	*http.Client
	// contains filtered or unexported fields
}

func (*ProviderNetworkMirrorHandler) Download

func (handler *ProviderNetworkMirrorHandler) Download(ctx echo.Context, provider *models.Provider) error

Download implements ProviderHandler.Download

func (*ProviderNetworkMirrorHandler) GetPlatform

func (handler *ProviderNetworkMirrorHandler) GetPlatform(ctx echo.Context, provider *models.Provider, downloaderController router.Controller, cacheRequestID string) error

GetPlatform implements ProviderHandler.GetPlatform

func (*ProviderNetworkMirrorHandler) GetVersions

func (handler *ProviderNetworkMirrorHandler) GetVersions(ctx echo.Context, provider *models.Provider) error

GetVersions implements ProviderHandler.GetVersions

func (*ProviderNetworkMirrorHandler) String

func (handler *ProviderNetworkMirrorHandler) String() string

type ReverseProxy

type ReverseProxy struct {
	ServerURL *url.URL

	Rewrite        func(*httputil.ProxyRequest)
	ModifyResponse func(resp *http.Response) error
	ErrorHandler   func(http.ResponseWriter, *http.Request, error)
}

func (*ReverseProxy) NewRequest

func (reverseProxy *ReverseProxy) NewRequest(ctx echo.Context, targetURL *url.URL) (er error)

func (ReverseProxy) WithModifyResponse

func (reverseProxy ReverseProxy) WithModifyResponse(fn func(resp *http.Response) error) *ReverseProxy

func (ReverseProxy) WithRewrite

func (reverseProxy ReverseProxy) WithRewrite(fn func(req *httputil.ProxyRequest)) *ReverseProxy