Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ObservedCluster ¶
type ObservedCluster struct {
Items []*v1.KDBInstance
ByName map[string]*v1.KDBInstance
Ready int
}
func (ObservedCluster) AddInstance ¶
func (i ObservedCluster) AddInstance(instance *v1.KDBInstance)
func (ObservedCluster) GetInstanceByName ¶
func (i ObservedCluster) GetInstanceByName(instanceName string) *v1.KDBInstance
type ObservedRunner ¶
type ObservedRunner struct {
List []*SingleRunner // by instance name
BySet map[string]*SingleRunner // by StatefulSet name
SetNames sets.String
}
ObservedRunner represents the KDB instance.
func NewObservedRunner ¶
func NewObservedRunner( instance *v1.KDBInstance, runners []appsv1.StatefulSet, pods []corev1.Pod, ) *ObservedRunner
NewObservedRunner builds an ObservedSingleInstance from Kubernetes API objects.
type SingleRunner ¶
type SingleRunner struct {
Name string
Pods []*corev1.Pod
Runner *appsv1.StatefulSet
}
SingleRunner represents a single KDB instance.
func (SingleRunner) PodMatchesPodTemplate ¶
func (i SingleRunner) PodMatchesPodTemplate() (matches bool, known bool)
PodMatchesPodTemplate returns whether or not the Pod for this instance matches its specified PodTemplate. When it does not match, the Pod needs to be redeployed.
Source Files
Click to show internal directories.
Click to hide internal directories.