Documentation
¶
Index ¶
- Variables
- func GetNamespacedName(obj client.Object) types.NamespacedName
- type ConditionCommon
- type Event
- type EventType
- type ForwardersManager
- func (f *ForwardersManager) MetricsForwarderStatusForObj(obj client.Object) *ConditionCommon
- func (f *ForwardersManager) ProcessError(obj client.Object, reconcileErr error)
- func (f *ForwardersManager) ProcessEvent(obj client.Object, event Event)
- func (f *ForwardersManager) Register(obj client.Object)
- func (f *ForwardersManager) SetEnabledFeatures(dda client.Object, features []string)
- func (f *ForwardersManager) Start(stop <-chan struct{}) error
- func (f *ForwardersManager) Unregister(obj client.Object)
- type MetricsForwardersManager
Constants ¶
This section is empty.
Variables ¶
var ( // ErrEmptyAPIKey empty APIKey error ErrEmptyAPIKey = errors.New("empty api key") )
Functions ¶
func GetNamespacedName ¶ added in v1.15.0
func GetNamespacedName(obj client.Object) types.NamespacedName
GetNamespacedName builds a NamespacedName for a given monitored object
Types ¶
type ConditionCommon ¶ added in v1.0.0
type ConditionCommon struct {
ConditionType string
Status bool
LastUpdateTime metav1.Time
Reason string
Message string
}
ConditionCommon defines a common struct for the Status Condition
type EventType ¶
type EventType string
EventType enumerates the possible event types to be sent
const ( // CreationEvent should be used for resource creation events CreationEvent EventType = "Create" // DetectionEvent should be used for resource detection events DetectionEvent EventType = "Detect" // UpdateEvent should be used for resource update events UpdateEvent EventType = "Update" // DeletionEvent should be used for resource deletion events DeletionEvent EventType = "Delete" )
type ForwardersManager ¶
ForwardersManager is a collection of metricsForwarder per DatadogAgent ForwardersManager implements the controller-runtime Runnable interface
func NewForwardersManager ¶
func NewForwardersManager(k8sClient client.Client, platformInfo *kubernetes.PlatformInfo, datadogAgentInternalEnabled bool) *ForwardersManager
NewForwardersManager builds a new ForwardersManager object ForwardersManager implements the controller-runtime Runnable interface
func (*ForwardersManager) MetricsForwarderStatusForObj ¶
func (f *ForwardersManager) MetricsForwarderStatusForObj(obj client.Object) *ConditionCommon
MetricsForwarderStatusForObj returns the status of the metrics forwarder for a given object
func (*ForwardersManager) ProcessError ¶
func (f *ForwardersManager) ProcessError(obj client.Object, reconcileErr error)
ProcessError dispatches reconcile errors to their corresponding metric forwarders metric forwarders generates reconcile loop metrics based on the errors
func (*ForwardersManager) ProcessEvent ¶
func (f *ForwardersManager) ProcessEvent(obj client.Object, event Event)
ProcessEvent dispatches recorded events to their corresponding metric forwarders
func (*ForwardersManager) Register ¶
func (f *ForwardersManager) Register(obj client.Object)
Register starts a new metricsForwarder if a new MonitoredObject is detected
func (*ForwardersManager) SetEnabledFeatures ¶ added in v1.1.0
func (f *ForwardersManager) SetEnabledFeatures(dda client.Object, features []string)
SetEnabledFeatures sets the enabled features for a given object
func (*ForwardersManager) Start ¶
func (f *ForwardersManager) Start(stop <-chan struct{}) error
Start must be handled by the controller-runtime manager
func (*ForwardersManager) Unregister ¶
func (f *ForwardersManager) Unregister(obj client.Object)
Unregister stops a metricsForwarder when its corresponding MonitoredObject is deleted
type MetricsForwardersManager ¶ added in v1.16.0
type MetricsForwardersManager interface {
Register(client.Object)
Unregister(client.Object)
ProcessError(client.Object, error)
ProcessEvent(client.Object, Event)
MetricsForwarderStatusForObj(obj client.Object) *ConditionCommon
SetEnabledFeatures(obj client.Object, features []string)
}
MetricsForwardersManager defines interface for metrics forwarding
Source Files