controller

package

v0.0.0-...-a3a5c94 Latest Latest Go to latest Published: Aug 21, 2021 License: MIT Imports: 27 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gridworkz/kato

Documentation ¶

Index ¶

func APPDiscover(w http.ResponseWriter, r *http.Request)
func APPList(w http.ResponseWriter, r *http.Request)
func APPRegister(w http.ResponseWriter, r *http.Request)
func AddNode(w http.ResponseWriter, r *http.Request)
func CapRes(w http.ResponseWriter, r *http.Request)
func CheckNode(w http.ResponseWriter, r *http.Request)
func ClusterDiscover(w http.ResponseWriter, r *http.Request)
func ClusterInfo(w http.ResponseWriter, r *http.Request)
func Cordon(w http.ResponseWriter, r *http.Request)
func CreateLocalVolume(w http.ResponseWriter, r *http.Request)
func DeleteKatoNode(w http.ResponseWriter, r *http.Request)
func DeleteLabel(w http.ResponseWriter, r *http.Request)
func DeleteLocalVolume(w http.ResponseWriter, r *http.Request)
func DeleteNodeCondition(w http.ResponseWriter, r *http.Request)
func DownNode(w http.ResponseWriter, r *http.Request)
func Exist(i interface{})
func GetAllNodeHealth(w http.ResponseWriter, r *http.Request)
func GetDatacenterConfig(w http.ResponseWriter, r *http.Request)
func GetLabel(w http.ResponseWriter, r *http.Request)
func GetNode(w http.ResponseWriter, r *http.Request)
func GetNodeBasic(w http.ResponseWriter, r *http.Request)
func GetNodeDetails(w http.ResponseWriter, r *http.Request)
func GetNodeResource(w http.ResponseWriter, r *http.Request)
func GetNodes(w http.ResponseWriter, r *http.Request)
func GetRuleNodes(w http.ResponseWriter, r *http.Request)
func GetServicesHealthy(w http.ResponseWriter, r *http.Request)
func Init(c *option.Conf, ms *masterserver.MasterServer, kube kubecache.KubeClient)
func InstallNode(w http.ResponseWriter, r *http.Request)
func Instances(w http.ResponseWriter, r *http.Request)
func ListNodeCondition(w http.ResponseWriter, r *http.Request)
func ListenerDiscover(w http.ResponseWriter, r *http.Request)
func Ping(w http.ResponseWriter, r *http.Request)
func PluginResourcesConfig(w http.ResponseWriter, r *http.Request)
func PutDatacenterConfig(w http.ResponseWriter, r *http.Request)
func PutLabel(w http.ResponseWriter, r *http.Request)
func Resource(w http.ResponseWriter, r *http.Request)
func Resources(w http.ResponseWriter, r *http.Request)
func RoutesDiscover(w http.ResponseWriter, r *http.Request)
func ServiceDiscover(w http.ResponseWriter, r *http.Request)
func UnCordon(w http.ResponseWriter, r *http.Request)
func UpNode(w http.ResponseWriter, r *http.Request)
func UpdateNodeStatus(w http.ResponseWriter, r *http.Request)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func APPDiscover ¶

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

APPDiscover - Service discovery Used in scenarios where real-time requirements are not high, for example, docker finds the event_log address Request API to return available addresses

func APPList ¶

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

APPList - List registered apps

func APPRegister ¶

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

APPRegister - Service registration

func AddNode ¶

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

AddNode

func CapRes ¶

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

CapRes

func CheckNode ¶

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

CheckNode -

func ClusterDiscover ¶

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

ClusterDiscover

func ClusterInfo ¶

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

ClusterInfo

func Cordon ¶

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

Cordon

func CreateLocalVolume ¶

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

CreateLocalVolume

func DeleteKatoNode ¶

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

DeleteKatoNode

func DeleteLabel ¶

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

DeleteLabel

func DeleteLocalVolume ¶

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

DeleteLocalVolume

func DeleteNodeCondition ¶

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

DeleteNodeCondition

func DownNode ¶

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

DownNode - Node offline, compute node operation

func Exist ¶

func Exist(i interface{})

Exist

func GetAllNodeHealth ¶

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

GetAllNodeHealth

func GetDatacenterConfig ¶

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

GetDatacenterConfig

func GetLabel ¶

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

GetLabel

func GetNode ¶

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

GetNode

func GetNodeBasic ¶

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

GetNodeBasic

func GetNodeDetails ¶

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

GetNodeDetails

func GetNodeResource ¶

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

GetNodeResource -

func GetNodes ¶

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

GetNodes

func GetRuleNodes ¶

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

GetRuleNodes

func GetServicesHealthy ¶

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

GetServicesHealthy

func Init ¶

func Init(c *option.Conf, ms *masterserver.MasterServer, kube kubecache.KubeClient)

Init

func InstallNode ¶

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

InstallNode

func Instances ¶

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

Instances

func ListNodeCondition ¶

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

ListNodeCondition

func ListenerDiscover ¶

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

ListenerDiscover

func Ping ¶

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

Ping

func PluginResourcesConfig ¶

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

PluginResourcesConfig

func PutDatacenterConfig ¶

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

PutDatacenterConfig

func PutLabel ¶

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

PutLabel

func Resource ¶

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

Resource -

func Resources ¶

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

Resources specified node scheduler resources info

func RoutesDiscover ¶

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

RoutesDiscover no impl

func ServiceDiscover ¶

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

ServiceDiscover

func UnCordon ¶

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

UnCordon

func UpNode ¶

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

UpNode - Node goes online, compute node operation

func UpdateNodeStatus ¶

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

UpdateNodeStatus `{"status":"installing"}`

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL