config

Documentation

Index

• Constants
• func GetConfigMapForCache(client client.Client) (*corev1.ConfigMap, error)
• type ColocationCfgCache
• type ColocationHandlerForConfigMapEvent
  • func NewColocationHandlerForConfigMapEvent(client client.Client, initCfg configuration.ColocationCfg, ...) *ColocationHandlerForConfigMapEvent
  • func (p *ColocationHandlerForConfigMapEvent) GetCfgCopy() *configuration.ColocationCfg
  • func (p *ColocationHandlerForConfigMapEvent) IsCfgAvailable() bool
  • func (p *ColocationHandlerForConfigMapEvent) IsErrorStatus() bool
• type EnqueueRequestForConfigMap
  • func (p *EnqueueRequestForConfigMap) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (p *EnqueueRequestForConfigMap) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (p *EnqueueRequestForConfigMap) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (p *EnqueueRequestForConfigMap) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

Constants

const (
	ReasonColocationConfigUnmarshalFailed = "ColocationCfgUnmarshalFailed"
	ReasonSLOConfigUnmarshalFailed        = "SLOCfgUnmarshalFailed"
)

Functions

func GetConfigMapForCache

func GetConfigMapForCache(client client.Client) (*corev1.ConfigMap, error)

Types

type ColocationCfgCache

type ColocationCfgCache interface {
	GetCfgCopy() *configuration.ColocationCfg
	IsCfgAvailable() bool
	IsErrorStatus() bool
}

type ColocationHandlerForConfigMapEvent

type ColocationHandlerForConfigMapEvent struct {
	EnqueueRequestForConfigMap

	Client client.Client
	// contains filtered or unexported fields
}

func NewColocationHandlerForConfigMapEvent

func NewColocationHandlerForConfigMapEvent(client client.Client, initCfg configuration.ColocationCfg, recorder record.EventRecorder) *ColocationHandlerForConfigMapEvent

func (*ColocationHandlerForConfigMapEvent) GetCfgCopy

func (p *ColocationHandlerForConfigMapEvent) GetCfgCopy() *configuration.ColocationCfg

func (*ColocationHandlerForConfigMapEvent) IsCfgAvailable

func (p *ColocationHandlerForConfigMapEvent) IsCfgAvailable() bool

func (*ColocationHandlerForConfigMapEvent) IsErrorStatus

func (p *ColocationHandlerForConfigMapEvent) IsErrorStatus() bool

type EnqueueRequestForConfigMap

type EnqueueRequestForConfigMap struct {
	EnqueueRequest     func(q *workqueue.RateLimitingInterface)
	SyncCacheIfChanged func(configMap *corev1.ConfigMap) bool
}

func (*EnqueueRequestForConfigMap) Create

func (p *EnqueueRequestForConfigMap) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (*EnqueueRequestForConfigMap) Delete

func (p *EnqueueRequestForConfigMap) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*EnqueueRequestForConfigMap) Generic

func (p *EnqueueRequestForConfigMap) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (*EnqueueRequestForConfigMap) Update

func (p *EnqueueRequestForConfigMap) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)