Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/go-eagle/eagle
/ Producer
Interface
Producer
pkg/queue/interface.go:4–6 ·
view source on GitHub ↗
Producer queue producer
Source
from the content-addressed store, hash-verified
2
3
// Producer queue producer
4
type
Producer
interface
{
5
Publish(message string) error
6
}
7
8
// Consumer queue consumer
9
type
Consumer
interface
{
Callers
11
main
Function · 0.95
Publish
Function · 0.65
Publish
Method · 0.65
Publish
Function · 0.65
PublishWithDelay
Function · 0.65
Publish
Method · 0.65
NewProducer
Function · 0.95
NewProducer
Function · 0.95
Start
Method · 0.95
ReConnect
Method · 0.95
Start
Method · 0.95
Implementers
4
Producer
pkg/queue/kafka/producer.go
Producer
pkg/queue/rabbitmq/producer.go
Channel
pkg/queue/rabbitmq/channel.go
Producer
pkg/queue/nats/producer.go
Calls
no outgoing calls
Tested by
no test coverage detected