pubsub

Documentation

Index

• type PubSub
  • func NewPubSub[T any](params PubSubParams) (*PubSub[T], error)
  • func (p *PubSub[T]) Close(ctx context.Context) (err error)
  • func (p *PubSub[T]) Publish(ctx context.Context, message T) error
  • func (p *PubSub[T]) Subscribe(ctx context.Context, subscriber pubsub.Subscriber[T]) (err error)
• type PubSubParams

Types

type PubSub

type PubSub[T any] struct {
	// contains filtered or unexported fields
}

func NewPubSub

func NewPubSub[T any](params PubSubParams) (*PubSub[T], error)

func (*PubSub[T]) Close

func (p *PubSub[T]) Close(ctx context.Context) (err error)

func (*PubSub[T]) Publish

func (p *PubSub[T]) Publish(ctx context.Context, message T) error

func (*PubSub[T]) Subscribe

func (p *PubSub[T]) Subscribe(ctx context.Context, subscriber pubsub.Subscriber[T]) (err error)

type PubSubParams

type PubSubParams struct {
	// Subject is the NATS subject to publish to. It is also used as the subscription subject if SubscriptionSubject is empty.
	Subject string
	// SubscriptionSubject is the NATS subject to subscribe to. If empty, Subject is used.
	// This is useful when the subscription subject is different from the publishing subject, e.g. when using wildcards.
	SubscriptionSubject string
	// Conn is the NATS connection to use for publishing and subscribing.
	Conn *nats.Conn
}