Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeleteEventFiles ¶
DeleteEventFiles deletes the specified event files from the queue
func EnqueueEvent ¶
func EnqueueEvent(event UsageEvent) error
EnqueueEvent writes a usage event to the queue directory
func FlushQueue ¶
FlushQueue loads pending events from queue and sends them to the repository
func GetQueuePath ¶
func GetQueuePath() string
GetQueuePath returns the path to the usage queue directory
Types ¶
type UsageEvent ¶
type UsageEvent struct {
AssetName string `json:"asset_name"`
AssetVersion string `json:"asset_version"`
AssetType string `json:"asset_type"`
Timestamp string `json:"timestamp"`
}
UsageEvent represents a single asset usage event
func DequeueEvents ¶
func DequeueEvents(limit int) ([]UsageEvent, []string, error)
DequeueEvents reads up to 'limit' events from the queue directory Returns events, file paths, and error
Source Files
Click to show internal directories.
Click to hide internal directories.