eventdistributer

package
v0.22.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 25, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CanvasUpdatedEvent        = "canvas_updated"
	CanvasVersionUpdatedEvent = "canvas_version_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"
)
View Source 
const (
	RunStartedEvent  = "run_started"
	RunFinishedEvent = "run_finished"
)

Variables

This section is empty.

Functions

func AgentSessionWebsocketTopic added in v0.21.0 

func AgentSessionWebsocketTopic(sessionID string) string

AgentSessionWebsocketTopic is the hub key shared by publisher and subscriber. Access control is enforced at subscribe time — we trust the topic on broadcast.

func HandleAgentSessionEvent added in v0.21.0 

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

func HandleCanvasDeleted added in v0.10.0 

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

func HandleCanvasEventCreated added in v0.6.0 

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

func HandleCanvasExecution added in v0.6.0 

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

func HandleCanvasRun added in v0.21.0 

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

func HandleCanvasUpdated added in v0.10.0 

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

func HandleCanvasVersionUpdated added in v0.11.0 

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

func HandleQueueItemConsumed added in v0.6.0 

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

func HandleQueueItemCreated added in v0.6.0 

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

Types

type CanvasEventWebsocketEvent added in v0.6.0 

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

type CanvasStatePayload added in v0.10.0 

type CanvasStatePayload struct {
	ID        string `json:"id"`
	CanvasID  string `json:"canvasId,omitempty"`
	VersionID string `json:"versionId,omitempty"`
}

type CanvasStateWebsocketEvent added in v0.10.0 

type CanvasStateWebsocketEvent struct {
	Event   string             `json:"event"`
	Payload CanvasStatePayload `json:"payload"`
}

type ExecutionStateWebsocketEvent 

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

type QueueItemWebsocketEvent 

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

type RunStateWebsocketEvent added in v0.21.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.