diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-07-24 09:54:23 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-07-24 09:54:44 +0000 |
| commit | 836b47cb7e99a977c5a23b059ca1d0b5065d310e (patch) | |
| tree | 1604da8f482d02effa033c94a84be42bc0c848c3 /fluent-bit/examples | |
| parent | Releasing debian version 1.44.3-2. (diff) | |
| download | netdata-836b47cb7e99a977c5a23b059ca1d0b5065d310e.tar.xz netdata-836b47cb7e99a977c5a23b059ca1d0b5065d310e.zip | |
Merging upstream version 1.46.3.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'fluent-bit/examples')
54 files changed, 0 insertions, 1911 deletions
diff --git a/fluent-bit/examples/CMakeLists.txt b/fluent-bit/examples/CMakeLists.txt deleted file mode 100644 index 92f98d4f1..000000000 --- a/fluent-bit/examples/CMakeLists.txt +++ /dev/null @@ -1,5 +0,0 @@ -add_subdirectory(hello_world) -if(FLB_OUT_LIB) - add_subdirectory(out_lib) -endif() - diff --git a/fluent-bit/examples/filter_rust/Cargo.lock b/fluent-bit/examples/filter_rust/Cargo.lock deleted file mode 100644 index 267887091..000000000 --- a/fluent-bit/examples/filter_rust/Cargo.lock +++ /dev/null @@ -1,219 +0,0 @@ -# This file is automatically @generated by Cargo. -# It is not intended for manual editing. -version = 3 - -[[package]] -name = "autocfg" -version = "1.1.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "d468802bab17cbc0cc575e9b053f41e72aa36bfa6b7f55e3529ffa43161b97fa" - -[[package]] -name = "byteorder" -version = "1.4.3" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "14c189c53d098945499cdfa7ecc63567cf3886b3332b312a5b4585d8d3a6a610" - -[[package]] -name = "chrono" -version = "0.4.19" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "670ad68c9088c2a963aaa298cb369688cf3f9465ce5e2d4ca10e6e0098a1ce73" -dependencies = [ - "libc", - "num-integer", - "num-traits", - "time", - "winapi", -] - -[[package]] -name = "filter_rust" -version = "0.1.0" -dependencies = [ - "chrono", - "libc", - "rmp-serde", - "serde", - "serde_bytes", - "serde_json", -] - -[[package]] -name = "itoa" -version = "1.0.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "112c678d4050afce233f4f2852bb2eb519230b3cf12f33585275537d7e41578d" - -[[package]] -name = "libc" -version = "0.2.126" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "349d5a591cd28b49e1d1037471617a32ddcda5731b99419008085f72d5a53836" - -[[package]] -name = "num-integer" -version = "0.1.45" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "225d3389fb3509a24c93f5c29eb6bde2586b98d9f016636dff58d7c6f7569cd9" -dependencies = [ - "autocfg", - "num-traits", -] - -[[package]] -name = "num-traits" -version = "0.2.15" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "578ede34cf02f8924ab9447f50c28075b4d3e5b269972345e7e0372b38c6cdcd" -dependencies = [ - "autocfg", -] - -[[package]] -name = "paste" -version = "1.0.7" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "0c520e05135d6e763148b6426a837e239041653ba7becd2e538c076c738025fc" - -[[package]] -name = "proc-macro2" -version = "1.0.42" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c278e965f1d8cf32d6e0e96de3d3e79712178ae67986d9cf9151f51e95aac89b" -dependencies = [ - "unicode-ident", -] - -[[package]] -name = "quote" -version = "1.0.20" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3bcdf212e9776fbcb2d23ab029360416bb1706b1aea2d1a5ba002727cbcab804" -dependencies = [ - "proc-macro2", -] - -[[package]] -name = "rmp" -version = "0.8.11" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "44519172358fd6d58656c86ab8e7fbc9e1490c3e8f14d35ed78ca0dd07403c9f" -dependencies = [ - "byteorder", - "num-traits", - "paste", -] - -[[package]] -name = "rmp-serde" -version = "1.1.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "25786b0d276110195fa3d6f3f31299900cf71dfbd6c28450f3f58a0e7f7a347e" -dependencies = [ - "byteorder", - "rmp", - "serde", -] - -[[package]] -name = "ryu" -version = "1.0.10" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f3f6f92acf49d1b98f7a81226834412ada05458b7364277387724a237f062695" - -[[package]] -name = "serde" -version = "1.0.140" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "fc855a42c7967b7c369eb5860f7164ef1f6f81c20c7cc1141f2a604e18723b03" -dependencies = [ - "serde_derive", -] - -[[package]] -name = "serde_bytes" -version = "0.11.6" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "212e73464ebcde48d723aa02eb270ba62eff38a9b732df31f33f1b4e145f3a54" -dependencies = [ - "serde", -] - -[[package]] -name = "serde_derive" -version = "1.0.140" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6f2122636b9fe3b81f1cb25099fcf2d3f542cdb1d45940d56c713158884a05da" -dependencies = [ - "proc-macro2", - "quote", - "syn", -] - -[[package]] -name = "serde_json" -version = "1.0.82" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "82c2c1fdcd807d1098552c5b9a36e425e42e9fbd7c6a37a8425f390f781f7fa7" -dependencies = [ - "itoa", - "ryu", - "serde", -] - -[[package]] -name = "syn" -version = "1.0.98" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c50aef8a904de4c23c788f104b7dddc7d6f79c647c7c8ce4cc8f73eb0ca773dd" -dependencies = [ - "proc-macro2", - "quote", - "unicode-ident", -] - -[[package]] -name = "time" -version = "0.1.44" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6db9e6914ab8b1ae1c260a4ae7a49b6c5611b40328a735b21862567685e73255" -dependencies = [ - "libc", - "wasi", - "winapi", -] - -[[package]] -name = "unicode-ident" -version = "1.0.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "15c61ba63f9235225a22310255a29b806b907c9b8c964bcbd0a2c70f3f2deea7" - -[[package]] -name = "wasi" -version = "0.10.0+wasi-snapshot-preview1" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "1a143597ca7c7793eff794def352d41792a93c481eb1042423ff7ff72ba2c31f" - -[[package]] -name = "winapi" -version = "0.3.9" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5c839a674fcd7a98952e593242ea400abe93992746761e38641405d28b00f419" -dependencies = [ - "winapi-i686-pc-windows-gnu", - "winapi-x86_64-pc-windows-gnu", -] - -[[package]] -name = "winapi-i686-pc-windows-gnu" -version = "0.4.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ac3b87c63620426dd9b991e5ce0329eff545bccbbb34f3be09ff6fb6ab51b7b6" - -[[package]] -name = "winapi-x86_64-pc-windows-gnu" -version = "0.4.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f" diff --git a/fluent-bit/examples/filter_rust/Cargo.toml b/fluent-bit/examples/filter_rust/Cargo.toml deleted file mode 100644 index 924c9bdfc..000000000 --- a/fluent-bit/examples/filter_rust/Cargo.toml +++ /dev/null @@ -1,15 +0,0 @@ -[package] -name = "filter_rust" -version = "0.1.0" -edition = "2021" - -[lib] -crate-type = ["cdylib"] - -[dependencies] -serde = { version = "*", features = ["derive"] } -serde_json = "1.0" -serde_bytes = "0.11" -rmp-serde = "1.1" -chrono = "0.4" -libc = "0.2" diff --git a/fluent-bit/examples/filter_rust/README.md b/fluent-bit/examples/filter_rust/README.md deleted file mode 100644 index f1f3841a6..000000000 --- a/fluent-bit/examples/filter_rust/README.md +++ /dev/null @@ -1,59 +0,0 @@ -# Fluent Bit / filter_rust - -This source source tree provides an example of WASM program with WASI mode mainly written in Rust. - -## Prerequisites - -* Rust - * rustc 1.61.0 (fe5b13d68 2022-05-18) -* [rustup](https://rustup.rs/) (For preparing rust compiler and toolchains) - -## How to build - -Add `wasm32-unknown-unknown` target for Rust toolchain: - -```console -$ rustup target add wasm32-unknown-unknown -``` - -Then, execute _cargo build_ as follows: - -```console -$ cargo build --target wasm32-unknown-unknown --release -``` - -Finally, `*.wasm` file will be created: - -```console -$ ls target/wasm32-unknown-unknown/release/*.wasm -target/wasm32-unknown-unknown/release/filter_rust.wasm -``` - -## How to confirm WASM filter integration - -Create fluent-bit configuration file as follows: - -```ini -[SERVICE] - Flush 1 - Daemon Off - Log_Level info - HTTP_Server Off - HTTP_Listen 0.0.0.0 - HTTP_Port 2020 - -[INPUT] - Name dummy - Tag dummy.local - -[FILTER] - Name wasm - match dummy.* - WASM_Path /path/to/filter_rust.wasm - Function_Name rust_filter - accessible_paths .,/path/to/fluent-bit - -[OUTPUT] - Name stdout - Match * -``` diff --git a/fluent-bit/examples/filter_rust/src/lib.rs b/fluent-bit/examples/filter_rust/src/lib.rs deleted file mode 100644 index c409ba53a..000000000 --- a/fluent-bit/examples/filter_rust/src/lib.rs +++ /dev/null @@ -1,32 +0,0 @@ -// Import pure and fast JSON library written in Rust -use serde_json::json; -use serde_json::Value; -// Import chrono library to handle time related operation conveniently -use chrono::{Utc, TimeZone}; -use std::slice; -use std::str; -use std::os::raw::c_char; -use std::io::Write; - -#[no_mangle] -pub extern "C" fn rust_filter(tag: *const c_char, tag_len: u32, time_sec: u32, time_nsec: u32, record: *const c_char, record_len: u32) -> *const u8 { - let slice_tag: &[u8] = unsafe { slice::from_raw_parts(tag as *const u8, tag_len as usize) }; - let slice_record: &[u8] = unsafe { slice::from_raw_parts(record as *const u8, record_len as usize) }; - let mut vt: Vec<u8> = Vec::new(); - vt.write(slice_tag).expect("Unable to write"); - let vtag = str::from_utf8(&vt).unwrap(); - let v: Value = serde_json::from_slice(slice_record).unwrap(); - let dt = Utc.timestamp(time_sec as i64, time_nsec); - let time = dt.format("%Y-%m-%dT%H:%M:%S.%9f %z").to_string(); - - let message = json!({ - "message": v["message"], - "time": format!("{}", time), - "tag": vtag, - "original": v.to_string(), - "lang": "Rust", - }); - - let buf: String = message.to_string(); - buf.as_ptr() -} diff --git a/fluent-bit/examples/filter_rust_clib/Cargo.lock b/fluent-bit/examples/filter_rust_clib/Cargo.lock deleted file mode 100644 index 577860a85..000000000 --- a/fluent-bit/examples/filter_rust_clib/Cargo.lock +++ /dev/null @@ -1,219 +0,0 @@ -# This file is automatically @generated by Cargo. -# It is not intended for manual editing. -version = 3 - -[[package]] -name = "autocfg" -version = "1.1.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "d468802bab17cbc0cc575e9b053f41e72aa36bfa6b7f55e3529ffa43161b97fa" - -[[package]] -name = "byteorder" -version = "1.4.3" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "14c189c53d098945499cdfa7ecc63567cf3886b3332b312a5b4585d8d3a6a610" - -[[package]] -name = "chrono" -version = "0.4.19" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "670ad68c9088c2a963aaa298cb369688cf3f9465ce5e2d4ca10e6e0098a1ce73" -dependencies = [ - "libc", - "num-integer", - "num-traits", - "time", - "winapi", -] - -[[package]] -name = "filter_rust_clib" -version = "0.1.0" -dependencies = [ - "chrono", - "libc", - "rmp-serde", - "serde", - "serde_bytes", - "serde_json", -] - -[[package]] -name = "itoa" -version = "1.0.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "112c678d4050afce233f4f2852bb2eb519230b3cf12f33585275537d7e41578d" - -[[package]] -name = "libc" -version = "0.2.126" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "349d5a591cd28b49e1d1037471617a32ddcda5731b99419008085f72d5a53836" - -[[package]] -name = "num-integer" -version = "0.1.45" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "225d3389fb3509a24c93f5c29eb6bde2586b98d9f016636dff58d7c6f7569cd9" -dependencies = [ - "autocfg", - "num-traits", -] - -[[package]] -name = "num-traits" -version = "0.2.15" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "578ede34cf02f8924ab9447f50c28075b4d3e5b269972345e7e0372b38c6cdcd" -dependencies = [ - "autocfg", -] - -[[package]] -name = "paste" -version = "1.0.7" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "0c520e05135d6e763148b6426a837e239041653ba7becd2e538c076c738025fc" - -[[package]] -name = "proc-macro2" -version = "1.0.42" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c278e965f1d8cf32d6e0e96de3d3e79712178ae67986d9cf9151f51e95aac89b" -dependencies = [ - "unicode-ident", -] - -[[package]] -name = "quote" -version = "1.0.20" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3bcdf212e9776fbcb2d23ab029360416bb1706b1aea2d1a5ba002727cbcab804" -dependencies = [ - "proc-macro2", -] - -[[package]] -name = "rmp" -version = "0.8.11" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "44519172358fd6d58656c86ab8e7fbc9e1490c3e8f14d35ed78ca0dd07403c9f" -dependencies = [ - "byteorder", - "num-traits", - "paste", -] - -[[package]] -name = "rmp-serde" -version = "1.1.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "25786b0d276110195fa3d6f3f31299900cf71dfbd6c28450f3f58a0e7f7a347e" -dependencies = [ - "byteorder", - "rmp", - "serde", -] - -[[package]] -name = "ryu" -version = "1.0.10" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f3f6f92acf49d1b98f7a81226834412ada05458b7364277387724a237f062695" - -[[package]] -name = "serde" -version = "1.0.140" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "fc855a42c7967b7c369eb5860f7164ef1f6f81c20c7cc1141f2a604e18723b03" -dependencies = [ - "serde_derive", -] - -[[package]] -name = "serde_bytes" -version = "0.11.6" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "212e73464ebcde48d723aa02eb270ba62eff38a9b732df31f33f1b4e145f3a54" -dependencies = [ - "serde", -] - -[[package]] -name = "serde_derive" -version = "1.0.140" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6f2122636b9fe3b81f1cb25099fcf2d3f542cdb1d45940d56c713158884a05da" -dependencies = [ - "proc-macro2", - "quote", - "syn", -] - -[[package]] -name = "serde_json" -version = "1.0.82" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "82c2c1fdcd807d1098552c5b9a36e425e42e9fbd7c6a37a8425f390f781f7fa7" -dependencies = [ - "itoa", - "ryu", - "serde", -] - -[[package]] -name = "syn" -version = "1.0.98" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c50aef8a904de4c23c788f104b7dddc7d6f79c647c7c8ce4cc8f73eb0ca773dd" -dependencies = [ - "proc-macro2", - "quote", - "unicode-ident", -] - -[[package]] -name = "time" -version = "0.1.44" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6db9e6914ab8b1ae1c260a4ae7a49b6c5611b40328a735b21862567685e73255" -dependencies = [ - "libc", - "wasi", - "winapi", -] - -[[package]] -name = "unicode-ident" -version = "1.0.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "15c61ba63f9235225a22310255a29b806b907c9b8c964bcbd0a2c70f3f2deea7" - -[[package]] -name = "wasi" -version = "0.10.0+wasi-snapshot-preview1" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "1a143597ca7c7793eff794def352d41792a93c481eb1042423ff7ff72ba2c31f" - -[[package]] -name = "winapi" -version = "0.3.9" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5c839a674fcd7a98952e593242ea400abe93992746761e38641405d28b00f419" -dependencies = [ - "winapi-i686-pc-windows-gnu", - "winapi-x86_64-pc-windows-gnu", -] - -[[package]] -name = "winapi-i686-pc-windows-gnu" -version = "0.4.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ac3b87c63620426dd9b991e5ce0329eff545bccbbb34f3be09ff6fb6ab51b7b6" - -[[package]] -name = "winapi-x86_64-pc-windows-gnu" -version = "0.4.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f" diff --git a/fluent-bit/examples/filter_rust_clib/Cargo.toml b/fluent-bit/examples/filter_rust_clib/Cargo.toml deleted file mode 100644 index 400508d23..000000000 --- a/fluent-bit/examples/filter_rust_clib/Cargo.toml +++ /dev/null @@ -1,15 +0,0 @@ -[package] -name = "filter_rust_clib" -version = "0.1.0" -edition = "2021" - -[lib] -crate-type = ["cdylib", "staticlib", "rlib"] - -[dependencies] -serde = { version = "*", features = ["derive"] } -serde_json = "1.0" -serde_bytes = "0.11" -rmp-serde = "1.1" -chrono = "0.4" -libc = "0.2" diff --git a/fluent-bit/examples/filter_rust_clib/Makefile b/fluent-bit/examples/filter_rust_clib/Makefile deleted file mode 100644 index c8d7f4292..000000000 --- a/fluent-bit/examples/filter_rust_clib/Makefile +++ /dev/null @@ -1,25 +0,0 @@ -WASI_SDK_ROOT ?= /opt/wasi-sdk -STACK_SIZE ?= 8192 -INITIAL_MEMORY_SIZE ?= 65536 - -rustclib: - cargo build --target wasm32-unknown-unknown --release - -build: wasm rustclib - -wasm: rustclib rust_clib_filter.h - ${WASI_SDK_ROOT}/bin/clang -O3 -nostdlib \ - -z stack-size=${STACK_SIZE} -Wl,--initial-memory=${INITIAL_MEMORY_SIZE} \ - -o rust_clib_filter.wasm rust_clib_filter.c \ - -L ./target/wasm32-unknown-unknown/release -lfilter_rust_clib \ - -Wl,--export=__heap_base -Wl,--export=__data_end -Wl,--export=rust_clib_filter \ - -Wl,--no-entry -Wl,--strip-all -Wl,--allow-undefined - -rust_clib_filter.h: - cbindgen --crate filter_rust_clib --output filter_rust_clib.h --lang c - - -clean: - rm -f *.wasm - rm -f *.h - cargo clean diff --git a/fluent-bit/examples/filter_rust_clib/README.md b/fluent-bit/examples/filter_rust_clib/README.md deleted file mode 100644 index 9be89598b..000000000 --- a/fluent-bit/examples/filter_rust_clib/README.md +++ /dev/null @@ -1,77 +0,0 @@ -# Fluent Bit / filter_rust_clib - -This source source tree provides an example of WASM program with WASI mode mainly written in Rust. - -## Prerequisites - -* Rust - * rustc 1.61.0 (fe5b13d68 2022-05-18) -* [rustup](https://rustup.rs/) (For preparing rust compiler and toolchains) -* [cbindgen](https://github.com/eqrion/cbindgen) (For preparing C headers to include exported Rust's c style function(s)) -* [WASI SDK](https://github.com/WebAssembly/wasi-sdk) - -For Ubuntu, it's easy to install with: - -```console -$ export WASI_VERSION=14 -$ export WASI_VERSION_FULL=${WASI_VERSION}.0 -$ wget https://github.com/WebAssembly/wasi-sdk/releases/download/wasi-sdk-${WASI_VERSION}/wasi-sdk-${WASI_VERSION_FULL}-linux.tar.gz -$ sudo mkdir -p /opt/wasi-sdk/ -$ sudo tar xvf wasi-sdk-${WASI_VERSION_FULL}-linux.tar.gz --strip-components=1 -C /opt/wasi-sdk -``` - -## How to build - -Add `wasm32-unknown-unknown` target for Rust toolchain: - -```console -$ rustup target add wasm32-unknown-unknown -``` - -Install `cbindgen` command as follows: - -```console -$ cargo install --force cbindgen -``` - -Then, execute _make build_ as follows: - -```console -$ make build -``` - -Finally, `*.wasm` file will be created: - -```console -$ ls *.wasm -rust_clib_filter.wasm -``` - -## How to confirm WASI integration - -Create fluent-bit configuration file as follows: - -```ini -[SERVICE] - Flush 1 - Daemon Off - Log_Level info - HTTP_Server Off - HTTP_Listen 0.0.0.0 - HTTP_Port 2020 - -[INPUT] - Name dummy - Tag dummy.local - -[FILTER] - Name wasm - match dummy.* - WASM_Path /path/to/rust_clib_filter.wasm - Function_Name rust_clib_filter - accessible_paths .,/path/to/fluent-bit - -[OUTPUT] - Name stdout - Match * -``` diff --git a/fluent-bit/examples/filter_rust_clib/rust_clib_filter.c b/fluent-bit/examples/filter_rust_clib/rust_clib_filter.c deleted file mode 100644 index ca19d516a..000000000 --- a/fluent-bit/examples/filter_rust_clib/rust_clib_filter.c +++ /dev/null @@ -1,9 +0,0 @@ -#include <stdio.h> -#include <string.h> -#include <time.h> -#include "filter_rust_clib.h" - -char* rust_clib_filter(char* tag, int len, uint32_t sec, uint32_t nsec, char* record, int record_len) -{ - return (char *)rust_filter(tag, strlen(tag), sec, nsec, record, strlen(record)); -} diff --git a/fluent-bit/examples/filter_rust_clib/src/lib.rs b/fluent-bit/examples/filter_rust_clib/src/lib.rs deleted file mode 100644 index c409ba53a..000000000 --- a/fluent-bit/examples/filter_rust_clib/src/lib.rs +++ /dev/null @@ -1,32 +0,0 @@ -// Import pure and fast JSON library written in Rust -use serde_json::json; -use serde_json::Value; -// Import chrono library to handle time related operation conveniently -use chrono::{Utc, TimeZone}; -use std::slice; -use std::str; -use std::os::raw::c_char; -use std::io::Write; - -#[no_mangle] -pub extern "C" fn rust_filter(tag: *const c_char, tag_len: u32, time_sec: u32, time_nsec: u32, record: *const c_char, record_len: u32) -> *const u8 { - let slice_tag: &[u8] = unsafe { slice::from_raw_parts(tag as *const u8, tag_len as usize) }; - let slice_record: &[u8] = unsafe { slice::from_raw_parts(record as *const u8, record_len as usize) }; - let mut vt: Vec<u8> = Vec::new(); - vt.write(slice_tag).expect("Unable to write"); - let vtag = str::from_utf8(&vt).unwrap(); - let v: Value = serde_json::from_slice(slice_record).unwrap(); - let dt = Utc.timestamp(time_sec as i64, time_nsec); - let time = dt.format("%Y-%m-%dT%H:%M:%S.%9f %z").to_string(); - - let message = json!({ - "message": v["message"], - "time": format!("{}", time), - "tag": vtag, - "original": v.to_string(), - "lang": "Rust", - }); - - let buf: String = message.to_string(); - buf.as_ptr() -} diff --git a/fluent-bit/examples/filter_wasm_c/Makefile b/fluent-bit/examples/filter_wasm_c/Makefile deleted file mode 100644 index 77d8772a2..000000000 --- a/fluent-bit/examples/filter_wasm_c/Makefile +++ /dev/null @@ -1,15 +0,0 @@ -WASI_SDK_ROOT ?= /opt/wasi-sdk -STACK_SIZE ?= 8192 -INITIAL_MEMORY_SIZE ?= 65536 - -.PHONY: wasm - -wasm: - ${WASI_SDK_ROOT}/bin/clang -O3 -nostdlib \ - -z stack-size=${STACK_SIZE} -Wl,--initial-memory=${INITIAL_MEMORY_SIZE} \ - -o c_filter.wasm c_filter.c \ - -Wl,--export=__heap_base -Wl,--export=__data_end -Wl,--export=c_filter \ - -Wl,--no-entry -Wl,--strip-all -Wl,--allow-undefined - -clean: - rm -f *.wasm diff --git a/fluent-bit/examples/filter_wasm_c/README.md b/fluent-bit/examples/filter_wasm_c/README.md deleted file mode 100644 index 64c06e5f3..000000000 --- a/fluent-bit/examples/filter_wasm_c/README.md +++ /dev/null @@ -1,69 +0,0 @@ -# Fluent Bit / filter_wasm_c - -This source source tree provides an example of WASM filter program with WASI mode. - -## Prerequisites - -Tested on - -* [WASI SDK](https://github.com/WebAssembly/wasi-sdk) - -For Ubuntu, it's easy to install with: - -```console -$ export WASI_VERSION=14 -$ export WASI_VERSION_FULL=${WASI_VERSION}.0 -$ wget https://github.com/WebAssembly/wasi-sdk/releases/download/wasi-sdk-${WASI_VERSION}/wasi-sdk-${WASI_VERSION_FULL}-linux.tar.gz -$ sudo mkdir -p /opt/wasi-sdk/ -$ sudo tar xvf wasi-sdk-${WASI_VERSION_FULL}-linux.tar.gz --strip-components=1 -C /opt/wasi-sdk -``` - -## How to build - -Execute _make_ as follows: - -```console -$ make -/opt/wasi-sdk/bin/clang -O3 -nostdlib \ - -z stack-size=8192 -Wl,--initial-memory=65536 \ - -o c_filter.wasm c_filter.c \ - -Wl,--export=__heap_base -Wl,--export=__data_end -Wl,--export=c_filter \ - -Wl,--no-entry -Wl,--strip-all -Wl,--allow-undefined -``` - -Finally, under the same directory, `*.wasm` file will be created: - -```console -$ ls *.wasm -c_filter.wasm -``` - -## How to confirm WASM filter integration - -Create fluent-bit configuration file as follows: - -```ini -[SERVICE] - Flush 1 - Daemon Off - Log_Level info - HTTP_Server Off - HTTP_Listen 0.0.0.0 - HTTP_Port 2020 - -[INPUT] - Name dummy - Tag dummy.local - -[FILTER] - Name wasm - match dummy.* - WASM_Path c_filter.wasm - Function_Name c_filter - accessible_paths .,/path/to/fluent-bit - -[OUTPUT] - Name stdout - Match * - -``` diff --git a/fluent-bit/examples/filter_wasm_c/c_filter.c b/fluent-bit/examples/filter_wasm_c/c_filter.c deleted file mode 100644 index 53a45c20b..000000000 --- a/fluent-bit/examples/filter_wasm_c/c_filter.c +++ /dev/null @@ -1,22 +0,0 @@ -#include <stdio.h> -#include <stdint.h> -#include <stdlib.h> -#include <time.h> - -char* c_filter(char* tag, int len, uint32_t sec, uint32_t nsec, char* record, int record_len) -{ - char *buf; - buf = malloc(1024); - if (!buf) { - printf("malloc buf failed\n"); - return NULL; - } - - struct timespec ts; - ts.tv_sec = sec; - ts.tv_nsec = nsec; - - sprintf(buf, "{\"tag\":\"%s\",\"time\":\"%lld.%9ld\", \"message\":\"Hello, from C!\", \"original\": %s}", - tag, (long long)ts.tv_sec, ts.tv_nsec, record); - return buf; -} diff --git a/fluent-bit/examples/filter_wasm_go/README.md b/fluent-bit/examples/filter_wasm_go/README.md deleted file mode 100644 index 863cf8360..000000000 --- a/fluent-bit/examples/filter_wasm_go/README.md +++ /dev/null @@ -1,63 +0,0 @@ -# Fluent Bit / filter_wasm_go - -This source source tree provides an example of WASM filter program with WASI mode. - -## Prerequisites - -Tested on - -* TinyGo - * [tinygo](https://tinygo.org/) tinygo version 0.23.0 linux/amd64 (using go version go1.18.2 and LLVM version 14.0.0) - * [tinygo](https://tinygo.org/) tinygo version 0.24.0 linux/amd64 (using go version go1.18.2 and LLVM version 14.0.0) - -For Ubuntu, it's easy to install with: - -```console -$ wget https://github.com/tinygo-org/tinygo/releases/download/v0.24.0/tinygo_0.24.0_amd64.deb -$ sudo dpkg -i tinygo_0.24.0_amd64.deb -``` - -## How to build - -Execute _tinygo build_ as follows: - -```console -$ tinygo build -wasm-abi=generic -target=wasi -o filter.wasm filter.go -``` - -Finally, under the same directory, `*.wasm` file will be created: - -```console -$ ls *.wasm -filter.wasm -``` - -## How to confirm WASM filter integration - -Create fluent-bit configuration file as follows: - -```ini -[SERVICE] - Flush 1 - Daemon Off - Log_Level info - HTTP_Server Off - HTTP_Listen 0.0.0.0 - HTTP_Port 2020 - -[INPUT] - Name dummy - Tag dummy.local - -[FILTER] - Name wasm - match dummy.* - WASM_Path /path/to/filter.wasm - Function_Name go_filter - accessible_paths .,/path/to/fluent-bit - -[OUTPUT] - Name stdout - Match * - -``` diff --git a/fluent-bit/examples/filter_wasm_go/filter.go b/fluent-bit/examples/filter_wasm_go/filter.go deleted file mode 100644 index fe7303c68..000000000 --- a/fluent-bit/examples/filter_wasm_go/filter.go +++ /dev/null @@ -1,41 +0,0 @@ -package main - -import ( - "fmt" - "time" - "unsafe" - - "github.com/valyala/fastjson" -) - -//export go_filter -func go_filter(tag *uint8, tag_len uint, time_sec uint, time_nsec uint, record *uint8, record_len uint) *uint8 { - btag := unsafe.Slice(tag, tag_len) // Note, requires Go 1.17 (tinygo 0.20) - brecord := unsafe.Slice(record, record_len) - now := time.Unix(int64(time_sec), int64(time_nsec)) - - br := string(brecord) - var p fastjson.Parser - value, err := p.Parse(br) - if err != nil { - fmt.Println(err) - return nil - } - obj, err := value.Object() - if err != nil { - fmt.Println(err) - return nil - } - - var arena fastjson.Arena - obj.Set("time", arena.NewString(now.String())) - obj.Set("tag", arena.NewString(string(btag))) - obj.Set("original", arena.NewString(br)) - s := obj.String() - s += string(rune(0)) // Note: explicit null terminator. - rv := []byte(s) - - return &rv[0] -} - -func main() {} diff --git a/fluent-bit/examples/filter_wasm_go/go.mod b/fluent-bit/examples/filter_wasm_go/go.mod deleted file mode 100644 index 8250a72d2..000000000 --- a/fluent-bit/examples/filter_wasm_go/go.mod +++ /dev/null @@ -1,9 +0,0 @@ -module filter_wasm_go - -go 1.18 - -require ( - github.com/valyala/fastjson v1.6.3 // indirect - github.com/vmihailenco/msgpack/v5 v5.3.5 // indirect - github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect -) diff --git a/fluent-bit/examples/filter_wasm_go/go.sum b/fluent-bit/examples/filter_wasm_go/go.sum deleted file mode 100644 index 2489b8d54..000000000 --- a/fluent-bit/examples/filter_wasm_go/go.sum +++ /dev/null @@ -1,18 +0,0 @@ -github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= -github.com/goccy/go-json v0.9.10 h1:hCeNmprSNLB8B8vQKWl6DpuH0t60oEs+TAk9a7CScKc= -github.com/goccy/go-json v0.9.10/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I= -github.com/josharian/intern v1.0.0 h1:vlS4z54oSdjm0bgjRigI+G1HpF+tI+9rE5LLzOg8HmY= -github.com/josharian/intern v1.0.0/go.mod h1:5DoeVV0s6jJacbCEi61lwdGj/aVlrQvzHFFd8Hwg//Y= -github.com/mailru/easyjson v0.7.7 h1:UGYAvKxe3sBsEDzO8ZeWOSlIQfWFlxbzLZe7hwFURr0= -github.com/mailru/easyjson v0.7.7/go.mod h1:xzfreul335JAWq5oZzymOObrkdz5UnU4kGfJJLY9Nlc= -github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= -github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= -github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= -github.com/valyala/fastjson v1.6.3 h1:tAKFnnwmeMGPbwJ7IwxcTPCNr3uIzoIj3/Fh90ra4xc= -github.com/valyala/fastjson v1.6.3/go.mod h1:CLCAqky6SMuOcxStkYQvblddUtoRxhYMGLrsQns1aXY= -github.com/vmihailenco/msgpack/v5 v5.3.5 h1:5gO0H1iULLWGhs2H5tbAHIZTV8/cYafcFOr9znI5mJU= -github.com/vmihailenco/msgpack/v5 v5.3.5/go.mod h1:7xyJ9e+0+9SaZT0Wt1RGleJXzli6Q/V5KbhBonMG9jc= -github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g= -github.com/vmihailenco/tagparser/v2 v2.0.0/go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds= -gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= -gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/fluent-bit/examples/hello_world/CMakeLists.txt b/fluent-bit/examples/hello_world/CMakeLists.txt deleted file mode 100644 index 2e55b75f0..000000000 --- a/fluent-bit/examples/hello_world/CMakeLists.txt +++ /dev/null @@ -1,9 +0,0 @@ -set(src - ${src} - hello_world.c - ) - -find_package (Threads) -add_executable(hello_world ${src}) -target_link_libraries(hello_world fluent-bit-shared) -target_link_libraries(hello_world ${CMAKE_THREAD_LIBS_INIT}) diff --git a/fluent-bit/examples/hello_world/README.md b/fluent-bit/examples/hello_world/README.md deleted file mode 100644 index f9fc5a4e7..000000000 --- a/fluent-bit/examples/hello_world/README.md +++ /dev/null @@ -1,6 +0,0 @@ -# Fluent Bit / Hello World - -This tool uses the Fluent Bit library version to flush data to one of the -registered outputs. - -When using Fluent Bit as a library means the caller becomes the input. diff --git a/fluent-bit/examples/hello_world/hello_world.c b/fluent-bit/examples/hello_world/hello_world.c deleted file mode 100644 index f4925bf67..000000000 --- a/fluent-bit/examples/hello_world/hello_world.c +++ /dev/null @@ -1,60 +0,0 @@ -/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ - -/* Fluent Bit Demo - * =============== - * Copyright (C) 2015 Treasure Data Inc. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include <fluent-bit.h> - -int main() -{ - int i; - int n; - char tmp[256]; - flb_ctx_t *ctx; - int in_ffd; - int out_ffd; - - /* Initialize library */ - ctx = flb_create(); - if (!ctx) { - exit(EXIT_FAILURE); - } - - in_ffd = flb_input(ctx, "lib", NULL); - flb_input_set(ctx, in_ffd, "tag", "test", NULL); - - out_ffd = flb_output(ctx, "stdout", NULL); - flb_output_set(ctx, out_ffd, "match", "test", NULL); - - /* Start the background worker */ - flb_start(ctx); - - /* Push some data */ - for (i = 0; i < 100; i++) { - n = snprintf(tmp, sizeof(tmp) - 1, - "[%f, {\"key\": \"val %i\"}]", - flb_time_now(), i); - flb_lib_push(ctx, in_ffd, tmp, n); - } - - flb_stop(ctx); - - /* Release Resources */ - flb_destroy(ctx); - - return 0; -} diff --git a/fluent-bit/examples/kafka_filter/.env b/fluent-bit/examples/kafka_filter/.env deleted file mode 100644 index 61c27af84..000000000 --- a/fluent-bit/examples/kafka_filter/.env +++ /dev/null @@ -1,4 +0,0 @@ -KAFKA_HOST=kafka-broker -KAFKA_PORT=9092 -ZOOKEEPER_HOST=zookeeper -ZOOKEEPER_PORT=2181 diff --git a/fluent-bit/examples/kafka_filter/.gitignore b/fluent-bit/examples/kafka_filter/.gitignore deleted file mode 100644 index f8edd2f2e..000000000 --- a/fluent-bit/examples/kafka_filter/.gitignore +++ /dev/null @@ -1,2 +0,0 @@ -build/ -kafka/ diff --git a/fluent-bit/examples/kafka_filter/Dockerfile b/fluent-bit/examples/kafka_filter/Dockerfile deleted file mode 100644 index 5a18e63e6..000000000 --- a/fluent-bit/examples/kafka_filter/Dockerfile +++ /dev/null @@ -1,44 +0,0 @@ -FROM debian:bullseye-slim as builder -ENV DEBIAN_FRONTEND noninteractive -ENV KAFKA_URL https://downloads.apache.org/kafka/3.4.1/kafka_2.13-3.4.1.tgz -ENV KAFKA_SHA256 a76f17a52b8f2cd31de11571ff366a714820b6e4e02893b0159d09db0edaf998 - -# hadolint ignore=DL3008 -RUN apt-get update && \ - apt-get upgrade -y && \ - apt-get install -y --no-install-recommends \ - build-essential \ - curl \ - ca-certificates \ - cmake \ - pkg-config \ - libsasl2-dev \ - libssl-dev \ - flex \ - openjdk-11-jre-headless \ - bison \ - netcat-openbsd \ - && apt-get clean \ - && rm -rf /var/lib/apt/lists/* - -# Download kafka to access "kafka-topics" script -WORKDIR /kafka -RUN bash -c 'curl -L $KAFKA_URL | tee kafka.tgz | sha256sum -c <(echo "$KAFKA_SHA256 -")' \ - && tar --strip-components=1 -xf kafka.tgz \ - && mv /kafka/bin/kafka-topics.sh /kafka/bin/kafka-topics -ENV PATH="${PATH}:/kafka/bin" - -WORKDIR /build/ -COPY . /source -RUN cmake -DFLB_DEV=On \ - -DFLB_IN_KAFKA=On \ - -DFLB_OUT_KAFKA=On \ - -DFLB_CONFIG_YAML=Off \ - /source && \ - cmake --build . --parallel - -FROM builder as runner -COPY --from=builder /build/bin/fluent-bit /usr/local/bin/fluent-bit -COPY examples/kafka_filter/kafka.conf /etc/kafka.conf -COPY examples/kafka_filter/kafka.lua /etc/kafka.lua -CMD ["/usr/local/bin/fluent-bit", "-c", "/etc/kafka.conf"] diff --git a/fluent-bit/examples/kafka_filter/Makefile b/fluent-bit/examples/kafka_filter/Makefile deleted file mode 100644 index 75b4b3a8c..000000000 --- a/fluent-bit/examples/kafka_filter/Makefile +++ /dev/null @@ -1,11 +0,0 @@ -build: - docker compose build - -start: - docker compose up -d - docker compose logs -f fluent-bit kafka-consumer - -stop: - docker compose down - -.PHONY: build start stop diff --git a/fluent-bit/examples/kafka_filter/docker-compose.yml b/fluent-bit/examples/kafka_filter/docker-compose.yml deleted file mode 100644 index dc758c9ec..000000000 --- a/fluent-bit/examples/kafka_filter/docker-compose.yml +++ /dev/null @@ -1,68 +0,0 @@ -version: '3.4' - -x-service-common-fields: &service-common-fields - volumes: - - ./scripts:/scripts - env_file: - - ./.env - - -services: - fluent-bit: - <<: *service-common-fields - build: - context: ../.. - target: runner - dockerfile: examples/kafka_filter/Dockerfile - command: /scripts/flb-start.sh - depends_on: - - kafka-consumer - - - kafka-create-topics: - <<: *service-common-fields - image: confluentinc/cp-server:7.0.1 - command: /scripts/create-topics.sh - depends_on: - - kafka-broker - - - kafka-producer: - <<: *service-common-fields - image: confluentinc/cp-server:7.0.1 - command: /scripts/kafka-produce.sh - depends_on: - - fluent-bit - - - kafka-consumer: - <<: *service-common-fields - image: confluentinc/cp-server:7.0.1 - command: /scripts/kafka-consume.sh - depends_on: - - kafka-create-topics - - - kafka-broker: - image: confluentinc/cp-server:7.0.1 - hostname: broker - container_name: kafka-broker - depends_on: - - zookeeper - environment: - KAFKA_BROKER_ID: 1 - KAFKA_ZOOKEEPER_CONNECT: "${ZOOKEEPER_HOST}:${ZOOKEEPER_PORT}" - KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: "PLAINTEXT:PLAINTEXT" - KAFKA_ADVERTISED_LISTENERS: "PLAINTEXT://${KAFKA_HOST}:${KAFKA_PORT}" - KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1 - KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0 - KAFKA_CONFLUENT_LICENSE_TOPIC_REPLICATION_FACTOR: 1 - - - zookeeper: - image: confluentinc/cp-zookeeper:7.0.1 - hostname: zookeeper - container_name: zookeeper - environment: - ZOOKEEPER_CLIENT_PORT: "${ZOOKEEPER_PORT}" - ZOOKEEPER_TICK_TIME: 2000 diff --git a/fluent-bit/examples/kafka_filter/kafka.conf b/fluent-bit/examples/kafka_filter/kafka.conf deleted file mode 100644 index 2c3daf782..000000000 --- a/fluent-bit/examples/kafka_filter/kafka.conf +++ /dev/null @@ -1,22 +0,0 @@ -[SERVICE] - Flush 0.1 - Grace 2 - Log_Level info - -[INPUT] - Name kafka - brokers kafka-broker:9092 - topics fb-source - poll_ms 100 - format json - -[FILTER] - Name lua - Match * - script kafka.lua - call modify_kafka_message - -[OUTPUT] - Name kafka - brokers kafka-broker:9092 - topics fb-sink diff --git a/fluent-bit/examples/kafka_filter/kafka.lua b/fluent-bit/examples/kafka_filter/kafka.lua deleted file mode 100644 index 3c6d9dc17..000000000 --- a/fluent-bit/examples/kafka_filter/kafka.lua +++ /dev/null @@ -1,8 +0,0 @@ -local count = 0 -function modify_kafka_message(tag, timestamp, record) - count = count + 1 - local payload = record.payload - payload.topic = record.topic - payload.status = 'processed by fluent-bit, total records: '..tostring(count) - return 1, timestamp, payload -end diff --git a/fluent-bit/examples/kafka_filter/scripts/common.sh b/fluent-bit/examples/kafka_filter/scripts/common.sh deleted file mode 100644 index d9a2bc6f4..000000000 --- a/fluent-bit/examples/kafka_filter/scripts/common.sh +++ /dev/null @@ -1,17 +0,0 @@ -#!/bin/bash -ue - -wait_kafka() { - while ! nc -z "$KAFKA_HOST" "$KAFKA_PORT"; do - sleep 0.1 - done -} - -wait_topic() { - wait_kafka - local topic=$1 - [ -z "$topic" ] && return 1 - while true; do - kafka-topics --list --bootstrap-server "$KAFKA_HOST:$KAFKA_PORT" | grep -q "^$topic$" && break - sleep 0.1 - done -} diff --git a/fluent-bit/examples/kafka_filter/scripts/create-topics.sh b/fluent-bit/examples/kafka_filter/scripts/create-topics.sh deleted file mode 100755 index a7adbddf1..000000000 --- a/fluent-bit/examples/kafka_filter/scripts/create-topics.sh +++ /dev/null @@ -1,9 +0,0 @@ -#!/bin/bash -ue - -# shellcheck disable=SC1091 -. /scripts/common.sh - -wait_kafka - -kafka-topics --create --partitions 1 --replication-factor 1 --topic fb-source --bootstrap-server "$KAFKA_HOST:$KAFKA_PORT" -kafka-topics --create --partitions 1 --replication-factor 1 --topic fb-sink --bootstrap-server "$KAFKA_HOST:$KAFKA_PORT" diff --git a/fluent-bit/examples/kafka_filter/scripts/flb-start.sh b/fluent-bit/examples/kafka_filter/scripts/flb-start.sh deleted file mode 100755 index 56e5ee0d6..000000000 --- a/fluent-bit/examples/kafka_filter/scripts/flb-start.sh +++ /dev/null @@ -1,8 +0,0 @@ -#!/bin/bash -ue - -# shellcheck disable=SC1091 -. /scripts/common.sh - -wait_topic fb-sink - -exec /usr/local/bin/fluent-bit -c /etc/kafka.conf diff --git a/fluent-bit/examples/kafka_filter/scripts/kafka-consume.sh b/fluent-bit/examples/kafka_filter/scripts/kafka-consume.sh deleted file mode 100755 index 729c4876d..000000000 --- a/fluent-bit/examples/kafka_filter/scripts/kafka-consume.sh +++ /dev/null @@ -1,9 +0,0 @@ -#!/bin/bash -ue - -# shellcheck disable=SC1091 -. /scripts/common.sh - -wait_topic fb-sink - -kafka-console-consumer --topic fb-sink --bootstrap-server \ - "$KAFKA_HOST:$KAFKA_PORT" diff --git a/fluent-bit/examples/kafka_filter/scripts/kafka-produce.sh b/fluent-bit/examples/kafka_filter/scripts/kafka-produce.sh deleted file mode 100755 index eea99ca27..000000000 --- a/fluent-bit/examples/kafka_filter/scripts/kafka-produce.sh +++ /dev/null @@ -1,13 +0,0 @@ -#!/bin/bash -ue - -# shellcheck disable=SC1091 -. /scripts/common.sh - -wait_topic fb-sink - -for i in $(seq 1 100); do - sleep 1 - echo "{ \"name\": \"object-$i\" }" | \ - kafka-console-producer --topic fb-source \ - --broker-list "$KAFKA_HOST:$KAFKA_PORT" -done diff --git a/fluent-bit/examples/out_lib/CMakeLists.txt b/fluent-bit/examples/out_lib/CMakeLists.txt deleted file mode 100644 index db04ff1c1..000000000 --- a/fluent-bit/examples/out_lib/CMakeLists.txt +++ /dev/null @@ -1,9 +0,0 @@ -set(src - ${src} - out_lib.c - ) - -find_package (Threads) -add_executable(out_lib ${src}) -target_link_libraries(out_lib fluent-bit-shared) -target_link_libraries(out_lib ${CMAKE_THREAD_LIBS_INIT}) diff --git a/fluent-bit/examples/out_lib/README.md b/fluent-bit/examples/out_lib/README.md deleted file mode 100644 index f9fc5a4e7..000000000 --- a/fluent-bit/examples/out_lib/README.md +++ /dev/null @@ -1,6 +0,0 @@ -# Fluent Bit / Hello World - -This tool uses the Fluent Bit library version to flush data to one of the -registered outputs. - -When using Fluent Bit as a library means the caller becomes the input. diff --git a/fluent-bit/examples/out_lib/out_lib.c b/fluent-bit/examples/out_lib/out_lib.c deleted file mode 100644 index ada207b0c..000000000 --- a/fluent-bit/examples/out_lib/out_lib.c +++ /dev/null @@ -1,94 +0,0 @@ -/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ - -/* Fluent Bit Demo - * =============== - * Copyright (C) 2015-2017 Treasure Data Inc. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include <fluent-bit.h> -#include <msgpack.h> - -int my_stdout_json(void *record, size_t size, void *data) -{ - printf("[%s]",__FUNCTION__); - printf("%s",(char*)record); - printf("\n"); - - flb_lib_free(record); - return 0; -} - -int my_stdout_msgpack(void* data, size_t size) -{ - printf("[%s]",__FUNCTION__); - msgpack_object_print(stdout, *(msgpack_object*)data); - printf("\n"); - - flb_lib_free(data); - return 0; -} - -int main() -{ - int i; - int n; - char tmp[256]; - flb_ctx_t *ctx; - struct flb_lib_out_cb callback; - int in_ffd; - int out_ffd; - - /* Initialize library */ - ctx = flb_create(); - if (!ctx) { - exit(EXIT_FAILURE); - } - - in_ffd = flb_input(ctx, "lib", NULL); - flb_input_set(ctx, in_ffd, "tag", "test", NULL); - - /* Register my callback function */ - - /* JSON format */ - callback.cb = my_stdout_json; - callback.data = NULL; - - out_ffd = flb_output(ctx, "lib", &callback); - flb_output_set(ctx, out_ffd, "match", "test", "format", "json", NULL); - - /* Msgpack format */ - /* - out_ffd = flb_output(ctx, "lib", my_stdout_msgpack); - flb_output_set(ctx, out_ffd, "match", "test", NULL); - */ - - /* Start the background worker */ - flb_start(ctx); - - /* Push some data */ - for (i = 0; i < 100; i++) { - n = snprintf(tmp, sizeof(tmp) - 1, - "[%f, {\"key\": \"val %i\"}]", - flb_time_now(), i); - flb_lib_push(ctx, in_ffd, tmp, n); - } - - flb_stop(ctx); - - /* Release Resources */ - flb_destroy(ctx); - - return 0; -} diff --git a/fluent-bit/examples/perf_test/.env b/fluent-bit/examples/perf_test/.env deleted file mode 100644 index c24399e96..000000000 --- a/fluent-bit/examples/perf_test/.env +++ /dev/null @@ -1,5 +0,0 @@ -FB_BASELINE_IMAGE=fluent/fluent-bit:latest -LOG_PREFIX=test -LOG_COUNT=100 -LOG_RATE=20 -LOG_SIZE=1000 diff --git a/fluent-bit/examples/perf_test/docker-compose.yml b/fluent-bit/examples/perf_test/docker-compose.yml deleted file mode 100644 index 9f67440ad..000000000 --- a/fluent-bit/examples/perf_test/docker-compose.yml +++ /dev/null @@ -1,38 +0,0 @@ -version: "3.4" - -services: - - fb-baseline: - image: ${FB_BASELINE_IMAGE} - volumes: - - log-volume:/logs:ro - - ./fluent-bit.conf:/fluent-bit/etc/fluent-bit.conf:ro - - fb-delta: - build: - context: ../.. - dockerfile: dockerfiles/Dockerfile - target: production - volumes: - - log-volume:/logs:ro - - ./fluent-bit.conf:/fluent-bit/etc/fluent-bit.conf:ro - ports: - - "2020:2020" - - data-generator: - image: fluentbitdev/fluent-bit-ci:benchmark - command: bash /scripts/entrypoint.sh - volumes: - - log-volume:/logs:rw - - ./scripts:/scripts:ro - environment: - LOG_PREFIX: ${LOG_PREFIX} - LOG_COUNT: ${LOG_COUNT} - LOG_SIZE: ${LOG_SIZE} - # For multiline set this to >0 - LINE_COUNT: ${LINE_COUNT} - # For multiline set this to the sleep period between log entries rather than the rate - LOG_RATE: ${LOG_RATE} - -volumes: - log-volume: diff --git a/fluent-bit/examples/perf_test/fluent-bit.conf b/fluent-bit/examples/perf_test/fluent-bit.conf deleted file mode 100644 index 3defa36e2..000000000 --- a/fluent-bit/examples/perf_test/fluent-bit.conf +++ /dev/null @@ -1,27 +0,0 @@ -[SERVICE] - Daemon Off - # Log_Level debug - HTTP_Server On - # HTTP_Listen 0.0.0.0 - HTTP_Port 2020 - flush 1 - storage.metrics on - storage.path /data/ - storage.sync normal - storage.checksum off - storage.backlog.mem_limit 1G - storage.max_chunks_up 128 - -[INPUT] - Name dummy - fixed_timestamp on - -[INPUT] - Name tail - Path /logs/* - # Intended for use with multiline data generator - multiline.parser java - -[OUTPUT] - Name null - Match * diff --git a/fluent-bit/examples/perf_test/scripts/entrypoint.sh b/fluent-bit/examples/perf_test/scripts/entrypoint.sh deleted file mode 100755 index 4b53d4c70..000000000 --- a/fluent-bit/examples/perf_test/scripts/entrypoint.sh +++ /dev/null @@ -1,25 +0,0 @@ -#!/bin/bash -set -eu - -LOG_DIR=${LOG_DIR:-/logs} -LOG_PREFIX=${LOG_PREFIX:-multi} -LOG_COUNT=${LOG_COUNT:-100} -LOG_RATE=${LOG_RATE:-20} -LOG_SIZE=${LOG_SIZE:-1000} -LINE_COUNT=${LINE_COUNT:-0} - -rm -vfr "${LOG_DIR:?}/$LOG_PREFIX*" - -for i in $(seq "$LOG_COUNT") -do - export OUTPUT_LOGFILE="$LOG_DIR/$LOG_PREFIX-$i.log" - if [[ "$LINE_COUNT" -gt 0 ]]; then - /scripts/multi-line-log-generator.sh & - else - echo "Creating $OUTPUT_LOGFILE" - # Far too much debug - /run_log_generator.py --log-size-in-bytes "$LOG_SIZE" --log-rate "$LOG_RATE" --log-agent-input-type tail --tail-file-path "$OUTPUT_LOGFILE" &> /dev/null & - fi -done - -wait diff --git a/fluent-bit/examples/perf_test/scripts/multi-line-log-generator.sh b/fluent-bit/examples/perf_test/scripts/multi-line-log-generator.sh deleted file mode 100755 index 1e6236d48..000000000 --- a/fluent-bit/examples/perf_test/scripts/multi-line-log-generator.sh +++ /dev/null @@ -1,23 +0,0 @@ -#!/bin/bash -set -eu - - -OUTPUT_LOGFILE=${OUTPUT_LOGFILE:-/logs/test.log} -rm -fv "$OUTPUT_LOGFILE" - -LOG_RATE=${LOG_RATE:-0.2} -LINE_COUNT=${LINE_COUNT:-100} - -echo "Sleep for $LOG_RATE and create $OUTPUT_LOGFILE with $LINE_COUNT+1 lines per entry" - -while true; do - cat >> "$OUTPUT_LOGFILE" << EOF -Exception in thread "main" java.lang.RuntimeException: A test exception -EOF - for _ in $(seq "$LINE_COUNT"); do -cat >> "$OUTPUT_LOGFILE" << EOF - at com.stackify.stacktrace.StackTraceExample.methodB(StackTraceExample.java:13) -EOF - done - sleep "$LOG_RATE" -done diff --git a/fluent-bit/examples/tracing/docker-compose.yml b/fluent-bit/examples/tracing/docker-compose.yml deleted file mode 100644 index 94d006349..000000000 --- a/fluent-bit/examples/tracing/docker-compose.yml +++ /dev/null @@ -1,26 +0,0 @@ -version: "3" - -services: - fluent-bit: - build: - context: ../.. - dockerfile: dockerfiles/Dockerfile - args: - - FLB_CHUNK_TRACE=On - ports: - - "2020:2020" - volumes: - - ./fluent-bit.conf:/fluent-bit/etc/fluent-bit.conf:ro - command: - - /fluent-bit/bin/fluent-bit - - -Z - - -c - - /fluent-bit/etc/fluent-bit.conf - - enable-tracing: - image: ubuntu:20.04 - command: /enable-tracing.sh - volumes: - - ./enable-tracing.sh:/enable-tracing.sh:ro - environment: - REMOTE_HOST: fluent-bit diff --git a/fluent-bit/examples/tracing/enable-tracing.sh b/fluent-bit/examples/tracing/enable-tracing.sh deleted file mode 100755 index 5bff2b90f..000000000 --- a/fluent-bit/examples/tracing/enable-tracing.sh +++ /dev/null @@ -1,21 +0,0 @@ -#!/bin/bash -set -eu - -REMOTE_HOST=${REMOTE_HOST:-127.0.0.1} - -if command -v http &> /dev/null ; then - http -v "$REMOTE_HOST":2020/api/v1/trace/dummy.0 output=stdout prefix=trace. params:='{"format":"json"}' -elif command -v curl &> /dev/null ; then - curl --header 'Content-Type: application/json' --data '{"output": "stdout", "params": { "format": "json" }, "prefix": "trace."}' "$REMOTE_HOST":2020/api/v1/trace/dummy.0 -else - echo "No curl or httpie installed" - if command -v apt-get &> /dev/null ; then - apt-get -qq update - apt-get -qq install -y curl - elif command -v yum &> /dev/null ; then - yum install -y curl - else - exit 1 - fi - curl --header 'Content-Type: application/json' --data '{"output": "stdout", "params": { "format": "json" }, "prefix": "trace."}' "$REMOTE_HOST":2020/api/v1/trace/dummy.0 -fi diff --git a/fluent-bit/examples/tracing/fluent-bit.conf b/fluent-bit/examples/tracing/fluent-bit.conf deleted file mode 100644 index 0d83db70d..000000000 --- a/fluent-bit/examples/tracing/fluent-bit.conf +++ /dev/null @@ -1,14 +0,0 @@ -[SERVICE] - Http_Server On - -[INPUT] - Name dummy - -[FILTER] - Name record_modifier - Match * - Record foo bar - -[OUTPUT] - Name stdout - Match * diff --git a/fluent-bit/examples/wasi_serde_json/Cargo.lock b/fluent-bit/examples/wasi_serde_json/Cargo.lock deleted file mode 100644 index e20066914..000000000 --- a/fluent-bit/examples/wasi_serde_json/Cargo.lock +++ /dev/null @@ -1,123 +0,0 @@ -# This file is automatically @generated by Cargo. -# It is not intended for manual editing. -version = 3 - -[[package]] -name = "autocfg" -version = "1.1.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "d468802bab17cbc0cc575e9b053f41e72aa36bfa6b7f55e3529ffa43161b97fa" - -[[package]] -name = "chrono" -version = "0.4.19" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "670ad68c9088c2a963aaa298cb369688cf3f9465ce5e2d4ca10e6e0098a1ce73" -dependencies = [ - "libc", - "num-integer", - "num-traits", - "time", - "winapi", -] - -[[package]] -name = "itoa" -version = "1.0.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "112c678d4050afce233f4f2852bb2eb519230b3cf12f33585275537d7e41578d" - -[[package]] -name = "libc" -version = "0.2.126" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "349d5a591cd28b49e1d1037471617a32ddcda5731b99419008085f72d5a53836" - -[[package]] -name = "num-integer" -version = "0.1.45" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "225d3389fb3509a24c93f5c29eb6bde2586b98d9f016636dff58d7c6f7569cd9" -dependencies = [ - "autocfg", - "num-traits", -] - -[[package]] -name = "num-traits" -version = "0.2.15" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "578ede34cf02f8924ab9447f50c28075b4d3e5b269972345e7e0372b38c6cdcd" -dependencies = [ - "autocfg", -] - -[[package]] -name = "ryu" -version = "1.0.10" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f3f6f92acf49d1b98f7a81226834412ada05458b7364277387724a237f062695" - -[[package]] -name = "serde" -version = "1.0.137" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "61ea8d54c77f8315140a05f4c7237403bf38b72704d031543aa1d16abbf517d1" - -[[package]] -name = "serde_json" -version = "1.0.81" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "9b7ce2b32a1aed03c558dc61a5cd328f15aff2dbc17daad8fb8af04d2100e15c" -dependencies = [ - "itoa", - "ryu", - "serde", -] - -[[package]] -name = "time" -version = "0.1.44" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6db9e6914ab8b1ae1c260a4ae7a49b6c5611b40328a735b21862567685e73255" -dependencies = [ - "libc", - "wasi", - "winapi", -] - -[[package]] -name = "wasi" -version = "0.10.0+wasi-snapshot-preview1" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "1a143597ca7c7793eff794def352d41792a93c481eb1042423ff7ff72ba2c31f" - -[[package]] -name = "wasi_serde_json" -version = "0.1.0" -dependencies = [ - "chrono", - "serde_json", -] - -[[package]] -name = "winapi" -version = "0.3.9" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5c839a674fcd7a98952e593242ea400abe93992746761e38641405d28b00f419" -dependencies = [ - "winapi-i686-pc-windows-gnu", - "winapi-x86_64-pc-windows-gnu", -] - -[[package]] -name = "winapi-i686-pc-windows-gnu" -version = "0.4.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ac3b87c63620426dd9b991e5ce0329eff545bccbbb34f3be09ff6fb6ab51b7b6" - -[[package]] -name = "winapi-x86_64-pc-windows-gnu" -version = "0.4.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f" diff --git a/fluent-bit/examples/wasi_serde_json/Cargo.toml b/fluent-bit/examples/wasi_serde_json/Cargo.toml deleted file mode 100644 index c9778b46d..000000000 --- a/fluent-bit/examples/wasi_serde_json/Cargo.toml +++ /dev/null @@ -1,10 +0,0 @@ -[package] -name = "wasi_serde_json" -version = "0.1.0" -edition = "2021" - -# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html - -[dependencies] -serde_json = "1.0" -chrono = "0.4"
\ No newline at end of file diff --git a/fluent-bit/examples/wasi_serde_json/README.md b/fluent-bit/examples/wasi_serde_json/README.md deleted file mode 100644 index 9df44189d..000000000 --- a/fluent-bit/examples/wasi_serde_json/README.md +++ /dev/null @@ -1,65 +0,0 @@ -# Fluent Bit / wasi_serde_json - -This source source tree provides an example of WASM program with WASI mode. - -## Prerequisites - -* Rust - * rustc 1.61.0 (fe5b13d68 2022-05-18) -* [rustup](https://rustup.rs/) (For preparing rust compiler and toolchains) - -## How to build - -Add `wasm32-wasi` target for Rust toolchain: - -```console -$ rustup target add wasm32-wasi -``` - -Then, execute _cargo build_ as follows: - -```console -$ cargo build --target wasm32-wasi --release -``` - -Finally, under target/wasm32-wasi/release directory, `*.wasm` file will be created: - -```console -$ ls target/wasm32-wasi/release/*.wasm -target/wasm32-wasi/release/wasi_serde_json.wasm -``` - -## How to confirm WASI integration - -Create parsers.conf as follows: - -```ini -[PARSER] - Name wasi - Format json - Time_Key time - Time_Format %Y-%m-%dT%H:%M:%S.%L %z -``` - -And Create fluent-bit configuration file as follows: - -```ini -[SERVICE] - Flush 1 - Daemon Off - Parsers_File parsers.conf - Log_Level info - HTTP_Server Off - HTTP_Listen 0.0.0.0 - HTTP_Port 2020 - -[INPUT] - Name exec_wasi - Tag exec.wasi.local - WASI_Path /path/to/wasi_serde_json.wasm - Parser wasi - -[OUTPUT] - Name stdout - Match * -``` diff --git a/fluent-bit/examples/wasi_serde_json/src/main.rs b/fluent-bit/examples/wasi_serde_json/src/main.rs deleted file mode 100644 index 29ee25f4f..000000000 --- a/fluent-bit/examples/wasi_serde_json/src/main.rs +++ /dev/null @@ -1,32 +0,0 @@ -// Import rust's io and filesystem module -use std::io::prelude::*; -use std::fs; -// Import pure and fast JSON library written in Rust -use serde_json::json; -// Import chrono library to handle time related operation conveniently -use chrono::Utc; - -// Entry point to our WASI applications -fn main() { - // Note that fractional second must be handled by `.%9f` not `%L` like as fluent-bit. - let time = Utc::now().format("%Y-%m-%dT%H:%M:%S.%9f %z").to_string(); - // The type of `john` is `serde_json::Value` - let john = json!({ - "name": "John Doe", - "age": 43, - "phones": [ - "+44 1234567", - "+44 2345678" - ], - "time": format!("{}", time), - }); - // Print out serialized JSON data for john - // This will handle writing to stdout for us using the WASI APIs (e.g fd_write) - println!("{}", john.to_string()); - - // Create a file (Testing for exposed wasi API) - let mut file = fs::File::create("helloworld.txt").expect("Unable to create file"); - - // Write the text to the file we created (Testing for exposed wasi API) - write!(file, "Hello world!\n").unwrap(); -}
\ No newline at end of file diff --git a/fluent-bit/examples/windows/docker/README.md b/fluent-bit/examples/windows/docker/README.md deleted file mode 100644 index 7efbb1962..000000000 --- a/fluent-bit/examples/windows/docker/README.md +++ /dev/null @@ -1,28 +0,0 @@ -# Fluent Bit running in Windows Container
-
-You can test the Fluent Bit image on a Windows Container host as follows:
-
-```
-PS> $SAMPLE_DIR="<REPO_CHECKOUT_FOLDER>\examples\windows"
-PS> docker run -v $SAMPLE_DIR\docker\conf:c:\config -v $SAMPLE_DIR\docker\logs:c:\logs -v $SAMPLE_DIR\docker\state:c:\state fluent/fluent-bit:1.3.7-nanoserver
-```
-
-You should see something like the following output:
-
-```
-Fluent Bit v1.3.7
-Copyright (C) Treasure Data
-
-[2020/02/16 16:02:02] [ info] [storage] initializing...
-[2020/02/16 16:02:02] [ info] [storage] in-memory
-[2020/02/16 16:02:02] [ info] [storage] normal synchronization mode, checksum disabled, max_chunks_up=128
-[2020/02/16 16:02:02] [ info] [engine] started (pid=1256)
-[2020/02/16 16:02:02] [ info] [sp] stream processor started
-{"date":"2020-02-16T06:02:02.951104Z","log":"{\"date\":\"2019-08-12T05:28:39.075296Z\",\"log\":\"2019-08-12 05:28:29 10.240.0.77 GET /bundles/MsAjaxJs v=c42ygB2U07n37m_Sfa8ZbLGVu4Rr2gsBo7MvUEnJeZ81 80 - 10.240.0.35 Mozilla/5.0+(Windows+NT+10.0;+Win64;+x64)+AppleWebKit/537.36+(KHTML,+like+Gecko)+Chrome/76.0.3809.100+Safari/537.36 http://52.237.212.148/Contact 200 0 0 65\"}"}
-{"date":"2020-02-16T06:02:02.951136Z","log":"{\"date\":\"2019-08-12T05:28:39.075296Z\",\"log\":\"2019-08-12 05:28:29 10.240.0.77 GET /Scripts/respond.js - 80 - 10.240.0.4 Mozilla/5.0+(Windows+NT+10.0;+Win64;+x64)+AppleWebKit/537.36+(KHTML,+like+Gecko)+Chrome/76.0.3809.100+Safari/537.36 http://52.237.212.148/Contact 200 0 0 40\"}"}
-{"date":"2020-02-16T06:02:02.951137Z","log":"{\"date\":\"2019-08-12T05:28:39.075296Z\",\"log\":\"2019-08-12 05:28:29 10.240.0.77 GET /Content/Site.css - 80 - 10.240.0.35 Mozilla/5.0+(Windows+NT+10.0;+Win64;+x64)+AppleWebKit/537.36+(KHTML,+like+Gecko)+Chrome/76.0.3809.100+Safari/537.36 http://52.237.212.148/Contact 200 0 0 70\"}"}
-{"date":"2020-02-16T06:02:02.951137Z","log":"{\"date\":\"2019-08-12T05:28:39.075297Z\",\"log\":\"2019-08-12 05:28:29 10.240.0.77 GET /bundles/WebFormsJs v=AAyiAYwMfvmwjNSBfIMrBAqfU5exDukMVhrRuZ-PDU01 80 - 10.240.0.4 Mozilla/5.0+(Windows+NT+10.0;+Win64;+x64)+AppleWebKit/537.36+(KHTML,+like+Gecko)+Chrome/76.0.3809.100+Safari/537.36 http://52.237.212.148/Contact 200 0 "}
-{"date":"2020-02-16T06:02:02.951138Z","log":"0 47\"}"}
-{"date":"2020-02-16T06:02:02.951138Z","log":"{\"date\":\"2019-08-12T05:28:39.075297Z\",\"log\":\"2019-08-12 05:28:29 10.240.0.77 GET /favicon.ico - 80 - 10.240.0.4 Mozilla/5.0+(Windows+NT+10.0;+Win64;+x64)+AppleWebKit/537.36+(KHTML,+like+Gecko)+Chrome/76.0.3809.100+Safari/537.36 http://52.237.212.148/Contact 200 0 0 28\"}"}
-{"date":"2020-02-16T06:02:02.951138Z","log":"{\"date\":\"2019-08-12T05:31:37.941523Z\",\"log\":\"2019-08-12 05:30:57 10.240.0.77 GET / - 80 - 10.240.0.4 - - 200 0 64 769\"}"}
-```
\ No newline at end of file diff --git a/fluent-bit/examples/windows/docker/conf/fluent-bit.conf b/fluent-bit/examples/windows/docker/conf/fluent-bit.conf deleted file mode 100644 index 1fca9d29e..000000000 --- a/fluent-bit/examples/windows/docker/conf/fluent-bit.conf +++ /dev/null @@ -1,18 +0,0 @@ -[SERVICE]
- Flush 5
- Daemon off
- Log_Level info
-
-[INPUT]
- Name tail
- Path c:\\logs\\*.log
- Refresh_Interval 60
- Ignore_Older 10s
- Rotate_Wait 5
- DB c:\\state\\logs.db
-
-[OUTPUT]
- Name stdout
- Match *
- Format json_lines
- json_date_format iso8601
\ No newline at end of file diff --git a/fluent-bit/examples/windows/docker/logs/application.log b/fluent-bit/examples/windows/docker/logs/application.log deleted file mode 100644 index 9ad9ee96b..000000000 --- a/fluent-bit/examples/windows/docker/logs/application.log +++ /dev/null @@ -1,7 +0,0 @@ -{"date":"2019-08-12T05:28:39.075296Z","log":"2019-08-12 05:28:29 10.240.0.77 GET /bundles/MsAjaxJs v=c42ygB2U07n37m_Sfa8ZbLGVu4Rr2gsBo7MvUEnJeZ81 80 - 10.240.0.35 Mozilla/5.0+(Windows+NT+10.0;+Win64;+x64)+AppleWebKit/537.36+(KHTML,+like+Gecko)+Chrome/76.0.3809.100+Safari/537.36 http://52.237.212.148/Contact 200 0 0 65"}
-{"date":"2019-08-12T05:28:39.075296Z","log":"2019-08-12 05:28:29 10.240.0.77 GET /Scripts/respond.js - 80 - 10.240.0.4 Mozilla/5.0+(Windows+NT+10.0;+Win64;+x64)+AppleWebKit/537.36+(KHTML,+like+Gecko)+Chrome/76.0.3809.100+Safari/537.36 http://52.237.212.148/Contact 200 0 0 40"}
-{"date":"2019-08-12T05:28:39.075296Z","log":"2019-08-12 05:28:29 10.240.0.77 GET /Content/Site.css - 80 - 10.240.0.35 Mozilla/5.0+(Windows+NT+10.0;+Win64;+x64)+AppleWebKit/537.36+(KHTML,+like+Gecko)+Chrome/76.0.3809.100+Safari/537.36 http://52.237.212.148/Contact 200 0 0 70"}
-{"date":"2019-08-12T05:28:39.075297Z","log":"2019-08-12 05:28:29 10.240.0.77 GET /bundles/WebFormsJs v=AAyiAYwMfvmwjNSBfIMrBAqfU5exDukMVhrRuZ-PDU01 80 - 10.240.0.4 Mozilla/5.0+(Windows+NT+10.0;+Win64;+x64)+AppleWebKit/537.36+(KHTML,+like+Gecko)+Chrome/76.0.3809.100+Safari/537.36 http://52.237.212.148/Contact 200 0
-0 47"}
-{"date":"2019-08-12T05:28:39.075297Z","log":"2019-08-12 05:28:29 10.240.0.77 GET /favicon.ico - 80 - 10.240.0.4 Mozilla/5.0+(Windows+NT+10.0;+Win64;+x64)+AppleWebKit/537.36+(KHTML,+like+Gecko)+Chrome/76.0.3809.100+Safari/537.36 http://52.237.212.148/Contact 200 0 0 28"}
-{"date":"2019-08-12T05:31:37.941523Z","log":"2019-08-12 05:30:57 10.240.0.77 GET / - 80 - 10.240.0.4 - - 200 0 64 769"}
\ No newline at end of file diff --git a/fluent-bit/examples/windows/kubernetes/README.md b/fluent-bit/examples/windows/kubernetes/README.md deleted file mode 100644 index f750a5d11..000000000 --- a/fluent-bit/examples/windows/kubernetes/README.md +++ /dev/null @@ -1,27 +0,0 @@ -# Fluent Bit running as a sidecar on Kubernetes Windows node
-
-You can test the Fluent Bit image as a sidecar on a Kubernetes Windows node as follows:
-
-```
-kubectl create namespace fluentbit
-kubectl apply -n fluentbit -f $SAMPLE_DIR\kubernetes\configmap.yaml
-kubectl apply -n fluentbit -f $SAMPLE_DIR\kubernetes\deployment.yaml
-```
-
-Ensure that the resources have been correctly deployed.
-
-```
-kubectl get pod -n fluentbit
-NAME READY STATUS RESTARTS AGE
-logging-fluentbit-sidecar-6ff8c84494-zt4ft 2/2 Running 0 31m
-
-kubectl get svc -n fluentbit
-NAME TYPE CLUSTER-IP EXTERNAL-IP PORT(S) AGE
-logging-fluentbit-sidecar LoadBalancer 10.0.27.172 52.237.212.148 80:30172/TCP 126m
-```
-
-If you tail the logs on the Fluent Bit sidecar, and then explore the website running in the external ip and port 80, you should see generated logs ...
-
-```
-kubectl logs logging-fluentbit-sidecar-6ff8c84494-zt4ft -n fluentbit -c fluentbit-logger -f
-```
\ No newline at end of file diff --git a/fluent-bit/examples/windows/kubernetes/configmap.yaml b/fluent-bit/examples/windows/kubernetes/configmap.yaml deleted file mode 100644 index 18ee0b99d..000000000 --- a/fluent-bit/examples/windows/kubernetes/configmap.yaml +++ /dev/null @@ -1,24 +0,0 @@ -apiVersion: v1
-kind: ConfigMap
-metadata:
- name: fluentbit-config
-data:
- fluent-bit.conf: |-
- [SERVICE]
- Flush 5
- Daemon off
- Log_Level info
-
- [INPUT]
- Name tail
- Path c:\\logs\\*.log
- Refresh_Interval 60
- Ignore_Older 10s
- Rotate_Wait 5
- DB c:\\state\\logs.db
-
- [OUTPUT]
- Name stdout
- Match *
- Format json_lines
- json_date_format iso8601
diff --git a/fluent-bit/examples/windows/kubernetes/deployment.yaml b/fluent-bit/examples/windows/kubernetes/deployment.yaml deleted file mode 100644 index 7bbf2996f..000000000 --- a/fluent-bit/examples/windows/kubernetes/deployment.yaml +++ /dev/null @@ -1,55 +0,0 @@ -apiVersion: v1
-kind: Service
-metadata:
- name: logging-fluentbit-sidecar
- labels:
- app: logging-fluentbit-sidecar
-spec:
- ports:
- - name: http
- port: 80
- targetPort: 80
- selector:
- app: website
- type: LoadBalancer
----
-apiVersion: apps/v1
-kind: Deployment
-metadata:
- name: logging-fluentbit-sidecar
-spec:
- replicas: 1
- selector:
- matchLabels:
- app: website
- template:
- metadata:
- labels:
- app: website
- spec:
- containers:
- - name: aspnet-web
- image: mcr.microsoft.com/dotnet/framework/samples:aspnetapp
- volumeMounts:
- - mountPath: c:\inetpub\logs\LogFiles\W3SVC1\
- name: log-volume
- - name: fluentbit-logger
- image: fluent/fluent-bit:1.3.7-nanoserver
- imagePullPolicy: Always
- volumeMounts:
- - mountPath: c:\config
- name: config
- - mountPath: c:\logs
- name: log-volume
- - mountPath: c:\state
- name: log-state
- volumes:
- - name: config
- configMap:
- name: fluentbit-config
- - name: log-volume
- emptyDir: {}
- - name: log-state
- emptyDir: {}
- nodeSelector:
- beta.kubernetes.io/os: windows
\ No newline at end of file |