Files

codecs

common

length_delimited.rs mod.rs

decoding

format

avro.rs bytes.rs gelf.rs influxdb.rs json.rs mod.rs native.rs native_json.rs protobuf.rs syslog.rs vrl.rs

framing

bytes.rs character_delimited.rs chunked_gelf.rs length_delimited.rs mod.rs newline_delimited.rs octet_counting.rs

error.rs mod.rs

encoding

format

avro.rs cef.rs common.rs csv.rs gelf.rs json.rs logfmt.rs mod.rs native.rs native_json.rs protobuf.rs raw_message.rs text.rs

framing

bytes.rs character_delimited.rs length_delimited.rs mod.rs newline_delimited.rs

dnsmsg_parser

dns_message.rs dns_message_parser.rs ede.rs lib.rs

dnstap_parser

vrl_functions

mod.rs parse_dnstap.rs

internal_events.rs lib.rs parser.rs schema.rs

docs_renderer

main.rs renderer.rs

enrichment

find_enrichment_table_records.rs get_enrichment_table_record.rs lib.rs tables.rs vrl_util.rs

fakedata

file_source

file_watcher

paths_provider

buffer.rs checkpointer.rs file_server.rs fingerprinter.rs internal_events.rs lib.rs metadata_ext.rs

generate_avro_fixtures

generate-avro-fixtures.rs

k8s_e2e_tests

lib.rs metrics.rs

k8s_test_framework

exec_tail.rs framework.rs helm_values_file.rs interface.rs kubernetes_version.rs lib.rs lock.rs log_lookup.rs namespace.rs pod.rs port_forward.rs reader.rs resource_file.rs restart_rollout.rs temp_file.rs test_pod.rs up_down.rs util.rs vector.rs wait_for_resource.rs wait_for_rollout.rs

loki_logproto

opentelemetry_proto

convert.rs lib.rs proto.rs

portpicker

prometheus_parser

tracing_limit

vdev

commands

build

licenses.rs mod.rs publish_metadata.rs vector.rs vrl_wasm.rs

check

component_docs.rs component_features.rs deny.rs examples.rs fmt.rs licenses.rs markdown.rs mod.rs rust.rs scripts.rs

compose_tests

ci_paths.rs mod.rs show.rs start.rs stop.rs test.rs

config

set

e2e

ci_paths.rs mod.rs show.rs start.rs stop.rs test.rs

integration

ci_paths.rs mod.rs show.rs start.rs stop.rs test.rs

meta

install_git_hooks.rs mod.rs starship.rs

release

channel.rs github.rs homebrew.rs mod.rs prepare.rs push.rs

complete.rs crate_versions.rs exec.rs features.rs fmt.rs info.rs mod.rs package.rs run.rs status.rs test.rs test_vrl.rs version.rs

testing

config.rs integration.rs mod.rs runner.rs state.rs

app.rs config.rs features.rs git.rs macros.rs main.rs platform.rs util.rs

vector

api

schema

components

mod.rs sink.rs source.rs state.rs transform.rs

events

encoding.rs log.rs metric.rs mod.rs output.rs trace.rs

metrics

sink

generic.rs mod.rs

source

file.rs generic.rs mod.rs

transform

generic.rs mod.rs

allocated_bytes.rs errors.rs filter.rs host.rs mod.rs output.rs received_bytes.rs received_events.rs sent_bytes.rs sent_events.rs uptime.rs

filter.rs health.rs meta.rs mod.rs relay.rs sort.rs

handler.rs mod.rs server.rs

aws

auth.rs mod.rs region.rs timeout.rs

codecs

decoding

config.rs decoder.rs mod.rs

encoding

config.rs encoder.rs mod.rs transformer.rs

mod.rs ready_frames.rs

common

http

error.rs mod.rs server_auth.rs

datadog.rs expansion.rs mod.rs s3.rs sqs.rs

components

validation

resources

event.rs http.rs mod.rs

validators

component_spec

mod.rs sync.rs test_case.rs util.rs

conditions

datadog_search.rs is_log.rs is_metric.rs is_trace.rs mod.rs vrl.rs

config

loading

config_builder.rs loader.rs mod.rs secret.rs source.rs

unit_test

mod.rs unit_test_components.rs

api.rs builder.rs cmd.rs compiler.rs diff.rs dot_graph.rs enrichment_table.rs format.rs graph.rs mod.rs provider.rs schema.rs secret.rs sink.rs source.rs transform.rs validation.rs vars.rs watcher.rs

enrichment_tables

memory

config.rs internal_events.rs mod.rs table.rs

file.rs geoip.rs mmdb.rs mod.rs

internal_events

