replayer

Documentation

Index

• type AuditEvent
• type AuditProcessor
  • func NewAuditProcessor(esConf *xsearch.ElasticSearchConf, ...) (*AuditProcessor, error)
  • func (auditProcessor *AuditProcessor) Start(stopCh <-chan struct{})
  • func (auditProcessor *AuditProcessor) Stop()

Types

type AuditEvent

type AuditEvent struct {
	Pod   *corev1.Pod
	Event *k8s_audit.Event
}

type AuditProcessor

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

func NewAuditProcessor

func NewAuditProcessor(
	esConf *xsearch.ElasticSearchConf,
	buffer, interval, traceTimeout time.Duration,
	cluster string, enableTrace bool) (*AuditProcessor, error)

NewAuditProcessor create new audit log processor

func (*AuditProcessor) Start

func (auditProcessor *AuditProcessor) Start(stopCh <-chan struct{})

Start satrt processing traces

func (*AuditProcessor) Stop

func (auditProcessor *AuditProcessor) Stop()