lint

Author: ogtownsend

pkg/monitoring/balance/generic_balance.go

@@ -115,7 +115,7 @@ func (m *genericBalanceMonitor) HealthReport() map[string]error {
 	return map[string]error{m.Name(): m.Healthy()}
 }
 
-// monitor fn continously updates balances, until stop signal is received.
+// monitor fn continuously updates balances, until stop signal is received.
 func (m *genericBalanceMonitor) start() {
 	defer close(m.done)
 	ctx, cancel := m.stop.NewCtx()

pkg/monitoring/balance/metadata.go

@@ -16,23 +16,23 @@ const (
 // TODO: Refactor as a proto referenced from the other proto files (telemetry messages)
 type ExecutionMetadata struct {
 	// Execution Context - Source
-	SourceId string
+	SourceID string
 	// Execution Context - Chain
 	ChainFamilyName string
-	ChainId         string
+	ChainID         string
 	NetworkName     string
 	NetworkNameFull string
 	// Execution Context - Workflow (capabilities.RequestMetadata)
-	WorkflowId               string
+	WorkflowID               string
 	WorkflowOwner            string
-	WorkflowExecutionId      string
+	WorkflowExecutionID      string
 	WorkflowName             string
-	WorkflowDonId            uint32
+	WorkflowDonID            uint32
 	WorkflowDonConfigVersion uint32
-	ReferenceId              string
+	ReferenceID              string
 	// Execution Context - Capability
 	CapabilityType           string
-	CapabilityId             string
+	CapabilityID             string
 	CapabilityTimestampStart uint32
 	CapabilityTimestampEmit  uint32
 }
@@ -44,26 +44,26 @@ func (m ExecutionMetadata) Attributes() []attribute.KeyValue {
 
 	return []attribute.KeyValue{
 		// Execution Context - Source
-		attribute.String("source_id", ValOrUnknown(m.SourceId)),
+		attribute.String("source_id", ValOrUnknown(m.SourceID)),
 		// Execution Context - Chain
 		attribute.String("chain_family_name", ValOrUnknown(m.ChainFamilyName)),
-		attribute.String("chain_id", ValOrUnknown(m.ChainId)),
+		attribute.String("chain_id", ValOrUnknown(m.ChainID)),
 		attribute.String("network_name", ValOrUnknown(m.NetworkName)),
 		attribute.String("network_name_full", ValOrUnknown(m.NetworkNameFull)),
 		// Execution Context - Workflow (capabilities.RequestMetadata)
-		attribute.String("workflow_id", ValOrUnknown(m.WorkflowId)),
+		attribute.String("workflow_id", ValOrUnknown(m.WorkflowID)),
 		attribute.String("workflow_owner", ValOrUnknown(m.WorkflowOwner)),
-		// Notice: We lower the cardinality on the WorkflowExecutionId so it can be used by metrics
+		// Notice: We lower the cardinality on the WorkflowExecutionID so it can be used by metrics
 		// This label has good chances to be unique per workflow, in a reasonable bounded time window
 		// TODO: enable this when sufficiently tested (PromQL queries like alerts might need to change if this is used)
-		// attribute.String("workflow_execution_id_short", ValShortOrUnknown(m.WorkflowExecutionId, WorkflowExecutionIDShortLen)),
+		// attribute.String("workflow_execution_id_short", ValShortOrUnknown(m.WorkflowExecutionID, WorkflowExecutionIDShortLen)),
 		attribute.String("workflow_name", ValOrUnknown(workflowName)),
-		attribute.Int64("workflow_don_id", int64(m.WorkflowDonId)),
+		attribute.Int64("workflow_don_id", int64(m.WorkflowDonID)),
 		attribute.Int64("workflow_don_config_version", int64(m.WorkflowDonConfigVersion)),
-		attribute.String("reference_id", ValOrUnknown(m.ReferenceId)),
+		attribute.String("reference_id", ValOrUnknown(m.ReferenceID)),
 		// Execution Context - Capability
 		attribute.String("capability_type", ValOrUnknown(m.CapabilityType)),
-		attribute.String("capability_id", ValOrUnknown(m.CapabilityId)),
+		attribute.String("capability_id", ValOrUnknown(m.CapabilityID)),
 		// Notice: we don't include the timestamps here (high cardinality)
 	}
 }