add StartTIme in one more place

Author: VihasMakwana

internal/pkg/agent/application/coordinator/coordinator_state.go

@@ -157,14 +157,14 @@ func (c *Coordinator) applyComponentState(state runtime.ComponentComponentState)
 	for i, other := range c.state.Components {
 		// We want to update the component state if the incoming update is from the same instance or a newer instance of the component.
 		// We determine this by comparing start times, since a newer instance would have a later start time.
-		if other.Component.ID == state.Component.ID && (other.Component.StartTime <= state.Component.StartTime) {
+		if other.Component.ID == state.Component.ID && (other.Component.StartTime.UnixNano() <= state.Component.StartTime.UnixNano()) {
 			if other.State.Pid != state.State.Pid {
 				c.componentPidRequiresUpdate.Store(true)
 			}
 			c.state.Components[i] = state
 			found = true
 			break
-		} else if other.Component.ID == state.Component.ID && other.Component.StartTime > state.Component.StartTime {
+		} else if other.Component.ID == state.Component.ID && other.Component.StartTime.UnixNano() > state.Component.StartTime.UnixNano() {
 			// This is a case where a component has transitioned to a new state but we receive a late update from the older component.
 			ignore = true
 			break

internal/pkg/agent/application/coordinator/coordinator_state_test.go

@@ -24,12 +24,12 @@ func TestApplyComponentState_LateStoppedFromDifferentRuntimeIgnored(t *testing.T
 	comp1 := pkgcomponent.Component{
 		ID:             "filestream-default",
 		RuntimeManager: pkgcomponent.OtelRuntimeManager,
-		StartTime:      time.Now().UnixNano(),
+		StartTime:      time.Now(),
 	}
 	comp2 := pkgcomponent.Component{
 		ID:             "system/metrics-default",
 		RuntimeManager: pkgcomponent.OtelRuntimeManager,
-		StartTime:      time.Now().UnixNano(),
+		StartTime:      time.Now(),
 	}
 	coord := &Coordinator{
 		state: State{
@@ -69,12 +69,12 @@ func TestApplyComponentState_LateStoppedFromDifferentRuntimeIgnored(t *testing.T
 	comp1New := pkgcomponent.Component{
 		ID:             "filestream-default",
 		RuntimeManager: pkgcomponent.ProcessRuntimeManager,
-		StartTime:      time.Now().UnixNano(),
+		StartTime:      time.Now(),
 	}
 	comp2New := pkgcomponent.Component{
 		ID:             "system/metrics-default",
 		RuntimeManager: pkgcomponent.ProcessRuntimeManager,
-		StartTime:      time.Now().UnixNano(),
+		StartTime:      time.Now(),
 	}
 
 	coord.applyComponentState(runtime.ComponentComponentState{
@@ -203,7 +203,7 @@ func TestApplyComponentState_StartingFromNewRuntimeReplacesExisting(t *testing.T
 		Component: pkgcomponent.Component{
 			ID:             "filestream-default",
 			RuntimeManager: pkgcomponent.OtelRuntimeManager,
-			StartTime:      time.Now().Unix(),
+			StartTime:      time.Now(),
 		},
 		State: runtime.ComponentState{
 			State:   client.UnitStateHealthy,
@@ -217,7 +217,7 @@ func TestApplyComponentState_StartingFromNewRuntimeReplacesExisting(t *testing.T
 		Component: pkgcomponent.Component{
 			ID:             "filestream-default",
 			RuntimeManager: pkgcomponent.ProcessRuntimeManager,
-			StartTime:      time.Now().Unix(),
+			StartTime:      time.Now(),
 		},
 		State: runtime.ComponentState{
 			State:   client.UnitStateStarting,

pkg/component/component.go

@@ -300,7 +300,8 @@ type Component struct {
 
 	OutputStatusReporting *StatusReporting `yaml:"-"`
 
-	StartTime int64 `yaml:"-"`
+	// StartTime is the time when the component was first created. The value is in nanoseconds since the Unix epoch.
+	StartTime time.Time `yaml:"-"`
 }
 
 type StatusReporting struct {
@@ -640,7 +641,7 @@ func (r *RuntimeSpecs) componentsForInputType(
 					Features:              featureFlags.AsProto(),
 					Component:             componentConfig.AsProto(),
 					OutputStatusReporting: extractStatusReporting(output.Config),
-					StartTime:             time.Now().Unix(),
+					StartTime:             time.Now(),
 				})
 			}
 		}
@@ -687,6 +688,7 @@ func (r *RuntimeSpecs) componentsForInputType(
 					Features:              featureFlags.AsProto(),
 					Component:             componentConfig.AsProto(),
 					OutputStatusReporting: extractStatusReporting(output.Config),
+					StartTime:             time.Now(),
 				})
 			}
 		}