action

type BrokerState int32

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

type State int32

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

type WebSocketConfig struct {
	URL            string        `json:"url"`
	ReconnectDelay time.Duration `json:"reconnect_delay"`
	MaxRetries     int           `json:"max_retries"`
	PingInterval   time.Duration `json:"ping_interval"`
	PongWait       time.Duration `json:"pong_wait"`
	WriteWait      time.Duration `json:"write_wait"`
}

type Webhook struct {
	ID        string            `json:"id" db:"id"`
	Event     string            `json:"event" db:"event"`
	URL       string            `json:"url" db:"url"`
	Headers   map[string]string `json:"headers" db:"headers"`
	Secret    string            `json:"secret" db:"secret"`
	Enabled   bool              `json:"enabled" db:"enabled"`
	CreatedAt time.Time         `json:"created_at" db:"created_at"`
}

type WebhookCreateRequest struct {
	Event   string            `json:"event" validate:"required"`
	URL     string            `json:"url" validate:"required,url"`
	Headers map[string]string `json:"headers"`
	Enabled *bool             `json:"enabled"`
}

type WebhookListResponse struct {
	Success bool       `json:"success"`
	Data    []*Webhook `json:"data,omitempty"`
	Total   int        `json:"total"`
	Error   string     `json:"error,omitempty"`
}

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

type WebhookResponse struct {
	Success bool     `json:"success"`
	Data    *Webhook `json:"data,omitempty"`
	Error   string   `json:"error,omitempty"`
}

type WebhookState int32

type WebhookUpdateRequest struct {
	Event   *string           `json:"event"`
	URL     *string           `json:"url"`
	Headers map[string]string `json:"headers"`
	Enabled *bool             `json:"enabled"`
}