state

Documentation

Overview

Package state provides the persistent storage layer for component states.

Index

• Constants
• Variables
• func CreateMachineIDIfNotExist(ctx context.Context, dbRW *sql.DB, dbRO *sql.DB, providedUID string) (string, error)
• func CreateTableAPIVersion(ctx context.Context, db *sql.DB) error
• func CreateTableMachineMetadata(ctx context.Context, dbRW *sql.DB) error
• func GetComponents(ctx context.Context, db *sql.DB, machineID string) (string, error)
• func GetLoginInfo(ctx context.Context, dbRO *sql.DB, machineID string) (string, error)
• func GetMachineID(ctx context.Context, dbRO *sql.DB) (string, error)
• func ReadLatestAPIVersion(ctx context.Context, db *sql.DB) (string, error)
• func RecordMetrics(ctx context.Context, db *sql.DB) error
• func Register(reg *prometheus.Registry) 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, dbRW *sql.DB, machineID string, token string) error

Constants

const (
	TableNameAPIVersion = "api_version"

	ColumnAPIVersion = "version"
)

const (
	TableNameMachineMetadata = "machine_metadata"

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

Variables

var ErrEmptyAPIVersion = errors.New("api version is empty")

Functions

func CreateMachineIDIfNotExist

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

func CreateTableAPIVersion

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

func CreateTableMachineMetadata

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

func GetComponents

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

func GetLoginInfo

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

func GetMachineID

func GetMachineID(ctx context.Context, dbRO *sql.DB) (string, error)

Reads the machine ID from the database. Returns an empty string and sql.ErrNoRows if the machine ID is not found.

func ReadLatestAPIVersion

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

ReadLatestAPIVersion reads the latest API version from the database.

func RecordMetrics

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

func Register

func Register(reg *prometheus.Registry) 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, dbRW *sql.DB, machineID string, token string) error