gateway

type AuthorizedKey struct {
	KeyType   KeyType `json:"keyType,omitempty"`
	PublicKey string  `json:"publicKey,omitempty"`
}

type CacheSettings struct {
	MaxAgeMs int32 `json:"maxAgeMs,omitempty"` // Maximum age of a cached response in milliseconds.
	Store    bool  `json:"store,omitempty"`    // If true, cache the response.
	// Deprecated: positive MaxAgeMs implies ReadFromCache is true
	ReadFromCache bool `json:"readFromCache,omitempty"` // If true, attempt to read a cached response for the request
}

type HTTPTriggerRequest struct {
	Input    json.RawMessage  `json:"input"`    // Input parameters for the workflow.
	Key      AuthorizedKey    `json:"key"`      // Signing key for the request
	Workflow WorkflowSelector `json:"workflow"` // Selector for the workflow to execute.
}

type HTTPTriggerResponse struct {
	WorkflowID          string            `json:"workflow_id,omitempty"`           // ID of the triggered workflow.
	WorkflowExecutionID string            `json:"workflow_execution_id,omitempty"` // ID of the workflow execution.
	Status              HTTPTriggerStatus `json:"status,omitempty"`                // Status of the trigger request.
}

type HTTPTriggerStatus string

type KeyType string

type OutboundHTTPRequest struct {
	URL           string            `json:"url"`                 // URL to query, only http and https protocols are supported.
	Method        string            `json:"method,omitempty"`    // HTTP verb, defaults to GET.
	Headers       map[string]string `json:"headers,omitempty"`   // HTTP headers, defaults to empty.
	Body          []byte            `json:"body,omitempty"`      // HTTP request body
	TimeoutMs     uint32            `json:"timeoutMs,omitempty"` // Timeout in milliseconds
	CacheSettings CacheSettings     `json:"cacheSettings"`       // Best-effort cache control for the request

	// Maximum number of bytes to read from the response body.  If the gateway max response size is smaller than this value, the gateway max response size will be used.
	MaxResponseBytes uint32 `json:"maxBytes,omitempty"`
	WorkflowID       string `json:"workflowId"`
	WorkflowOwner    string `json:"workflowOwner"`
}

type OutboundHTTPResponse struct {
	// ErrorMessage contains error details for gateway-level errors (validation, internal errors, or external endpoint failures like timeouts).
	// This field is empty when the request successfully reaches the customer's endpoint and returns a response (regardless of HTTP status code).
	ErrorMessage string `json:"errorMessage,omitempty"`

	// IsExternalEndpointError indicates the request was sent to the customer's endpoint but failed while sending the request or receiving the response.
	// (e.g., connection timeout, response too large, unreachable host). When true, ErrorMessage contains the failure details.
	IsExternalEndpointError bool `json:"isExternalEndpointError,omitempty"`

	// IsValidationError indicates the request was blocked by the gateway BEFORE being sent to the customer's endpoint
	// due to policy violations (e.g., blocked HTTP headers, blocked IP addresses, invalid URL).
	// This is distinct from StatusCode 4xx, which would indicate the customer's endpoint received and rejected the request.
	IsValidationError bool `json:"isValidationError,omitempty"`

	// StatusCode is the HTTP status code returned by the customer's endpoint (e.g., 2xx, 4xx, 5xx).
	// This field is only populated when the request successfully reaches the customer's endpoint and the response is received.
	StatusCode int `json:"statusCode,omitempty"`

	Headers                 map[string]string `json:"headers,omitempty"`                 // HTTP headers returned by the customer's endpoint
	Body                    []byte            `json:"body,omitempty"`                    // HTTP response body returned by the customer's endpoint
	ExternalEndpointLatency time.Duration     `json:"externalEndpointLatency,omitempty"` // Time taken by the customer's endpoint to respond
}

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

type WorkflowMetadata struct {
	WorkflowSelector WorkflowSelector
	AuthorizedKeys   []AuthorizedKey
}

type WorkflowSelector struct {
	WorkflowID    string `json:"workflowID,omitempty"`    // Unique ID of the workflow.
	WorkflowName  string `json:"workflowName,omitempty"`  // Name of the workflow.
	WorkflowOwner string `json:"workflowOwner,omitempty"` // Owner of the workflow.
	WorkflowTag   string `json:"workflowTag,omitempty"`   // Tag for the workflow.
}