state

Documentation

Overview

Package state provides the persistent storage layer for the PCI query results.

Index

• Constants
• Variables
• func CreateTable(ctx context.Context, db *sql.DB) error
• func FindEvent(ctx context.Context, db *sql.DB, event Event) (bool, error)
• func InsertEvent(ctx context.Context, db *sql.DB, event Event) error
• func Purge(ctx context.Context, db *sql.DB, opts ...OpOption) (int, error)
• type Event
  • func ReadEvents(ctx context.Context, db *sql.DB, opts ...OpOption) ([]Event, error)
• type Op
• type OpOption
  • func WithBefore(t time.Time) OpOption
  • func WithLimit(limit int) OpOption
  • func WithSince(t time.Time) OpOption
  • func WithSortUnixSecondsAscendingOrder() OpOption
  • func WithSortUnixSecondsDescendingOrder() OpOption

Constants

const (
	// unix timestamp in seconds when the event was observed
	ColumnUnixSeconds = "unix_seconds"

	// "lspci -vv"
	ColumnDataSource = "data_source"

	// "acs_enabled"
	ColumnEventType = "event_type"

	// reasons for the events
	ColumnReasons = "reasons"
)

const DefaultRetentionPeriod = 128 * time.Hour

const TableNamePCIEvents = "components_pci_events"

Variables

var ErrInvalidLimit = errors.New("limit must be greater than or equal to 0")

Functions

func CreateTable

func CreateTable(ctx context.Context, db *sql.DB) error

func FindEvent

func FindEvent(ctx context.Context, db *sql.DB, event Event) (bool, error)

func InsertEvent

func InsertEvent(ctx context.Context, db *sql.DB, event Event) error

func Purge

func Purge(ctx context.Context, db *sql.DB, opts ...OpOption) (int, error)

Types

type Event

type Event struct {
	UnixSeconds int64
	DataSource  string
	EventType   string
	Reasons     []string
}

func ReadEvents

func ReadEvents(ctx context.Context, db *sql.DB, opts ...OpOption) ([]Event, error)

Returns nil if no event is found.

type Op

type Op struct {
	// contains filtered or unexported fields
}

type OpOption

type OpOption func(*Op)

func WithBefore

func WithBefore(t time.Time) OpOption

WithBefore sets the before timestamp for the delete queries. If not specified, it deletes all events.

func WithLimit

func WithLimit(limit int) OpOption

func WithSince

func WithSince(t time.Time) OpOption

WithSince sets the since timestamp for the select queries. If not specified, it returns all events.

func WithSortUnixSecondsAscendingOrder

func WithSortUnixSecondsAscendingOrder() OpOption

WithSortUnixSecondsAscendingOrder sorts the events by unix_seconds in ascending order, meaning its read query returns the oldest events first.

func WithSortUnixSecondsDescendingOrder

func WithSortUnixSecondsDescendingOrder() OpOption

WithSortUnixSecondsDescendingOrder sorts the events by unix_seconds in descending order, meaning its read query returns the newest events first.