event

Documentation

Index

• type Bus
• type BusPublisher
• type BusSubscriber
• type EventContext
• type EventHandler
• type Subscriber

Types

type Bus

type Bus interface {
	BusSubscriber
	BusPublisher
}

Bus englobes global (subscribe, publish) bus behavior

var (
	BusDefault Bus = evbus.New()
)

type BusPublisher

type BusPublisher interface {
	Publish(topic string, args ...interface{})
}

BusPublisher defines publishing-related bus behavior

type BusSubscriber

type BusSubscriber interface {
	Subscribe(topic string, fn interface{}) error
	SubscribeAsync(topic string, fn interface{}, transactional bool) error
	Unsubscribe(topic string, handler interface{}) error
}

BusSubscriber defines subscription-related bus behavior

type EventContext

type EventContext struct {
	context.Context
	Publisher interface{}
	Param     interface{}
}

type EventHandler

type EventHandler func(ctx EventContext)

type Subscriber

type Subscriber struct {
	Topic string
	Fn    EventHandler
}