postgresql

package

v0.2.0-beta.1 Latest Latest Go to latest Published: Aug 15, 2025 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type DB interface {
	Exec(query string, args ...any) (sql.Result, error)
	QueryRow(query string, args ...any) *sql.Row
}

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

func NewStore(db DB) *PostgresStore

func (ps *PostgresStore) ClearStores() error

func (ps *PostgresStore) CreateStores() error

func (ps *PostgresStore) DeleteStores() error

func (ps *PostgresStore) GetLastTick(name string) (time.Time, error)

func (ps *PostgresStore) GetTaskSettings(name string) (*store.TaskSettings, error)

func (ps *PostgresStore) SaveExecution(name string, info *store.ExecutionInfo) error

func (ps *PostgresStore) SaveTask(name string, settings *store.TaskSettings) error

func (ps *PostgresStore) TaskExists(name string) (bool, error)

func (ps *PostgresStore) UpdateTaskStatus(name string, status store.TaskStatus) error