adaptive_concurrency.rs aggregate.rs amqp.rs apache_metrics.rs api.rs aws.rs aws_cloudwatch_logs.rs aws_ec2_metadata.rs aws_ecs_metrics.rs aws_kinesis.rs aws_kinesis_firehose.rs aws_sqs.rs batch.rs codecs.rs common.rs conditions.rs datadog_agent.rs datadog_metrics.rs datadog_traces.rs dedupe.rs demo_logs.rs dnstap.rs docker_logs.rs encoding_transcode.rs eventstoredb_metrics.rs exec.rs file.rs file_descriptor.rs filter.rs fluent.rs gcp_pubsub.rs grpc.rs heartbeat.rs host_metrics.rs http.rs http_client.rs http_client_source.rs influxdb.rs internal_logs.rs journald.rs kafka.rs kubernetes_logs.rs log_to_metric.rs logplex.rs loki.rs lua.rs metric_to_log.rs mod.rs mongodb_metrics.rs mqtt.rs nginx_metrics.rs open.rs parser.rs postgresql_metrics.rs prelude.rs process.rs prometheus.rs pulsar.rs redis.rs reduce.rs remap.rs sample.rs sematext_metrics.rs socket.rs splunk_hec.rs statsd_sink.rs tag_cardinality_limit.rs tcp.rs template.rs throttle.rs udp.rs unix.rs websocket.rs websocket_server.rs windows.rs

internal_telemetry

allocations

allocator

mod.rs stack.rs token.rs tracer.rs tracing.rs tracing_allocator.rs

kubernetes

meta_cache.rs mod.rs pod_manager_logic.rs reflector.rs

proto

mod.rs vector.rs

providers

secrets

aws_secrets_manager.rs directory.rs exec.rs file.rs mod.rs test.rs

sinks

amqp

config.rs encoder.rs mod.rs request_builder.rs service.rs sink.rs

appsignal

config.rs encoder.rs mod.rs normalizer.rs request_builder.rs service.rs sink.rs

aws_cloudwatch_logs

config.rs healthcheck.rs mod.rs request.rs request_builder.rs retry.rs service.rs sink.rs

aws_cloudwatch_metrics

aws_kinesis

firehose

config.rs mod.rs record.rs

streams

config.rs mod.rs record.rs

config.rs mod.rs record.rs request_builder.rs service.rs sink.rs

aws_s3

config.rs mod.rs sink.rs

aws_s_s

sns

client.rs config.rs mod.rs

sqs

client.rs config.rs mod.rs

client.rs config.rs mod.rs request_builder.rs retry.rs service.rs sink.rs

azure_blob

config.rs mod.rs request_builder.rs

azure_common

config.rs mod.rs service.rs sink.rs

azure_monitor_logs

config.rs mod.rs service.rs sink.rs

blackhole

config.rs mod.rs sink.rs

clickhouse

config.rs mod.rs request_builder.rs service.rs sink.rs

console

config.rs mod.rs sink.rs

databend

compression.rs config.rs encoding.rs mod.rs request_builder.rs service.rs sink.rs

datadog

events

config.rs mod.rs request_builder.rs service.rs sink.rs

logs

config.rs mod.rs service.rs sink.rs

metrics

config.rs encoder.rs mod.rs normalizer.rs request_builder.rs service.rs sink.rs

traces

apm_stats

aggregation.rs bucket.rs flusher.rs mod.rs weight.rs

config.rs mod.rs request_builder.rs service.rs sink.rs

elasticsearch

common.rs config.rs encoder.rs health.rs mod.rs request_builder.rs retry.rs service.rs sink.rs

file

bytes_path.rs mod.rs

gcp

stackdriver

logs

config.rs encoder.rs mod.rs request_builder.rs service.rs sink.rs

metrics

config.rs mod.rs request_builder.rs sink.rs

cloud_storage.rs mod.rs pubsub.rs

gcp_chronicle

chronicle_unstructured.rs compression.rs mod.rs partitioner.rs sink.rs

gcs_common

config.rs mod.rs service.rs sink.rs

greptimedb

logs

config.rs http_request_builder.rs mod.rs sink.rs

metrics

batch.rs config.rs mod.rs request.rs request_builder.rs service.rs sink.rs

honeycomb

config.rs encoder.rs mod.rs request_builder.rs service.rs sink.rs

http

batch.rs config.rs encoder.rs mod.rs request_builder.rs service.rs sink.rs

humio

logs.rs metrics.rs mod.rs

influxdb

logs.rs metrics.rs mod.rs

kafka

config.rs mod.rs request_builder.rs service.rs sink.rs tests.rs

keep

config.rs encoder.rs mod.rs request_builder.rs service.rs sink.rs

loki

