auditing

Documentation

Index

• Constants
• type AuditLog
  • func Previous(ctx context.Context, log *AuditLog) (*AuditLog, error)
  • func ProcessEventsFromAuditTrail(ctx context.Context, schema *proto.Schema, traceId string) ([]*AuditLog, error)

Constants

const (
	Insert = "insert"
	Update = "update"
	Delete = "delete"
)

Audit operations

const (
	ColumnId               = "id"
	ColumnTableName        = "table_name"
	ColumnOp               = "op"
	ColumnData             = "data"
	ColumnIdentityId       = "identity_id"
	ColumnTraceId          = "trace_id"
	ColumnCreatedAt        = "created_at"
	ColumnEventProcessedAt = "event_processed_at"
)

Audit table column names

const TableName = "keel_audit"

Audit table name

Types

type AuditLog

type AuditLog struct {
	Id               string
	TableName        string
	Op               string
	Data             map[string]any
	CreatedAt        time.Time
	EventProcessedAt time.Time
}

func Previous

func Previous(ctx context.Context, log *AuditLog) (*AuditLog, error)

Previous returns the previous log entry for the given data row.

func ProcessEventsFromAuditTrail

func ProcessEventsFromAuditTrail(ctx context.Context, schema *proto.Schema, traceId string) ([]*AuditLog, error)

ProcessEventsFromAuditTrail inspects the audit table for logs which need to be turned into events, updates their event_processed_at column, and then returns them.