nats

Documentation

Index

• type Observer
  • func (o *Observer) Close() error
  • func (o *Observer) SetTopics(ctx context.Context, topics []string) error
• type Publisher
  • func NewPublisher(url string, eventMarshaler event.MarshalerFunc, options ...nats.Option) (*Publisher, error)
  • func (p *Publisher) Close()
  • func (p *Publisher) Publish(ctx context.Context, topics []string, groupId, aggregateId string, ...) error
• type Subscriber
  • func NewSubscriber(url string, eventUnmarshaler event.UnmarshalerFunc, ...) (*Subscriber, error)
  • func (b *Subscriber) Close()
  • func (b *Subscriber) Subscribe(ctx context.Context, subscriptionId string, topics []string, eh event.Handler) (eventbus.Observer, error)

Types

type Observer

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

Observer handles events from kafka

func (*Observer) Close

func (o *Observer) Close() error

Close cancel observation and close connection to kafka.

func (*Observer) SetTopics

func (o *Observer) SetTopics(ctx context.Context, topics []string) error

SetTopics set new topics to observe.

type Publisher

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

Publisher implements a eventbus.Publisher interface.

func NewPublisher

func NewPublisher(url string, eventMarshaler event.MarshalerFunc, options ...nats.Option) (*Publisher, error)

NewPublisher creates a publisher.

func (*Publisher) Close

func (p *Publisher) Close()

Close close connection to nats

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, topics []string, groupId, aggregateId string, event event.Event) error

Publish publishes an event to topics.

type Subscriber

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

Subscriber implements a eventbus.Subscriber interface.

func NewSubscriber

func NewSubscriber(url string, eventUnmarshaler event.UnmarshalerFunc, goroutinePoolGo eventbus.GoroutinePoolGoFunc, errFunc eventbus.ErrFunc, options ...nats.Option) (*Subscriber, error)

NewSubscriber creates a subscriber.

func (*Subscriber) Close

func (b *Subscriber) Close()

Close closes subscriber.

func (*Subscriber) Subscribe

func (b *Subscriber) Subscribe(ctx context.Context, subscriptionId string, topics []string, eh event.Handler) (eventbus.Observer, error)

Subscribe creates a observer that listen on events from topics.