auditstorage

package

v0.0.0-...-c6a46fa Latest Latest Go to latest Published: Oct 29, 2026 License: MIT Imports: 30 Imported by: 0

Details

This section is empty.

This section is empty.

func NewAuditEventsStorage(db *gorm.DB, logger *logging.Logger) auditsvc.AuditEventsStorage

func NewAuditOutboxEventsOutbox(db *gorm.DB, processors []txoutbox.MessageProcessor) auditsvc.AuditOutboxEventsOutbox

func NewAuditRetentionSettingsStorage(db *gorm.DB, logger *logging.Logger) auditsvc.AuditRetentionSettingsStorage

func NewTableGenerators() table.GeneratorList

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

EventPageStorage lists audit events with row-offset pagination.

func NewEventPageStorage(db *gorm.DB) *EventPageStorage

func (s *EventPageStorage) FindPage(ctx context.Context, flt *auditservice.AuditEventFilter, offset, limit int) ([]*auditservice.AuditEvent, error)

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

PendingEventStorage moves pending audit events into a workspace.

func NewPendingEventStorage(db *gorm.DB) *PendingEventStorage

func (s *PendingEventStorage) AdoptPendingEvents(ctx context.Context, userID, workspaceID uuid.UUID, until time.Time) (int64, error)

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

RetentionStorage runs the bulk queries behind audit retention cleanup.

func NewRetentionStorage(db *gorm.DB) *RetentionStorage

func (s *RetentionStorage) DeleteOlderThan(ctx context.Context, workspaceID uuid.UUID, cutoff time.Time) (int64, error)

func (s *RetentionStorage) DistinctWorkspaceIDs(ctx context.Context) ([]uuid.UUID, error)

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

func NewStorages(db *gorm.DB, logger *logging.Logger, processors []txoutbox.MessageProcessor) *Storages

func (s Storages) AuditEvents() auditsvc.AuditEventsStorage

func (s Storages) AuditOutboxEvents() auditsvc.AuditOutboxEventsOutbox

func (s Storages) AuditRetentionSettings() auditsvc.AuditRetentionSettingsStorage

func (s Storages) ExecuteInTransaction(ctx context.Context, cb func(ctx context.Context, tx auditsvc.Storage) error) error

func (s Storages) IdempotencyKeys() idempotency.Storage

func (s *Storages) WithAdvisoryLock(ctx context.Context, scope string, lockID int64) error