template

Documentation

Index

• func NewLeveledLogger(logger *zap.Logger) retryablehttp.LeveledLogger
• func NewSink(logger *zap.Logger, webhookTemplates []config.WebhookTemplate, ...) (audit.Sink, error)
• type Executer
  • func NewWebhookTemplate(logger *zap.Logger, url, body string, headers map[string]string, ...) (Executer, error)
• type LeveledLogger
  • func (l *LeveledLogger) Debug(msg string, keyvals ...interface{})
  • func (l *LeveledLogger) Error(msg string, keyvals ...interface{})
  • func (l *LeveledLogger) Info(msg string, keyvals ...interface{})
  • func (l *LeveledLogger) Warn(msg string, keyvals ...any)
• type Sink
  • func (t *Sink) Close() error
  • func (t *Sink) SendAudits(ctx context.Context, events []audit.Event) error
  • func (t *Sink) String() string

Functions

func NewLeveledLogger

func NewLeveledLogger(logger *zap.Logger) retryablehttp.LeveledLogger

func NewSink

func NewSink(logger *zap.Logger, webhookTemplates []config.WebhookTemplate, maxBackoffDuration time.Duration) (audit.Sink, error)

NewSink is the constructor for a Sink.

Types

type Executer

type Executer interface {
	Execute(context.Context, audit.Event) error
}

Executer will try and send the event to the configured URL with all of the parameters. It will send the request with the retyrable client.

func NewWebhookTemplate

func NewWebhookTemplate(logger *zap.Logger, url, body string, headers map[string]string, maxBackoffDuration time.Duration) (Executer, error)

NewWebhookTemplate is the constructor for a WebhookTemplate.

type LeveledLogger

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

func (*LeveledLogger) Debug

func (l *LeveledLogger) Debug(msg string, keyvals ...interface{})

func (*LeveledLogger) Error

func (l *LeveledLogger) Error(msg string, keyvals ...interface{})

func (*LeveledLogger) Info

func (l *LeveledLogger) Info(msg string, keyvals ...interface{})

func (*LeveledLogger) Warn

func (l *LeveledLogger) Warn(msg string, keyvals ...any)

type Sink

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

func (*Sink) Close

func (t *Sink) Close() error

func (*Sink) SendAudits

func (t *Sink) SendAudits(ctx context.Context, events []audit.Event) error

func (*Sink) String

func (t *Sink) String() string