handlers

Documentation

Index

• func AppUpdateCheck(w http.ResponseWriter, r *http.Request)
• func CORS(w http.ResponseWriter, r *http.Request)
• func CreateAppFromAirgap(w http.ResponseWriter, r *http.Request)
• func DownloadApp(w http.ResponseWriter, r *http.Request)
• func DownloadSnapshotLogs(w http.ResponseWriter, r *http.Request)
• func GenerateNodeJoinCommandMaster(w http.ResponseWriter, r *http.Request)
• func GenerateNodeJoinCommandWorker(w http.ResponseWriter, r *http.Request)
• func GetAppRegistry(w http.ResponseWriter, r *http.Request)
• func Healthz(w http.ResponseWriter, r *http.Request)
• func JSON(w http.ResponseWriter, code int, payload interface{})
• func Login(w http.ResponseWriter, r *http.Request)
• func Metadata(w http.ResponseWriter, r *http.Request)
• func NodeProxy(upstream *httputil.ReverseProxy) func(http.ResponseWriter, *http.Request)
• func NotImplemented(w http.ResponseWriter, r *http.Request)
• func Root(w http.ResponseWriter, r *http.Request)
• func StreamJSON(c *websocket.Conn, payload interface{})
• func SyncLicense(w http.ResponseWriter, r *http.Request)
• func UpdateAppConfig(w http.ResponseWriter, r *http.Request)
• func UpdateAppRegistry(w http.ResponseWriter, r *http.Request)
• func UploadExistingApp(w http.ResponseWriter, r *http.Request)
• type AppUpdateCheckRequest
• type AppUpdateCheckResponse
• type CreateAppFromAirgapRequest
• type CreateAppFromAirgapResponse
• type DatabaseResponse
• type EntitlementResponse
• type GenerateNodeJoinCommandResponse
• type Handlers
• type HealthzResponse
• type LoginRequest
• type LoginResponse
• type MetadataResponse
• type SPAHandler
  • func (h SPAHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type StatusResponse
• type StorageResponse
• type SyncLicenseRequest
• type SyncLicenseResponse
• type UpdateAppConfigRequest
• type UpdateAppConfigResponse
• type UpdateAppRegistryRequest
• type UpdateAppRegistryResponse
• type UploadExistingAppRequest
• type UploadResponse

Functions

func AppUpdateCheck

func AppUpdateCheck(w http.ResponseWriter, r *http.Request)

func CORS

func CORS(w http.ResponseWriter, r *http.Request)

func CreateAppFromAirgap

func CreateAppFromAirgap(w http.ResponseWriter, r *http.Request)

func DownloadApp

func DownloadApp(w http.ResponseWriter, r *http.Request)

func DownloadSnapshotLogs

func DownloadSnapshotLogs(w http.ResponseWriter, r *http.Request)

func GenerateNodeJoinCommandMaster

func GenerateNodeJoinCommandMaster(w http.ResponseWriter, r *http.Request)

func GenerateNodeJoinCommandWorker

func GenerateNodeJoinCommandWorker(w http.ResponseWriter, r *http.Request)

func GetAppRegistry

func GetAppRegistry(w http.ResponseWriter, r *http.Request)

func Healthz

func Healthz(w http.ResponseWriter, r *http.Request)

func JSON

func JSON(w http.ResponseWriter, code int, payload interface{})

func Login

func Login(w http.ResponseWriter, r *http.Request)

func Metadata

func Metadata(w http.ResponseWriter, r *http.Request)

func NodeProxy

func NodeProxy(upstream *httputil.ReverseProxy) func(http.ResponseWriter, *http.Request)

func NotImplemented

func NotImplemented(w http.ResponseWriter, r *http.Request)

func Root

func Root(w http.ResponseWriter, r *http.Request)

func StreamJSON

func StreamJSON(c *websocket.Conn, payload interface{})

func SyncLicense

func SyncLicense(w http.ResponseWriter, r *http.Request)

func UpdateAppConfig

func UpdateAppConfig(w http.ResponseWriter, r *http.Request)

func UpdateAppRegistry

func UpdateAppRegistry(w http.ResponseWriter, r *http.Request)

func UploadExistingApp

func UploadExistingApp(w http.ResponseWriter, r *http.Request)

UploadExistingApp can be used to upload a multipart form file to the existing app This is used in the KOTS CLI when calling kots upload ...

Types

type AppUpdateCheckRequest

type AppUpdateCheckRequest struct {
}

type AppUpdateCheckResponse

type AppUpdateCheckResponse struct {
	AvailableUpdates int64 `json:"availableUpdates"`
}

type CreateAppFromAirgapRequest

type CreateAppFromAirgapRequest struct {
}

type CreateAppFromAirgapResponse

type CreateAppFromAirgapResponse struct {
}

type DatabaseResponse

type DatabaseResponse struct {
	Connected bool `json:"connected"`
}

type EntitlementResponse

type EntitlementResponse struct {
	Title string      `json:"title"`
	Value interface{} `json:"value"`
	Label string      `json:"label"`
}

type GenerateNodeJoinCommandResponse

type GenerateNodeJoinCommandResponse struct {
	Command []string `json:"command"`
	Expiry  string   `json:"expiry"`
}

type Handlers

type Handlers struct {
}

type HealthzResponse

type HealthzResponse struct {
	Version string         `json:"version"`
	GitSHA  string         `json:"gitSha"`
	Status  StatusResponse `json:"status"`
}

type LoginRequest

type LoginRequest struct {
	Password string `json:"password"`
}

type LoginResponse

type LoginResponse struct {
	Token string `json:"token"`
}

type MetadataResponse

type MetadataResponse struct {
	IconURI       string `json:"iconUri"`
	Name          string `json:"name"`
	Namespace     string `json:"namespace"`
	IsKurlEnabled bool   `json:"isKurlEnabled"`
}

type SPAHandler

type SPAHandler struct {
	StaticPath string
	IndexPath  string
}

spaHandler implements the http.Handler interface, so we can use it to respond to HTTP requests. The path to the static directory and path to the index file within that static directory are used to serve the SPA in the given static directory.

func (SPAHandler) ServeHTTP

func (h SPAHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP inspects the URL path to locate a file within the static dir on the SPA handler. If a file is found, it will be served. If not, the file located at the index path on the SPA handler will be served. This is suitable behavior for serving an SPA (single page application).

type StatusResponse

type StatusResponse struct {
	Database DatabaseResponse `json:"database"`
	Storage  StorageResponse  `json:"storage"`
}

type StorageResponse

type StorageResponse struct {
	Available bool `json:"available"`
}

type SyncLicenseRequest

type SyncLicenseRequest struct {
	LicenseData string `json:"licenseData"`
}

type SyncLicenseResponse

type SyncLicenseResponse struct {
	ID              string                `json:"id"`
	ExpiresAt       time.Time             `json:"expiresAt"`
	ChannelName     string                `json:"channelName"`
	LicenseSequence int64                 `json:"licenseSequence"`
	LicenseType     string                `json:"licenseType"`
	Entitlements    []EntitlementResponse `json:"entitlements"`
}

type UpdateAppConfigRequest

type UpdateAppConfigRequest struct {
	Sequence         int64                      `json:"sequence"`
	CreateNewVersion bool                       `json:"createNewVersion"`
	ConfigGroups     []*kotsv1beta1.ConfigGroup `json:"configGroups"`
}

type UpdateAppConfigResponse

type UpdateAppConfigResponse struct {
	Success       bool     `json:"success"`
	Error         string   `json:"error,omitempty"`
	RequiredItems []string `json:"requiredItems,omitempty"`
}

type UpdateAppRegistryRequest

type UpdateAppRegistryRequest struct {
	Hostname  string `json:"hostname"`
	Username  string `json:"username"`
	Password  string `json:"password"`
	Namespace string `json:"namespace"`
}

type UpdateAppRegistryResponse

type UpdateAppRegistryResponse struct {
	Hostname  string `json:"hostname"`
	Username  string `json:"username"`
	Namespace string `json:"namespace"`
}

type UploadExistingAppRequest

type UploadExistingAppRequest struct {
	Slug         string `json:"slug"`
	VersionLabel string `json:"versionLabel,omitempty"`
	UpdateCursor string `json:"updateCursor,omitempty"`
}

type UploadResponse

type UploadResponse struct {
	Slug string `json:"slug"`
}