Versions in this module Expand all Collapse all v0 v0.3.0 Mar 24, 2025 Changes in this version + func AsEvent(data any) (string, any) + func EventName(v any) string v0.2.0 Mar 21, 2025 Changes in this version + func Typed(data any) (string, any) v0.1.0 Mar 21, 2025 Changes in this version + func RegisterEventService(s *grpc.Server, engine *Engine) + type Engine struct + func New(opts ...Option) *Engine + func (s *Engine) Size() int + func (s *Engine) Submit(eventName string, data any) error + func (s *Engine) SubmitWithContext(ctx context.Context, eventName string, data any) error + func (s *Engine) Subscribe(eventName string, handler Handler) + type Event struct + Context context.Context + Data any + Timestamp time.Time + func (e Event) Cancel() + type Handler func(Event) error + func Wrap[T any](handler TypedHandler[T]) Handler + type Option func(*Engine) + func WithRemote(conn *grpc.ClientConn) Option + type TypedEvent struct + Data T + type TypedHandler func(TypedEvent[T]) error
Go to main page