exporter

package
v1.11.3 Latest Latest
Warning

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

Go to latest
Published: Sep 5, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

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 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
Package testing is a generated GoMock package.
Package testing is a generated GoMock package.

Jump to

Keyboard shortcuts

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