eventbus

Documentation

Index

• Constants
• func ReceiveClientDeliveryEventName(clientID string) string
• type EventCenter
  • func NewEventCenter[T any](opts ...EventCenterOption) *EventCenter[T]
  • func (e *EventCenter[T]) AddListener(eventName string, handler EventHandler[T]) (listenerId, meta string)
  • func (e *EventCenter[T]) DeleteListener(eventName string, id string)
  • func (e *EventCenter[T]) Emit(eventName string, meta string, payload T) error
  • func (e *EventCenter[T]) EventListenerCount(eventName string) int
• type EventCenterOption
  • func WithListenerQueueCapacity(capacity int) EventCenterOption
• type EventHandler

Constants

const (
	// ReceivedClientDeliveryEventNamePrefix is the local event name prefix for client delivery wake/direct events.
	// Event name format: "event.delivery.task.client." + <clientID>
	ReceivedClientDeliveryEventNamePrefix = "event.delivery.task.client."
)

Functions

func ReceiveClientDeliveryEventName

func ReceiveClientDeliveryEventName(clientID string) string

ReceiveClientDeliveryEventName returns the local event name for client delivery events.

Types

type EventCenter

type EventCenter[T any] struct {
	// contains filtered or unexported fields
}

func NewEventCenter

func NewEventCenter[T any](opts ...EventCenterOption) *EventCenter[T]

func (*EventCenter[T]) AddListener

func (e *EventCenter[T]) AddListener(eventName string, handler EventHandler[T]) (listenerId, meta string)

func (*EventCenter[T]) DeleteListener

func (e *EventCenter[T]) DeleteListener(eventName string, id string)

func (*EventCenter[T]) Emit

func (e *EventCenter[T]) Emit(eventName string, meta string, payload T) error

func (*EventCenter[T]) EventListenerCount

func (e *EventCenter[T]) EventListenerCount(eventName string) int

type EventCenterOption

type EventCenterOption func(*eventCenterOptions)

func WithListenerQueueCapacity

func WithListenerQueueCapacity(capacity int) EventCenterOption

type EventHandler

type EventHandler[T any] func(T)