event

Documentation

Index

• func Emit(topic string, event any)
• func Stop()
• func Unsubscribe(sub Subscription)
• type HandlerFunc
• type Subscription
  • func Subscribe(topic string, h HandlerFunc) Subscription

Functions

func Emit

func Emit(topic string, event any)

Emit and event to the given topic

func Stop

func Stop()

Stop stops the event stream, cleaning up its resources.

func Unsubscribe

func Unsubscribe(sub Subscription)

Unsubscribe unsubribes the given Subscription from its topic.

Types

type HandlerFunc

type HandlerFunc func(context.Context, any)

HandlerFunc is the function being called when receiving an event.

type Subscription

type Subscription struct {
	Topic     string
	CreatedAt int64
	Fn        HandlerFunc
}

Subscription represents a handler subscribed to a specific topic.

func Subscribe

func Subscribe(topic string, h HandlerFunc) Subscription

Subscribe a HandlerFunc to the given topic. A Subscription is being returned that can be used to unsubscribe from the topic.