Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
60 changes: 60 additions & 0 deletions .github/workflows/ci.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,60 @@
name: CI

permissions:
contents: read
pull-requests: read

on:
pull_request:
branches:
- main

jobs:
fmt:
name: Rustfmt
runs-on: ubuntu-latest
steps:
- name: Checkout code
uses: actions/checkout@v4

- name: Install Rust toolchain
uses: dtolnay/rust-toolchain@stable
with:
components: rustfmt

- name: Check formatting
run: cargo fmt --check

clippy:
name: Clippy
runs-on: ubuntu-latest
steps:
- name: Checkout code
uses: actions/checkout@v4

- name: Install Rust toolchain
uses: dtolnay/rust-toolchain@stable
with:
components: clippy

- name: Cache cargo dependencies
uses: Swatinem/rust-cache@v2

- name: Run Clippy
run: cargo clippy --all-targets --all-features -- -D warnings

test:
name: Tests
runs-on: ubuntu-latest
steps:
- name: Checkout code
uses: actions/checkout@v4

- name: Install Rust toolchain
uses: dtolnay/rust-toolchain@stable

- name: Cache cargo dependencies
uses: Swatinem/rust-cache@v2

- name: Run tests
run: cargo test --all-features
5 changes: 1 addition & 4 deletions src/producer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -20,10 +20,7 @@ pub async fn create(mut receiver: mpsc::Receiver<entity::VisitInfo>, producer: T
}
};

let message = match TopicWriterMessageBuilder::default()
.data(payload)
.build()
{
let message = match TopicWriterMessageBuilder::default().data(payload).build() {
Ok(msg) => msg,
Err(err) => {
tracing::error!("build message: {}", err);
Expand Down