config.rs event.rs healthcheck.rs mod.rs service.rs sink.rs

mqtt

config.rs mod.rs request_builder.rs service.rs sink.rs

nats

config.rs mod.rs request_builder.rs service.rs sink.rs

new_relic

config.rs encoding.rs healthcheck.rs mod.rs model.rs service.rs sink.rs

opentelemetry

postgres

config.rs mod.rs service.rs sink.rs

prometheus

remote_write

config.rs mod.rs request_builder.rs service.rs sink.rs

collector.rs exporter.rs mod.rs

pulsar

config.rs encoder.rs mod.rs request_builder.rs service.rs sink.rs util.rs

redis

config.rs mod.rs request_builder.rs service.rs sink.rs

s3_common

config.rs mod.rs partitioner.rs service.rs sink.rs

sematext

logs.rs metrics.rs mod.rs

splunk_hec

common

acknowledgements.rs mod.rs request.rs response.rs service.rs util.rs

logs

config.rs encoder.rs mod.rs request_builder.rs sink.rs

metrics

config.rs encoder.rs mod.rs request_builder.rs sink.rs

statsd

batch.rs config.rs encoder.rs mod.rs normalizer.rs request_builder.rs service.rs sink.rs

util

adaptive_concurrency

controller.rs future.rs layer.rs mod.rs semaphore.rs service.rs

buffer

metrics

mod.rs normalize.rs split.rs

compression.rs json.rs mod.rs partition.rs vec.rs

service

net

mod.rs tcp.rs udp.rs unix.rs

concurrency.rs health.rs map.rs

auth.rs batch.rs builder.rs compressor.rs datagram.rs encoding.rs http.rs metadata.rs mod.rs normalizer.rs partitioner.rs processed_event.rs request_builder.rs retries.rs service.rs sink.rs snappy.rs socket_bytes_sink.rs statistic.rs tcp.rs udp.rs unix.rs uri.rs zstd.rs

vector

config.rs mod.rs service.rs sink.rs

webhdfs

config.rs mod.rs

websocket

config.rs mod.rs sink.rs

websocket_server

buffering.rs config.rs mod.rs sink.rs

axiom.rs mezmo.rs mod.rs opendal_common.rs papertrail.rs prelude.rs socket.rs

source_sender

errors.rs mod.rs

sources

apache_metrics

mod.rs parser.rs

aws_ecs_metrics

mod.rs parser.rs

aws_kinesis_firehose

errors.rs filters.rs handlers.rs mod.rs models.rs

aws_s3

aws_sqs

config.rs mod.rs source.rs

datadog_agent

logs.rs metrics.rs mod.rs traces.rs

dnstap

mod.rs tcp.rs unix.rs

docker_logs

eventstoredb_metrics

mod.rs types.rs

exec

file_descriptors

file_descriptor.rs mod.rs stdin.rs

fluent

message.rs mod.rs

host_metrics

cgroups.rs cpu.rs disk.rs filesystem.rs memory.rs mod.rs network.rs process.rs tcp.rs

http_client

client.rs mod.rs

kubernetes_logs

parser

cri.rs docker.rs mod.rs

transform_utils

mod.rs optional.rs

k8s_paths_provider.rs lifecycle.rs mod.rs namespace_metadata_annotator.rs node_metadata_annotator.rs partial_events_merger.rs path_helpers.rs pod_metadata_annotator.rs util.rs

mongodb_metrics

mod.rs types.rs

nginx_metrics

mod.rs parser.rs

opentelemetry

grpc.rs http.rs mod.rs reply.rs status.rs

prometheus

mod.rs parser.rs pushgateway.rs remote_write.rs scrape.rs

redis

channel.rs list.rs mod.rs

socket

mod.rs tcp.rs udp.rs unix.rs

splunk_hec

acknowledgements.rs mod.rs

statsd

mod.rs parser.rs unix.rs

util

grpc

decompression.rs mod.rs

http

encoding.rs headers.rs method.rs mod.rs prelude.rs query.rs

net

tcp

mod.rs request_limiter.rs

body_decoding.rs encoding_config.rs framestream.rs http_client.rs message_decoding.rs mod.rs multiline_config.rs unix.rs unix_datagram.rs unix_stream.rs wrappers.rs

vector

amqp.rs demo_logs.rs file.rs gcp_pubsub.rs heroku_logs.rs http_server.rs internal_logs.rs internal_metrics.rs journald.rs kafka.rs logstash.rs mod.rs nats.rs postgresql_metrics.rs pulsar.rs static_metrics.rs syslog.rs

tap

test_util

compression.rs mod.rs

top

cmd.rs dashboard.rs events.rs metrics.rs mod.rs state.rs

