startup

Documentation

Index

• func Start()
• type AutoOperatorConfigurationResourceHandler
  • func NewAutoOperatorConfigurationResourceHandler(client client.Client, readyCheckExecuter *ReadyCheckExecuter) *AutoOperatorConfigurationResourceHandler
  • func (r *AutoOperatorConfigurationResourceHandler) CreateOrUpdateOperatorConfigurationResource(ctx context.Context, operatorConfigurationValues *OperatorConfigurationValues, ...) (*dash0v1alpha1.Dash0OperatorConfiguration, error)
  • func (r *AutoOperatorConfigurationResourceHandler) NotifiyOperatorManagerJustBecameLeader(_ context.Context, _ *logr.Logger)
• type InstrumentAtStartupRunnable
  • func NewInstrumentAtStartupRunnable(manager manager.Manager, instrumenter *instrumentation.Instrumenter) *InstrumentAtStartupRunnable
  • func (r *InstrumentAtStartupRunnable) NeedLeaderElection() bool
  • func (r *InstrumentAtStartupRunnable) Start(ctx context.Context) error
• type OperatorConfigurationValues
• type ReadyCheckExecuter
  • func NewReadyCheckExecuter(client client.Client, operatorNamespace string, webhookServiceName string) *ReadyCheckExecuter
• type SecretRef

Functions

func Start

func Start()

Types

type AutoOperatorConfigurationResourceHandler

type AutoOperatorConfigurationResourceHandler struct {
	client.Client
	// contains filtered or unexported fields
}

func NewAutoOperatorConfigurationResourceHandler

func NewAutoOperatorConfigurationResourceHandler(
	client client.Client,
	readyCheckExecuter *ReadyCheckExecuter,
) *AutoOperatorConfigurationResourceHandler

func (*AutoOperatorConfigurationResourceHandler) CreateOrUpdateOperatorConfigurationResource

func (r *AutoOperatorConfigurationResourceHandler) CreateOrUpdateOperatorConfigurationResource(
	ctx context.Context,
	operatorConfigurationValues *OperatorConfigurationValues,
	logger *logr.Logger,
) (*dash0v1alpha1.Dash0OperatorConfiguration, error)

CreateOrUpdateOperatorConfigurationResource waits until this replica becomes the leader, then it creates or updates the Dash0 operator configuration resource. The function will create/update the resource asynchronously, that is, when the function returns the resource might not have been created/updated yet. The function will optimistically return the resource that is going to be created/updated, without guarantees that the resource will be created/updated successfully.

func (*AutoOperatorConfigurationResourceHandler) NotifiyOperatorManagerJustBecameLeader

func (r *AutoOperatorConfigurationResourceHandler) NotifiyOperatorManagerJustBecameLeader(_ context.Context, _ *logr.Logger)

type InstrumentAtStartupRunnable

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

InstrumentAtStartupRunnable executes an unconditional apply/update of instrumentation for all workloads in Dash0-enabled namespaces, according to the respective settings of the Dash0 monitoring resource in the namespace. See godoc comment on Instrumenter#InstrumentAtStartup.

func NewInstrumentAtStartupRunnable

func NewInstrumentAtStartupRunnable(
	manager manager.Manager,
	instrumenter *instrumentation.Instrumenter,
) *InstrumentAtStartupRunnable

func (*InstrumentAtStartupRunnable) NeedLeaderElection

func (r *InstrumentAtStartupRunnable) NeedLeaderElection() bool

NeedLeaderElection implements the LeaderElectionRunnable interface, which indicates that the InstrumentAtStartupRunnable requires leader election.

func (*InstrumentAtStartupRunnable) Start

func (r *InstrumentAtStartupRunnable) Start(ctx context.Context) error

Start runs the instrumentation procedure.

type OperatorConfigurationValues

type OperatorConfigurationValues struct {
	Endpoint string
	Token    string
	SecretRef
	ApiEndpoint                                      string
	Dataset                                          string
	SelfMonitoringEnabled                            bool
	KubernetesInfrastructureMetricsCollectionEnabled bool
	CollectPodLabelsAndAnnotationsEnabled            bool
	ClusterName                                      string
}

type ReadyCheckExecuter

type ReadyCheckExecuter struct {
	client.Client

	OperatorNamespace  string
	WebhookServiceName string
	// contains filtered or unexported fields
}

func NewReadyCheckExecuter

func NewReadyCheckExecuter(
	client client.Client,
	operatorNamespace string,
	webhookServiceName string,
) *ReadyCheckExecuter

type SecretRef

type SecretRef struct {
	Name string
	Key  string
}