http

May 13, 2026

Changes in this version

+ func CallVoid(ctx context.Context, req *http.Request, opts ...CallOption) error

+ type CallOption func(*callConfig)

+ func WithClient(c *http.Client) CallOption

+ func WithInsecureTLS() CallOption

type HTTPError

+ Body []byte

+ Header http.Header

Apr 11, 2026

Changes in this version

type BaseSSEConn

+ func (b *BaseSSEConn[O]) SendRetry(ms int)

type SSEOutgoingMessage

+ Retry int

Apr 10, 2026

Changes in this version

+ const MaxErrorBodySize

type HTTPStatusError

+ Header http.Header

Apr 9, 2026

Changes in this version

+ func DetectBatch(body []byte) bool

+ func SplitBatch(body []byte) ([]json.RawMessage, error)

Apr 9, 2026

Changes in this version

+ type AtomicIDGen struct

+ func (g *AtomicIDGen) Next() string

+ type EventStore interface

+ Replay func(streamID string, lastEventID string) ([]StoredEvent, error)

+ Store func(streamID string, event StoredEvent) error

+ Trim func(streamID string) error

+ type IDGen interface

+ Next func() string

+ type MemoryEventStore struct

+ func NewMemoryEventStore(maxPerStream int) *MemoryEventStore

+ func (s *MemoryEventStore) Replay(streamID string, lastEventID string) ([]StoredEvent, error)

+ func (s *MemoryEventStore) Store(streamID string, event StoredEvent) error

+ func (s *MemoryEventStore) Trim(streamID string) error

type SSEHub

+ func (h *SSEHub[O]) BroadcastEventWithID(event, id string, msg O)

+ func (h *SSEHub[O]) SendEventWithID(connId, event, id string, msg O) bool

+ type StoredEvent struct

+ Data []byte

+ Event string

+ ID string

Apr 9, 2026

Changes in this version

+ func DoWithAuthRetry(cfg *AuthRetryConfig, buildReq func() (*http.Request, error), ...) (*http.Response, error)

+ func ParseWWWAuthenticate(header string) (resourceMetadata string, scopes []string, err error)

+ type AuthRetryConfig struct

+ OnForbidden func(resp *http.Response) error

+ OnUnauthorized func(resp *http.Response) error

+ SetAuth func(req *http.Request) error

+ type AuthRetryError struct

+ Cause error

+ Message string

+ RequiredScopes []string

+ StatusCode int

+ WWWAuthenticate string

+ func (e *AuthRetryError) Error() string

+ func (e *AuthRetryError) Unwrap() error

Apr 9, 2026

Changes in this version

+ func GenerateSessionID() string

+ func IsHTTPTransient(statusCode int) bool

+ func ParseAcceptTypes(accept string) (acceptsJSON, acceptsSSE bool)

+ func ReadFrame(r *bufio.Reader) ([]byte, error)

+ func ResolveURL(baseURL, ref string) (string, error)

+ func WriteFrame(w io.Writer, data []byte) error

+ type HTTPStatusError struct

+ Body string

+ StatusCode int

+ func (e *HTTPStatusError) Error() string

Apr 9, 2026

Changes in this version

+ type SSEEventReader struct

+ func NewSSEEventReader(r io.Reader) *SSEEventReader

+ func (r *SSEEventReader) ReadEvent() (SSEReadEvent, error)

+ type SSEReadEvent struct

+ Comment string

+ Data string

+ Event string

+ ID string

+ Retry int

Apr 2, 2026

Changes in this version

type BaseSSEConn

+ func (b *BaseSSEConn[O]) Ready() <-chan struct{}

Apr 2, 2026

Changes in this version

+ func ListenAndServeGraceful(srv *http.Server, opts ...GracefulOption) error

+ func StreamableServe(handler StreamableHandlerFunc, config *StreamableConfig) http.HandlerFunc

+ type GracefulOption func(*gracefulConfig)

+ func WithContext(ctx context.Context) GracefulOption

+ func WithDrainTimeout(d time.Duration) GracefulOption

+ func WithOnShutdown(fn func()) GracefulOption

+ func WithSignals(sigs ...os.Signal) GracefulOption

+ type SSEEvent struct

+ Data any

+ Event string

+ ID string

+ type SingleResponse struct

+ Body any

+ StatusCode int

+ type StreamResponse struct

+ Events <-chan SSEEvent

+ type StreamableConfig struct

+ Codec Codec[any, any]

+ func DefaultStreamableConfig() *StreamableConfig

+ type StreamableHandlerFunc func(ctx context.Context, r *http.Request) StreamableResponse

+ type StreamableResponse interface

Apr 2, 2026

Changes in this version

+ func SSEServe[O any, S SSEConn[O]](handler SSEHandler[O, S], config *SSEConnConfig) http.HandlerFunc

