events

Documentation

Index

• type Event
• type Handler
• type Queue
• type Subscription

Types

type Event

type Event struct {
	Topic       string
	ContentType string
	Body        []byte
	ID          string
}

Event encapsulates an event that is transported via EventQueue

type Handler

type Handler func(event *Event)

Handler is a callback function used to handle received event

type Queue

type Queue interface {
	Publish(event *Event) error
	Subscribe(topic string, handler Handler) (Subscription, error)
	Close()
}

Queue is an abstraction over possible implementation of messaging

type Subscription

type Subscription interface {
	Unsubscribe() error
}

Subscription represents an active subscription within Queue. Subscription can be stopped by calling Unsubscribe()