eventlog

Documentation

Overview

Package eventlog persists session-scoped envelopes for resume and subscription replay. The default implementation is in-memory ring per session.

Index

• type Entry
• type Log
• type Memory
  • func NewMemory(maxPerSession int) *Memory
  • func (m *Memory) Append(e Entry) error
  • func (m *Memory) Since(sessionID string, fromSeq uint64) ([]Entry, error)
  • func (m *Memory) SinceJob(jobID string, fromSeq uint64) ([]Entry, error)
  • func (m *Memory) Trim(sessionID string, beforeSeq uint64) error

Types

type Entry

type Entry struct {
	SessionID string
	EventSeq  uint64
	JobID     string
	StoredAt  time.Time
	Envelope  arcp.Envelope
}

Entry is one persisted envelope.

type Log

type Log interface {
	Append(e Entry) error
	Since(sessionID string, fromSeq uint64) ([]Entry, error)
	SinceJob(jobID string, fromSeq uint64) ([]Entry, error)
	Trim(sessionID string, beforeSeq uint64) error
}

Log is the event-log interface.

type Memory

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

Memory is a per-session in-memory event log with a fixed retention window. It is not durable; for production deployments wire a persistent Log against your own store.

func NewMemory

func NewMemory(maxPerSession int) *Memory

NewMemory returns a Memory log retaining at most maxPerSession entries per session (the oldest are dropped past the limit).

func (*Memory) Append

func (m *Memory) Append(e Entry) error

Append stores e indexed by session id.

func (*Memory) Since

func (m *Memory) Since(sessionID string, fromSeq uint64) ([]Entry, error)

Since returns entries for sessionID whose EventSeq > fromSeq.

func (*Memory) SinceJob

func (m *Memory) SinceJob(jobID string, fromSeq uint64) ([]Entry, error)

SinceJob returns entries for jobID whose EventSeq > fromSeq across all sessions.

func (*Memory) Trim

func (m *Memory) Trim(sessionID string, beforeSeq uint64) error

Trim drops entries for sessionID whose EventSeq <= beforeSeq.