state

Documentation

Overview

Package state provides processed-message deduplication for Expensor readers.

Index

• func GenerateKey(source, messageID, date string) string
• type Manager
  • func NewDBManager(processedStore ProcessedMessageStore, tenant store.Tenant, logger *slog.Logger) *Manager
  • func (m *Manager) IsProcessed(ctx context.Context, msgKey string) bool
  • func (m *Manager) MarkProcessed(ctx context.Context, msgKey string) error
• type ProcessedMessageStore

Functions

func GenerateKey

func GenerateKey(source, messageID, date string) string

GenerateKey creates a unique key for a message using SHA256 hash.

Types

type Manager

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

Manager tracks processed messages to avoid reprocessing.

func NewDBManager

func NewDBManager(processedStore ProcessedMessageStore, tenant store.Tenant, logger *slog.Logger) *Manager

NewDBManager creates a state manager backed by the runtime database.

func (*Manager) IsProcessed

func (m *Manager) IsProcessed(ctx context.Context, msgKey string) bool

IsProcessed checks if a message has been processed.

func (*Manager) MarkProcessed

func (m *Manager) MarkProcessed(ctx context.Context, msgKey string) error

MarkProcessed marks a message as processed.

type ProcessedMessageStore

type ProcessedMessageStore interface {
	IsMessageProcessed(ctx context.Context, tenant store.Tenant, key string) (bool, error)
	MarkMessageProcessed(ctx context.Context, tenant store.Tenant, key string, at time.Time) error
}

ProcessedMessageStore is the DB persistence surface used by DB-backed state managers.