common

Dec 11, 2023

Changes in this version

+ func AgentConditionToMetaV1(condition v1alpha1.DatadogAgentCondition) metav1.Condition

type StatusWrapper

+ GetStatusCondition func() []metav1.Condition

Oct 3, 2023

Changes in this version

type Options

+ APIExtClient *apiextensionclient.Clientset

+ func (o *Options) SetApiExtensionClient(client *apiextensionclient.Clientset)

Aug 3, 2023

Changes in this version

+ type StatusWrapper interface

+ GetAgentStatus func() *commonv1.DaemonSetStatus

+ GetClusterAgentStatus func() *commonv1.DeploymentStatus

+ GetClusterChecksRunnerStatus func() *commonv1.DeploymentStatus

+ GetObjectMeta func() metav1.Object

+ func NewV1StatusWrapper(dda *v1alpha1.DatadogAgent) StatusWrapper

+ func NewV2StatusWrapper(dda *v2alpha1.DatadogAgent) StatusWrapper

Apr 3, 2023

Changes in this version

+ func IsV2Available(cl *kubernetes.Clientset) (bool, error)

+ func OverrideComponentImage(spec *v2alpha1.DatadogAgentSpec, cmpName v2alpha1.ComponentName, ...) error

+ func SplitImageString(in string) (name string, tag string)

type Options

+ func (o *Options) IsDatadogAgentV2Available() bool

+ type StatusWapper interface

+ GetAgentStatus func() *commonv1.DaemonSetStatus

+ GetClusterAgentStatus func() *commonv1.DeploymentStatus

+ GetClusterChecksRunnerStatus func() *commonv1.DeploymentStatus

+ GetObjectMeta func() metav1.Object

+ func NewV1StatusWapper(dda *v1alpha1.DatadogAgent) StatusWapper

+ func NewV2StatusWapper(dda *v2alpha1.DatadogAgent) StatusWapper

May 6, 2020

Changes in this version

+ const ADPrefix

+ const AgentLabelValue

+ const ClcRunnerLabelValue

+ const ComponentLabelKey

+ var AgentLabel = fmt.Sprintf("%s=%s", ComponentLabelKey, AgentLabelValue)

+ var ClcRunnerLabel = fmt.Sprintf("%s=%s", ComponentLabelKey, ClcRunnerLabelValue)

+ func AskForConfirmation(input string) bool

+ func AskForInput(question string) (string, error)

+ func GetDurationAsString(obj *metav1.ObjectMeta) string

+ func HasImagePattern(image string) bool

+ func IntToString(i int32) string

+ func IsAnnotated(annotations map[string]string, prefix string) bool

+ func NewClient(clientConfig clientcmd.ClientConfig) (client.Client, error)

+ func NewClientset(clientConfig clientcmd.ClientConfig) (*kubernetes.Clientset, error)

+ func StreamToBytes(stream io.Reader) ([]byte, error)

+ func ValidateAnnotationsContent(annotations map[string]string, identifier string) ([]string, bool)

+ func ValidateAnnotationsMatching(annotations map[string]string, validIDs map[string]bool) []string

+ func ValidateUpgrade(image string, latest bool) error

+ type Options struct

+ Client client.Client

+ Clientset *kubernetes.Clientset

+ ConfigFlags *genericclioptions.ConfigFlags

+ UserNamespace string

+ func (o *Options) GetClientConfig() clientcmd.ClientConfig

+ func (o *Options) Init(cmd *cobra.Command) error

+ func (o *Options) SetClient(client client.Client)

+ func (o *Options) SetClientset(clientset *kubernetes.Clientset)

+ func (o *Options) SetConfigFlags()

+ func (o *Options) SetNamespace(ns string)