eventdistributer

package

v0.0.34 Latest Latest Go to latest Published: Jan 7, 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 HandleWorkflowEventCreated(messageBody []byte, wsHub *ws.Hub) error

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

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

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

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

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

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