eventdistributer

package

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

Details

View Source

const (
	CanvasUpdatedEvent = "canvas_updated"
	CanvasDeletedEvent = "canvas_deleted"
)

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 HandleCanvasDeleted(messageBody []byte, wsHub *ws.Hub) error

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

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

func HandleCanvasUpdated(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 CanvasStatePayload struct {
	ID string `json:"id"`
}

type CanvasStateWebsocketEvent struct {
	Event   string             `json:"event"`
	Payload CanvasStatePayload `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"`
}