hub / github.com/assembla/cony
github.com/assembla/cony @v0.3.2
Chat with this repo
145 symbols
435 edges
19 files
47 documented · 32%
What it actually does AI analysis from the code graph — generated when you open this
loading…
README
Cony
High-level AMQP 0.9.1 client library. It's wrapper around low-level streadway/amqp library.
Goals
Provide a way to work with AMQP declaratively
Requirments
The library uses atomic.Value, so Go 1.4+ is needed.
Documentation
Thread-safety
Cony is thread-safe as long as streadway/amqp is thread-safe. It's recommended to open AMQP channel per thread, so in case of cony it should be Consumer Producer per goroutine.
License
BSD 2 clause - see LICENSE for more details.
Extension points exported contracts — how you extend this code
Backoffer (Interface)Backoffer is interface to hold Backoff strategy [1 implementers]
backoff.go
Declarer (Interface)
Declarer is implemented by *amqp.Channel [1 implementers]
declaration.go
ConsumerOpt (FuncType)
ConsumerOpt is a consumer's functional option type
consumer.go
PublisherOpt (FuncType)
PublisherOpt is a functional option type for Publisher
publisher.go
ClientOpt (FuncType)
ClientOpt is a Client's functional option type
client.go
Declaration (FuncType)
Declaration is a callback type to declare AMQP queue/exchange/binding
declaration.go
Core symbols most depended-on inside this repo
Cancelcalled by 14
consumer.go
serve
called by 11
consumer.go
Errors
called by 10
client.go
Loop
called by 10
client.go
reportErr
called by 10
client.go
Backoff
called by 8
backoff.go
Declare
called by 8
client.go
NewClient
called by 8
client.go
Shape
Languages
Go100%
Modules by API surface
client.go20 symbols
consumer_test.go16 symbols
consumer.go14 symbols
publisher_test.go12 symbols
cony.go12 symbols
client_test.go12 symbols
publisher.go10 symbols
cony_test.go9 symbols
declaration.go8 symbols
declaration_test.go7 symbols
doc_test.go5 symbols
backoff.go5 symbols