include type definitions

Signed-off-by: Jeeva Kandasamy <jkandasa@gmail.com>

Author: jkandasa

pkg/types/labels.go

@@ -16,13 +16,14 @@ const (
 	LabelWriteOnly = "write_only"
 
 	// Node specific labels
-	LabelNodeSleepNode          = "sleep_node"           // messages always will be kept in sleep queue
-	LabelNodeSleepQueueDisabled = "sleep_queue_disabled" // failed messages and messages will not be kept in sleep queue
-	LabelNodeVersion            = "version"              // version of the application
-	LabelNodeLibraryVersion     = "library_version"      // version of the underlying library
-	LabelNodeAssignedFirmware   = "assigned_firmware"    // assigned firmware of the node
-	LabelNodeOTABlockOrder      = "ota_block_order"      // used on OTA
-	LabelNodeInactiveDuration   = "inactive_duration"    // mark the node as DOWN, if there is no message on the specified period
+	LabelNodeSleepNode            = "sleep_node"             // messages always will be kept in sleep queue
+	LabelNodeSleepQueueDisabled   = "sleep_queue_disabled"   // failed messages and messages will not be kept in sleep queue
+	LabelNodeSleepMessageValidity = "sleep_message_validity" // node sleeping message validity in string, eg: 1s, 5h
+	LabelNodeVersion              = "version"                // version of the application
+	LabelNodeLibraryVersion       = "library_version"        // version of the underlying library
+	LabelNodeAssignedFirmware     = "assigned_firmware"      // assigned firmware of the node
+	LabelNodeOTABlockOrder        = "ota_block_order"        // used on OTA
+	LabelNodeInactiveDuration     = "inactive_duration"      // mark the node as DOWN, if there is no message on the specified period
 
 	// Field specific labels
 	LabelMetricType = "metric_type"

pkg/types/message/types.go

@@ -61,6 +61,7 @@ type Message struct {
 	IsAckEnabled bool                 `json:"isAckEnabled" yaml:"isAckEnabled"` // Is Acknowledge enabled?
 	IsSleepNode  bool                 `json:"isSleepNode" yaml:"isSleepNode"`   // Is this message for active node or sleep node?
 	Timestamp    time.Time            `json:"timestamp" yaml:"timestamp"`
+	Validity     string               `json:"validity,omitempty" yaml:"validity,omitempty"` // if the message entered in to sleeping queue, validity duration
 }
 
 // NewMessage returns empty message