nats

Documentation

Index

• func IsTopicValid(topic string) bool
• func New(logger *zap.Logger, mqCfg messageQueue.Config, routerUrl string) (messageQueue.MessageQueue, error)
• type Factory
  • func (factory *Factory) Create(logger *zap.Logger, mqCfg messageQueue.Config, routerUrl string) (messageQueue.MessageQueue, error)
• type Nats
  • func (nats Nats) Subscribe(trigger *fv1.MessageQueueTrigger) (messageQueue.Subscription, error)
  • func (nats Nats) Unsubscribe(subscription messageQueue.Subscription) error

Functions

func IsTopicValid

func IsTopicValid(topic string) bool

func New

func New(logger *zap.Logger, mqCfg messageQueue.Config, routerUrl string) (messageQueue.MessageQueue, error)

Types

type Factory

type Factory struct{}

func (*Factory) Create

func (factory *Factory) Create(logger *zap.Logger, mqCfg messageQueue.Config, routerUrl string) (messageQueue.MessageQueue, error)

type Nats

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

func (Nats) Subscribe

func (nats Nats) Subscribe(trigger *fv1.MessageQueueTrigger) (messageQueue.Subscription, error)

func (Nats) Unsubscribe

func (nats Nats) Unsubscribe(subscription messageQueue.Subscription) error