Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
25 commits
Select commit Hold shift + click to select a range
1f48561
feat(connectors): scaffold HTTP sink connector with types and stub Si…
mlevkov Mar 11, 2026
9554d19
feat(connectors): implement HTTP sink core — consume, retry, batch modes
mlevkov Mar 11, 2026
810828f
fix(connectors): remediate 12 review findings in HTTP sink (CR round 1)
mlevkov Mar 11, 2026
ba236eb
fix(connectors): remediate 7 follow-up review findings in HTTP sink (…
mlevkov Mar 11, 2026
81036b0
docs(connectors): add HTTP sink example config.toml
mlevkov Mar 12, 2026
c4d0258
docs(connectors): add HTTP sink README with usage, config reference, …
mlevkov Mar 12, 2026
f23ce56
test(connectors): add 46 unit tests for HTTP sink connector
mlevkov Mar 12, 2026
bd5fca6
fix(connectors): address 5 test/docs review findings for HTTP sink
mlevkov Mar 12, 2026
82d43ad
test(connectors): add integration tests for HTTP sink using WireMock
mlevkov Mar 12, 2026
f58e781
fix(connectors): remediate round 1 review findings for HTTP sink
mlevkov Mar 12, 2026
929b14a
fix(connectors): remediate round 2 review findings for HTTP sink
mlevkov Mar 12, 2026
4e778bf
docs(connectors): expand HTTP sink README with use cases, auth, deplo…
mlevkov Mar 13, 2026
624161e
feat(http-sink): add TCP keep-alive and connection pool idle timeout
mlevkov Mar 13, 2026
3ac51b1
test(http-sink): add multi-topic integration test
mlevkov Mar 13, 2026
50277fd
docs(http-sink): add connector runtime model and achievability table
mlevkov Mar 13, 2026
15b6d62
docs(http-sink): add runtime source references and connection pool de…
mlevkov Mar 13, 2026
c7e7171
docs(http-sink): add message flow section explaining input vs output …
mlevkov Mar 13, 2026
98994f1
fix(http-sink): remediate code review findings — error accounting, va…
mlevkov Mar 13, 2026
a09c4b3
refactor(http-sink): use Bytes type in send_batch_body signature for …
mlevkov Mar 13, 2026
3c6d192
fix(http-sink): remediate follow-up review findings (F1-F6)
mlevkov Mar 13, 2026
d9694ad
docs(http-sink): add comprehensive integration test documentation
mlevkov Mar 13, 2026
818fc7c
fix(http-sink): fix compilation errors and apply rustfmt formatting
mlevkov Mar 13, 2026
ec179a9
style(http-sink): align ASCII architecture diagram in test docs
mlevkov Mar 13, 2026
e9939ce
Merge remote-tracking branch 'origin/master' into feat/http-sink-conn…
mlevkov Mar 13, 2026
a1e43f9
fix(http-sink): resolve 5 CI failures — typos, markdown, fmt, license…
mlevkov Mar 13, 2026
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
18 changes: 18 additions & 0 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,7 @@ members = [
"core/connectors/runtime",
"core/connectors/sdk",
"core/connectors/sinks/elasticsearch_sink",
"core/connectors/sinks/http_sink",
"core/connectors/sinks/iceberg_sink",
"core/connectors/sinks/mongodb_sink",
"core/connectors/sinks/postgres_sink",
Expand Down
1 change: 1 addition & 0 deletions DEPENDENCIES.md
Original file line number Diff line number Diff line change
Expand Up @@ -456,6 +456,7 @@ iggy_binary_protocol: 0.9.2-edge.1, "Apache-2.0",
iggy_common: 0.9.2-edge.1, "Apache-2.0",
iggy_connector_elasticsearch_sink: 0.3.2-edge.1, "Apache-2.0",
iggy_connector_elasticsearch_source: 0.3.2-edge.1, "Apache-2.0",
iggy_connector_http_sink: 0.1.0, "Apache-2.0",
iggy_connector_iceberg_sink: 0.3.2-edge.1, "Apache-2.0",
iggy_connector_mongodb_sink: 0.3.0, "Apache-2.0",
iggy_connector_postgres_sink: 0.3.2-edge.1, "Apache-2.0",
Expand Down
48 changes: 48 additions & 0 deletions core/connectors/sinks/http_sink/Cargo.toml
Original file line number Diff line number Diff line change
@@ -0,0 +1,48 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you 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.

[package]
name = "iggy_connector_http_sink"
version = "0.1.0"
description = "Iggy HTTP sink connector for delivering stream messages to any HTTP endpoint via webhooks, REST APIs, or serverless functions."
edition = "2024"
license = "Apache-2.0"
keywords = ["iggy", "messaging", "streaming", "http", "sink"]
categories = ["command-line-utilities", "database", "network-programming"]
homepage = "https://iggy.apache.org"
documentation = "https://iggy.apache.org/docs"
repository = "https://github.com/apache/iggy"
readme = "../../README.md"

[lib]
crate-type = ["cdylib", "lib"]

[dependencies]
async-trait = { workspace = true }
base64 = { workspace = true }
bytes = { workspace = true }
humantime = { workspace = true }
iggy_connector_sdk = { workspace = true }
reqwest = { workspace = true }
serde = { workspace = true }
serde_json = { workspace = true }
simd-json = { workspace = true }
tokio = { workspace = true }
tracing = { workspace = true }

[dev-dependencies]
toml = { workspace = true }
Loading
Loading