database

Documentation

Index

• type MetadataStore
• type SQLiteStore
  • func NewSQLiteStore(dbPath string) (*SQLiteStore, error)
  • func (s *SQLiteStore) Close() error
  • func (s *SQLiteStore) DeleteJob(jobID string) error
  • func (s *SQLiteStore) GetExecution(executionID string) (*models.Execution, error)
  • func (s *SQLiteStore) GetExecutions(jobID string, limit int) ([]*models.Execution, error)
  • func (s *SQLiteStore) GetJob(jobID string) (*models.Job, error)
  • func (s *SQLiteStore) GetPlugin(pluginName string) (*models.Plugin, error)
  • func (s *SQLiteStore) GetWorker(workerID string) (*models.Worker, error)
  • func (s *SQLiteStore) Initialize(config map[string]interface{}) error
  • func (s *SQLiteStore) ListJobs(filter map[string]interface{}) ([]*models.Job, error)
  • func (s *SQLiteStore) ListPlugins(pluginType string) ([]*models.Plugin, error)
  • func (s *SQLiteStore) ListWorkers() ([]*models.Worker, error)
  • func (s *SQLiteStore) RegisterPlugin(plugin *models.Plugin) error
  • func (s *SQLiteStore) RegisterWorker(worker *models.Worker) error
  • func (s *SQLiteStore) SaveExecution(exec *models.Execution) error
  • func (s *SQLiteStore) SaveJob(job *models.Job) error
  • func (s *SQLiteStore) UnregisterWorker(workerID string) error
  • func (s *SQLiteStore) UpdateExecution(exec *models.Execution) error
  • func (s *SQLiteStore) UpdateJob(job *models.Job) error
  • func (s *SQLiteStore) UpdatePluginStatus(pluginName string, enabled bool) error
  • func (s *SQLiteStore) UpdateWorkerHeartbeat(workerID string) error

Types

type MetadataStore

type MetadataStore interface {
	// Initialize initializes the database connection and schema
	Initialize(config map[string]interface{}) error

	// Close closes the database connection
	Close() error

	// Job operations
	SaveJob(job *models.Job) error
	GetJob(jobID string) (*models.Job, error)
	ListJobs(filter map[string]interface{}) ([]*models.Job, error)
	UpdateJob(job *models.Job) error
	DeleteJob(jobID string) error

	// Execution operations
	SaveExecution(exec *models.Execution) error
	GetExecution(executionID string) (*models.Execution, error)
	GetExecutions(jobID string, limit int) ([]*models.Execution, error)
	UpdateExecution(exec *models.Execution) error

	// Worker operations
	RegisterWorker(worker *models.Worker) error
	UpdateWorkerHeartbeat(workerID string) error
	GetWorker(workerID string) (*models.Worker, error)
	ListWorkers() ([]*models.Worker, error)
	UnregisterWorker(workerID string) error

	// Plugin operations
	RegisterPlugin(plugin *models.Plugin) error
	GetPlugin(pluginName string) (*models.Plugin, error)
	ListPlugins(pluginType string) ([]*models.Plugin, error)
	UpdatePluginStatus(pluginName string, enabled bool) error
}

MetadataStore defines the interface for metadata storage

type SQLiteStore

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

SQLiteStore implements MetadataStore using SQLite

func NewSQLiteStore

func NewSQLiteStore(dbPath string) (*SQLiteStore, error)

NewSQLiteStore creates a new SQLite metadata store

func (*SQLiteStore) Close

func (s *SQLiteStore) Close() error

Close implements MetadataStore.Close

func (*SQLiteStore) DeleteJob

func (s *SQLiteStore) DeleteJob(jobID string) error

DeleteJob implements MetadataStore.DeleteJob

func (*SQLiteStore) GetExecution

func (s *SQLiteStore) GetExecution(executionID string) (*models.Execution, error)

GetExecution implements MetadataStore.GetExecution

func (*SQLiteStore) GetExecutions

func (s *SQLiteStore) GetExecutions(jobID string, limit int) ([]*models.Execution, error)

GetExecutions implements MetadataStore.GetExecutions

func (*SQLiteStore) GetJob

func (s *SQLiteStore) GetJob(jobID string) (*models.Job, error)

GetJob implements MetadataStore.GetJob

func (*SQLiteStore) GetPlugin

func (s *SQLiteStore) GetPlugin(pluginName string) (*models.Plugin, error)

GetPlugin implements MetadataStore.GetPlugin

func (*SQLiteStore) GetWorker

func (s *SQLiteStore) GetWorker(workerID string) (*models.Worker, error)

GetWorker implements MetadataStore.GetWorker

func (*SQLiteStore) Initialize

func (s *SQLiteStore) Initialize(config map[string]interface{}) error

Initialize implements MetadataStore.Initialize

func (*SQLiteStore) ListJobs

func (s *SQLiteStore) ListJobs(filter map[string]interface{}) ([]*models.Job, error)

ListJobs implements MetadataStore.ListJobs

func (*SQLiteStore) ListPlugins

func (s *SQLiteStore) ListPlugins(pluginType string) ([]*models.Plugin, error)

ListPlugins implements MetadataStore.ListPlugins

func (*SQLiteStore) ListWorkers

func (s *SQLiteStore) ListWorkers() ([]*models.Worker, error)

ListWorkers implements MetadataStore.ListWorkers

func (*SQLiteStore) RegisterPlugin

func (s *SQLiteStore) RegisterPlugin(plugin *models.Plugin) error

RegisterPlugin implements MetadataStore.RegisterPlugin

func (*SQLiteStore) RegisterWorker

func (s *SQLiteStore) RegisterWorker(worker *models.Worker) error

RegisterWorker implements MetadataStore.RegisterWorker

func (*SQLiteStore) SaveExecution

func (s *SQLiteStore) SaveExecution(exec *models.Execution) error

SaveExecution implements MetadataStore.SaveExecution

func (*SQLiteStore) SaveJob

func (s *SQLiteStore) SaveJob(job *models.Job) error

SaveJob implements MetadataStore.SaveJob

func (*SQLiteStore) UnregisterWorker

func (s *SQLiteStore) UnregisterWorker(workerID string) error

UnregisterWorker implements MetadataStore.UnregisterWorker

func (*SQLiteStore) UpdateExecution

func (s *SQLiteStore) UpdateExecution(exec *models.Execution) error

UpdateExecution implements MetadataStore.UpdateExecution

func (*SQLiteStore) UpdateJob

func (s *SQLiteStore) UpdateJob(job *models.Job) error

UpdateJob implements MetadataStore.UpdateJob

func (*SQLiteStore) UpdatePluginStatus

func (s *SQLiteStore) UpdatePluginStatus(pluginName string, enabled bool) error

UpdatePluginStatus implements MetadataStore.UpdatePluginStatus

func (*SQLiteStore) UpdateWorkerHeartbeat

func (s *SQLiteStore) UpdateWorkerHeartbeat(workerID string) error

UpdateWorkerHeartbeat implements MetadataStore.UpdateWorkerHeartbeat