nats

Documentation

Index

• Constants
• func Register(cfg *config.Config)
• type NatsPublisher
  • func New(conn stan.Conn) *NatsPublisher
  • func (n NatsPublisher) Close() error
  • func (n NatsPublisher) Publish(subject string, evt *event.Event) error

Constants

const (
	ErrNatsConnection = "nats connection error"
)

Functions

func Register

func Register(cfg *config.Config)

Register 注册 NATS 事件发布器

Types

type NatsPublisher

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

NatsPublisher represent event publisher.

func New

func New(conn stan.Conn) *NatsPublisher

New return new NatsPublisher instance.

func (NatsPublisher) Close

func (n NatsPublisher) Close() error

Close NATS connection.

func (NatsPublisher) Publish

func (n NatsPublisher) Publish(subject string, evt *event.Event) error

Publish serializes the event and publishes it on the bus.