🔥 tcp timestamp

openstatusHQ · Oct 9, 2024 · 516e646 · 516e646
1 parent 988916d
commit 516e646
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/apps/checker/handlers/tcp.go b/apps/checker/handlers/tcp.go
@@ -28,6 +28,7 @@ type TCPData struct {
 	Timing       string `json:"timing"`
 	ErrorMessage string `json:"errorMessage"`
 	Region       string `json:"region"`
+	Trigger      string `json:"trigger"`
 
 	RequestId     int64 `json:"requestId,omitempty"`
 	WorkspaceID   int64 `json:"workspaceId"`
@@ -111,6 +112,7 @@ func (h Handler) TCPHandler(c *gin.Context) {
 			Timing:        string(timingAsString),
 			Latency:       latency,
 			CronTimestamp: req.CronTimestamp,
+			Trigger:       "cron",
 		}
 
 		if req.Status == "active" && req.DegradedAfter > 0 && latency > req.DegradedAfter {
@@ -167,6 +169,7 @@ func (h Handler) TCPHandler(c *gin.Context) {
 			Region:        h.Region,
 			MonitorID:     monitorId,
 			Error:         1,
+			Trigger:       "cron",
 		}, dataSourceName); err != nil {
 			log.Ctx(ctx).Error().Err(err).Msg("failed to send event to tinybird")
 		}
@@ -277,6 +280,7 @@ func (h Handler) TCPHandlerRegion(c *gin.Context) {
 			Timing:        string(timingAsString),
 			Latency:       latency,
 			RequestId:     req.RequestId,
+			Trigger:       "API",
 		}
 
 		if req.RequestId != 0 {
@@ -297,6 +301,7 @@ func (h Handler) TCPHandlerRegion(c *gin.Context) {
 			MonitorID:     monitorId,
 			Error:         1,
 			RequestId:     req.RequestId,
+			Trigger:       "api",
 		}, dataSourceName); err != nil {
 			log.Ctx(ctx).Error().Err(err).Msg("failed to send event to tinybird")
 		}

diff --git a/packages/tinybird/datasources/tcp_response.datasource b/packages/tinybird/datasources/tcp_response.datasource
@@ -10,6 +10,8 @@ SCHEMA >
     `latency` Int64 `json:$.latency`,
     `errorMessage` Nullable(String) `json:$.errorMessage`,
     `error` Int16 `json:$.error`
+    `trigger` Nullable(String) `json:$.trigger`,
+
 
 ENGINE "MergeTree"
 ENGINE_PARTITION_KEY "toYYYYMM(fromUnixTimestamp64Milli(timestamp))"