storage

package
v2.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 21, 2026 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultEtcdPageSize      = 5000 // Maximum locations (xnames) and task results to store in each etcd entry
	DefaultMaxMessageLen     = 130  // Maximum length of Task messages and errors when over all object is too large
	DefaultMaxEtcdObjectSize = 1570000
)

Variables

This section is empty.

Functions

func OpenDB added in v2.8.0 

func OpenDB(config PostgresConfig, log *logrus.Logger) (*sql.DB, error)

Types

type DistributedLockProvider 

type DistributedLockProvider interface {
	Init(Logger *logrus.Logger) error
	Ping() error
	GetDuration() time.Duration
	DistributedTimedLock(maxLockTime time.Duration) error
	Unlock() error
	// Close closes the distributed lock provider and releases any resources it holds.
	Close() error
}

type ETCDLockProvider 

type ETCDLockProvider struct {
	Logger   *logrus.Logger
	Duration time.Duration
	// contains filtered or unexported fields
}

func (*ETCDLockProvider) Close added in v2.8.0 

func (d *ETCDLockProvider) Close() error

func (*ETCDLockProvider) DistributedTimedLock 

func (d *ETCDLockProvider) DistributedTimedLock(maxLockTime time.Duration) error

func (*ETCDLockProvider) GetDuration 

func (d *ETCDLockProvider) GetDuration() time.Duration

func (*ETCDLockProvider) Init 

func (e *ETCDLockProvider) Init(Logger *logrus.Logger) error

func (*ETCDLockProvider) Ping 

func (d *ETCDLockProvider) Ping() error

func (*ETCDLockProvider) Unlock 

func (d *ETCDLockProvider) Unlock() error

type ETCDStorage 

type ETCDStorage struct {
	Logger            *logrus.Logger
	DisableSizeChecks bool
	PageSize          int
	MaxMessageLen     int
	MaxEtcdObjectSize int
	// contains filtered or unexported fields
}

func (*ETCDStorage) Close added in v2.8.0 

func (e *ETCDStorage) Close() error

func (*ETCDStorage) DeletePowerCapOperation 

func (e *ETCDStorage) DeletePowerCapOperation(taskID uuid.UUID, opID uuid.UUID) error

func (*ETCDStorage) DeletePowerCapTask 

func (e *ETCDStorage) DeletePowerCapTask(taskID uuid.UUID) error

func (*ETCDStorage) DeletePowerStatus 

func (e *ETCDStorage) DeletePowerStatus(xname string) error

func (*ETCDStorage) DeleteTransition 

func (e *ETCDStorage) DeleteTransition(transitionID uuid.UUID) error

func (*ETCDStorage) DeleteTransitionTask 

func (e *ETCDStorage) DeleteTransitionTask(transitionID uuid.UUID, taskID uuid.UUID) error

func (*ETCDStorage) GetAllPowerCapOperationsForTask 

func (e *ETCDStorage) GetAllPowerCapOperationsForTask(taskID uuid.UUID) ([]model.PowerCapOperation, error)

func (*ETCDStorage) GetAllPowerCapTasks 

func (e *ETCDStorage) GetAllPowerCapTasks() ([]model.PowerCapTask, error)

func (*ETCDStorage) GetAllPowerStatus 

func (e *ETCDStorage) GetAllPowerStatus() (model.PowerStatus, error)

func (*ETCDStorage) GetAllTasksForTransition 

func (e *ETCDStorage) GetAllTasksForTransition(transitionID uuid.UUID) ([]model.TransitionTask, error)

func (*ETCDStorage) GetAllTransitions 

func (e *ETCDStorage) GetAllTransitions() ([]model.Transition, error)

func (*ETCDStorage) GetPowerCapOperation 

func (e *ETCDStorage) GetPowerCapOperation(taskID, opID uuid.UUID) (model.PowerCapOperation, error)

func (*ETCDStorage) GetPowerCapTask 

func (e *ETCDStorage) GetPowerCapTask(taskID uuid.UUID) (model.PowerCapTask, error)

func (*ETCDStorage) GetPowerStatus 

