database

package

v1.0.0 Latest Latest Go to latest Published: Oct 1, 2025 License: BSD-3-Clause Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

BoltDBClient is a wrapper around bbolt.DB for job persistence.

func NewDB(path string) (*BoltDBClient, error)

NewDB opens a BoltDB database and initializes the necessary buckets.

func (c *BoltDBClient) AcquireLock(jobID, instanceID string) (bool, error)

AcquireLock attempts to acquire a lock for a job.

func (c *BoltDBClient) Close() error

Close closes the BoltDB database.

func (c *BoltDBClient) GetJob(id string) (*types.Job, error)

GetJob retrieves a job from the BoltDB database.

func (c *BoltDBClient) LoadJobs() ([]types.Job, error)

LoadJobs loads all jobs from the BoltDB database.

func (c *BoltDBClient) ReleaseLock(jobID, instanceID string) error

ReleaseLock releases a lock for a job.

func (c *BoltDBClient) SaveJob(job *types.Job) error

SaveJob saves a job to the BoltDB database.