esx

type EventBus interface {
	MessageBus
	Replay() iter.Seq[Message]
}

type InMemoryStore struct {
	*SimpleMessageBus
	// contains filtered or unexported fields
}

type Message struct {
	Payload     any    `json:"payload"`
	Type        string `json:"type"`
	ReflectType reflect.Type
	Timestamp   time.Time
}

type MessageBus interface {
	Publish(ctx context.Context, message Message) error
	Subscribe(handler *MessageHandler)
}

type MessageHandler struct {
	Type     reflect.Type
	TypeName string
	Handler  MessageHandlerFunc
}

type MessageHandlerFunc func(ctx context.Context, payload any) error

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

type TypedMessageHandlerFunc[T any] func(ctx context.Context, payload T) error