Versions in this module Expand all Collapse all v6 v6.9.3 Mar 25, 2026 Changes in this version + const MessageTypeError + const MessageTypeHTTPReq + const MessageTypeHTTPResp + const MessageTypePing + const MessageTypePong + const MessageTypeStreamChunk + const MessageTypeStreamEnd + const MessageTypeStreamStart + type HTTPRequest struct + Body []byte + Headers http.Header + Method string + URL string + type HTTPResponse struct + Body []byte + Headers http.Header + Status int + type Manager struct + func NewManager(opts Options) *Manager + func (m *Manager) Handler() http.Handler + func (m *Manager) NonStream(ctx context.Context, provider string, req *HTTPRequest) (*HTTPResponse, error) + func (m *Manager) Path() string + func (m *Manager) Send(ctx context.Context, provider string, msg Message) (<-chan Message, error) + func (m *Manager) Stop(_ context.Context) error + func (m *Manager) Stream(ctx context.Context, provider string, req *HTTPRequest) (<-chan StreamEvent, error) + type Message struct + ID string + Payload map[string]any + Type string + type Options struct + LogDebugf func(string, ...any) + LogInfof func(string, ...any) + LogWarnf func(string, ...any) + OnConnected func(string) + OnDisconnected func(string, error) + Path string + ProviderFactory func(*http.Request) (string, error) + type StreamEvent struct + Err error + Headers http.Header + Payload []byte + Status int + Type string v6.9.2-rc1 Mar 25, 2026
Go to main page