observed

Documentation

Index

• type ObservedCluster
  • func (i ObservedCluster) AddInstance(instance *v1.KDBInstance)
  • func (i ObservedCluster) GetInstanceByName(instanceName string) *v1.KDBInstance
• type ObservedSingleInstance
  • func NewObservedSingleInstance(instance *v1.KDBInstance, runners []appsv1.StatefulSet, pods []corev1.Pod) *ObservedSingleInstance
• type SingleInstance
  • func (i SingleInstance) PodMatchesPodTemplate() (matches bool, known bool)

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 ObservedSingleInstance

type ObservedSingleInstance struct {
	List     []*SingleInstance          // by instance name
	BySet    map[string]*SingleInstance // by StatefulSet name
	SetNames sets.String
}

ObservedSingleInstance represents the KDB instance.

func NewObservedSingleInstance

func NewObservedSingleInstance(
	instance *v1.KDBInstance,
	runners []appsv1.StatefulSet,
	pods []corev1.Pod,
) *ObservedSingleInstance

NewObservedSingleInstance builds an ObservedSingleInstance from Kubernetes API objects.

type SingleInstance

type SingleInstance struct {
	Name   string
	Pods   []*corev1.Pod
	Runner *appsv1.StatefulSet
}

SingleInstance represents a single KDB instance.

func (SingleInstance) PodMatchesPodTemplate

func (i SingleInstance) 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.