state

Documentation

Overview

Package state provides the persistent storage layer for component states.

Index

• Constants
• func Compact(ctx context.Context, db *sql.DB) error
• func CreateMachineIDIfNotExist(ctx context.Context, db *sql.DB, providedUID string) (string, error)
• func CreateTableAPIVersion(ctx context.Context, db *sql.DB) error
• func CreateTableBootIDs(ctx context.Context, db *sql.DB) error
• func CreateTableMachineMetadata(ctx context.Context, db *sql.DB) error
• func GetComponents(ctx context.Context, db *sql.DB, machineID string) (string, error)
• func GetFirstBootID(ctx context.Context, db *sql.DB) (string, error)
• func GetLastBootID(ctx context.Context, db *sql.DB) (string, error)
• func GetLoginInfo(ctx context.Context, db *sql.DB, machineID string) (string, error)
• func InsertBootID(ctx context.Context, db *sql.DB, bootID string, time time.Time) error
• func ReadAPIVersion(ctx context.Context, db *sql.DB) (string, error)
• func RecordMetrics(ctx context.Context, db *sql.DB) error
• func Register(reg *prometheus.Registry) error
• func UpdateAPIVersion(ctx context.Context, db *sql.DB, apiVersion string) error
• func UpdateAPIVersionIfNotExists(ctx context.Context, db *sql.DB, apiVersion string) (string, error)
• func UpdateComponents(ctx context.Context, db *sql.DB, machineID string, components string) error
• func UpdateLoginInfo(ctx context.Context, db *sql.DB, machineID string, token string) error
• type RebootEvent
  • func GetRebootEvents(ctx context.Context, db *sql.DB, since time.Time) ([]RebootEvent, error)

Constants

const (
	TableNameAPIVersion = "api_version"

	ColumnAPIVersion = "version"
)

const (
	TableNameMachineBootIDs = "machine_boot_ids"

	ColumnBootID          = "boot_id"
	ColumnBootUnixSeconds = "boot_unix_seconds"
)

const (
	TableNameMachineMetadata = "machine_metadata"

	ColumnMachineID   = "machine_id"
	ColumnUnixSeconds = "unix_seconds"
	ColumnToken       = "token"
	ColumnComponents  = "components"
)

Functions

func Compact

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

func CreateMachineIDIfNotExist

func CreateMachineIDIfNotExist(ctx context.Context, db *sql.DB, providedUID string) (string, error)

func CreateTableAPIVersion

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

func CreateTableBootIDs

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

func CreateTableMachineMetadata

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

func GetComponents

func GetComponents(ctx context.Context, db *sql.DB, machineID string) (string, error)

func GetFirstBootID

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

func GetLastBootID

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

Returns an empty string and no error if no boot ID is found.

func GetLoginInfo

func GetLoginInfo(ctx context.Context, db *sql.DB, machineID string) (string, error)

func InsertBootID

func InsertBootID(ctx context.Context, db *sql.DB, bootID string, time time.Time) error

func ReadAPIVersion

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

func RecordMetrics

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

func Register

func Register(reg *prometheus.Registry) error

func UpdateAPIVersion

func UpdateAPIVersion(ctx context.Context, db *sql.DB, apiVersion string) error

func UpdateAPIVersionIfNotExists

func UpdateAPIVersionIfNotExists(ctx context.Context, db *sql.DB, apiVersion string) (string, error)

func UpdateComponents

func UpdateComponents(ctx context.Context, db *sql.DB, machineID string, components string) error

func UpdateLoginInfo

func UpdateLoginInfo(ctx context.Context, db *sql.DB, machineID string, token string) error

Types

type RebootEvent

type RebootEvent struct {
	BootID      string
	UnixSeconds int64
}

func GetRebootEvents

func GetRebootEvents(ctx context.Context, db *sql.DB, since time.Time) ([]RebootEvent, error)

Reboot events are events where the boot ID changed.