nodes

package

Go to main page

Versions in this module

v0

v0.4.9

Dec 24, 2025

v0.4.8

Nov 5, 2025

Changes in this version

type NodeManager

+ func (n *NodeManager) CountAll() (int64, error)

+ func (n *NodeManager) CountAllByEnv(envID uint) (int64, error)

+ func (n *NodeManager) CountByEnvTarget(env string, target string, hours int64) (int64, error)

+ func (n *NodeManager) CountSearchByEnv(env, term, target string, hours int64) (int64, error)

+ func (n *NodeManager) GetByEnvPage(env, target string, hours int64, offset, limit int, orderBy string, desc bool) ([]OsqueryNode, error)

+ func (n *NodeManager) SearchByEnv(env, term, target string, hours int64) ([]OsqueryNode, error)

+ func (n *NodeManager) SearchByEnvPage(env, term, target string, hours int64, offset, limit int, orderBy string, ...) ([]OsqueryNode, error)

+ func (n *NodeManager) SearchByField(fieldType, term, target string, hours int64, limit int) ([]OsqueryNode, error)

v0.4.7

Sep 30, 2025

Changes in this version

type NodeManager

+ func (n *NodeManager) GetByIdentifierEnv(identifier string, envid uint) (OsqueryNode, error)

+ func (n *NodeManager) GetEnvIDPlatforms(envID uint) ([]string, error)

v0.4.6

Sep 2, 2025

v0.4.5

Aug 9, 2025

Changes in this version

+ const EnvironmentSelector

+ const PlatformSelector

+ func ActiveTimeCutoff(hours int64) time.Time

+ func ApplyNodeTarget(query *gorm.DB, target string, hours int64) *gorm.DB

+ type NodeCache struct

+ func NewNodeCache(nodes *NodeManager) *NodeCache

+ func (nc *NodeCache) Close()

+ func (nc *NodeCache) GetByKey(ctx context.Context, nodeKey string) (OsqueryNode, error)

+ func (nc *NodeCache) InvalidateAll(ctx context.Context)

+ func (nc *NodeCache) InvalidateNode(ctx context.Context, nodeKey string)

+ func (nc *NodeCache) UpdateNodeInCache(ctx context.Context, node OsqueryNode)

type StatsData

+ func GetStats(db *gorm.DB, column, value string, hours int64) (StatsData, error)

v0.4.4

Mar 26, 2025

Changes in this version

+ func CacheFullKeyByNodeKey(n OsqueryNode) string

+ func CacheFullKeyByUUID(n OsqueryNode) string

+ func CacheFullKeyRaw(identifier string, envID uint) string

+ func CachePartialKeyByNodeKey(n OsqueryNode) string

+ func CachePartialKeyByUUID(n OsqueryNode) string

+ func CachePartialKeyRaw(identifier string, envID uint) string

type ArchiveOsqueryNode

+ LastSeen time.Time

type NodeManager

+ Cache *redis.Client

+ func (n *NodeManager) GetFullFromCache(uuid string, envID uint, ctx context.Context) (OsqueryNode, error)

+ func (n *NodeManager) GetPartialFromCache(nodeKey string, envID uint, ctx context.Context) (OsqueryNode, error)

+ func (n *NodeManager) RefreshLastSeenBatch(nodeID []uint) error

+ func (n *NodeManager) SetFullCached(node OsqueryNode, ctx context.Context) error

+ func (n *NodeManager) SetPartialCached(node OsqueryNode, ctx context.Context) error

+ func (n *NodeManager) UpdateIP(nodeID uint, ip string) error

type OsqueryNode

+ LastSeen time.Time

v0.4.3

Feb 22, 2025

Changes in this version

+ const ActiveNodes

+ const AllNodes

+ const InactiveNodes

+ func IsActive(n OsqueryNode, inactive int64) bool

+ type ArchiveOsqueryNode struct

+ BytesReceived int

+ CPU string

+ ConfigHash string

+ DaemonHash string

+ Environment string

+ EnvironmentID uint

