common

Documentation

Index

• Constants
• Variables
• func AskForConfirmation(input string) bool
• func AskForInput(question string) (string, error)
• func GetDurationAsString(obj metav1.Object) string
• func HasImagePattern(image string) bool
• func IntToString(i int32) string
• func IsAnnotated(annotations map[string]string, prefix string) bool
• func IsV2Available(cl *kubernetes.Clientset) (bool, error)
• func NewClient(clientConfig clientcmd.ClientConfig) (client.Client, error)
• func NewClientset(clientConfig clientcmd.ClientConfig) (*kubernetes.Clientset, error)
• func OverrideComponentImage(spec *v2alpha1.DatadogAgentSpec, cmpName v2alpha1.ComponentName, ...) error
• func SplitImageString(in string) (name string, tag string)
• 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
  • func (o *Options) GetClientConfig() clientcmd.ClientConfig
  • func (o *Options) Init(cmd *cobra.Command) error
  • func (o *Options) IsDatadogAgentV2Available() bool
  • func (o *Options) SetClient(client client.Client)
  • func (o *Options) SetClientset(clientset *kubernetes.Clientset)
  • func (o *Options) SetConfigFlags()
  • func (o *Options) SetNamespace(ns string)
• type StatusWrapper
  • func NewV1StatusWrapper(dda *v1alpha1.DatadogAgent) StatusWrapper
  • func NewV2StatusWrapper(dda *v2alpha1.DatadogAgent) StatusWrapper

Constants

const (
	// ADPrefix prefix used for AD annotations
	ADPrefix = "ad.datadoghq.com/"
	// AgentLabelValue label value to define the Agent
	AgentLabelValue = "agent"
	// ComponentLabelKey label key used to define the datadog agent component
	ComponentLabelKey = "agent.datadoghq.com/component"
	// ClcRunnerLabelValue label value to define the Cluster Checks Runner
	ClcRunnerLabelValue = "cluster-checks-runner"
)

Variables

var (
	// AgentLabel can be used as a LabelSelector for the Agent
	AgentLabel = fmt.Sprintf("%s=%s", ComponentLabelKey, AgentLabelValue)
	// ClcRunnerLabel can be used as a LabelSelector for the Cluster Checks Runner
	ClcRunnerLabel = fmt.Sprintf("%s=%s", ComponentLabelKey, ClcRunnerLabelValue)
)

Functions

func AskForConfirmation

func AskForConfirmation(input string) bool

AskForConfirmation asks for the user's confirmation before taking an action

func AskForInput

func AskForInput(question string) (string, error)

AskForInput asks the user for a given information

func GetDurationAsString

func GetDurationAsString(obj metav1.Object) string

GetDurationAsString gets object's age

func HasImagePattern

func HasImagePattern(image string) bool

HasImagePattern returns true if the image string respects the format <string>/<string>:<string>

func IntToString

func IntToString(i int32) string

IntToString converts int32 to string

func IsAnnotated

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

IsAnnotated returns true if annotations contain a key with a given prefix

func IsV2Available

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

IsV2Available returns true if the v2alpha1.DatadogAgent resource kind is available

func NewClient

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

NewClient returns a new controller-runtime client instance

func NewClientset

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

NewClientset returns a new client-go instance

func OverrideComponentImage

func OverrideComponentImage(spec *v2alpha1.DatadogAgentSpec, cmpName v2alpha1.ComponentName, imageName, imageTag string) error

func SplitImageString

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

func StreamToBytes

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

StreamToBytes converts a stream to bytes

func ValidateAnnotationsContent

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

ValidateAnnotationsContent reports errors in AD annotations content the identifier string is expected to include the AD prefix

func ValidateAnnotationsMatching

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

ValidateAnnotationsMatching detects if AD annotations don't match a valid container identifier

func ValidateUpgrade

func ValidateUpgrade(image string, latest bool) error

ValidateUpgrade valides the input of the upgrade commands

Types

type Options

type Options struct {
	ConfigFlags *genericclioptions.ConfigFlags
	Client      client.Client
	Clientset   *kubernetes.Clientset

	UserNamespace string
	// contains filtered or unexported fields
}

Options encapsulates the common fields of command options

func (*Options) GetClientConfig

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

GetClientConfig returns the client config

func (*Options) Init

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

Init initialize the common config of command options

func (*Options) IsDatadogAgentV2Available

func (o *Options) IsDatadogAgentV2Available() bool

IsDatadogAgentV2Available returns true if the v2Alpha1.DatadogAgent resource is available

func (*Options) SetClient

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

SetClient configures the client

func (*Options) SetClientset

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

SetClientset configures the clientset

func (*Options) SetConfigFlags

func (o *Options) SetConfigFlags()

SetConfigFlags configures the config flags

func (*Options) SetNamespace

func (o *Options) SetNamespace(ns string)

SetNamespace configures the namespace

type StatusWrapper

type StatusWrapper interface {
	GetObjectMeta() metav1.Object
	GetAgentStatus() *commonv1.DaemonSetStatus
	GetClusterAgentStatus() *commonv1.DeploymentStatus
	GetClusterChecksRunnerStatus() *commonv1.DeploymentStatus
}

func NewV1StatusWrapper

func NewV1StatusWrapper(dda *v1alpha1.DatadogAgent) StatusWrapper

func NewV2StatusWrapper

func NewV2StatusWrapper(dda *v2alpha1.DatadogAgent) StatusWrapper