exporter

Documentation

Index

• Constants
• type ClickHouseExporter
  • func NewClickHouseExporter(k8sClient kubernetes.Interface, opt *options.Options) (*ClickHouseExporter, error)
  • func (e *ClickHouseExporter) AddRecord(record ipfixentities.Record, isRecordIPv6 bool) error
  • func (e *ClickHouseExporter) Start()
  • func (e *ClickHouseExporter) Stop()
  • func (e *ClickHouseExporter) UpdateOptions(opt *options.Options)
• type IPFIXExporter
  • func NewIPFIXExporter(k8sClient kubernetes.Interface, opt *options.Options, ...) *IPFIXExporter
  • func (e *IPFIXExporter) AddRecord(record ipfixentities.Record, isRecordIPv6 bool) error
  • func (e *IPFIXExporter) Start()
  • func (e *IPFIXExporter) Stop()
  • func (e *IPFIXExporter) UpdateOptions(opt *options.Options)
• type Interface
• type LogExporter
  • func NewLogExporter(opt *options.Options) (*LogExporter, error)
  • func (e *LogExporter) AddRecord(record ipfixentities.Record, isRecordIPv6 bool) error
  • func (e *LogExporter) Start()
  • func (e *LogExporter) Stop()
  • func (e *LogExporter) UpdateOptions(opt *options.Options)
• type S3Exporter
  • func NewS3Exporter(k8sClient kubernetes.Interface, opt *options.Options) (*S3Exporter, error)
  • func (e *S3Exporter) AddRecord(record ipfixentities.Record, isRecordIPv6 bool) error
  • func (e *S3Exporter) Start()
  • func (e *S3Exporter) Stop()
  • func (e *S3Exporter) UpdateOptions(opt *options.Options)

Constants

const (
	CACertFile      = "ca.crt"
	CertDir         = "/etc/flow-aggregator/certs"
	DefaultInterval = 1 * time.Second
	Timeout         = 1 * time.Minute
)

Types

type ClickHouseExporter

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

func NewClickHouseExporter

func NewClickHouseExporter(k8sClient kubernetes.Interface, opt *options.Options) (*ClickHouseExporter, error)

func (*ClickHouseExporter) AddRecord

func (e *ClickHouseExporter) AddRecord(record ipfixentities.Record, isRecordIPv6 bool) error

func (*ClickHouseExporter) Start

func (e *ClickHouseExporter) Start()

func (*ClickHouseExporter) Stop

func (e *ClickHouseExporter) Stop()

func (*ClickHouseExporter) UpdateOptions

func (e *ClickHouseExporter) UpdateOptions(opt *options.Options)

type IPFIXExporter

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

func NewIPFIXExporter

func NewIPFIXExporter(
	k8sClient kubernetes.Interface,
	opt *options.Options,
	registry ipfix.IPFIXRegistry,
) *IPFIXExporter

func (*IPFIXExporter) AddRecord

func (e *IPFIXExporter) AddRecord(record ipfixentities.Record, isRecordIPv6 bool) error

func (*IPFIXExporter) Start

func (e *IPFIXExporter) Start()

func (*IPFIXExporter) Stop

func (e *IPFIXExporter) Stop()

func (*IPFIXExporter) UpdateOptions

func (e *IPFIXExporter) UpdateOptions(opt *options.Options)

type Interface

type Interface interface {
	Start()
	Stop()
	AddRecord(record ipfixentities.Record, isRecordIPv6 bool) error
	UpdateOptions(opt *options.Options)
}

Interface is the interface that all supported exporters must implement. Note that the objects implementing this interface make no concurrency guarantee: none of the interface functions should be called concurrently.

type LogExporter

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

func NewLogExporter

func NewLogExporter(opt *options.Options) (*LogExporter, error)

func (*LogExporter) AddRecord

func (e *LogExporter) AddRecord(record ipfixentities.Record, isRecordIPv6 bool) error

func (*LogExporter) Start

func (e *LogExporter) Start()

func (*LogExporter) Stop

func (e *LogExporter) Stop()

func (*LogExporter) UpdateOptions

func (e *LogExporter) UpdateOptions(opt *options.Options)

type S3Exporter

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

func NewS3Exporter

func NewS3Exporter(k8sClient kubernetes.Interface, opt *options.Options) (*S3Exporter, error)

func (*S3Exporter) AddRecord

func (e *S3Exporter) AddRecord(record ipfixentities.Record, isRecordIPv6 bool) error

func (*S3Exporter) Start

func (e *S3Exporter) Start()

func (*S3Exporter) Stop

func (e *S3Exporter) Stop()

func (*S3Exporter) UpdateOptions

func (e *S3Exporter) UpdateOptions(opt *options.Options)