websocket

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

type Message struct {
	Type  string  `json:"type"`            // "ping" | "subscribe" | "unsubscribe"
	Event string  `json:"event,omitempty"` // event type, e.g., "step-stats"
	Ids   []int32 `json:"ids,omitempty"`   // subscribed ids; empty slice means "all ids for this event"
}

type OutEvent struct {
	Type string `json:"type,omitempty"` // e.g., "step-stats"
	Id   int32  `json:"id,omitempty"`   // e.g., workflow id
}

type WSEvent struct {
	EventId uint64      `json:"event_id"`          // monotonic, filled by EmitWS
	Type    string      `json:"type"`              // entity: "task","worker","workflow","step","job","user"
	Id      int32       `json:"id,omitempty"`      // optional: present for single-entity events
	Action  string      `json:"action,omitempty"`  // e.g., "created","updated","deleted","status"
	Payload interface{} `json:"payload,omitempty"` // additional data
}