sseserver

type EventClient struct {
	Id            EventClientId
	Connection    EventClientChan
	Identity      identitymodels.Identity
	Subscriptions []Subscription
}

type EventClientChan chan SseEvent

type EventClientId string

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

type EventMessage struct {
	Clients []EventClientId
	SseEvent
}

type EventServer struct {
	// Events are pushed to this channel by the main events-gathering routine
	Message chan EventMessage

	// New client connections
	NewClients chan *EventClient

	// Closed client connections
	ClosedClients chan EventClientId

	// Total client connections
	Clients EventClients
}

type SSESubscribe struct {
	ClientId EventClientId `json:"clientId" validate:"required"`
	Topic    Subscription  `json:"topic" validate:"required"`
}

type SseEvent struct {
	Event string `json:"event"`
	Data  string `json:"data" validate:"required"`
}

type Subscription string