Versions in this module Expand all Collapse all v0 v0.2.0 Oct 3, 2026 v0.1.0 Oct 1, 2026 Changes in this version + var ErrNotFound = errors.New("audit entry not found") + func JobIDFrom(ctx context.Context) string + func RecordJobID(ctx context.Context, jobID string) + func Summarize(body []byte, contentType string) string + func WithJobIDSink(ctx context.Context) context.Context + type Entry struct + DurationMs int64 + ID string + JobID string + Method string + OperationID string + Path string + RequestSummary string + ResponseCode int + Roles []string + SourceIP string + Timestamp time.Time + TraceID string + User string + type Publisher interface + Publish func(ctx context.Context, subject string, data []byte) error + type Store interface + Get func(ctx context.Context, id string) (*Entry, error) + List func(ctx context.Context, limit int, offset int) ([]Entry, int, error) + ListAll func(ctx context.Context) ([]Entry, error) + Write func(ctx context.Context, entry Entry) error + type StreamStore struct + func NewStreamStore(logger *slog.Logger, stream jetstream.Stream, publisher Publisher, ...) *StreamStore + func (s *StreamStore) Get(ctx context.Context, id string) (*Entry, error) + func (s *StreamStore) List(ctx context.Context, limit int, offset int) ([]Entry, int, error) + func (s *StreamStore) ListAll(ctx context.Context) ([]Entry, error) + func (s *StreamStore) Write(ctx context.Context, entry Entry) error
Go to main page