Versions in this module Expand all Collapse all v1 v1.0.0 Apr 28, 2022 Changes in this version + var ErrAlreadyExists = fmt.Errorf("exists already") + var ErrNotFound = fmt.Errorf("not found") + type FileLogStore struct + Base string + func NewFileLogStore(base string) (*FileLogStore, error) + func (fs *FileLogStore) GarbageCollect(olderThan time.Duration) error + func (fs *FileLogStore) Open(id string) (io.WriteCloser, error) + func (fs *FileLogStore) Read(id string) (io.ReadCloser, error) + func (fs *FileLogStore) Write(id string) (io.Writer, error) + type Jobs interface + Find func(ctx context.Context, filter []*v1.FilterExpression, ...) (slice []v1.JobStatus, total int, err error) + GarbageCollect func(olderThan time.Duration) error + Get func(ctx context.Context, name string) (*v1.JobStatus, error) + GetJobSpec func(name string) (spec *v1.JobSpec, data []byte, err error) + Store func(ctx context.Context, job v1.JobStatus) error + StoreJobSpec func(name string, spec v1.JobSpec, data []byte) error + func NewInMemoryJobStore() Jobs + type Logs interface + GarbageCollect func(olderThan time.Duration) error + Open func(id string) (io.WriteCloser, error) + Read func(id string) (io.ReadCloser, error) + Write func(id string) (io.Writer, error) + func NewInMemoryLogStore() Logs + type NumberGroup interface + Latest func(group string) (nr int, err error) + Next func(group string) (nr int, err error)