sink

Documentation

Index

• Constants
• type BaseAuditSink
  • func (b *BaseAuditSink) Run(ctx context.Context, bus eventbus.EventBus)
• type Initializer
• type Interface
  • func NewLogBasedAuditSink(c *global.AuditConfiguration, _ metrics.MetricEmitter) Interface
• type LogBasedAuditSink
  • func (f *LogBasedAuditSink) GetBufferSize() int
  • func (f *LogBasedAuditSink) GetHandler() eventbus.ConsumeFunc
  • func (f *LogBasedAuditSink) GetName() string

Constants

const (
	SinkNameLogBased = "log"
)

Types

type BaseAuditSink

type BaseAuditSink struct {
	Interface
	// contains filtered or unexported fields
}

func (*BaseAuditSink) Run

func (b *BaseAuditSink) Run(ctx context.Context, bus eventbus.EventBus)

type Initializer

type Initializer func(conf *global.AuditConfiguration, emitter metrics.MetricEmitter) Interface

type Interface

type Interface interface {
	GetHandler() eventbus.ConsumeFunc
	GetName() string
	GetBufferSize() int
	Run(ctx context.Context, bus eventbus.EventBus)
}

func NewLogBasedAuditSink

func NewLogBasedAuditSink(c *global.AuditConfiguration, _ metrics.MetricEmitter) Interface

type LogBasedAuditSink

type LogBasedAuditSink struct {
	BaseAuditSink
	// contains filtered or unexported fields
}

func (*LogBasedAuditSink) GetBufferSize

func (f *LogBasedAuditSink) GetBufferSize() int

func (*LogBasedAuditSink) GetHandler

func (f *LogBasedAuditSink) GetHandler() eventbus.ConsumeFunc

func (*LogBasedAuditSink) GetName

func (f *LogBasedAuditSink) GetName() string