Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var GRPCStatusToHTTP = grpcStatusToHTTP
grpcStatusToHTTP maps a gRPC status code to an HTTP-like status code so the engine's error classifier and metrics work uniformly across all driver types.
OK(0) → 200 InvalidArgument(3) → 400 OutOfRange(11) → 400 Unauthenticated(16) → 401 PermissionDenied(7) → 403 NotFound(5) → 404 AlreadyExists(6) → 409 ResourceExhausted(8) → 429 Unimplemented(12) → 501 Unavailable(14) → 503 DeadlineExceeded(4) → 504 other → 500
GRPCStatusToHTTP is exported for testing.
Functions ¶
This section is empty.
Types ¶
type BrowserDriver ¶
type BrowserDriver struct{}
BrowserDriver executes tasks using a headless Chrome browser via chromedp. Each Execute call spawns an isolated browser instance to avoid memory leaks.
func NewBrowserDriver ¶
func NewBrowserDriver() *BrowserDriver
NewBrowserDriver creates a BrowserDriver.
type DNSDriver ¶
type DNSDriver struct {
// contains filtered or unexported fields
}
DNSDriver performs DNS lookups using the miekg/dns library.
func NewDNSDriver ¶
func NewDNSDriver() *DNSDriver
NewDNSDriver creates a DNSDriver with a shared DNS client.
type GRPCDriver ¶ added in v1.1.0
type GRPCDriver struct {
// contains filtered or unexported fields
}
GRPCDriver executes unary gRPC requests. It uses server reflection to resolve request/response types so no .proto files are required at runtime. Connections and method descriptors are cached across calls.
URL format:
grpc://host:port/package.Service/Method — plaintext grpcs://host:port/package.Service/Method — TLS
func NewGRPCDriver ¶ added in v1.1.0
func NewGRPCDriver() *GRPCDriver
NewGRPCDriver creates a GRPCDriver.
type HTTPDriver ¶
type HTTPDriver struct {
// contains filtered or unexported fields
}
HTTPDriver executes HTTP requests.
func NewHTTPDriver ¶
func NewHTTPDriver() *HTTPDriver
NewHTTPDriver creates an HTTPDriver with a shared transport.
type WebSocketDriver ¶
type WebSocketDriver struct{}
WebSocketDriver connects to a WebSocket endpoint, sends messages, and waits.
func NewWebSocketDriver ¶
func NewWebSocketDriver() *WebSocketDriver
NewWebSocketDriver creates a WebSocketDriver.
Source Files