Skip to content

Commit

Permalink
Add constants for common settings
Browse files Browse the repository at this point in the history
  • Loading branch information
s-fairchild committed Jun 14, 2024
1 parent 2341b2a commit c50fa91
Showing 1 changed file with 20 additions and 17 deletions.
37 changes: 20 additions & 17 deletions pkg/cluster/install_metrics.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,12 +14,13 @@ import (
const (
metricPackage = "backend.openshiftcluster"
metricInstall = metricPackage + ".installphase"
enabled = "Enabled"

Check failure on line 17 in pkg/cluster/install_metrics.go

View workflow job for this annotation

GitHub Actions / golangci-lint

File is not `gofmt`-ed with `-s` (gofmt)
disabled = "Disabled"
custom = "Custom"
defaultSet = "Default"
)

func (m *manager) emitFeatures(ctx context.Context) error {
// TODO capture if client-id and client-secret are set before they are created by RP
// TODO capture if the vnet is non default sooner
// TODO break these up into separate functions
dimensions := map[string]string{
"resourceid": m.doc.ResourceID,
"subscriptionid": m.env.SubscriptionID(),
Expand All @@ -35,9 +36,9 @@ func (m *manager) emitFeatures(ctx context.Context) error {
}

if m.doc.OpenShiftCluster.Tags != nil {
dimensions["tags"] = "Enabled"
dimensions["tags"] = enabled
} else {
dimensions["tags"] = "Disabled"
dimensions["tags"] = disabled
}

err := m.gatherAuthMetrics(dimensions)
Expand All @@ -62,7 +63,9 @@ func (m *manager) emitFeatures(ctx context.Context) error {

func (m *manager) gatherNodeMetrics(dimensions map[string]string) error {
if m.doc.OpenShiftCluster.Properties.MasterProfile.DiskEncryptionSetID != "" {
dimensions["masterprofile.diskencryptionsetid"] = "Enabled"
dimensions["masterprofile.diskencryptionsetid"] = enabled
} else {
dimensions["masterprofile.diskencryptionsetid"] = disabled
}

if m.doc.OpenShiftCluster.Properties.MasterProfile.EncryptionAtHost == api.EncryptionAtHostEnabled {
Expand Down Expand Up @@ -104,17 +107,17 @@ func (m *manager) gatherNodeMetrics(dimensions map[string]string) error {

func (m *manager) gatherAuthMetrics(dimensions map[string]string) error {
if m.doc.OpenShiftCluster.Properties.PlatformWorkloadIdentityProfile != nil {
dimensions["workloadidentity"] = "Enabled"
dimensions["workloadidentity"] = enabled
} else if m.doc.OpenShiftCluster.Properties.ServicePrincipalProfile != nil {
dimensions["serviceprincipal"] = "Enabled"
dimensions["serviceprincipal"] = disabled
} else {
return fmt.Errorf("no authentication type found")
}

if m.doc.OpenShiftCluster.Properties.ClusterProfile.PullSecret != "" {
dimensions["pullsecret"] = "Enabled"
dimensions["pullsecret"] = enabled
} else {
dimensions["pullsecret"] = "Disabled"
dimensions["pullsecret"] = disabled
}

return nil
Expand All @@ -140,19 +143,19 @@ func (m *manager) gatherNetworkMetrics(dimensions map[string]string) error {
}

if m.doc.OpenShiftCluster.Properties.NetworkProfile.PodCIDR != "10.128.0.0/14" {
dimensions["podcidr"] = "Custom"
dimensions["podcidr"] = custom
} else {
dimensions["podcidr"] = "Default"
dimensions["podcidr"] = defaultSet
}

if m.doc.OpenShiftCluster.Properties.NetworkProfile.ServiceCIDR != "172.30.0.0/16" {
dimensions["servicecidr"] = "Custom"
dimensions["servicecidr"] = custom
} else {
dimensions["servicecidr"] = "Default"
dimensions["servicecidr"] = defaultSet
}

if m.doc.OpenShiftCluster.Properties.ClusterProfile.Domain != "" {
dimensions["domain"] = "Enabled"
dimensions["domain"] = enabled
}

if m.doc.OpenShiftCluster.Properties.NetworkProfile.LoadBalancerProfile.ManagedOutboundIPs != nil {
Expand All @@ -168,9 +171,9 @@ func (m *manager) gatherNetworkMetrics(dimensions map[string]string) error {
}

if m.doc.OpenShiftCluster.Properties.FeatureProfile.GatewayEnabled {
dimensions["gatewayenabled"] = "Enabled"
dimensions["gatewayenabled"] = enabled
} else {
dimensions["gatewayenabled"] = "Disabled"
dimensions["gatewayenabled"] = disabled
}

return nil
Expand Down

0 comments on commit c50fa91

Please sign in to comment.