eventdistributer

package

v0.6.0 Latest Latest Go to latest Published: Feb 1, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

View Source

const (
	ExecutionCreatedEvent  = "execution_created"
	ExecutionFinishedEvent = "execution_finished"
	ExecutionStartedEvent  = "execution_started"
)

View Source

const (
	QueueItemCreatedEvent  = "queue_item_created"
	QueueItemConsumedEvent = "queue_item_consumed"
)

This section is empty.

func HandleCanvasEventCreated(messageBody []byte, wsHub *ws.Hub) error

func HandleCanvasExecution(messageBody []byte, wsHub *ws.Hub) error

func HandleQueueItemConsumed(messageBody []byte, wsHub *ws.Hub) error

func HandleQueueItemCreated(messageBody []byte, wsHub *ws.Hub) error

type CanvasEventWebsocketEvent struct {
	Event   string          `json:"event"`
	Payload json.RawMessage `json:"payload"`
}

type ExecutionStateWebsocketEvent struct {
	Event   string          `json:"event"`
	Payload json.RawMessage `json:"payload"`
}

type QueueItemWebsocketEvent struct {
	Event   string          `json:"event"`
	Payload json.RawMessage `json:"payload"`
}