+ type BaseSSEConn struct

+ Codec Codec[any, O]

+ ConnIdStr string

+ NameStr string

+ Writer *conc.Writer[SSEOutgoingMessage[O]]

+ func (b *BaseSSEConn[O]) Close()

+ func (b *BaseSSEConn[O]) ConnId() string

+ func (b *BaseSSEConn[O]) Done() <-chan struct{}

+ func (b *BaseSSEConn[O]) InputChan() chan<- SSEOutgoingMessage[O]

+ func (b *BaseSSEConn[O]) Name() string

+ func (b *BaseSSEConn[O]) OnClose()

+ func (b *BaseSSEConn[O]) OnStart(w http.ResponseWriter, r *http.Request) error

+ func (b *BaseSSEConn[O]) SendEvent(event string, msg O)

+ func (b *BaseSSEConn[O]) SendEventWithID(event string, id string, msg O)

+ func (b *BaseSSEConn[O]) SendKeepalive()

+ func (b *BaseSSEConn[O]) SendOutput(msg O)

+ type JSONSSEConn = BaseSSEConn[any]

+ type JSONSSEHandler struct

+ func (h *JSONSSEHandler) Validate(w http.ResponseWriter, r *http.Request) (*JSONSSEConn, bool)

+ type SSEConn interface

+ ConnId func() string

+ Done func() <-chan struct{}

+ Name func() string

+ OnClose func()

+ OnStart func(w http.ResponseWriter, r *http.Request) error

+ SendKeepalive func()

+ type SSEConnConfig struct

+ KeepalivePeriod time.Duration

+ func DefaultSSEConnConfig() *SSEConnConfig

+ type SSEHandler interface

+ Validate func(w http.ResponseWriter, r *http.Request) (S, bool)

+ type SSEHub struct

+ func NewSSEHub[O any]() *SSEHub[O]

+ func (h *SSEHub[O]) Broadcast(msg O)

+ func (h *SSEHub[O]) BroadcastEvent(event string, msg O)

+ func (h *SSEHub[O]) CloseAll()

+ func (h *SSEHub[O]) Count() int

+ func (h *SSEHub[O]) Register(conn *BaseSSEConn[O])

+ func (h *SSEHub[O]) Send(connId string, msg O) bool

+ func (h *SSEHub[O]) SendEvent(connId string, event string, msg O) bool

+ func (h *SSEHub[O]) Unregister(connId string)

+ type SSEOutgoingMessage struct

+ Comment string

+ Data *O

+ Event string

+ ID string

Dec 31, 2025

Changes in this version

+ type BaseConn struct

+ Codec Codec[I, O]

+ ConnIdStr string

+ NameStr string

+ PingId int64

+ Writer *conc.Writer[OutgoingMessage[O]]

+ func (b *BaseConn[I, O]) ConnId() string

+ func (b *BaseConn[I, O]) DebugInfo() any

+ func (b *BaseConn[I, O]) HandleMessage(msg I) error

+ func (b *BaseConn[I, O]) InputChan() chan<- OutgoingMessage[O]

+ func (b *BaseConn[I, O]) Name() string

+ func (b *BaseConn[I, O]) OnClose()

+ func (b *BaseConn[I, O]) OnError(err error) error

+ func (b *BaseConn[I, O]) OnStart(conn *websocket.Conn) error

+ func (b *BaseConn[I, O]) OnTimeout() bool

+ func (b *BaseConn[I, O]) ReadMessage(conn *websocket.Conn) (I, error)

+ func (b *BaseConn[I, O]) SendError(err error)

+ func (b *BaseConn[I, O]) SendOutput(msg O)

+ func (b *BaseConn[I, O]) SendPing() error

+ type BaseHandler struct

+ Codec Codec[I, O]

+ Name string

+ func (h *BaseHandler[I, O]) Validate(w http.ResponseWriter, r *http.Request) (*BaseConn[I, O], bool)

+ type BinaryProtoCodec struct

+ Input I

+ NewInput func() I

+ func (c *BinaryProtoCodec[I, O]) Decode(data []byte, msgType MessageType) (I, error)

+ func (c *BinaryProtoCodec[I, O]) Encode(msg O) ([]byte, MessageType, error)

+ type Codec interface

+ Decode func(data []byte, msgType MessageType) (I, error)

+ Encode func(msg O) ([]byte, MessageType, error)

+ type JSONCodec struct

+ func (c *JSONCodec) Decode(data []byte, msgType MessageType) (any, error)

+ func (c *JSONCodec) Encode(msg any) ([]byte, MessageType, error)

type JSONConn

+ func NewJSONConn() *JSONConn

+ type MessageType int

+ const BinaryMessage

+ const TextMessage

+ type OutgoingMessage struct

+ Data *O

+ Error error

+ Ping *PingData

+ type PingData struct