func (e *ETCDStorage) GetPowerStatus(xname string) (model.PowerStatusComponent, error)

func (*ETCDStorage) GetPowerStatusHierarchy 

func (e *ETCDStorage) GetPowerStatusHierarchy(xname string) (model.PowerStatus, error)

func (*ETCDStorage) GetPowerStatusMaster 

func (e *ETCDStorage) GetPowerStatusMaster() (time.Time, error)

func (*ETCDStorage) GetTransition 

func (e *ETCDStorage) GetTransition(transitionID uuid.UUID) (transition model.Transition, transitionFirstPage model.Transition, err error)

func (*ETCDStorage) GetTransitionPages 

func (e *ETCDStorage) GetTransitionPages(transitionId string) ([]model.TransitionPage, error)

func (*ETCDStorage) GetTransitionTask 

func (e *ETCDStorage) GetTransitionTask(transitionID, taskID uuid.UUID) (model.TransitionTask, error)

func (*ETCDStorage) Init 

func (e *ETCDStorage) Init(Logger *logrus.Logger) error

func (*ETCDStorage) Ping 

func (e *ETCDStorage) Ping() error

func (*ETCDStorage) StorePowerCapOperation 

func (e *ETCDStorage) StorePowerCapOperation(op model.PowerCapOperation) error

func (*ETCDStorage) StorePowerCapTask 

func (e *ETCDStorage) StorePowerCapTask(task model.PowerCapTask) error

func (*ETCDStorage) StorePowerStatus 

func (e *ETCDStorage) StorePowerStatus(p model.PowerStatusComponent) error

func (*ETCDStorage) StorePowerStatusMaster 

func (e *ETCDStorage) StorePowerStatusMaster(now time.Time) error

func (*ETCDStorage) StoreTransition 

func (e *ETCDStorage) StoreTransition(transition model.Transition) error

func (*ETCDStorage) StoreTransitionTask 

func (e *ETCDStorage) StoreTransitionTask(task model.TransitionTask) error

func (*ETCDStorage) TASPowerStatusMaster 

func (e *ETCDStorage) TASPowerStatusMaster(now time.Time, testVal time.Time) (bool, error)

func (*ETCDStorage) TASTransition 

func (e *ETCDStorage) TASTransition(transition model.Transition, testVal model.Transition) (bool, error)

type MEMLockProvider 

type MEMLockProvider struct {
	Logger   *logrus.Logger
	Duration time.Duration
	// contains filtered or unexported fields
}

func (*MEMLockProvider) Close added in v2.8.0 

func (d *MEMLockProvider) Close() error

func (*MEMLockProvider) DistributedTimedLock 

func (d *MEMLockProvider) DistributedTimedLock(maxLockTime time.Duration) error

func (*MEMLockProvider) GetDuration 

func (d *MEMLockProvider) GetDuration() time.Duration

func (*MEMLockProvider) Init 

func (d *MEMLockProvider) Init(Logger *logrus.Logger) error

func (*MEMLockProvider) Ping 

func (d *MEMLockProvider) Ping() error

func (*MEMLockProvider) Unlock 

func (d *MEMLockProvider) Unlock() error

type MEMStorage 

type MEMStorage struct {
	Logger            *logrus.Logger
	DisableSizeChecks bool
	PageSize          int
	MaxMessageLen     int
	MaxEtcdObjectSize int
	// contains filtered or unexported fields
}

func (*MEMStorage) Close added in v2.8.0 

func (m *MEMStorage) Close() error

func (*MEMStorage) DeletePowerCapOperation 

func (m *MEMStorage) DeletePowerCapOperation(taskID uuid.UUID, opID uuid.UUID) error

func (*MEMStorage) DeletePowerCapTask 

func (m *MEMStorage) DeletePowerCapTask(taskID uuid.UUID) error

func (*MEMStorage) DeletePowerStatus 

func (m *MEMStorage) DeletePowerStatus(xname string) error

func (*MEMStorage) DeleteTransition 

func (m *MEMStorage) DeleteTransition(transitionID uuid.UUID) error

func (*MEMStorage) DeleteTransitionTask 

func (m *MEMStorage) DeleteTransitionTask(transitionID uuid.UUID, taskID uuid.UUID) error

