webhook

package

v1.3.0 Latest Latest Go to latest Published: May 2, 2026 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var Upgrader = websocket.Upgrader{
	CheckOrigin: func(r *http.Request) bool { return true },
}

This section is empty.

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

func NewDispatcher(cfg *config.Config) *Dispatcher

func (d *Dispatcher) AddWSClient(sessionID string, conn *websocket.Conn)

AddWSClient registers websocket connection for session.

func (d *Dispatcher) CloseSession(sessionID string)

CloseSession closes all websocket connections for session.

func (d *Dispatcher) Emit(sessionID, event string, data any)

func (d *Dispatcher) RemoveWSClient(sessionID string, conn *websocket.Conn)

RemoveWSClient removes websocket connection.

func (d *Dispatcher) StartRetryWorker()

StartRetryWorker periodically retries queued events.

type Event struct {
	SessionID string `json:"sessionId"`
	Event     string `json:"event"`
	Data      any    `json:"data,omitempty"`
}

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

Queue buffers events when webhook delivery fails. Events are retried periodically.

func NewQueue() *Queue

func (q *Queue) Drain() []Event

func (q *Queue) Len() int

func (q *Queue) Push(evt Event)