otaupdate

Documentation

Index

• func GetPods(store cachemanager.StorageWrapper) http.Handler
• func HealthyCheck(rest *rest.RestConfigManager, nodeName string, handler OTAHandler) http.Handler
• func UpdatePod(clientset kubernetes.Interface, nodeName string) http.Handler
• func WriteErr(w http.ResponseWriter, errReason string, httpStatus int)
• func WriteJSONResponse(w http.ResponseWriter, data []byte)
• type OTAHandler

Functions

func GetPods

func GetPods(store cachemanager.StorageWrapper) http.Handler

GetPods return pod list

func HealthyCheck

func HealthyCheck(rest *rest.RestConfigManager, nodeName string, handler OTAHandler) http.Handler

HealthyCheck checks if cloud-edge is disconnected before ota update handle, ota update is not allowed when disconnected

func UpdatePod

func UpdatePod(clientset kubernetes.Interface, nodeName string) http.Handler

UpdatePod update a specifc pod(namespace/podname) to the latest version

func WriteErr

func WriteErr(w http.ResponseWriter, errReason string, httpStatus int)

WriteErr writes the http status and the error string on the response

func WriteJSONResponse

func WriteJSONResponse(w http.ResponseWriter, data []byte)

Derived from kubelet writeJSONResponse

Types

type OTAHandler

type OTAHandler func(kubernetes.Interface, string) http.Handler