statefulset

Documentation

Index

• Constants
• func CreateStatefulSet(stsProperties *statefulSetProperties) (*appsv1.StatefulSet, error)
• func NewStatefulSetProperties(dynakube *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 NewReconcilerFunc
• type Reconciler
  • func NewReconciler(clt client.Client, apiReader client.Reader, scheme *runtime.Scheme, ...) *Reconciler
  • func (r *Reconciler) AddOnAfterStatefulSetCreateListener(event kubeobjects.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

	GatewayConfigVolumeName = "ag-lib-gateway-config"
	GatewayTempVolumeName   = "ag-lib-gateway-temp"
	GatewayDataVolumeName   = "ag-lib-gateway-data"
	GatewaySslVolumeName    = "ag-lib-gateway-ssl"
	LogVolumeName           = "ag-log-gateway"
	TmpVolumeName           = "ag-tmp-gateway"
	GatewayConfigMountPoint = "/var/lib/dynatrace/gateway/config"
	GatewayTempMountPoint   = "/var/lib/dynatrace/gateway/temp"
	GatewayDataMountPoint   = "/var/lib/dynatrace/gateway/data"
	GatewaySslMountPoint    = "/var/lib/dynatrace/gateway/ssl"
	LogMountPoint           = "/var/log/dynatrace/gateway"
	TmpMountPoint           = "/var/tmp/dynatrace/gateway"
)

const (
	DeploymentTypeActiveGate = "active_gate"
)

Functions

func CreateStatefulSet

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

func NewStatefulSetProperties

func NewStatefulSetProperties(dynakube *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, capability capability.Capability) *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 NewReconcilerFunc

type NewReconcilerFunc = func(clt client.Client, apiReader client.Reader, scheme *runtime.Scheme, dynakube *dynatracev1beta1.DynaKube, capability capability.Capability) *Reconciler

type Reconciler

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

func NewReconciler

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

func (*Reconciler) AddOnAfterStatefulSetCreateListener

func (r *Reconciler) AddOnAfterStatefulSetCreateListener(event kubeobjects.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