Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Support async #49

Merged
merged 119 commits into from
May 11, 2024
Merged
Show file tree
Hide file tree
Changes from 114 commits
Commits
Show all changes
119 commits
Select commit Hold shift + click to select a range
9fdcd85
Reconcile with latest main
rustworthy Feb 23, 2024
cbeb2ce
Use x509-parser for tls test. Add test verifier
rustworthy Feb 24, 2024
a3b99c4
Make minimal versions pass again
rustworthy Feb 24, 2024
7ab8ab3
Comment out Openssl installation on windows in CI
rustworthy Feb 24, 2024
e6b3a4c
Revert "Comment out Openssl installation on windows in CI"
rustworthy Feb 24, 2024
ab38bfc
Restore patch version. Comment out OpenSSL install on CI
rustworthy Feb 24, 2024
ce4c8f2
Update tls test to use job runner
rustworthy Feb 24, 2024
fb2ddf1
interim
rustworthy Feb 24, 2024
2d4ef10
Improme consumer builder api
rustworthy Feb 24, 2024
0582514
Run fmt
rustworthy Feb 24, 2024
7f44798
Split client mod
rustworthy Feb 25, 2024
84864da
Producer -> Client
rustworthy Feb 25, 2024
6d11ad9
Fix 'commit_batch' on Client
rustworthy Feb 25, 2024
a875a35
Consumer -> Worker
rustworthy Feb 25, 2024
a1c613a
Add JobId struct
rustworthy Feb 26, 2024
008126d
Use JobId in lib
rustworthy Feb 27, 2024
9a56dea
Use WorkerId new-type
rustworthy Feb 27, 2024
566d2a2
Split Batch mod into logic constructs
rustworthy Feb 27, 2024
b7560ba
Use BatchId for operaions with Batch
rustworthy Feb 27, 2024
2fb7c63
re-export async trait
rustworthy Feb 28, 2024
755d452
Make 'jid', 'kind' and 'args' public on Job struct
rustworthy Feb 28, 2024
65110cf
Clean up in worker crate
rustworthy Mar 1, 2024
dcd6d97
Re-export rustls for convenience
rustworthy Mar 1, 2024
3c9ade4
re-export tokio main, clean up
rustworthy Mar 1, 2024
55890c8
Group re-exports in lib.rs
rustworthy Mar 2, 2024
00a6d1d
Fix copypasta in cmd.rs
rustworthy Mar 2, 2024
5382d5e
Rm redundant method on Worker
rustworthy Mar 20, 2024
dde77ce
Respecrt clippy on beta chan
rustworthy Mar 20, 2024
faeb436
Use try_seconds instead of seconds on Duration struct
rustworthy Mar 20, 2024
9ba6e85
Use try_seconds instead of seconds on Duration struct in tests
rustworthy Mar 20, 2024
fe65c67
Pin chrono at 0.4.32 to make minimal-versions pass
rustworthy Mar 20, 2024
ab59c97
Pin chrono at 0.4.32 to make minimal-versions pass
rustworthy Mar 20, 2024
8b979a4
Fix opts in Worker::connect method
rustworthy Mar 20, 2024
5077f2a
Use 'dep:' for feature deps
rustworthy Apr 2, 2024
5b041c9
Use tokio-native-tls for tls feature
rustworthy Apr 2, 2024
4efd5b6
Rm re-exports. Use tokio/macros for binaries feat only
rustworthy Apr 2, 2024
d657f69
Restore pin of min version for openssl
rustworthy Apr 3, 2024
53969f7
Use JoinSet in loadtest binary
rustworthy Apr 3, 2024
ea5fa8b
Rm left-over from proto/mod
rustworthy Apr 3, 2024
d3389ca
Keep 'CommitBatch' public in crate
rustworthy Apr 3, 2024
b3a272d
Keep 'GetBatchStatus' public in crate
rustworthy Apr 3, 2024
c70ff2c
Keep 'OpenBatch' public in crate
rustworthy Apr 3, 2024
a561377
Clean up in Cleint::init
rustworthy Apr 4, 2024
e2ccfcf
Split private and public methods for Client into blocks
rustworthy Apr 4, 2024
a1a701e
Derive Debug for ClientOptions
rustworthy Apr 4, 2024
9e55c24
Update self_to_cmd to not use format
rustworthy Apr 4, 2024
3aba8da
Add 'new' method for Ack cmd
rustworthy Apr 4, 2024
8270b7e
Add docs to 'generic' and 'generic_with_backtrace'
rustworthy Apr 4, 2024
b97071e
Only make commands pub(crate)
rustworthy Apr 4, 2024
6a32b4e
Add disclaimer on batch and job progress: ent only
rustworthy Apr 5, 2024
84897e9
Make jid private again
rustworthy Apr 5, 2024
fddd71f
Keep `args` private on `Job`
rustworthy Apr 5, 2024
11c9a87
Rm rudimentary extern cate syntax from test binaries
rustworthy Apr 5, 2024
bfc76fc
Rm left-over from testing
rustworthy Apr 5, 2024
5ee03bd
Use mem::take in pop_bytes_written on MockStream
rustworthy Apr 5, 2024
8da1e6c
Rm left-over print stmts from testing from tests/mock
rustworthy Apr 5, 2024
44a3b31
Restore hello_c test as hello_worker
rustworthy Apr 5, 2024
8b6e784
Clean up 'roundtrip' test
rustworthy Apr 5, 2024
b633b19
Rm 'extern' declaration from tests/real
rustworthy Apr 6, 2024
dd3a989
Make min-versions pass again
rustworthy Apr 7, 2024
5a17498
Support both openssl and rustls
rustworthy Apr 21, 2024
13eaace
Support both openssl and rustls. Clean up
rustworthy Apr 21, 2024
8d54b0c
Support both openssl and rustls. Min versions fix
rustworthy Apr 21, 2024
f1e5966
Support both openssl and rustls. Add TlsStream error
rustworthy Apr 21, 2024
58cb247
Support both openssl and rustls. Rustls clean up
rustworthy Apr 22, 2024
6628efb
Rm `async` from loadtest binary name
rustworthy Apr 22, 2024
6af3dcc
Rm leading underscore in `ops_count` var in loadtest
rustworthy Apr 22, 2024
f8d3f32
Rm redundant 'asynchronously' from the docs in proto::client mod
rustworthy Apr 22, 2024
e9cd581
Update private docs for ClientOptions
rustworthy Apr 22, 2024
2df103d
Craete BatchId, WorkerId, and JobId with `::new`
rustworthy Apr 22, 2024
a491964
Add `AsRef<str>` impl for BatchId, WorkerId, and JobId
rustworthy Apr 22, 2024
bb60f6b
Run formatter. Fix doc code
rustworthy Apr 22, 2024
14bcf64
Take 'Fail' in WorkerStatesRegistry::register_failure
rustworthy Apr 23, 2024
609950f
Impl IntoIterator for WorkerStatesRegistry
rustworthy Apr 23, 2024
db9b636
Add docs for Closure newtype
rustworthy Apr 23, 2024
757f92e
Restore JobRunner impl for &' mut F
rustworthy Apr 23, 2024
6469573
Update worker in community::roundtrip test to chain `register`
rustworthy Apr 23, 2024
803400d
Do not requiere *Ext in src::worker::mod
rustworthy Apr 23, 2024
4b29f9c
Restore docs for WorkerBuilder::default
rustworthy Apr 23, 2024
d869858
Rm redunrant helper methods on Worker
rustworthy Apr 23, 2024
9329ea0
Restore docs on WorkerBuilder::connect
rustworthy Apr 23, 2024
3b05585
Place comments in worker::mod to original location
rustworthy Apr 23, 2024
14e06ad
Rm redundate .take on statuses iterator
rustworthy Apr 23, 2024
df8a4b1
Run cargo fmt
rustworthy Apr 23, 2024
2bd215d
Use JoinSet in Worker::run. Update consumer::terminate test.
rustworthy Apr 24, 2024
2d4da65
Update signature in batch ent methods to accept AsRef<BatchId>
rustworthy Apr 24, 2024
0703983
Add serde transparent for newtype ids
rustworthy Apr 24, 2024
55d9bea
Ask for String rather than &str in TlsStream::new
rustworthy Apr 24, 2024
8d91c26
Rm redundant TlsStrean::create_new
rustworthy Apr 24, 2024
a44c63a
Pin serde at 1.0.186 to make min versions pass
rustworthy Apr 24, 2024
a088548
Add WorkerBuilder::add_to_labels method. Demonstrate in test
rustworthy Apr 26, 2024
ce4a65f
Rm empty line in WorkerBuilder::register
rustworthy Apr 26, 2024
da28e8d
Rename WorkerBuilder::register to WorkerBuilder::register_fn
rustworthy Apr 27, 2024
050a28d
Add to WorkerBuilder::register and ::register_fn docs
rustworthy Apr 27, 2024
6644a2f
Re-use WorkerBuilder::connect_with in ::connect
rustworthy Apr 27, 2024
6e5121a
Do not use *Ext as bounds
rustworthy Apr 27, 2024
0490637
Clean up worker::health module
rustworthy Apr 27, 2024
dfda0db
Rm excessive bounds
rustworthy Apr 27, 2024
56ccfb6
Store STATUS_TERMINATING in Fakotry signalled so
rustworthy Apr 27, 2024
44b8cfb
Store STATUS_TERMINATING in Fakotry signalled so
rustworthy Apr 27, 2024
f07d932
Add PartialEq<str> to proto::single::id module newtypes
rustworthy Apr 28, 2024
cdb8caf
Do not require static string in tls::rustls
rustworthy Apr 28, 2024
fd231d1
Use permalink in Worker::listen_for_heartbeats docs
rustworthy Apr 28, 2024
15d1711
Make WorkerBuilder return Self
rustworthy Apr 28, 2024
7724d24
Run cargo fmt on sources
rustworthy Apr 28, 2024
46e5457
Make min version pass
rustworthy Apr 28, 2024
57c958c
Make min version pass. Re-gen lockfile
rustworthy Apr 28, 2024
70d40ad
Make min version pass. Use rustls_pki_types dev dep
rustworthy Apr 28, 2024
a01fd91
Rm excessive bounds
rustworthy May 1, 2024
19cecc6
Add --all-faeture to 'make check' command
rustworthy May 1, 2024
dd30648
Update docs for worker::runner::Closure
rustworthy May 1, 2024
ca7f148
Fix clippy warnings
rustworthy May 1, 2024
9ca01da
Rm excessive bounds in native_tls and rustls modules
rustworthy May 2, 2024
2442473
Use 'Stream' enum for underlying steam errors
rustworthy May 3, 2024
bcfcadc
Pascal-case NativeTLS and RustTLS variants
rustworthy May 9, 2024
9c2511a
Refactor maybe_bid method on Client
rustworthy May 9, 2024
3bd0091
Add note on chrono::try_<unit> in Cargo.toml
rustworthy May 9, 2024
e907dac
Do not pin chrono at 0.4.32 for min version job
rustworthy May 9, 2024
cf3fb4e
Add Worker::builder method
rustworthy May 9, 2024
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
8 changes: 4 additions & 4 deletions .github/workflows/test.yml
Original file line number Diff line number Diff line change
Expand Up @@ -110,10 +110,10 @@ jobs:
os: [macos-latest, windows-latest]
steps:
# if your project needs OpenSSL, uncomment this to fix Windows builds.
- run: echo "VCPKG_ROOT=$env:VCPKG_INSTALLATION_ROOT" | Out-File -FilePath $env:GITHUB_ENV -Append
if: runner.os == 'Windows'
- run: vcpkg install openssl:x64-windows-static-md
if: runner.os == 'Windows'
# - run: echo "VCPKG_ROOT=$env:VCPKG_INSTALLATION_ROOT" | Out-File -FilePath $env:GITHUB_ENV -Append
# if: runner.os == 'Windows'
# - run: vcpkg install openssl:x64-windows-static-md
# if: runner.os == 'Windows'
- uses: actions/checkout@v4
with:
submodules: true
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/tls.yml
Original file line number Diff line number Diff line change
Expand Up @@ -29,4 +29,4 @@ jobs:
- name: Run tests
env:
FAKTORY_URL_SECURE: tcp://localhost:17419
run: cargo test --locked --features tls --test tls
run: cargo test --locked --features native_tls,rustls --test tls
1 change: 1 addition & 0 deletions .gitignore
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
/target/
**/*.rs.bk
perf.*
.vscode
Loading
Loading