db

Documentation

Index

• type Status
• type StatusStore
  • func NewStatusStore(store *Store) (*StatusStore, error)
  • func (db *StatusStore) GetAll() ([]*Status, error)
  • func (db *StatusStore) Put(status *Status) error
  • func (db *StatusStore) Sync(stats []*Status) error
• type Store
  • func Open(path string) (*Store, error)
  • func (db *Store) DeleteBucket(name []byte) error
  • func (db *Store) NewBucket(name []byte) error

Types

type Status

type Status struct {
	Plan          string     `json:"plan"`
	NextRun       time.Time  `json:"next_run"`
	LastRun       *time.Time `json:"last_run,omitempty"`
	LastRunStatus string     `json:"last_run_status,omitempty"`
	LastRunLog    string     `json:"last_run_log,omitempty"`
}

type StatusStore

type StatusStore struct {
	*Store
	// contains filtered or unexported fields
}

func NewStatusStore

func NewStatusStore(store *Store) (*StatusStore, error)

NewStatusStore creates bucket if not found

func (*StatusStore) GetAll

func (db *StatusStore) GetAll() ([]*Status, error)

GetAll loads all jobs stats from db

func (*StatusStore) Put

func (db *StatusStore) Put(status *Status) error

Put upserts job status

func (*StatusStore) Sync

func (db *StatusStore) Sync(stats []*Status) error

Sync plans found on disk with db

type Store

type Store struct {
	*bolt.DB
}

func Open

func Open(path string) (*Store, error)

Open creates or opens a bolt db at the specified path.

func (*Store) DeleteBucket

func (db *Store) DeleteBucket(name []byte) error

func (*Store) NewBucket

func (db *Store) NewBucket(name []byte) error