Documentation
¶
Overview ¶
Package nats provides NATS adapters for the generic subscriber package.
New code should import this focused adapter path:
import "github.com/InsideGallery/core/queue/generic/subscriber/nats" subscriber := nats.NewSubscriber(conn)
Compatibility: queue/generic/subscriber/driver remains available for existing consumers. Prefer this package for NATS-specific adapter aliases so the generic subscriber root package does not grow provider-specific names.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config = legacy.NATSConfig
Config adapts NATS client configuration to the generic subscriber config contract.
type Subscriber ¶
type Subscriber = legacy.NATSSubscriber
Subscriber adapts a NATS client to the generic subscriber client contract.
func NewSubscriber ¶
func NewSubscriber(conn *client.Client) *Subscriber
NewSubscriber returns a NATS-backed generic subscriber client.
type Subscription ¶
type Subscription = legacy.NATSSubscription
Subscription adapts a NATS subscription to the generic subscriber subscription contract.
Source Files
Click to show internal directories.
Click to hide internal directories.