adapters

package
v3.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 11, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Rendered for js/wasm

Overview

Package adapters provides platform-specific adapters for running Go HTTP servers.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BufferedResponseWriter

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

BufferedResponseWriter collects HTTP response for Cloudflare (non-streaming)

func NewBufferedResponseWriter

func NewBufferedResponseWriter() *BufferedResponseWriter

NewBufferedResponseWriter creates a new buffered response writer

func (*BufferedResponseWriter) Header

func (w *BufferedResponseWriter) Header() http.Header

func (*BufferedResponseWriter) ToCloudflareResponse

func (w *BufferedResponseWriter) ToCloudflareResponse() js.Value

ToCloudflareResponse converts the buffered response to a Cloudflare Response

func (*BufferedResponseWriter) Write

func (w *BufferedResponseWriter) Write(data []byte) (int, error)

func (*BufferedResponseWriter) WriteHeader

func (w *BufferedResponseWriter) WriteHeader(statusCode int)

type CloudflareAdapter

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

CloudflareAdapter provides compatibility layer for Cloudflare Workers

func NewCloudflareAdapter

func NewCloudflareAdapter(config CloudflareConfig) *CloudflareAdapter

NewCloudflareAdapter creates a new adapter for Cloudflare Workers

func (*CloudflareAdapter) RegisterFetchHandler

func (ca *CloudflareAdapter) RegisterFetchHandler()

RegisterFetchHandler registers the fetch event handler for Cloudflare Workers

type CloudflareConfig

type CloudflareConfig struct {
	// Handler is the HTTP handler to use. If nil, http.DefaultServeMux is used.
	Handler http.Handler

	// EnableStreaming enables response streaming if supported
	EnableStreaming bool

	// MaxBodySize sets the maximum request body size (0 for unlimited)
	MaxBodySize int64

	// OnError is called when an error occurs during request handling
	OnError func(error)
}

CloudflareConfig contains configuration options for Cloudflare Workers

type StreamingResponseWriter

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

StreamingResponseWriter implements streaming responses for Cloudflare

func NewStreamingResponseWriter

func NewStreamingResponseWriter() *StreamingResponseWriter

NewStreamingResponseWriter creates a new streaming response writer

func (*StreamingResponseWriter) Flush

func (w *StreamingResponseWriter) Flush()

Flush implements http.Flusher

func (*StreamingResponseWriter) Header

func (w *StreamingResponseWriter) Header() http.Header

func (*StreamingResponseWriter) ToCloudflareResponse

func (w *StreamingResponseWriter) ToCloudflareResponse() js.Value

ToCloudflareResponse converts the streaming response to a Cloudflare Response

func (*StreamingResponseWriter) Write

func (w *StreamingResponseWriter) Write(data []byte) (int, error)

func (*StreamingResponseWriter) WriteHeader

func (w *StreamingResponseWriter) WriteHeader(statusCode int)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL