api

package

Go to main page

Versions in this module

v0

v0.5.0

Jan 14, 2025

Changes in this version

type API

+ func (e *API) V0CordonK3SAgent(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0UnCordonK3SAgent(w http.ResponseWriter, r *http.Request)

v0.4.2

May 7, 2024

v0.4.1

Mar 19, 2024

Changes in this version

type API

+ K3SAgentStatus bool

+ Kubernetes *controller.Controller

+ Mesos mesos.Mesos

+ func (e *API) AgentRestart()

+ func (e *API) ClusterRestart(ds bool)

+ func (e *API) GetTaskIDFromAnnotation(annotations map[string]string) string

+ func (e *API) GetTaskIDFromLabel(labels map[string]string) string

+ func (e *API) NotFound(w http.ResponseWriter, r *http.Request)

+ func (e *API) ServerRestart()

+ func (e *API) V0AdjustClusterResources(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0CapabilitiesDisclosure(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0ClusterShutdown(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0ClusterStart(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0Restart(w http.ResponseWriter, r *http.Request)

v0.4.0

Nov 24, 2022

Changes in this version

+ type API struct

+ BootstrapProtocol string

+ Config *cfg.Config

+ Framework *mesosutil.FrameworkConfig

+ Redis Redis

+ func New(cfg *cfg.Config, frm *mesosutil.FrameworkConfig) *API

+ func (e *API) CheckAuth(r *http.Request, w http.ResponseWriter) bool

+ func (e *API) CheckIfNotTask(keys *goredis.ScanIterator) bool

+ func (e *API) CleanupNodes()

+ func (e *API) Commands() *mux.Router

+ func (e *API) ConnectRedis()

+ func (e *API) CountRedisKey(pattern string) int

+ func (e *API) DelRedisKey(key string) int64

+ func (e *API) ErrorMessage(number int, function string, msg string) []byte

+ func (e *API) GetAllRedisKeys(pattern string) *goredis.ScanIterator

+ func (e *API) GetRedisKey(key string) string

+ func (e *API) GetTaskFromEvent(update *mesosproto.Event_Update) mesosutil.Command

+ func (e *API) PingRedis() error

+ func (e *API) SaveConfig()

+ func (e *API) SaveFrameworkRedis()

+ func (e *API) SaveTaskRedis(cmd mesosutil.Command)

+ func (e *API) ScheduleCleanup()

+ func (e *API) SetRedisKey(data []byte, key string)

+ func (e *API) V0Cleanup(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0GetCountK3SAgent(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0GetCountK3SServer(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0GetKubeVersion(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0GetKubeconfig(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0ScaleDatastore(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0ScaleK3SAgent(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0ScaleK3SServer(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0StatusK8s(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0StatusM3s(w http.ResponseWriter, r *http.Request)

+ func (e *API) V0UpdateBootstrap(w http.ResponseWriter, r *http.Request)

+ func (e *API) Versions(w http.ResponseWriter, r *http.Request)

+ type Redis struct

+ RedisCTX context.Context

+ RedisClient *goredis.Client

v0.3.0

Apr 22, 2022

Changes in this version

+ func CountRedisKey(pattern string) int

+ func DelRedisKey(key string) int64

+ func ErrorMessage(number int, function string, msg string) []byte

+ func GetAllRedisKeys(pattern string) *goredis.ScanIterator

+ func GetRedisKey(key string) string

+ func GetTaskFromEvent(update *mesosproto.Event_Update) mesosutil.Command

+ func SaveConfig()

+ func V0UpdateBootstrap(w http.ResponseWriter, r *http.Request)

+ func Versions(w http.ResponseWriter, r *http.Request)

v0.2.0

Oct 16, 2021

Changes in this version

+ func CheckAuth(r *http.Request, w http.ResponseWriter) bool

+ func Commands() *mux.Router

+ func SetConfig(cfg *cfg.Config)

+ func V0GetCountK3S(w http.ResponseWriter, r *http.Request)

+ func V0GetCountK3SAgent(w http.ResponseWriter, r *http.Request)

+ func V0GetKubeVersion(w http.ResponseWriter, r *http.Request)

+ func V0GetKubeconfig(w http.ResponseWriter, r *http.Request)

+ func V0KillTask(w http.ResponseWriter, r *http.Request)

+ func V0ScaleEtcd(w http.ResponseWriter, r *http.Request)

+ func V0ScaleK3S(w http.ResponseWriter, r *http.Request)

+ func V0ScaleK3SAgent(w http.ResponseWriter, r *http.Request)

+ func V0StatusK8s(w http.ResponseWriter, r *http.Request)

+ func V0StatusM3s(w http.ResponseWriter, r *http.Request)

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