audit

Documentation

Index

• Constants
• func CreateConn(connectSocket bool) (createConn audit.CreateConn)
• func CreateOtelAuditMsg(ctx context.Context, r *http.Request, categoryDescription string, ...) msgs.Msg
• func GetOperationType(method string) msgs.OperationType
• type AuditClient
  • func NewOtelAuditClient(ctx context.Context, createConn audit.CreateConn, ...) (*AuditClient, error)
  • func (c *AuditClient) Send(ctx context.Context, msg msgs.Msg, options ...base.SendOption) error
• type Client
• type ResponseWriter
  • func NewResponseWriter(w http.ResponseWriter) *ResponseWriter
  • func (w *ResponseWriter) StatusCode() int
  • func (w *ResponseWriter) WriteHeader(statusCode int)

Constants

const (
	Unknown = "Unknown"

	MetricAuditLogRecordsTotal       = "otel_audit_log_records_total"
	MetricAuditLogSendErrorsTotal    = "otel_audit_log_send_errors_total"
	MetricAuditLogConnectionDegraded = "otel_audit_log_connection_degraded"
)

Functions

func CreateConn

func CreateConn(connectSocket bool) (createConn audit.CreateConn)

func CreateOtelAuditMsg

func CreateOtelAuditMsg(ctx context.Context, r *http.Request, categoryDescription string, accessLevel string, callerIdentities map[msgs.CallerIdentityType][]msgs.CallerIdentityEntry) msgs.Msg

func GetOperationType

func GetOperationType(method string) msgs.OperationType

Types

type AuditClient

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

func NewOtelAuditClient

func NewOtelAuditClient(ctx context.Context, createConn audit.CreateConn, registerer prometheus.Registerer, options ...base.Option) (*AuditClient, error)

NewOtelAuditClient creates an audit client that wraps the given connection factory with best-effort fallback. If the connection fails, it falls back to a no-op connection and sets the degraded gauge. Non-connection errors from the underlying audit library are returned to the caller.

func (*AuditClient) Send

func (c *AuditClient) Send(ctx context.Context, msg msgs.Msg, options ...base.SendOption) error

type Client

type Client interface {
	Send(ctx context.Context, msg msgs.Msg, options ...base.SendOption) error
}

type ResponseWriter

type ResponseWriter struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

ResponseWriter wraps http.ResponseWriter to capture the status code for audit logging.

func NewResponseWriter

func NewResponseWriter(w http.ResponseWriter) *ResponseWriter

func (*ResponseWriter) StatusCode

func (w *ResponseWriter) StatusCode() int

StatusCode returns the HTTP status code that was written. Returns http.StatusOK if WriteHeader was never called.

func (*ResponseWriter) WriteHeader

func (w *ResponseWriter) WriteHeader(statusCode int)