+ ExtraData string

+ HardwareSerial string

+ Hostname string

+ IPAddress string

+ LastConfig time.Time

+ LastQueryRead time.Time

+ LastQueryWrite time.Time

+ LastResult time.Time

+ LastStatus time.Time

+ Localname string

+ Memory string

+ NodeKey string

+ OsqueryUser string

+ OsqueryVersion string

+ Platform string

+ PlatformVersion string

+ RawEnrollment string

+ Trigger string

+ UUID string

+ UserID uint

+ Username string

+ type NodeHistoryHostname struct

+ Count int

+ Hostname string

+ UUID string

+ type NodeHistoryIPAddress struct

+ Count int

+ IPAddress string

+ UUID string

+ type NodeHistoryLocalname struct

+ Count int

+ Localname string

+ UUID string

+ type NodeHistoryUsername struct

+ Count int

+ UUID string

+ Username string

+ type NodeManager struct

+ DB *gorm.DB

+ func CreateNodes(backend *gorm.DB) *NodeManager

+ func (n *NodeManager) Archive(uuid, trigger string) error

+ func (n *NodeManager) ArchiveDeleteByUUID(uuid string) error

+ func (n *NodeManager) CarveRefresh(node OsqueryNode, lastIp string, incBytes int) error

+ func (n *NodeManager) CarveRefreshByUUID(uuid, lastIp string, incBytes int) error

+ func (n *NodeManager) CheckByHost(host string) bool

+ func (n *NodeManager) CheckByKey(nodeKey string) bool

+ func (n *NodeManager) CheckByUUID(uuid string) bool

+ func (n *NodeManager) CheckByUUIDEnv(uuid, environment string) bool

+ func (n *NodeManager) CheckByUUIDEnvID(uuid string, envID int) bool

+ func (n *NodeManager) ConfigRefresh(node OsqueryNode, lastIp string, incBytes int) error

+ func (n *NodeManager) Create(node *OsqueryNode) error

+ func (n *NodeManager) GetAllPlatforms() ([]string, error)

+ func (n *NodeManager) GetByEnv(environment, target string, hours int64) ([]OsqueryNode, error)

+ func (n *NodeManager) GetByIdentifier(identifier string) (OsqueryNode, error)

+ func (n *NodeManager) GetByKey(nodekey string) (OsqueryNode, error)

+ func (n *NodeManager) GetByPlatform(platform, target string, hours int64) ([]OsqueryNode, error)

+ func (n *NodeManager) GetBySelector(stype, selector, target string, hours int64) ([]OsqueryNode, error)

+ func (n *NodeManager) GetByUUID(uuid string) (OsqueryNode, error)

+ func (n *NodeManager) GetByUUIDEnv(uuid string, envid uint) (OsqueryNode, error)

+ func (n *NodeManager) GetEnvPlatforms(environment string) ([]string, error)

+ func (n *NodeManager) GetHistoryHostname(uuid, hostname string) (NodeHistoryHostname, error)

+ func (n *NodeManager) GetHistoryIPAddress(uuid, ipaddress string) (NodeHistoryIPAddress, error)

+ func (n *NodeManager) GetHistoryLocalname(uuid, localname string) (NodeHistoryLocalname, error)

+ func (n *NodeManager) GetHistoryUsername(uuid, username string) (NodeHistoryUsername, error)

+ func (n *NodeManager) GetMetadata(node OsqueryNode) NodeMetadata

+ func (n *NodeManager) GetStatsByEnv(environment string, hours int64) (StatsData, error)

+ func (n *NodeManager) GetStatsByPlatform(platform string, hours int64) (StatsData, error)

+ func (n *NodeManager) Gets(target string, hours int64) ([]OsqueryNode, error)

+ func (n *NodeManager) IncHistoryHostname(uuid, localname string) error

+ func (n *NodeManager) IncHistoryIPAddress(uuid, ipaddress string) error

+ func (n *NodeManager) IncHistoryLocalname(uuid, localname string) error