func (*MEMStorage) GetAllPowerCapOperationsForTask 

func (m *MEMStorage) GetAllPowerCapOperationsForTask(taskID uuid.UUID) ([]model.PowerCapOperation, error)

func (*MEMStorage) GetAllPowerCapTasks 

func (m *MEMStorage) GetAllPowerCapTasks() ([]model.PowerCapTask, error)

func (*MEMStorage) GetAllPowerStatus 

func (m *MEMStorage) GetAllPowerStatus() (model.PowerStatus, error)

func (*MEMStorage) GetAllTasksForTransition 

func (m *MEMStorage) GetAllTasksForTransition(transitionID uuid.UUID) ([]model.TransitionTask, error)

func (*MEMStorage) GetAllTransitions 

func (m *MEMStorage) GetAllTransitions() ([]model.Transition, error)

func (*MEMStorage) GetPowerCapOperation 

func (m *MEMStorage) GetPowerCapOperation(taskID uuid.UUID, opID uuid.UUID) (model.PowerCapOperation, error)

func (*MEMStorage) GetPowerCapTask 

func (m *MEMStorage) GetPowerCapTask(taskID uuid.UUID) (model.PowerCapTask, error)

func (*MEMStorage) GetPowerStatus 

func (m *MEMStorage) GetPowerStatus(xname string) (model.PowerStatusComponent, error)

func (*MEMStorage) GetPowerStatusHierarchy 

func (m *MEMStorage) GetPowerStatusHierarchy(xname string) (model.PowerStatus, error)

func (*MEMStorage) GetPowerStatusMaster 

func (m *MEMStorage) GetPowerStatusMaster() (time.Time, error)

func (*MEMStorage) GetTransition 

func (m *MEMStorage) GetTransition(transitionID uuid.UUID) (transition model.Transition, transitionFirstPage model.Transition, err error)

func (*MEMStorage) GetTransitionTask 

func (m *MEMStorage) GetTransitionTask(transitionID uuid.UUID, taskID uuid.UUID) (model.TransitionTask, error)

func (*MEMStorage) Init 

func (m *MEMStorage) Init(Logger *logrus.Logger) error

func (*MEMStorage) Ping 

func (m *MEMStorage) Ping() error

func (*MEMStorage) StorePowerCapOperation 

func (m *MEMStorage) StorePowerCapOperation(op model.PowerCapOperation) error

func (*MEMStorage) StorePowerCapTask 

func (m *MEMStorage) StorePowerCapTask(task model.PowerCapTask) error

func (*MEMStorage) StorePowerStatus 

func (m *MEMStorage) StorePowerStatus(p model.PowerStatusComponent) error

func (*MEMStorage) StorePowerStatusMaster 

func (m *MEMStorage) StorePowerStatusMaster(now time.Time) error

func (*MEMStorage) StoreTransition 

func (m *MEMStorage) StoreTransition(transition model.Transition) error

func (*MEMStorage) StoreTransitionTask 

func (m *MEMStorage) StoreTransitionTask(op model.TransitionTask) error

func (*MEMStorage) TASPowerStatusMaster 

func (m *MEMStorage) TASPowerStatusMaster(now time.Time, testVal time.Time) (bool, error)

func (*MEMStorage) TASTransition 

func (m *MEMStorage) TASTransition(transition model.Transition, testVal model.Transition) (bool, error)

type PostgresConfig added in v2.8.0 

type PostgresConfig struct {
	Host       string
	User       string
	DBName     string
	Password   string
	Port       uint
	RetryCount uint64
	RetryWait  uint64
	Insecure   bool
	Opts       string
	ConnStr    string
}

func DefaultPostgresConfig added in v2.8.0 

func DefaultPostgresConfig() PostgresConfig

type PostgresLockProvider added in v2.8.0 

type PostgresLockProvider struct {
	// Config holds the postgres configuration
	Config PostgresConfig
	// contains filtered or unexported fields
}

PostgresLockProvider implements a distributed lock provider using PostgreSQL's advisory locks.

func (*PostgresLockProvider) Close added in v2.8.0 

