Add NATS JetStream as a publish queue

Đang mở
  • Có gì không ổn?
#1,194 1 bình luận 0 reaction 0 người được giao Xem trên GitHub

Maintainer thường phản hồi trong vòng 4 ngày

Chưa có ai nhận issue này.

Đánh giá

Độ khó
4/5
Thời gian dự kiến
3-5 ngày
Mức phù hợp với người mới
35/100
Loại issue
Tính năng
Độ rõ ràng
Khá rõ ràng
Mức độ hoạt động
Sôi nổi
Công nghệ
go
Lĩnh vực
backend, stream-processing

Hướng nghiên cứu

The payload names no files. Start by reading how the existing publish-queue providers for RabbitMQ, SQS and GCP Pub/Sub consume messages, acknowledge them and handle redelivery, and how the existing NATS JetStream internal queue is configured. Done means a configured JetStream stream and subject feed events through normal topic and destination matching, with acknowledgement and redelivery matching the other providers.

Do mô hình lập chỉ mục viết ra từ nội dung của issue.

Mô tả

enhancement

Is your feature request related to a problem? Please describe.
Outpost cannot currently subscribe to NATS Jetstream's stream as an event source. It uses JetStream for its internal queues? We can’t use it to ingest events and route them to configured destinations.

Describe the solution you'd like
Allow Outpost to be configured to subscribe to NATS JetStream stream and subject. When an event arrives, Outpost should process it through its normal topic and destination matching, then deliver it to the matching webhook or other destination.

The integration should follow the same approach as Outpost’s other publish-queue providers, including appropriate message acknowledgement and redelivery behavior.

Describe alternatives you've considered
We could run a separate bridge that consumes from JetStream and calls Outpost’s  /api/v1/publish  endpoint. This adds another service and another network hop.

Additional context
Outpost already supports NATS JetStream for internal delivery and logging queues. This request is for using JetStream as an incoming publish queue, similar to the existing RabbitMQ, SQS, and GCP Pub/Sub integrations.

Ngôn ngữ chính
Go
Star
1.1k
Fork
70
Merge trung bình
3 ngày 21 giờ
Pull request đã merge (30 ngày)
34

Chuẩn bị môi trường

Dự án này không cung cấp dev container, Dockerfile hay hướng dẫn đóng góp, nên bạn cần tự thiết lập môi trường: hãy bắt đầu từ README và xem hướng dẫn đóng góp lần đầu của chúng tôi để biết các bước chung.

Bắt đầu từ đâu

  1. Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
  2. Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
  3. Fork repository và làm thay đổi trên một nhánh.
  4. Mở pull request có tham chiếu số hiệu của issue.

Issue khác của hookdeck/outpost

Tất cả issue của hookdeck/outpost

Issue tương tự

Thêm issue về Go

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.