jsondb

Documentation

Index

• Variables
• func ParseFile(file string) (*model.Status, error)
• type JSONDB
  • func New(location string, latestStatusToday bool) *JSONDB
  • func (s *JSONDB) Close() error
  • func (s *JSONDB) Compact(original string) error
  • func (s *JSONDB) FindByRequestID(dagFile string, requestID string) (*model.StatusFile, error)
  • func (s *JSONDB) Open(dagFile string, t time.Time, requestID string) error
  • func (s *JSONDB) ReadStatusRecent(dagFile string, n int) []*model.StatusFile
  • func (s *JSONDB) ReadStatusToday(dagFile string) (*model.Status, error)
  • func (s *JSONDB) RemoveAll(dagFile string) error
  • func (s *JSONDB) RemoveOld(dagFile string, retentionDays int) error
  • func (s *JSONDB) Rename(oldID, newID string) error
  • func (s *JSONDB) Update(dagFile, requestID string, status *model.Status) error
  • func (s *JSONDB) Write(status *model.Status) error

Variables

var (
	ErrWriterClosed  = errors.New("writer is closed")
	ErrWriterNotOpen = errors.New("writer is not open")
)

Functions

func ParseFile

func ParseFile(file string) (*model.Status, error)

Types

type JSONDB

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

JSONDB manages DAGs status files in local storage.

func New

func New(location string, latestStatusToday bool) *JSONDB

New creates a new JSONDB with default configuration.

func (*JSONDB) Close

func (s *JSONDB) Close() error

func (*JSONDB) Compact

func (s *JSONDB) Compact(original string) error

func (*JSONDB) FindByRequestID

func (s *JSONDB) FindByRequestID(dagFile string, requestID string) (*model.StatusFile, error)

func (*JSONDB) Open

func (s *JSONDB) Open(dagFile string, t time.Time, requestID string) error

func (*JSONDB) ReadStatusRecent

func (s *JSONDB) ReadStatusRecent(dagFile string, n int) []*model.StatusFile

func (*JSONDB) ReadStatusToday

func (s *JSONDB) ReadStatusToday(dagFile string) (*model.Status, error)

func (*JSONDB) RemoveAll

func (s *JSONDB) RemoveAll(dagFile string) error

func (*JSONDB) RemoveOld

func (s *JSONDB) RemoveOld(dagFile string, retentionDays int) error

func (*JSONDB) Rename

func (s *JSONDB) Rename(oldID, newID string) error

func (*JSONDB) Update

func (s *JSONDB) Update(dagFile, requestID string, status *model.Status) error

func (*JSONDB) Write

func (s *JSONDB) Write(status *model.Status) error