guardkubemgr

Documentation

Index

• type Kubemgr
  • func (k *Kubemgr) FetchConfig(ns string, sid string, cm bool) *spec.GuardianSpec
  • func (k *Kubemgr) InitConfigs()
  • func (k *Kubemgr) ReadConfigMap(namespace string, sid string) *spec.GuardianSpec
  • func (k *Kubemgr) ReadCrd(namespace string, serviceId string) *spec.GuardianSpec
  • func (k *Kubemgr) SetCm(ns string, sid string, guardianSpec *spec.GuardianSpec) string
  • func (k *Kubemgr) SetCrd(ns string, sid string, guardianSpec *spec.GuardianSpec) string
  • func (k *Kubemgr) WatchOnce(ns string, set func(ns string, sid string, g *spec.GuardianSpec))

Types

type Kubemgr

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

func (*Kubemgr) FetchConfig

func (k *Kubemgr) FetchConfig(ns string, sid string, cm bool) *spec.GuardianSpec

func (*Kubemgr) InitConfigs

func (k *Kubemgr) InitConfigs()

func (*Kubemgr) ReadConfigMap

func (k *Kubemgr) ReadConfigMap(namespace string, sid string) *spec.GuardianSpec

func (*Kubemgr) ReadCrd

func (k *Kubemgr) ReadCrd(namespace string, serviceId string) *spec.GuardianSpec

func (*Kubemgr) SetCm

func (k *Kubemgr) SetCm(ns string, sid string, guardianSpec *spec.GuardianSpec) string

Set a Guardian Config Map (Update if exists, create if not) Not using Kube's apply tp avoid kube's server side merge, ...so we need to do this ugly thingy... This ugly thingy has a race condition! Sometimes it will fail and we will just return false

func (*Kubemgr) SetCrd

func (k *Kubemgr) SetCrd(ns string, sid string, guardianSpec *spec.GuardianSpec) string

Set a Guardian Custom Resource (Update if exists, create if not) Kube does not support server side udpate with create if not exist, ...so we need to do this ugly thingy... This ugly thingy has a race condition! Sometimes it will fail and we will just return false

func (*Kubemgr) WatchOnce

func (k *Kubemgr) WatchOnce(ns string, set func(ns string, sid string, g *spec.GuardianSpec))