core

Documentation

Index

• func NewPublisher(connection *connection.NatsConnection) (pubsub.Publisher, error)
• func NewSubscriber(connection *connection.NatsConnection, opts ...SubscriberOption) (pubsub.Subscriber, error)
• type Publisher
  • func (p *Publisher) Publish(ctx context.Context, subject string, msgs ...*pubsub.Message) error
• type Subscriber
  • func (c *Subscriber) Subscribe(ctx context.Context, subject, _ string, ...) (pubsub.Unsubscribe, error)
• type SubscriberOption
  • func WithMeterSubscriberOption(meter metric.Meter) SubscriberOption
  • func WithTracerSubscriberOption(tracer tracing.Tracer) SubscriberOption

Functions

func NewPublisher

func NewPublisher(connection *connection.NatsConnection) (pubsub.Publisher, error)

func NewSubscriber

func NewSubscriber(connection *connection.NatsConnection, opts ...SubscriberOption) (pubsub.Subscriber, error)

Types

type Publisher

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

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, subject string, msgs ...*pubsub.Message) error

type Subscriber

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

func (*Subscriber) Subscribe

func (c *Subscriber) Subscribe(
	ctx context.Context,
	subject,
	_ string,
	handler func(context.Context, *pubsub.Message) pubsub.Acknowledger,
) (pubsub.Unsubscribe, error)

type SubscriberOption

type SubscriberOption func(*Subscriber)

func WithMeterSubscriberOption

func WithMeterSubscriberOption(meter metric.Meter) SubscriberOption

func WithTracerSubscriberOption

func WithTracerSubscriberOption(tracer tracing.Tracer) SubscriberOption