bus

Documentation

Index

• Constants
• func NewNATSConnection() (*nats.EncodedConn, error)
• type Bus
• type Handler
• type NATSBus
  • func NewNATSBus(nc *nats.EncodedConn) *NATSBus
  • func (n *NATSBus) Close() error
  • func (n *NATSBus) Publish(event testkube.Event) error
  • func (n *NATSBus) Subscribe(queueName string, handler Handler) error
  • func (n *NATSBus) Unsubscribe(queueName string) error

Constants

const (
	SubscribeBuffer  = 1
	SubscriptionName = "events"
)

Functions

func NewNATSConnection

func NewNATSConnection() (*nats.EncodedConn, error)

Types

type Bus

type Bus interface {
	Publish(event testkube.Event) error
	Subscribe(queue string, handler Handler) error
	Unsubscribe(queue string) error
	Close() error
}

type Handler

type Handler func(event testkube.Event) error

type NATSBus

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

func NewNATSBus

func NewNATSBus(nc *nats.EncodedConn) *NATSBus

func (*NATSBus) Close

func (n *NATSBus) Close() error

func (*NATSBus) Publish

func (n *NATSBus) Publish(event testkube.Event) error

func (*NATSBus) Subscribe

func (n *NATSBus) Subscribe(queueName string, handler Handler) error

func (*NATSBus) Unsubscribe

func (n *NATSBus) Unsubscribe(queueName string) error