bus

Documentation

Index

• Constants
• func NewNATSConnection(cfg ConnectionConfig, opts ...nats.Option) (*nats.Conn, error)
• func NewNATSEncodedConnection(cfg ConnectionConfig, opts ...nats.Option) (*nats.EncodedConn, error)
• func TestServerWithConnection() (*server.Server, *nats.Conn)
• type Bus
• type ConnectionConfig
• type EventBusMock
  • func NewEventBusMock() *EventBusMock
  • func (b *EventBusMock) Close() error
  • func (b *EventBusMock) ListQueues() []string
  • func (b *EventBusMock) Publish(event testkube.Event) error
  • func (b *EventBusMock) PublishTopic(topic string, event testkube.Event) error
  • func (b *EventBusMock) Subscribe(queue string, handler Handler) error
  • func (b *EventBusMock) SubscribeTopic(topic, queue string, handler Handler) error
  • func (b *EventBusMock) Unsubscribe(queue string) error
• 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) PublishTopic(topic string, event testkube.Event) error
  • func (n *NATSBus) Subscribe(queueName string, handler Handler) error
  • func (n *NATSBus) SubscribeTopic(topic, queueName string, handler Handler) error
  • func (n *NATSBus) Unsubscribe(queueName string) error

Constants

const (
	SubscribeBuffer        = 1
	SubscriptionName       = "events"
	InternalPublishTopic   = "internal.all"
	InternalSubscribeTopic = "internal.>"
)

Functions

func NewNATSConnection

func NewNATSConnection(cfg ConnectionConfig, opts ...nats.Option) (*nats.Conn, error)

func NewNATSEncodedConnection

func NewNATSEncodedConnection(cfg ConnectionConfig, opts ...nats.Option) (*nats.EncodedConn, error)

func TestServerWithConnection

func TestServerWithConnection() (*server.Server, *nats.Conn)

Types

type Bus

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

	PublishTopic(topic string, event testkube.Event) error
	SubscribeTopic(topic string, queue string, handler Handler) error

	Close() error
}

type ConnectionConfig

type ConnectionConfig struct {
	NatsURI            string
	NatsSecure         bool
	NatsSkipVerify     bool
	NatsCertFile       string
	NatsKeyFile        string
	NatsCAFile         string
	NatsConnectTimeout time.Duration
}

type EventBusMock

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

func NewEventBusMock

func NewEventBusMock() *EventBusMock

func (*EventBusMock) Close

func (b *EventBusMock) Close() error

func (*EventBusMock) ListQueues

func (b *EventBusMock) ListQueues() []string

func (*EventBusMock) Publish

func (b *EventBusMock) Publish(event testkube.Event) error

func (*EventBusMock) PublishTopic

func (b *EventBusMock) PublishTopic(topic string, event testkube.Event) error

func (*EventBusMock) Subscribe

func (b *EventBusMock) Subscribe(queue string, handler Handler) error

func (*EventBusMock) SubscribeTopic

func (b *EventBusMock) SubscribeTopic(topic, queue string, handler Handler) error

func (*EventBusMock) Unsubscribe

func (b *EventBusMock) Unsubscribe(queue string) 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

Publish publishes event to NATS on events topic

func (*NATSBus) PublishTopic

func (n *NATSBus) PublishTopic(topic string, event testkube.Event) error

PublishTopic publishes event to NATS on given topic

func (*NATSBus) Subscribe

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

Subscribe subscribes to NATS events topic

func (*NATSBus) SubscribeTopic

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

SubscribeTopic subscribes to NATS topic

func (*NATSBus) Unsubscribe

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