+ func (n *NodeManager) IncHistoryUsername(uuid, username string) error

+ func (n *NodeManager) IncreaseBytes(node OsqueryNode, incBytes int) error

+ func (n *NodeManager) IncreaseBytesByKey(nodekey string, incBytes int) error

+ func (n *NodeManager) IncreaseBytesByUUID(uuid string, incBytes int) error

+ func (n *NodeManager) MetadataRefresh(node OsqueryNode, updates map[string]interface{}) error

+ func (n *NodeManager) NewHistoryEntry(entry interface{}) error

+ func (n *NodeManager) NewHistoryHostname(entry NodeHistoryHostname) error

+ func (n *NodeManager) NewHistoryIPAddress(entry NodeHistoryIPAddress) error

+ func (n *NodeManager) NewHistoryLocalname(entry NodeHistoryLocalname) error

+ func (n *NodeManager) NewHistoryUsername(entry NodeHistoryUsername) error

+ func (n *NodeManager) QueryReadRefresh(node OsqueryNode, lastIp string, incBytes int) error

+ func (n *NodeManager) QueryWriteRefresh(node OsqueryNode, lastIp string, incBytes int) error

+ func (n *NodeManager) RecordHostname(hostname string, node OsqueryNode) error

+ func (n *NodeManager) RecordIPAddress(ipaddress string, node OsqueryNode) error

+ func (n *NodeManager) RecordLocalname(localname string, node OsqueryNode) error

+ func (n *NodeManager) RecordUsername(username string, node OsqueryNode) error

+ func (n *NodeManager) RefreshLastConfig(nodeKey string) error

+ func (n *NodeManager) RefreshLastEvent(node OsqueryNode, event string) error

+ func (n *NodeManager) RefreshLastEventByKey(nodeKey, event string) error

+ func (n *NodeManager) RefreshLastEventByUUID(uuid, event string) error

+ func (n *NodeManager) RefreshLastQueryRead(nodeKey string) error

+ func (n *NodeManager) RefreshLastQueryWrite(uuid string) error

+ func (n *NodeManager) RefreshLastResult(uuid string) error

+ func (n *NodeManager) RefreshLastStatus(uuid string) error

+ func (n *NodeManager) SeenHostname(uuid, hostname string) bool

+ func (n *NodeManager) SeenIPAddress(uuid, ipaddress string) bool

+ func (n *NodeManager) SeenLocalname(uuid, localname string) bool

+ func (n *NodeManager) SeenUsername(uuid, username string) bool

+ func (n *NodeManager) UpdateByUUID(data OsqueryNode, uuid string) error

+ func (n *NodeManager) UpdateIPAddress(ipaddress string, node OsqueryNode) error

+ func (n *NodeManager) UpdateIPAddressByKey(ipaddress, nodekey string) error

+ func (n *NodeManager) UpdateIPAddressByUUID(ipaddress, uuid string) error

+ func (n *NodeManager) UpdateMetadataByUUID(uuid string, metadata NodeMetadata) error

+ type NodeMetadata struct

+ BytesReceived int

+ ConfigHash string

+ DaemonHash string

+ Hostname string

+ IPAddress string

+ Localname string

+ OsqueryUser string

+ OsqueryVersion string

+ Platform string

+ PlatformVersion string

+ Username string

+ type OsqueryNode struct

+ BytesReceived int

+ CPU string

+ ConfigHash string

+ DaemonHash string

+ Environment string

+ EnvironmentID uint

+ ExtraData string

+ HardwareSerial string

+ Hostname string

+ IPAddress string

+ LastConfig time.Time

+ LastQueryRead time.Time

+ LastQueryWrite time.Time

+ LastResult time.Time

+ LastStatus time.Time

+ Localname string

+ Memory string

+ NodeKey string

+ OsqueryUser string

+ OsqueryVersion string

+ Platform string

+ PlatformVersion string

+ RawEnrollment string

+ UUID string

+ UserID uint

+ Username string

+ type StatsData struct

+ Active int64

+ Inactive int64

+ Total int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL