stream

type StreamItem struct {
	Event     *events.Event           `json:"event,omitempty"`
	SelfAudit *storage.SelfAuditEntry `json:"self_audit,omitempty"`
}

type Target interface {
	// Name returns the name of the stream target.
	Name() string
	// Type returns the type identifier of the stream target.
	Type() string
	// Enabled returns true if the target is enabled.
	Enabled() bool
	// Send sends the stream items to the target.
	Send(ctx context.Context, items []StreamItem) error
	// Close allows the target to clean up any resources.
	Close() error
}