nats

type Broadcaster struct {
	// contains filtered or unexported fields
}

type BroadcasterOptions struct {
	NATSAddress    string
	Logger         *zap.SugaredLogger
	OTelPropagator propagation.TextMapPropagator
}

type Bus struct {
	// contains filtered or unexported fields
}

type Options struct {
	NATSAddress    string
	Logger         *zap.Logger
	Streams        []nats.StreamConfig
	OTelPropagator propagation.TextMapPropagator
}

type SubscribeBroadcastOpts struct {
	MessageBuffer int
	Deserializer  serialization.Serializer
}

type SubscribeOpts struct {
	CreateConsumer bool
	ConsumerName   string
	DurableName    string
	DeliverPolicy  *jetstream.DeliverPolicy
	// Deprecated: only use for nats < 2.10
	FilterSubject string
	// use filter subjects for nats >= 2.10
	FilterSubjects  []string
	MaxAckPending   int
	MaxDeliverTries int
	MessageBuffer   int
	Deserializer    serialization.Serializer
}

type Subscriber struct {
	// contains filtered or unexported fields
}

type SubscriberOptions struct {
	NATSAddress    string
	OTelPropagator propagation.TextMapPropagator
}