Versions in this module Expand all Collapse all v0 v0.2.0 Sep 9, 2026 Changes in this version type FactType + const CancelRequested + const Orphaned + const Requeued v0.1.0 Sep 6, 2026 Changes in this version + type Fact struct + Attempt int + Detail json.RawMessage + Error string + Owner string + Seq int64 + TaskID string + Time time.Time + Type FactType + type FactType string + const Cancelled + const Claimed + const Completed + const DeadLettered + const Enqueued + const Failed + const Heartbeat + const Released + type Journal interface + All func(ctx context.Context) ([]Fact, error) + Append func(ctx context.Context, f Fact) (Fact, error) + Since func(ctx context.Context, after int64) ([]Fact, error) + type MemoryJournal struct + func NewMemoryJournal() *MemoryJournal + func (m *MemoryJournal) All(_ context.Context) ([]Fact, error) + func (m *MemoryJournal) Append(_ context.Context, f Fact) (Fact, error) + func (m *MemoryJournal) Since(_ context.Context, after int64) ([]Fact, error) Other modules containing this package github.com/larsartmann/go-taskqueue/internal/journal
Go to main page