chore: use stable Rust

.github/workflows/ci.yml

@@ -22,7 +22,7 @@ jobs:
           profile: minimal
           components: rustfmt, clippy
       - run: cargo install --force cargo-hakari
-      - run: cargo fmt --all -- --check
+      - run: cargo +nightly fmt --all -- --check
       - run: cargo clippy --workspace --all-targets --all-features --locked -- -D warnings
       - run: cargo hakari verify
 

Makefile

@@ -0,0 +1,14 @@
+.DEFAULT_GOAL := all
+
+.PHONY: all fmt build test
+
+all: fmt
+
+fmt:
+	(cargo +nightly fmt)
+
+build:
+	(cargo build)
+
+test:
+	(cargo test)

src/hstreamdb/src/channel_provider.rs

@@ -1,5 +1,4 @@
 use std::collections::HashMap;
-use std::default::default;
 use std::iter::FromIterator;
 
 use hstreamdb_pb::h_stream_api_client::HStreamApiClient;
@@ -80,7 +79,7 @@ pub struct ChannelProviderSettingsBuilder(ChannelProviderSettings);
 
 impl ChannelProviderSettings {
     pub fn builder() -> ChannelProviderSettingsBuilder {
-        ChannelProviderSettingsBuilder(default())
+        ChannelProviderSettingsBuilder(ChannelProviderSettings::default())
     }
 }
 

src/hstreamdb/src/lib.rs

@@ -1,6 +1,3 @@
-#![feature(default_free_fn)]
-#![feature(map_first_last)]
-
 pub mod appender;
 mod channel_provider;
 pub mod client;

src/hstreamdb/src/producer.rs

@@ -1,5 +1,4 @@
 use std::collections::HashMap;
-use std::default::default;
 use std::error::Error;
 use std::fmt::{Debug, Display};
 use std::io::Write;
@@ -69,7 +68,7 @@ pub struct FlushSettings {
 
 impl FlushSettings {
     pub fn builder() -> FlushSettingsBuilder {
-        default()
+        FlushSettingsBuilder::default()
     }
 }
 
@@ -241,7 +240,7 @@ impl Producer {
             }
             Ok(shard_id) => match self.shard_buffer.get_mut(&shard_id) {
                 None => {
-                    let mut buffer_state: BufferState = default();
+                    let mut buffer_state: BufferState = BufferState::default();
                     buffer_state.modify(&record);
                     self.shard_buffer_state.insert(shard_id, buffer_state);
                     self.shard_buffer.insert(shard_id, vec![record]);