store

type DeviceManager struct {
	GroupID       string             // The group this device belongs to
	NodeID        string             // The node this device belongs to
	DeviceID      string             // The device ID
	Online        bool               // Whether the device is online
	LastMessageAt time.Time          // The last time a message was received regarding this device
	Metrics       map[uint64]*Metric // The metrics of this device (Alias -> Metric)
	// contains filtered or unexported fields
}

type FetchedDevice struct {
	ID            string          `json:"id"`            // The device ID
	NodeID        string          `json:"nodeId"`        // The node ID
	GroupID       string          `json:"groupId"`       // The group ID
	Online        bool            `json:"online"`        // Whether the device is online
	LastMessageAt time.Time       `json:"lastMessageAt"` // The last time a message was received regarding this device
	Metrics       []FetchedMetric `json:"metrics"`       // The metrics of this device
}

type FetchedGroup struct {
	ID            string        `json:"id"`            // The group ID
	LastMessageAt time.Time     `json:"lastMessageAt"` // The last time a message was received regarding this group
	Nodes         []FetchedNode `json:"nodes"`         // The state of the nodes in the group
}

type FetchedMessage struct {
	GroupID      string    `json:"groupId"`      // The group ID
	NodeID       string    `json:"nodeId"`       // The node ID
	DeviceID     string    `json:"deviceId"`     // The device ID
	Type         Type      `json:"type"`         // The message type
	MetricAmount int       `json:"metricAmount"` // The amount of metrics in the message
	ReceivedAt   time.Time `json:"receivedAt"`   // The time the message was received
}

type FetchedMetric struct {
	Name      string    `json:"name"`
	Alias     uint64    `json:"alias"`
	Stale     bool      `json:"stale"`
	DataType  string    `json:"dataType"`
	Timestamp time.Time `json:"timestamp"`
	IsNull    bool      `json:"isNull"`
	Value     any       `json:"value"`
}

type FetchedNode struct {
	ID            string          `json:"id"`            // The node ID
	GroupID       string          `json:"groupId"`       // The group ID
	Online        bool            `json:"online"`        // Whether the node is online
	LastMessageAt time.Time       `json:"lastMessageAt"` // The last time a message was received regarding this node
	Devices       []FetchedDevice `json:"devices"`       // The state of the devices
	Metrics       []FetchedMetric `json:"metrics"`       // The metrics of this node
}

type GroupManager struct {
	GroupID       string                  // The group ID
	LastMessageAt time.Time               // The last time a message was received regarding this group
	Nodes         map[string]*NodeManager // The node managers for each node in the group
	// contains filtered or unexported fields
}

type Message struct {
	ReceivedAt time.Time
	GroupID    string
	NodeID     string
	Type       Type
	DeviceID   string
	Payload    *sparkplugb.Payload
}

type Metric struct {
	Name          string
	Alias         uint64
	DataType      sparkplugb.DataType
	LastTimeStamp *time.Time
	IsNull        bool
	Value         any
}

type NodeManager struct {
	GroupID       string                    // The group this node belongs to
	NodeID        string                    // The node ID
	Online        bool                      // Whether the node is online
	LastMessageAt time.Time                 // The last time a message was received regarding this node
	Devices       map[string]*DeviceManager // The device managers for each device of this node (DeviceID -> DeviceManager)
	Metrics       map[uint64]*Metric        // The metrics of this node (Alias -> Metric)
	// contains filtered or unexported fields
}

type StoreManager struct {
	Groups map[string]*GroupManager
	// contains filtered or unexported fields
}

type Type string