func (p *PostgresLockProvider) Close() (err error)

Close closes the database connection used by the PostgresLockProvider.

func (*PostgresLockProvider) DistributedTimedLock added in v2.8.0 

func (p *PostgresLockProvider) DistributedTimedLock(maxLockTime time.Duration) error

func (*PostgresLockProvider) GetDuration added in v2.8.0 

func (p *PostgresLockProvider) GetDuration() time.Duration

func (*PostgresLockProvider) Init added in v2.8.0 

func (p *PostgresLockProvider) Init(logger *logrus.Logger) error

Init initializes the PostgresLockProvider with a logger.

func (*PostgresLockProvider) Ping added in v2.8.0 

func (p *PostgresLockProvider) Ping() error

Ping checks the connection to the PostgreSQL database.

func (*PostgresLockProvider) Unlock added in v2.8.0 

func (p *PostgresLockProvider) Unlock() error

type PostgresStorage added in v2.8.0 

type PostgresStorage struct {
	Config PostgresConfig
	// contains filtered or unexported fields
}

func (*PostgresStorage) Close added in v2.8.0 

func (p *PostgresStorage) Close() error

func (*PostgresStorage) DeletePowerCapOperation added in v2.8.0 

func (p *PostgresStorage) DeletePowerCapOperation(_ uuid.UUID, opID uuid.UUID) error

func (*PostgresStorage) DeletePowerCapTask added in v2.8.0 

func (p *PostgresStorage) DeletePowerCapTask(taskID uuid.UUID) error

func (*PostgresStorage) DeletePowerStatus added in v2.8.0 

func (p *PostgresStorage) DeletePowerStatus(xname string) error

func (*PostgresStorage) DeleteTransition added in v2.8.0 

func (p *PostgresStorage) DeleteTransition(transitionID uuid.UUID) error

func (*PostgresStorage) DeleteTransitionTask added in v2.8.0 

func (p *PostgresStorage) DeleteTransitionTask(transitionID uuid.UUID, taskID uuid.UUID) error

func (*PostgresStorage) GetAllPowerCapOperationsForTask added in v2.8.0 

func (p *PostgresStorage) GetAllPowerCapOperationsForTask(taskID uuid.UUID) ([]model.PowerCapOperation, error)

func (*PostgresStorage) GetAllPowerCapTasks added in v2.8.0 

func (p *PostgresStorage) GetAllPowerCapTasks() ([]model.PowerCapTask, error)

func (*PostgresStorage) GetAllPowerStatus added in v2.8.0 

func (p *PostgresStorage) GetAllPowerStatus() (ps model.PowerStatus, err error)

func (*PostgresStorage) GetAllTasksForTransition added in v2.8.0 

func (p *PostgresStorage) GetAllTasksForTransition(transitionID uuid.UUID) ([]model.TransitionTask, error)

func (*PostgresStorage) GetAllTransitions added in v2.8.0 

func (p *PostgresStorage) GetAllTransitions() ([]model.Transition, error)

func (*PostgresStorage) GetPowerCapOperation added in v2.8.0 

func (p *PostgresStorage) GetPowerCapOperation(_ uuid.UUID, opID uuid.UUID) (model.PowerCapOperation, error)

func (*PostgresStorage) GetPowerCapTask added in v2.8.0 

func (p *PostgresStorage) GetPowerCapTask(taskID uuid.UUID) (model.PowerCapTask, error)

func (*PostgresStorage) GetPowerStatus added in v2.8.0 

func (p *PostgresStorage) GetPowerStatus(xname string) (psc model.PowerStatusComponent, err error)

func (*PostgresStorage) GetPowerStatusHierarchy added in v2.8.0 

func (p *PostgresStorage) GetPowerStatusHierarchy(xname string) (ps model.PowerStatus, err error)

func (*PostgresStorage) GetPowerStatusMaster added in v2.8.0 

func (p *PostgresStorage) GetPowerStatusMaster() (lastUpdated time.Time, err error)

func (*PostgresStorage) GetTransition added in v2.8.0 

func (p *PostgresStorage) GetTransition(transitionID uuid.UUID) (transition model.Transition, transitionFirstPage model.Transition, err error)

