jetstream

Documentation

Overview

Package jetstream implements a auditor that publishes audit logs to NATS JetStream

Audit messages are of the type https://choria.io/schemas/choria/signer/v1/signature_audit.json

Index

• type AuditorConfig
• type JetStream
  • func New(fw inter.Framework, c *AuditorConfig, site string) (auditor *JetStream, err error)
  • func (a *JetStream) Audit(act auditors.Action, caller string, req protocol.Request) error

Types

type AuditorConfig

type AuditorConfig struct {
	// ServerList is a comma sep list of JetStream servers in format nats://server:port,nats://server:port
	ServerList string `json:"servers"`

	// Topic is the topic to publish messages to
	Topic string `json:"topic"`
}

AuditorConfig configures the JetStream auditor

type JetStream

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

JetStream is a auditors.Auditor that publishes to NATS JetStream

func New

func New(fw inter.Framework, c *AuditorConfig, site string) (auditor *JetStream, err error)

New creates a new instance of the JetStream auditor

func (*JetStream) Audit

func (a *JetStream) Audit(act auditors.Action, caller string, req protocol.Request) error

Audit implements auditors.Auditor