persistence

Sep 11, 2024

Changes in this version

+ var ErrNoStatusData = fmt.Errorf("no status data")

+ var ErrNoStatusDataToday = fmt.Errorf("no status data today")

+ var ErrRequestIDNotFound = fmt.Errorf("request id not found")

+ type DAGListPaginationArgs struct

+ Limit int

+ Name *string

+ Page int

+ Tag *string

+ type DAGStore interface

+ Create func(name string, spec []byte) (string, error)

+ Delete func(name string) error

+ Find func(name string) (*dag.DAG, error)

+ GetDetails func(name string) (*dag.DAG, error)

+ GetMetadata func(name string) (*dag.DAG, error)

+ GetSpec func(name string) (string, error)

+ Grep func(pattern string) (ret []*GrepResult, errs []string, err error)

+ List func() (ret []*dag.DAG, errs []string, err error)

+ ListPagination func(params DAGListPaginationArgs) (*DagListPaginationResult, error)

+ Rename func(oldID, newID string) error

+ TagList func() ([]string, []string, error)

+ UpdateSpec func(name string, spec []byte) error

+ type DagListPaginationResult struct

+ Count int

+ DagList []*dag.DAG

+ ErrorList []string

+ type DataStores interface

+ DAGStore func() DAGStore

+ FlagStore func() FlagStore

+ HistoryStore func() HistoryStore

+ type FlagStore interface

+ IsSuspended func(id string) bool

+ ToggleSuspend func(id string, suspend bool) error

+ type GrepResult struct

+ DAG *dag.DAG

+ Matches []*grep.Match

+ Name string

+ type HistoryStore interface

+ Close func() error

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

+ Open func(dagFile string, t time.Time, requestID string) error

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

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

+ RemoveAll func(dagFile string) error

+ RemoveOld func(dagFile string, retentionDays int) error

+ Rename func(oldName, newName string) error

+ Update func(dagFile, requestID string, st *model.Status) error

+ Write func(status *model.Status) error