Ecosyste.ms: Repos
An open API service providing repository metadata for many open source software ecosystems.
Package Usage: go: github.com/streadway/amqp
Package amqp is an AMQP 0.9.1 client with RabbitMQ extensions
Understand the AMQP 0.9.1 messaging model by reviewing these links first. Much
of the terminology in this library directly relates to AMQP concepts.
Most other broker clients publish to queues, but in AMQP, clients publish
Exchanges instead. AMQP is programmable, meaning that both the producers and
consumers agree on the configuration of the broker, instead of requiring an
operator or system configuration that declares the logical topology in the
broker. The routing between producers and consumer queues is via Bindings.
These bindings form the logical topology of the broker.
In this library, a message sent from publisher is called a "Publishing" and a
message received to a consumer is called a "Delivery". The fields of
Publishings and Deliveries are close but not exact mappings to the underlying
wire format to maintain stronger types. Many other libraries will combine
message properties with message headers. In this library, the message well
known properties are strongly typed fields on the Publishings and Deliveries,
whereas the user defined headers are in the Headers field.
The method naming closely matches the protocol's method name with positional
parameters mapping to named protocol message fields. The motivation here is to
present a comprehensive view over all possible interactions with the server.
Generally, methods that map to protocol methods of the "basic" class will be
elided in this interface, and "select" methods of various channel mode selectors
will be elided for example Channel.Confirm and Channel.Tx.
The library is intentionally designed to be synchronous, where responses for
each protocol message are required to be received in an RPC manner. Some
methods have a noWait parameter like Channel.QueueDeclare, and some methods are
asynchronous like Channel.Publish. The error values should still be checked for
these methods as they will indicate IO failures like when the underlying
connection closes.
Clients of this library may be interested in receiving some of the protocol
messages other than Deliveries like basic.ack methods while a channel is in
confirm mode.
The Notify* methods with Connection and Channel receivers model the pattern of
asynchronous events like closes due to exceptions, or messages that are sent out
of band from an RPC call like basic.ack or basic.flow.
Any asynchronous events, including Deliveries and Publishings must always have
a receiver until the corresponding chans are closed. Without asynchronous
receivers, the sychronous methods will block.
It's important as a client to an AMQP topology to ensure the state of the
broker matches your expectations. For both publish and consume use cases,
make sure you declare the queues, exchanges and bindings you expect to exist
prior to calling Channel.Publish or Channel.Consume.
SSL/TLS - Secure connections
When Dial encounters an amqps:// scheme, it will use the zero value of a
tls.Config. This will only perform server certificate and host verification.
Use DialTLS when you wish to provide a client certificate (recommended),
include a private certificate authority's certificate in the cert chain for
server validity, or run insecure by not verifying the server certificate dial
your own connection. DialTLS will use the provided tls.Config when it
encounters an amqps:// scheme and will dial a plain connection when it
encounters an amqp:// scheme.
SSL/TLS in RabbitMQ is documented here: http://www.rabbitmq.com/ssl.html
This exports a Session object that wraps this library. It
automatically reconnects when the connection fails, and
blocks all pushes until the connection succeeds. It also
confirms every outgoing message, so none are lost.
It doesn't automatically ack each message, but leaves that
to the parent process, since it is usage-dependent.
Try running this in one terminal, and `rabbitmq-server` in another.
Stop & restart RabbitMQ to see how the queue reacts.
2 versions
Latest release: 11 months ago
7,453 dependent packages
View more package details: https://packages.ecosyste.ms/registries/proxy.golang.org/packages/github.com/streadway/amqp
View more repository details: https://repos.ecosyste.ms/hosts/GitHub/repositories/streadway%2Famqp
Dependent Repos 28,168
brotherlogic/logging
Logging for system- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 614 KB - Last synced: 1 day ago - Pushed: 2 days ago
ossf/scorecard-action
Official GitHub Action for OpenSSF Scorecard.- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
- v1.0.0 go.sum
Size: 6.44 MB - Last synced: about 12 hours ago - Pushed: about 12 hours ago
zeromike/syft Fork of anchore/syft
CLI tool and library for generating a Software Bill of Materials from container images and filesystems- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
- v1.0.0 go.sum
Size: 10.4 MB - Last synced: 12 months ago - Pushed: almost 2 years ago
aberja/argo Fork of argoproj/argo-workflows
Argo Workflows: Get stuff done with Kubernetes.- v1.0.0 go.sum
Size: 67.2 MB - Last synced: about 1 year ago - Pushed: about 1 year ago
krasish/test-infra Fork of kyma-project/test-infra
Test infrastructure for the Kyma project.- v0.0.0-20190404075320-75d898a42a94 development/gcp/cloud-functions/getfailureinstancedetails/go.sum
- v0.0.0-20190827072141-edfb9018d271 development/gcp/cloud-functions/getfailureinstancedetails/go.sum
- v1.0.0 development/gcp/cloud-functions/getfailureinstancedetails/go.sum
- v0.0.0-20190404075320-75d898a42a94 development/kyma-ci-force-bot/ciforcebot/go.sum
- v0.0.0-20190827072141-edfb9018d271 development/kyma-ci-force-bot/ciforcebot/go.sum
- v1.0.0 development/kyma-ci-force-bot/ciforcebot/go.sum
- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
- v1.0.0 go.sum
Size: 15.3 MB - Last synced: about 1 year ago - Pushed: about 1 year ago
cheqd/tendermint Fork of tendermint/tendermint
⟁ Tendermint Core (BFT Consensus) in Go- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
- v1.0.0 go.sum
Size: 142 MB - Last synced: about 1 month ago - Pushed: over 1 year ago
ryanlycch/go-zero-looklook Fork of Mikaelemmmm/go-zero-looklook
🔥基于go-zero(go zero) 微服务全技术栈开发最佳实践项目。Develop best practice projects based on the full technology stack of go zero (go zero) microservices.- v1.0.0 go.sum
Size: 101 MB - Last synced: 30 days ago - Pushed: 30 days ago
ahmedabu98/beam Fork of apache/beam
Apache Beam is a unified programming model for Batch and Streaming- v0.0.0-20190404075320-75d898a42a94 playground/backend/go.sum
- v0.0.0-20190827072141-edfb9018d271 playground/backend/go.sum
Size: 365 MB - Last synced: 27 days ago - Pushed: 28 days ago
observIQ/grafana-agent Fork of grafana/agent
Telemetry agent for the LGTM stack.- v0.0.0-20180528204448-e5adc2ada8b8 go.sum
- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
- v1.0.0 go.sum
Size: 48.3 MB - Last synced: 5 months ago - Pushed: 5 months ago
tharun208/loki Fork of grafana/loki
Like Prometheus, but for logs.- v0.0.0-20180528204448-e5adc2ada8b8 go.sum
- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
- v1.0.0 go.sum
- v0.0.0-20190404075320-75d898a42a94 operator/go.sum
- v0.0.0-20190827072141-edfb9018d271 operator/go.sum
- v0.0.0-20190404075320-75d898a42a94 tools/lambda-promtail/go.sum
- v0.0.0-20190827072141-edfb9018d271 tools/lambda-promtail/go.sum
Size: 168 MB - Last synced: 22 days ago - Pushed: about 1 year ago
Team-Kujira/ibc-go Fork of cosmos/ibc-go
Interblockchain Communication Protocol (IBC) implementation in Golang.- v0.0.0-20190404075320-75d898a42a94 e2e/go.sum
- v0.0.0-20190827072141-edfb9018d271 e2e/go.sum
- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 30.2 MB - Last synced: 19 days ago - Pushed: 8 months ago
jan--f/telemeter Fork of openshift/telemeter
Prometheus push federation- v0.0.0-20190404075320-75d898a42a94 tools/go.sum
- v0.0.0-20190827072141-edfb9018d271 tools/go.sum
Size: 35 MB - Last synced: 11 months ago - Pushed: 11 months ago
FranLucchini/try_seldonCore_JenkinsX
Check how to use Seldon Core with Jenkins X- v0.0.0-20190404075320-75d898a42a94 versionStream/tests/go.sum
- v0.0.0-20190827072141-edfb9018d271 versionStream/tests/go.sum
Size: 244 KB - Last synced: about 1 year ago - Pushed: almost 2 years ago
carlkyrillos/integreatly-operator Fork of integr8ly/integreatly-operator
An Openshift Operator based on the Operator SDK for installing and reconciling Integreatly services- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 126 MB - Last synced: 22 days ago - Pushed: 22 days ago
msrinivasssa/go-trial-app
- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 397 KB - Last synced: about 1 year ago - Pushed: about 1 year ago
jrivera-px/operator Fork of libopenstorage/operator
Storage operator for Kubernetes- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 34.9 MB - Last synced: about 1 year ago - Pushed: over 1 year ago
rxrddd/austin-v2
基于kratos 的聚合消息推送平台- v1.0.0 go.mod
- v1.0.0 go.sum
Size: 1.77 MB - Last synced: about 1 year ago - Pushed: about 1 year ago
paketo-buildpacks/go
A Cloud Native Buildpack for Go- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
- v1.0.0 go.sum
Size: 82.6 MB - Last synced: 7 days ago - Pushed: 7 days ago
slachiewicz/kubernetes-client Fork of fabric8io/kubernetes-client
Java client for Kubernetes & OpenShift- v0.0.0-20190404075320-75d898a42a94 extensions/camel-k/generator-v1/go.sum
- v0.0.0-20190404075320-75d898a42a94 extensions/camel-k/generator-v1alpha1/go.sum
- v0.0.0-20190404075320-75d898a42a94 extensions/knative/generator/go.sum
- v0.0.0-20190827072141-edfb9018d271 extensions/knative/generator/go.sum
- v0.0.0-20190404075320-75d898a42a94 extensions/tekton/generator-v1alpha1/go.sum
- v0.0.0-20190404075320-75d898a42a94 extensions/tekton/generator-v1beta1/go.sum
- v0.0.0-20190827072141-edfb9018d271 extensions/tekton/generator-v1beta1/go.sum
- v0.0.0-20190404075320-75d898a42a94 kubernetes-model-generator/go.sum
- v0.0.0-20190827072141-edfb9018d271 kubernetes-model-generator/go.sum
Size: 466 MB - Last synced: 6 days ago - Pushed: 7 days ago
paketo-buildpacks/dotnet-core
A Cloud Native Buildpack for .NET Core- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
- v1.0.0 go.sum
Size: 134 MB - Last synced: 7 days ago - Pushed: 7 days ago
influxdata/influxdb-observability
- v0.0.0-20190404075320-75d898a42a94 tests-integration/go.sum
- v0.0.0-20190827072141-edfb9018d271 tests-integration/go.sum
Size: 2.21 MB - Last synced: 18 days ago - Pushed: 18 days ago
TeachersPayTeachers/linux-audit-exporter
Export Linux audit status as Prometheus metrics- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 112 KB - Last synced: 3 months ago - Pushed: 3 months ago
eblindeman/dashboard Fork of kubernetes/dashboard
General-purpose web UI for Kubernetes clusters- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 152 MB - Last synced: about 1 year ago - Pushed: over 1 year ago
Zondax/rosetta-filecoin-lib
- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
- v1.0.0 go.sum
Size: 337 KB - Last synced: 16 days ago - Pushed: 17 days ago
RafaySystems/terraform-provider-rafay
Rafay terraform provider- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 4.34 MB - Last synced: about 20 hours ago - Pushed: about 21 hours ago
Boroda76/go_service_naked
- v1.0.0 go.mod
- v1.0.0 go.sum
Size: 791 KB - Last synced: 21 days ago - Pushed: about 1 year ago
drand/drand
🎲 A Distributed Randomness Beacon Daemon - Go implementation- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 50.9 MB - Last synced: about 21 hours ago - Pushed: about 21 hours ago
drh-determined-ai/determined Fork of determined-ai/determined
Determined: Deep Learning Training Platform- v0.0.0-20190404075320-75d898a42a94 agent/go.sum
- v0.0.0-20190827072141-edfb9018d271 agent/go.sum
- v0.0.0-20190404075320-75d898a42a94 master/go.sum
- v0.0.0-20190827072141-edfb9018d271 master/go.sum
Size: 114 MB - Last synced: about 1 year ago - Pushed: about 1 year ago
Seanstoppable/wtf Fork of wtfutil/wtf
The personal information dashboard for your terminal.- v0.0.0-20180528204448-e5adc2ada8b8 go.sum
Size: 47.6 MB - Last synced: 10 months ago - Pushed: 12 months ago
stratosnet/stratos-chain
Stratos Blockchain- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 5.26 MB - Last synced: about 11 hours ago - Pushed: about 12 hours ago
leoluz/argo-rollouts Fork of argoproj/argo-rollouts
Progressive Delivery for Kubernetes- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 25.8 MB - Last synced: 24 days ago - Pushed: about 1 year ago
dreamer-zq/cosmos-sdk Fork of cosmos/cosmos-sdk
:chains: A Framework for Building High Value Public Blockchains :sparkles:- v0.0.0-20190404075320-75d898a42a94 cosmovisor/go.sum
- v0.0.0-20190827072141-edfb9018d271 cosmovisor/go.sum
- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
- v1.0.0 go.sum
Size: 217 MB - Last synced: 24 days ago - Pushed: 7 months ago
millicent-money/cosmos-sdk
- v0.0.0-20190404075320-75d898a42a94 cosmovisor/go.sum
- v0.0.0-20190827072141-edfb9018d271 cosmovisor/go.sum
- v0.0.0-20190404075320-75d898a42a94 go.sum
- v0.0.0-20190827072141-edfb9018d271 go.sum
Size: 361 MB - Last synced: 9 months ago - Pushed: about 1 year ago