Merge remote-tracking branch 'origin/master' into pablosichert/source…

…s-exec-codec-integration

Signed-off-by: Pablo Sichert <mail@pablosichert.com>

.github/semantic.yml

@@ -122,6 +122,7 @@ scopes:
   - datadog_agent source # Anything `datadog_agent` source related
   - dnstap source # Anything `dnstap` source related
   - docker_logs source # Anything `docker_logs` source related
+  - exec source # Anything `exec` source related
   - file source # Anything `file` source related
   - fluent source # Anything `fluent` source related
   - generator source # Anything `generator` source related

.github/workflows/k8s_e2e.yml

@@ -93,7 +93,7 @@ jobs:
         || contains(github.event.pull_request.labels.*.name, 'ci-condition: k8s e2e tests enable')
         || contains(github.event.pull_request.labels.*.name, 'ci-condition: k8s e2e all targets')
     steps:
-      - uses: actions/github-script@v4.1
+      - uses: actions/github-script@v5
         id: set-matrix
         with:
           script: |

.github/workflows/test-harness.yml

@@ -18,7 +18,7 @@ jobs:
 
     steps:
     - name: Indicate that we picked up the command with a comment reaction
-      uses: actions/github-script@v4.1
+      uses: actions/github-script@v5
       with:
         github-token: '${{secrets.GITHUB_TOKEN}}'
         script: |
@@ -38,7 +38,7 @@ jobs:
 
     - name: Get Pull Request info
       id: pr-info
-      uses: actions/github-script@v4.1
+      uses: actions/github-script@v5
       with:
         script: |
           const pr_info_response = await github.pulls.get({
@@ -111,7 +111,7 @@ jobs:
         AWS_DEFAULT_REGION: '${{ secrets.TEST_HARNESS_AWS_DEFAULT_REGION }}'
 
     - name: Post a comment with the results
-      uses: actions/github-script@v4.1
+      uses: actions/github-script@v5
       with:
         github-token: '${{secrets.GITHUB_TOKEN}}'
         script: |

.github/workflows/test.yml

@@ -39,6 +39,8 @@ jobs:
         dependencies: ${{ steps.filter.outputs.dependencies }}
         internal_events: ${{ steps.filter.outputs.internal_events }}
         helm: ${{ steps.filter.outputs.helm }}
+        cue: ${{ steps.filter.outputs.cue }}
+        markdown: ${{ steps.filter.outputs.cue }}
       steps:
       - uses: actions/checkout@v2.3.4
       - uses: dorny/paths-filter@v2

CONTRIBUTING.md

@@ -0,0 +1 @@
+docs/CONTRIBUTING.md

Cargo.toml

@@ -240,7 +240,7 @@ lru = { version = "0.6.6", default-features = false, optional = true }
 maxminddb = { version = "0.21.0", default-features = false, optional = true }
 md-5 = { version = "0.9", optional = true }
 # make sure to update the external docs when the Lua version changes
-mlua = { version = "0.6.3", default-features = false, features = ["lua54", "send", "vendored"], optional = true }
+mlua = { version = "0.6.4", default-features = false, features = ["lua54", "send", "vendored"], optional = true }
 mongodb = { version = "2.0.0", default-features = false, features = ["tokio-runtime"], optional = true }
 async-nats = { version = "0.10.1", default-features = false, optional = true }
 no-proxy = { version  = "0.3.1", default-features = false, features = ["serialize"] }
@@ -272,7 +272,7 @@ strip-ansi-escapes = { version = "0.1.1", default-features = false }
 structopt = { version = "0.3.23", default-features = false }
 syslog = { version = "5.0.0", default-features = false, optional = true }
 syslog_loose = { version = "0.15.0", default-features = false, optional = true }
-tokio-postgres = { version = "0.7.2", default-features = false, features = ["runtime", "with-chrono-0_4"], optional = true }
+tokio-postgres = { version = "0.7.3", default-features = false, features = ["runtime", "with-chrono-0_4"], optional = true }
 toml = { version = "0.5.8", default-features = false }
 typetag = { version = "0.1.7", default-features = false }
 twox-hash = { version = "1.6.1", default-features = false }
@@ -294,7 +294,7 @@ security-framework = "2.3.1"
 
 [target.'cfg(unix)'.dependencies]
 atty = "0.2.14"
-nix = "0.22.1"
+nix = "0.22.2"
 
 [build-dependencies]
 prost-build = { version = "0.8", optional = true }
@@ -305,10 +305,10 @@ approx = "0.5.0"
 assert_cmd = "2.0.1"
 base64 = "0.13.0"
 criterion = { version = "0.3.5", features = ["html_reports", "async_tokio"] }
-libc = "0.2.102"
+libc = "0.2.103"
 libz-sys = "1.1.3"
 matches = "0.1.9"
-pretty_assertions = "0.7.2"
+pretty_assertions = "1.0.0"
 reqwest = { version = "0.11.4", features = ["json"] }
 tempfile = "3.2.0"
 tokio = { version = "1.12.0", features = ["test-util"] }

Makefile

@@ -678,7 +678,7 @@ check-kubernetes-yaml: ## Check that the generated Kubernetes YAML configs are u
 	${MAYBE_ENVIRONMENT_EXEC} ./scripts/kubernetes-yaml.sh check
 
 check-events: ## Check that events satisfy patterns set in https://github.com/timberio/vector/blob/master/rfcs/2020-03-17-2064-event-driven-observability.md
-	${MAYBE_ENVIRONMENT_EXEC} ./scripts/check-events.sh
+	${MAYBE_ENVIRONMENT_EXEC} ./scripts/check-events
 
 ##@ Rustdoc
 build-rustdoc: ## Build Vector's Rustdocs

README.md

@@ -19,7 +19,7 @@ pipeline that puts you in control of your observability data.
 [Collect][docs.sources], [transform][docs.transforms], and [route][docs.sinks]
 all your logs, metrics, and traces to any vendors you want today and any other
 vendors you may want tomorrow. Vector enables dramatic cost reduction, novel
-data enrichment, and data security where you need it, not where is most
+data enrichment, and data security where you need it, not where it is most
 convenient for your vendors. Additionally, it is open source and up to 10x
 faster than every alternative in the space.
 

benches/metrics_bench_util/mod.rs

@@ -36,7 +36,7 @@ fn disable_metrics_tracing_integration() {
 #[inline]
 fn boot() {
     vector::trace::init(false, false, "warn");
-    vector::metrics::init().expect("metrics initialization failed");
+    vector::metrics::init_test().expect("metrics initialization failed");
 }
 
 #[allow(dead_code)] // condition compilation
@@ -74,7 +74,7 @@ pub fn benchmark(c: &mut Criterion, mode: Mode) {
     boot();
     let metrics_core_enabled = mode != Mode::MetricsOff;
     assert_eq!(
-        vector::metrics::get_controller().is_ok(),
+        vector::metrics::Controller::get().is_ok(),
         metrics_core_enabled,
         "the presence of a controller must correspond to whether metrics core is on or off"
     );