audit

type Ctx ¶

type Ctx struct {
	ActorUserID *int64
	ActorName   string
	ActorSource string
	IP          string
	RequestID   string
}

func From(ctx context.Context) Ctx

type Pruner ¶

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

Pruner periodically deletes audit_log rows older than the configured retention.

func NewPruner(s *store.Store, interval time.Duration) *Pruner

func (p *Pruner) Loop(ctx context.Context)

func (p *Pruner) RunOnce(ctx context.Context) error

type Publisher ¶

type Publisher interface {
	Publish(ctx context.Context, e events.Event)
}

Publisher is the minimal interface the recorder needs to fan out realtime notifications. *events.Bus satisfies it. Optional: a nil publisher disables realtime emission without affecting audit_log writes.

type RecordReq ¶

type RecordReq struct {
	AppID            *int64
	AppSlug          string
	Category         string
	Action           string
	Before           []byte
	After            []byte
	Error            string
	ComposeVersionID *int64
}

RecordReq is the input to Recorder.Record.

type Recorder ¶

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

Recorder writes audit events to the DB-backed audit_log table.

func NewRecorder(s *store.Store) *Recorder

func (r *Recorder) Record(ctx context.Context, req RecordReq) (int64, error)

func (r *Recorder) SetBus(b Publisher)

func (r *Recorder) SetSyncTracking(on func() bool)