events

Documentation

Index

• type EventHandler
• type PubSub
• type Publisher
• type Subscriber
• type SubscriberConfig

Types

type EventHandler

type EventHandler interface {
	Handle(ctx context.Context, msg map[string]interface{}) error
	Cancel() error
}

type PubSub

type PubSub interface {
	Publisher
	Subscriber
}

type Publisher

type Publisher interface {
	Publish(ctx context.Context, topic string, msg map[string]interface{}) error
	Close() error
}

type Subscriber

type Subscriber interface {
	Subscribe(ctx context.Context, cfg SubscriberConfig) error
	Unsubscribe(ctx context.Context, id, topic string) error
	Close() error
}

type SubscriberConfig

type SubscriberConfig struct {
	ID      string
	Topic   string
	Handler EventHandler
}