ws

func CountWorkerGoroutines ¶

func CountWorkerGoroutines() int

CountWorkerGoroutines returns a best-effort count of websocket worker goroutines belonging to this package. Intended for diagnostics endpoints only.

func ForwardLines ¶

func ForwardLines(ctx context.Context, hub *Hub, lines <-chan string)

ForwardLines forwards plain text lines to the hub.

func ForwardLogJSON ¶

func ForwardLogJSON(ctx context.Context, hub *Hub, logs <-chan LogMessage)

ForwardLogJSON sends each LogMessage as its own JSON object frame.

func ForwardLogJSONBatched ¶

func ForwardLogJSONBatched(ctx context.Context, hub *Hub, logs <-chan LogMessage, maxBatch int, flushInterval time.Duration)

ForwardLogJSONBatched batches log messages into a JSON array frame to reduce frame count. Flushes when maxBatch reached or flushInterval elapsed.

func NormalizeContainerLine ¶

func NormalizeContainerLine(raw string) (level string, msg string, timestamp string)

NormalizeContainerLine parses a raw container log line into level + cleaned message. It extracts Docker's timestamp if present (when timestamps=true in Docker API).

func NormalizeProjectLine ¶

func NormalizeProjectLine(raw string) (level, service, msg, timestamp string)

NormalizeProjectLine additionally extracts service (pattern: service | message). Returns level, service, message, timestamp (RFC3339Nano) — timestamp may be empty.

func NowRFC3339 ¶

func NowRFC3339() string

func ProxyHTTP ¶

func ProxyHTTP(w http.ResponseWriter, r *http.Request, remoteWS string, header http.Header) error

ProxyHTTP upgrades the incoming client connection and bridges it to remoteWS.

func ServeClientWithOnRemove ¶

func ServeClientWithOnRemove(ctx context.Context, hub *Hub, conn *websocket.Conn, onRemove func())

ServeClientWithOnRemove registers the client with the hub and starts read/write pumps. Caller is responsible for creating/closing the websocket.Conn. If onRemove is non-nil, it is invoked when the client is removed from the hub.