transport

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

type HTTPConfig struct {
	URL     string
	Headers map[string]string
	// Client overrides the default http.Client. Optional.
	Client *http.Client
	// AllowSSE enables parsing of text/event-stream responses. When the
	// server sends SSE, the transport collates all `data:` events into a
	// single JSON-RPC response (the last well-formed frame wins).
	AllowSSE bool
}

type Kind string

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

type StdioConfig struct {
	// Cmd is the binary to execute.
	Cmd string
	// Args are the arguments passed to the subprocess.
	Args []string
	// Env holds additional environment variables (merged with os.Environ).
	Env map[string]string
	// Silent, when true, discards the subprocess stderr instead of forwarding.
	Silent bool
	// ShutdownGrace is the time allowed between SIGTERM and SIGKILL during
	// Close. Defaults to 5 seconds when zero.
	ShutdownGrace time.Duration
	// MaxLineBytes overrides the bufio.Scanner buffer size. Defaults to 16
	// MiB. Oversized responses are reported as transport errors.
	MaxLineBytes int
}

type Transport interface {
	// Call issues a single JSON-RPC request and returns the raw response
	// bytes. Timeouts and cancellation are honored via ctx.
	Call(ctx context.Context, method string, params any) (json []byte, err error)

	// Close releases resources (kills subprocess, closes HTTP connections).
	Close() error
}