+ ConnId string

+ Name string

+ PingId int64

+ type ProtoJSONCodec struct

+ Input I

+ MarshalOptions protojson.MarshalOptions

+ NewInput func() I

+ UnmarshalOptions protojson.UnmarshalOptions

+ func (c *ProtoJSONCodec[I, O]) Decode(data []byte, msgType MessageType) (I, error)

+ func (c *ProtoJSONCodec[I, O]) Encode(msg O) ([]byte, MessageType, error)

+ type TypedJSONCodec struct

+ func (c *TypedJSONCodec[I, O]) Decode(data []byte, msgType MessageType) (I, error)

+ func (c *TypedJSONCodec[I, O]) Encode(msg O) ([]byte, MessageType, error)

Jul 18, 2025

Changes in this version

+ var DefaultHttpClient *http.Client

+ var HighQPSHttpClient *http.Client

+ var LowQPSHttpClient *http.Client

+ var MediumQPSHttpClient *http.Client

+ func CORS(next http.Handler) http.Handler

+ func Call(req *http.Request, client *http.Client) (response any, err error)

+ func ErrorToHttpCode(err error) int

+ func HTTPErrorCode(err error) int

+ func JsonGet(url string, onReq func(req *http.Request)) (any, *http.Response, error)

+ func JsonToQueryString(json map[string]any) string

+ func MakeUrl(host, path string, args string) (url string)

+ func NewBytesRequest(method string, endpoint string, body []byte) (req *http.Request, err error)

+ func NewJsonRequest(method string, endpoint string, body map[string]any) (req *http.Request, err error)

+ func NewRequest(method string, endpoint string, bodyReader io.Reader) (req *http.Request, err error)

+ func NormalizeWsUrl(httpOrWsUrl string) string

+ func SendJsonResponse(writer http.ResponseWriter, resp any, err error)

+ func WSConnJSONReaderWriter(conn *websocket.Conn) (reader *conc.Reader[gut.StrMap], writer *conc.Writer[conc.Message[gut.StrMap]])

+ func WSConnWriteError(wsConn *websocket.Conn, err error) error

+ func WSConnWriteMessage(wsConn *websocket.Conn, msg any) error

+ func WSHandleConn[I any, S WSConn[I]](conn *websocket.Conn, ctx S, config *WSConnConfig)

+ func WSServe[I any, S WSConn[I]](handler WSHandler[I, S], config *WSConnConfig) http.HandlerFunc

+ type BiDirStreamConfig struct

+ PingPeriod time.Duration

+ PongPeriod time.Duration

+ func DefaultBiDirStreamConfig() *BiDirStreamConfig

+ type BiDirStreamConn interface

+ ConnId func() string

+ HandleMessage func(msg I) error

+ Name func() string

+ OnClose func()

+ OnError func(err error) error

+ OnTimeout func() bool

+ SendPing func() error

+ type HTTPError struct

+ Code int

+ Message string

+ func (t *HTTPError) Error() string

+ type JSONConn struct

+ ConnIdStr string

+ NameStr string

+ PingId int64

+ Writer *conc.Writer[conc.Message[any]]

+ func (j *JSONConn) ConnId() string

+ func (j *JSONConn) DebugInfo() any

+ func (j *JSONConn) HandleMessage(msg any) error

+ func (j *JSONConn) Name() string

+ func (j *JSONConn) OnClose()

+ func (j *JSONConn) OnError(err error) error

+ func (j *JSONConn) OnStart(conn *websocket.Conn) error

+ func (j *JSONConn) OnTimeout() bool

+ func (j *JSONConn) ReadMessage(conn *websocket.Conn) (out any, err error)

+ func (j *JSONConn) SendPing() error

+ type JSONHandler struct

+ func (j *JSONHandler) Validate(w http.ResponseWriter, r *http.Request) (out WSConn[any], isValid bool)

+ type RequestVarMap struct

+ func (r *RequestVarMap) GetKey(req *http.Request, key string) (value any)

+ func (r *RequestVarMap) SetKey(req *http.Request, key string, value any)

+ type URLWaiter struct

+ DelayBetweenChecks time.Duration

+ Headers map[string]string

+ Method string

+ Payload map[string]any

+ RequestFunc func(iter int, prevError error) (*http.Request, error)

+ Url string

+ ValidateFunc func(req *http.Request, resp *http.Response) error

+ func (u *URLWaiter) Run() (success bool, iter int, err error)

+ type WSConn interface

+ OnStart func(conn *websocket.Conn) error

+ ReadMessage func(w *websocket.Conn) (I, error)

+ type WSConnConfig struct

+ Upgrader websocket.Upgrader

+ func DefaultWSConnConfig() *WSConnConfig

+ type WSHandler interface

+ Validate func(w http.ResponseWriter, r *http.Request) (S, bool)