Documentation ¶
Index ¶
Constants ¶
View Source
const (
MessageQueueTypeNATS = "nats"
)
Message queue type constants
Variables ¶
View Source
var (
ErrorMessageQueueTypeUnsupported = errors.New("unsupported message queue type")
)
Functions ¶
This section is empty.
Types ¶
type MQClient ¶
type MQClient interface { Publish(string, interface{}) error Subscribe(string, func(interface{})) (int64, error) SubscribeWithGroup(string, string, func(interface{})) (int64, error) Unsubscribe(int64) error Group(int64) (string, error) Close() error }
func NewNATSClient ¶
NewNATSClient return MessageQueueClient
Click to show internal directories.
Click to hide internal directories.