topology

builder.rs controller.rs mod.rs ready_arrays.rs running.rs schema.rs task.rs

transforms

dedupe

config.rs mod.rs transform.rs

exclusive_route

config.rs mod.rs transform.rs

lua

v1

v2

reduce

config.rs merge_strategy.rs mod.rs transform.rs

sample

config.rs mod.rs transform.rs

tag_cardinality_limit

config.rs mod.rs tag_value_set.rs

throttle

config.rs mod.rs rate_limiter.rs transform.rs

aggregate.rs aws_ec2_metadata.rs filter.rs log_to_metric.rs metric_to_log.rs mod.rs remap.rs route.rs

amqp.rs app.rs async_read.rs cli.rs convert_config.rs dns.rs docker.rs encoding_transcode.rs expiring_hash_map.rs extra_context.rs gcp.rs generate.rs generate_schema.rs graph.rs heartbeat.rs http.rs kafka.rs lib.rs line_agg.rs list.rs nats.rs net.rs serde.rs signal.rs sink_ext.rs stats.rs template.rs trace.rs types.rs unit_test.rs utilization.rs validate.rs

vector_api_client

gql

components.rs health.rs meta.rs metrics.rs mod.rs tap.rs

test

client.rs lib.rs subscription.rs

vector_buffers

topology

channel

limited_queue.rs mod.rs receiver.rs sender.rs

acks.rs builder.rs mod.rs

variants

disk_v2

backed_archive.rs common.rs io.rs ledger.rs mod.rs reader.rs record.rs ser.rs writer.rs

in_memory.rs mod.rs

buffer_usage_data.rs config.rs encoding.rs internal_events.rs lib.rs

vector_common

internal_event

bytes_received.rs bytes_sent.rs cached_event.rs component_events_dropped.rs events_received.rs events_sent.rs mod.rs optional_tag.rs prelude.rs service.rs

byte_size_of.rs config.rs constants.rs event_data_eq.rs finalization.rs finalizer.rs id.rs json_size.rs lib.rs request_metadata.rs sensitive_string.rs shutdown.rs trigger.rs

vector_config

component

description.rs generate.rs marker.rs mod.rs

external

chrono.rs datetime.rs encoding_rs.rs indexmap.rs mod.rs no_proxy.rs serde_with.rs toml.rs tz.rs url.rs vrl.rs

schema

parser

component.rs mod.rs query.rs

visitors

human_name.rs inline_single.rs merge.rs mod.rs scoped_visit.rs unevaluated.rs

helpers.rs mod.rs

configurable.rs errors.rs http.rs lib.rs metadata.rs named.rs num.rs ser.rs stdlib.rs str.rs

vector_config_common

schema

gen.rs json_schema.rs mod.rs visit.rs

attributes.rs constants.rs human_friendly.rs lib.rs num.rs validation.rs

vector_config_macros

ast

container.rs field.rs mod.rs util.rs variant.rs

attrs.rs component_name.rs configurable.rs configurable_component.rs lib.rs

vector_core

config

global_options.rs log_schema.rs mod.rs output_id.rs proxy.rs telemetry.rs

event

lua

event.rs log.rs metric.rs mod.rs util.rs

metric

data.rs mod.rs series.rs tags.rs value.rs

util

log

all_fields.rs keys.rs mod.rs

array.rs discriminant.rs estimated_json_encoded_size_of.rs log_event.rs merge_state.rs metadata.rs mod.rs proto.rs ref.rs ser.rs trace.rs vrl_target.rs

metrics

ddsketch.rs label_filter.rs mod.rs recency.rs recorder.rs storage.rs

schema

definition.rs meaning.rs mod.rs requirement.rs

tls

incoming.rs maybe_tls.rs mod.rs outgoing.rs settings.rs

transform

runtime_transform

mod.rs vec_stream.rs

fanout.rs ipallowlist.rs lib.rs partition.rs serde.rs sink.rs source.rs tcp.rs time.rs vrl.rs

vector_lib

vector_lookup

lookup_v2

mod.rs optional_path.rs

vector_stream

batcher

config.rs data.rs limiter.rs mod.rs

concurrent_map.rs driver.rs expiration_map.rs futures_unordered_count.rs lib.rs partitioned_batcher.rs

vector_tap

controller.rs lib.rs notification.rs topology.rs

vector_vrl_cli

vector_vrl_functions

get_secret.rs lib.rs remove_secret.rs set_secret.rs set_semantic_meaning.rs

vector_vrl_tests

docs.rs main.rs test_enrichment.rs

vector_vrl_web_playground

vector/components/
mod.rs

Settings

Help

1
2

#![allow(missing_docs)]
pub mod validation;