flow

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

type ClientConfig struct {
	URL              string
	Username         string
	Password         string
	OnConnectHandler func()
}

type Event[T any] struct {
	Id        string    `json:"id"`
	Timestamp int64     `json:"timestamp"`
	EventType EventType `json:"event_type"`
	Triggerer string    `json:"triggerer"`
	Payload   T         `json:"payload"`
}

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

type EventType string