func (*PostgresStorage) GetTransitionTask added in v2.8.0 

func (p *PostgresStorage) GetTransitionTask(_ uuid.UUID, taskID uuid.UUID) (model.TransitionTask, error)

func (*PostgresStorage) Init added in v2.8.0 

func (p *PostgresStorage) Init(logger *logrus.Logger) error

func (*PostgresStorage) Ping added in v2.8.0 

func (p *PostgresStorage) Ping() error

func (*PostgresStorage) StorePowerCapOperation added in v2.8.0 

func (p *PostgresStorage) StorePowerCapOperation(op model.PowerCapOperation) error

func (*PostgresStorage) StorePowerCapTask added in v2.8.0 

func (p *PostgresStorage) StorePowerCapTask(task model.PowerCapTask) error

func (*PostgresStorage) StorePowerStatus added in v2.8.0 

func (p *PostgresStorage) StorePowerStatus(psc model.PowerStatusComponent) error

func (*PostgresStorage) StorePowerStatusMaster added in v2.8.0 

func (p *PostgresStorage) StorePowerStatusMaster(now time.Time) error

func (*PostgresStorage) StoreTransition added in v2.8.0 

func (p *PostgresStorage) StoreTransition(transition model.Transition) error

func (*PostgresStorage) StoreTransitionTask added in v2.8.0 

func (p *PostgresStorage) StoreTransitionTask(op model.TransitionTask) error

func (*PostgresStorage) TASPowerStatusMaster added in v2.8.0 

func (p *PostgresStorage) TASPowerStatusMaster(now time.Time, testVal time.Time) (bool, error)

func (*PostgresStorage) TASTransition added in v2.8.0 

func (p *PostgresStorage) TASTransition(transition model.Transition, testVal model.Transition) (bool, error)

type StorageProvider 

type StorageProvider interface {
	Init(Logger *logrus.Logger) error
	Ping() error

	GetPowerStatusMaster() (time.Time, error)
	StorePowerStatusMaster(now time.Time) error
	TASPowerStatusMaster(now time.Time, testVal time.Time) (bool, error)
	StorePowerStatus(p model.PowerStatusComponent) error
	DeletePowerStatus(xname string) error
	GetPowerStatus(xname string) (model.PowerStatusComponent, error)
	GetAllPowerStatus() (model.PowerStatus, error)
	GetPowerStatusHierarchy(xname string) (model.PowerStatus, error)

	StorePowerCapTask(task model.PowerCapTask) error
	StorePowerCapOperation(op model.PowerCapOperation) error
	GetPowerCapTask(taskID uuid.UUID) (model.PowerCapTask, error)
	GetPowerCapOperation(taskID uuid.UUID, opID uuid.UUID) (model.PowerCapOperation, error)
	GetAllPowerCapOperationsForTask(taskID uuid.UUID) ([]model.PowerCapOperation, error)
	GetAllPowerCapTasks() ([]model.PowerCapTask, error)
	DeletePowerCapTask(taskID uuid.UUID) error
	DeletePowerCapOperation(taskID uuid.UUID, opID uuid.UUID) error

	StoreTransition(transition model.Transition) error
	StoreTransitionTask(task model.TransitionTask) error
	GetTransition(transitionID uuid.UUID) (transition model.Transition, transtiionFirstPage model.Transition, err error)
	GetTransitionTask(transitionID uuid.UUID, taskID uuid.UUID) (model.TransitionTask, error)
	GetAllTasksForTransition(transitionID uuid.UUID) ([]model.TransitionTask, error)
	GetAllTransitions() ([]model.Transition, error)
	DeleteTransition(transitionID uuid.UUID) error
	DeleteTransitionTask(transitionID uuid.UUID, taskID uuid.UUID) error
	TASTransition(transition model.Transition, testVal model.Transition) (bool, error)
	// Close closes the storage provider and releases any resources it holds.
	Close() error
}

type TransitionWatchCBFunc 

type TransitionWatchCBFunc func(Transition model.Transition, wasDeleted bool, err error, userdata interface{}) bool

type WatchTransitionCBHandle 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.