statefulset

Documentation

Index

• Constants
• func BuildEecConfigMapName(instanceName string, module string) string
• func CreateStatefulSet(stsProperties *statefulSetProperties) (*appsv1.StatefulSet, error)
• func NewStatefulSetProperties(instance *dynatracev1beta1.DynaKube, ...) *statefulSetProperties
• type ExtensionController
  • func NewExtensionController(stsProperties *statefulSetProperties) *ExtensionController
  • func (eec *ExtensionController) BuildContainer() corev1.Container
  • func (eec *ExtensionController) BuildVolumes() []corev1.Volume
  • func (eec *ExtensionController) Limits(resourceName corev1.ResourceName) *resource.Quantity
  • func (eec *ExtensionController) Requests(resourceName corev1.ResourceName) *resource.Quantity
• type Reconciler
  • func NewReconciler(clt client.Client, apiReader client.Reader, scheme *runtime.Scheme, ...) *Reconciler
  • func (r *Reconciler) AddOnAfterStatefulSetCreateListener(event events.StatefulSetEvent)
  • func (r *Reconciler) Reconcile() (update bool, err error)
• type Statsd
  • func NewStatsd(stsProperties *statefulSetProperties) *Statsd
  • func (statsd *Statsd) BuildContainer() corev1.Container
  • func (statsd *Statsd) BuildVolumes() []corev1.Volume
  • func (statsd *Statsd) Limits(resourceName corev1.ResourceName) *resource.Quantity
  • func (statsd *Statsd) Requests(resourceName corev1.ResourceName) *resource.Quantity

Constants

const (
	InternalProxySecretMountPath = "/var/lib/dynatrace/secrets/internal-proxy"

	InternalProxySecretVolumeName = "internal-proxy-secret-volume"

	InternalProxySecretHost          = "host"
	InternalProxySecretHostMountPath = InternalProxySecretMountPath + "/" + InternalProxySecretHost

	InternalProxySecretPort          = "port"
	InternalProxySecretPortMountPath = InternalProxySecretMountPath + "/" + InternalProxySecretPort

	InternalProxySecretUsername          = "username"
	InternalProxySecretUsernameMountPath = InternalProxySecretMountPath + "/" + InternalProxySecretUsername

	InternalProxySecretPassword          = "password"
	InternalProxySecretPasswordMountPath = InternalProxySecretMountPath + "/" + InternalProxySecretPassword
)

const (
	DeploymentTypeActiveGate = "active_gate"
)

Functions

func BuildEecConfigMapName

func BuildEecConfigMapName(instanceName string, module string) string

func CreateStatefulSet

func CreateStatefulSet(stsProperties *statefulSetProperties) (*appsv1.StatefulSet, error)

func NewStatefulSetProperties

func NewStatefulSetProperties(instance *dynatracev1beta1.DynaKube, capabilityProperties *dynatracev1beta1.CapabilityProperties, kubeSystemUID types.UID,
	activeGateHash string, feature string, capabilityName string, serviceAccountOwner string,
	initContainers []corev1.Container, containerVolumeMounts []corev1.VolumeMount, volumes []corev1.Volume) *statefulSetProperties

Types

type ExtensionController

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

func NewExtensionController

func NewExtensionController(stsProperties *statefulSetProperties) *ExtensionController

func (*ExtensionController) BuildContainer

func (eec *ExtensionController) BuildContainer() corev1.Container

func (*ExtensionController) BuildVolumes

func (eec *ExtensionController) BuildVolumes() []corev1.Volume

func (*ExtensionController) Limits

func (eec *ExtensionController) Limits(resourceName corev1.ResourceName) *resource.Quantity

func (*ExtensionController) Requests

func (eec *ExtensionController) Requests(resourceName corev1.ResourceName) *resource.Quantity

type Reconciler

type Reconciler struct {
	client.Client
	Instance *dynatracev1beta1.DynaKube
	// contains filtered or unexported fields
}

func NewReconciler

func NewReconciler(clt client.Client, apiReader client.Reader, scheme *runtime.Scheme,
	instance *dynatracev1beta1.DynaKube, capability capability.Capability) *Reconciler

func (*Reconciler) AddOnAfterStatefulSetCreateListener

func (r *Reconciler) AddOnAfterStatefulSetCreateListener(event events.StatefulSetEvent)

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile() (update bool, err error)

type Statsd

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

func NewStatsd

func NewStatsd(stsProperties *statefulSetProperties) *Statsd

func (*Statsd) BuildContainer

func (statsd *Statsd) BuildContainer() corev1.Container

func (*Statsd) BuildVolumes

func (statsd *Statsd) BuildVolumes() []corev1.Volume

func (*Statsd) Limits

func (statsd *Statsd) Limits(resourceName corev1.ResourceName) *resource.Quantity

func (*Statsd) Requests

func (statsd *Statsd) Requests(resourceName corev1.ResourceName) *resource.Quantity