journal

Oct 30, 2026

Changes in this version

type FactType

+ const Parked

Oct 11, 2026

Changes in this version

+ type EffectStatus string

+ const EffectCommitted

+ const EffectNone

+ const EffectPartial

+ const EffectRolledBack

+ const EffectUnknown

type FactType

+ const ErrorObserved

+ const IncidentTaskMinted

+ type ReleasedDetail struct

+ Effect EffectStatus

+ Reason string

Oct 6, 2026

Changes in this version

type Fact

+ func AfterSeq(facts []Fact, after int64, limit int) []Fact

type FactType

+ const QuestionAnswered

+ const QuestionAsked

Sep 13, 2026

Changes in this version

type FactType

+ const Reprioritized

+ const SessionClosed

+ const SessionOpened

Sep 9, 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 CancelRequested

+ const Cancelled

+ const Claimed

+ const Completed

+ const DeadLettered

+ const Enqueued

+ const Failed

+ const Heartbeat

+ const Orphaned

+ const Released

+ const Requeued

+ 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)