Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions apis/v1alpha1/groupversion_info.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ var (
GroupVersion = schema.GroupVersion{Group: "cloudwatch.aws.amazon.com", Version: "v1alpha1"}

// SchemeBuilder is used to add go types to the GroupVersionKind scheme.
//nolint:staticcheck // SA1019: types self-register via SchemeBuilder.Register() in init().
SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

// AddToScheme adds the types in this group-version to the given scheme.
Expand Down
4 changes: 2 additions & 2 deletions apis/v1alpha1/zz_generated.deepcopy.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions apis/v1alpha2/groupversion_info.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ var (
GroupVersion = schema.GroupVersion{Group: "cloudwatch.aws.amazon.com", Version: "v1alpha2"}

// SchemeBuilder is used to add go types to the GroupVersionKind scheme.
//nolint:staticcheck // SA1019: types self-register via SchemeBuilder.Register() in init().
SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

// AddToScheme adds the types in this group-version to the given scheme.
Expand Down
2 changes: 1 addition & 1 deletion apis/v1alpha2/zz_generated.deepcopy.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

9 changes: 8 additions & 1 deletion cmd/amazon-cloudwatch-agent-target-allocator/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ package main
import (
"context"
"fmt"
"log/slog"
"os"
"os/signal"
"syscall"
Expand Down Expand Up @@ -88,7 +89,13 @@ func main() {
srv := server.NewServer(log, allocator, cfg.ListenAddr, httpOptions...)

discoveryCtx, discoveryCancel := context.WithCancel(ctx)
discoveryManager = discovery.NewManager(discoveryCtx, nil, prometheus.NewRegistry(), nil)
registry := prometheus.NewRegistry()
sdMetrics, err := discovery.CreateAndRegisterSDMetrics(registry)
if err != nil {
setupLog.Error(err, "Unable to register service discovery metrics")
os.Exit(1)
}
discoveryManager = discovery.NewManager(discoveryCtx, slog.New(slog.DiscardHandler), registry, sdMetrics)

targetDiscoverer = target.NewDiscoverer(log, discoveryManager, allocatorPrehook, srv)
collectorWatcher, collectorWatcherErr := collector.NewClient(log, cfg.ClusterConfig)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -294,7 +294,10 @@ func TestDiscovery_ScrapeConfigHashing(t *testing.T) {

scu := &mockScrapeConfigUpdater{}
ctx := context.Background()
d := discovery.NewManager(ctx, slog.Default(), prometheus.NewRegistry(), nil)
reg := prometheus.NewRegistry()
sdMetrics, err := discovery.CreateAndRegisterSDMetrics(reg)
require.NoError(t, err)
d := discovery.NewManager(ctx, slog.Default(), reg, sdMetrics)
manager := NewDiscoverer(ctrl.Log.WithName("test"), d, nil, scu)

for _, tc := range tests {
Expand Down Expand Up @@ -330,7 +333,10 @@ func TestDiscovery_ScrapeConfigHashing(t *testing.T) {
func TestDiscovery_NoConfig(t *testing.T) {
scu := &mockScrapeConfigUpdater{mockCfg: map[string]*promconfig.ScrapeConfig{}}
ctx, cancelFunc := context.WithCancel(context.Background())
d := discovery.NewManager(ctx, slog.Default(), prometheus.NewRegistry(), nil)
reg := prometheus.NewRegistry()
sdMetrics, err := discovery.CreateAndRegisterSDMetrics(reg)
require.NoError(t, err)
d := discovery.NewManager(ctx, slog.Default(), reg, sdMetrics)
manager := NewDiscoverer(ctrl.Log.WithName("test"), d, nil, scu)
defer close(manager.close)
defer cancelFunc()
Expand Down Expand Up @@ -377,7 +383,10 @@ func BenchmarkApplyScrapeConfig(b *testing.B) {

scu := &mockScrapeConfigUpdater{}
ctx := context.Background()
d := discovery.NewManager(ctx, slog.Default(), prometheus.NewRegistry(), nil)
reg := prometheus.NewRegistry()
sdMetrics, err := discovery.CreateAndRegisterSDMetrics(reg)
require.NoError(b, err)
d := discovery.NewManager(ctx, slog.Default(), reg, sdMetrics)
manager := NewDiscoverer(ctrl.Log.WithName("test"), d, nil, scu)

b.ResetTimer()
Expand Down
552 changes: 446 additions & 106 deletions config/crd/bases/cloudwatch.aws.amazon.com_amazoncloudwatchagents.yaml

Large diffs are not rendered by default.

215 changes: 177 additions & 38 deletions config/crd/bases/cloudwatch.aws.amazon.com_dcgmexporters.yaml

Large diffs are not rendered by default.

433 changes: 407 additions & 26 deletions config/crd/bases/cloudwatch.aws.amazon.com_instrumentations.yaml

Large diffs are not rendered by default.

215 changes: 177 additions & 38 deletions config/crd/bases/cloudwatch.aws.amazon.com_neuronmonitors.yaml

Large diffs are not rendered by default.

68 changes: 3 additions & 65 deletions config/rbac/role.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,9 @@ rules:
- cloudwatch.aws.amazon.com
resources:
- amazoncloudwatchagents
- dcgmexporters
- instrumentations
- neuronmonitors
verbs:
- get
- list
Expand All @@ -82,75 +85,10 @@ rules:
- cloudwatch.aws.amazon.com
resources:
- amazoncloudwatchagents/finalizers
verbs:
- get
- patch
- update
- apiGroups:
- cloudwatch.aws.amazon.com
resources:
- amazoncloudwatchagents/status
verbs:
- get
- patch
- update
- apiGroups:
- cloudwatch.aws.amazon.com
resources:
- dcgmexporters
verbs:
- get
- list
- patch
- update
- watch
- apiGroups:
- cloudwatch.aws.amazon.com
resources:
- dcgmexporters/finalizers
verbs:
- get
- patch
- update
- apiGroups:
- cloudwatch.aws.amazon.com
resources:
- dcgmexporters/status
verbs:
- get
- patch
- update
- apiGroups:
- cloudwatch.aws.amazon.com
resources:
- instrumentations
verbs:
- get
- list
- patch
- update
- watch
- apiGroups:
- cloudwatch.aws.amazon.com
resources:
- neuronmonitors
verbs:
- get
- list
- patch
- update
- watch
- apiGroups:
- cloudwatch.aws.amazon.com
resources:
- neuronmonitors/finalizers
verbs:
- get
- patch
- update
- apiGroups:
- cloudwatch.aws.amazon.com
resources:
- neuronmonitors/status
verbs:
- get
Expand Down
Loading
Loading