exporter

package
v1.14.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 30, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

This section is empty.

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 added in v1.12.0

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

func NewLogExporter added in v1.12.0

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

func (*LogExporter) AddRecord added in v1.12.0

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

func (*LogExporter) Start added in v1.12.0

func (e *LogExporter) Start()

func (*LogExporter) Stop added in v1.12.0

func (e *LogExporter) Stop()

func (*LogExporter) UpdateOptions added in v1.12.0

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)

Directories

Path Synopsis
Code generated by MockGen.
Code generated by MockGen.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL