event

Documentation

Index

• Constants
• Variables
• type AsyncEventBus
  • func (bus *AsyncEventBus) Publish(event Event)
  • func (bus *AsyncEventBus) Subscribe(eventType EventType, handler EventHandler)
• type Event
  • func NewEvent(eventType EventType, data any) Event
• type EventBus
• type EventHandler
• type EventType

Constants

const (
	SESSION_EXPIRIED = iota + 1
)

Variables

var DefaultEventBus = AsyncEventBus{
	// contains filtered or unexported fields
}

Types

type AsyncEventBus

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

func (*AsyncEventBus) Publish

func (bus *AsyncEventBus) Publish(event Event)

func (*AsyncEventBus) Subscribe

func (bus *AsyncEventBus) Subscribe(eventType EventType, handler EventHandler)

type Event

type Event struct {
	EventType EventType
	Ts        int64
	Data      interface{}
}

func NewEvent

func NewEvent(eventType EventType, data any) Event

type EventBus

type EventBus interface {
	Publish(event Event)
	Subscribe(eventType EventType, handler EventHandler)
}

type EventHandler

type EventHandler func(event Event)

type EventType

type EventType int