kubernetesauditacquisition

Documentation

Index

• type KubernetesAuditConfiguration
• type KubernetesAuditSource
  • func (ka *KubernetesAuditSource) CanRun() error
  • func (ka *KubernetesAuditSource) Configure(config []byte, logger *log.Entry, MetricsLevel int) error
  • func (ka *KubernetesAuditSource) ConfigureByDSN(dsn string, labels map[string]string, logger *log.Entry, uuid string) error
  • func (ka *KubernetesAuditSource) Dump() interface{}
  • func (ka *KubernetesAuditSource) GetAggregMetrics() []prometheus.Collector
  • func (ka *KubernetesAuditSource) GetMetrics() []prometheus.Collector
  • func (ka *KubernetesAuditSource) GetMode() string
  • func (ka *KubernetesAuditSource) GetName() string
  • func (ka *KubernetesAuditSource) GetUuid() string
  • func (ka *KubernetesAuditSource) OneShotAcquisition(out chan types.Event, t *tomb.Tomb) error
  • func (ka *KubernetesAuditSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) error
  • func (ka *KubernetesAuditSource) UnmarshalConfig(yamlConfig []byte) error

Types

type KubernetesAuditConfiguration

type KubernetesAuditConfiguration struct {
	ListenAddr                        string `yaml:"listen_addr"`
	ListenPort                        int    `yaml:"listen_port"`
	WebhookPath                       string `yaml:"webhook_path"`
	configuration.DataSourceCommonCfg `yaml:",inline"`
}

type KubernetesAuditSource

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

func (*KubernetesAuditSource) CanRun

func (ka *KubernetesAuditSource) CanRun() error

func (*KubernetesAuditSource) Configure

func (ka *KubernetesAuditSource) Configure(config []byte, logger *log.Entry, MetricsLevel int) error

func (*KubernetesAuditSource) ConfigureByDSN

func (ka *KubernetesAuditSource) ConfigureByDSN(dsn string, labels map[string]string, logger *log.Entry, uuid string) error

func (*KubernetesAuditSource) Dump

func (ka *KubernetesAuditSource) Dump() interface{}

func (*KubernetesAuditSource) GetAggregMetrics

func (ka *KubernetesAuditSource) GetAggregMetrics() []prometheus.Collector

func (*KubernetesAuditSource) GetMetrics

func (ka *KubernetesAuditSource) GetMetrics() []prometheus.Collector

func (*KubernetesAuditSource) GetMode

func (ka *KubernetesAuditSource) GetMode() string

func (*KubernetesAuditSource) GetName

func (ka *KubernetesAuditSource) GetName() string

func (*KubernetesAuditSource) GetUuid

func (ka *KubernetesAuditSource) GetUuid() string

func (*KubernetesAuditSource) OneShotAcquisition

func (ka *KubernetesAuditSource) OneShotAcquisition(out chan types.Event, t *tomb.Tomb) error

func (*KubernetesAuditSource) StreamingAcquisition

func (ka *KubernetesAuditSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) error

func (*KubernetesAuditSource) UnmarshalConfig

func (ka *KubernetesAuditSource) UnmarshalConfig(yamlConfig []byte) error