collectors

package
v1.6.4 Latest Latest
Warning

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

Go to latest
Published: Jan 27, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BPFCollector

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

BPFCollector dumps eBPF maps for diagnostic purposes

func NewBPFCollector

func NewBPFCollector(collection *bpf.Collection) *BPFCollector

NewBPFCollector creates a new eBPF map collector

func (*BPFCollector) Collect

func (c *BPFCollector) Collect(ctx context.Context) (interface{}, error)

func (*BPFCollector) Name

func (c *BPFCollector) Name() string

type ConfigCollector

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

ConfigCollector dumps runtime configuration state for diagnostics

func NewConfigCollector

func NewConfigCollector(
	ruleProvider ruleset.RuleProvider,
	bpfCollection *bpf.Collection,
	flags map[string]interface{},
	mgmtAddr string,
	ingressAddr string,
	bootstrapMode bool,
) *ConfigCollector

NewConfigCollector creates a new configuration collector

func (*ConfigCollector) Collect

func (c *ConfigCollector) Collect(ctx context.Context) (interface{}, error)

func (*ConfigCollector) Name

func (c *ConfigCollector) Name() string

type DNSCacheCollector

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

DNSCacheCollector dumps DNS cache from distributed map

func NewDNSCacheCollector

func NewDNSCacheCollector(resolvedHosts cluster.DMap) *DNSCacheCollector

NewDNSCacheCollector creates a new DNS cache collector

func (*DNSCacheCollector) Collect

func (c *DNSCacheCollector) Collect(ctx context.Context) (interface{}, error)

func (*DNSCacheCollector) Name

func (c *DNSCacheCollector) Name() string

type NATSCollector

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

NATSCollector dumps NATS JetStream state and KV buckets

func NewNATSCollector

func NewNATSCollector(server *natsserver.Server, js jetstream.JetStream) *NATSCollector

NewNATSCollector creates a new NATS state collector

func (*NATSCollector) Collect

func (c *NATSCollector) Collect(ctx context.Context) (interface{}, error)

func (*NATSCollector) Name

func (c *NATSCollector) Name() string

type NetworkCollector

type NetworkCollector struct{}

NetworkCollector dumps network interface state for diagnostics

func NewNetworkCollector

func NewNetworkCollector() *NetworkCollector

NewNetworkCollector creates a new network collector

func (*NetworkCollector) Collect

func (c *NetworkCollector) Collect(ctx context.Context) (interface{}, error)

func (*NetworkCollector) Name

func (c *NetworkCollector) Name() string

type PrometheusCollector

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

PrometheusCollector scrapes Prometheus metrics endpoint

func NewPrometheusCollector

func NewPrometheusCollector(metricsURL string) *PrometheusCollector

NewPrometheusCollector creates a new Prometheus metrics collector

func (*PrometheusCollector) Collect

func (c *PrometheusCollector) Collect(ctx context.Context) (interface{}, error)

func (*PrometheusCollector) Name

func (c *PrometheusCollector) Name() string

type TLSCollector

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

TLSCollector dumps TLS certificate metadata for diagnostics

func NewTLSCollector

func NewTLSCollector(caManager *ca.Manager) *TLSCollector

NewTLSCollector creates a new TLS certificate collector

func (*TLSCollector) Collect

func (c *TLSCollector) Collect(ctx context.Context) (interface{}, error)

func (*TLSCollector) Name

func (c *TLSCollector) Name() string

Jump to

Keyboard shortcuts

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