Skip to content
Branch: master
Find file Copy path
Find file Copy path
Fetching contributors…
Cannot retrieve contributors at this time
20 lines (16 sloc) 528 Bytes
package bahamut
import (
nats ""
// natsClient is an interface for objects that can act as a NATS client
type natsClient interface {
Publish(subj string, data []byte) error
RequestWithContext(ctx context.Context, subj string, data []byte) (*nats.Msg, error)
Subscribe(subj string, cb nats.MsgHandler) (*nats.Subscription, error)
QueueSubscribe(subj, queue string, cb nats.MsgHandler) (*nats.Subscription, error)
IsConnected() bool
IsReconnecting() bool
Flush() error
You can’t perform that action at this time.