src/server.bend relies on unsafe/foreign

raw source on the hub · import 0x2731c2a5d4185b57cf5353061639642e/src/server.bend as Server

2 imports

import Base
import ./json.bend as Json

Types

type ServerHeader source · line 4 · raw

Data

ServerHeader

@name:String -> @value:String -> ServerHeader

type Config source · line 8 · raw

Data

One listener lifetime per process. Zero port asks the OS for a free port.

Config

@address:String -> @port:U32 -> @max_body:U32 -> @max_pending:U32 -> @timeout_ms:U32 -> @grace_ms:U32 -> Config

type TransportLimits source · line 15 · raw

Data

Accepted socket budget and absolute time to receive the complete request.

TransportLimits

@max_connections:U32 -> @read_timeout_ms:U32 -> TransportLimits

type Started source · line 18 · raw

Data

Listening
```
@port:U32 -> Started
```
ListenError
```
@code:String -> Started
```

type Incoming source · line 22 · raw

Data

Incoming

@id:U32 -> @method:String -> @path:String -> @target:String -> @headers:List<&2, ServerHeader> -> @body:String -> Incoming

type Next source · line 25 · raw

Data

Received
```
@request:Incoming -> Next
```
Stopped
```
Next
```

type IncomingHead source · line 30 · raw

Data

Opt-in upload streaming exposes validated request metadata before the body.

IncomingHead

@id:U32 -> @method:String -> @path:String -> @target:String -> @headers:List<&2, ServerHeader> -> IncomingHead

type StreamNext source · line 33 · raw

Data

StreamReceived
```
@request:IncomingHead -> StreamNext
```
StreamStopped
```
StreamNext
```

type BodyNext source · line 37 · raw

Data

BodyChunk
```
@value:String -> BodyNext
```
BodyEnd
```
BodyNext
```
BodyFailure
```
@code:String -> BodyNext
```

type Reply source · line 42 · raw

Data

Reply

@status:U32 -> @headers:List<&2, ServerHeader> -> @body:String -> Reply

type Replied source · line 45 · raw

Data

Sent
```
Replied
```
ReplyError
```
@code:String -> Replied
```

type ConnectionMode source · line 50 · raw

Data

Streaming is opt-in. Ordinary Reply keeps its connection-closing behavior.

CloseAfter
```
ConnectionMode
```
KeepAlive
```
ConnectionMode
```

type StreamHead source · line 54 · raw

Data

StreamHead

@status:U32 -> @headers:List<&2, ServerHeader> -> @connection:ConnectionMode -> StreamHead

type Metrics source · line 200 · raw

Data

Process/listener lifetime counters and current bounded gauges. No reset API.

Metrics

@admitted:U32 -> @completed:U32 -> @failed:U32 -> @rejected:U32 -> @expired:U32 -> @read_expired:U32 -> @disconnected:U32 -> @connections:U32 -> @pending:U32 -> @handlers:U32 -> Metrics

Definitions

def config source · line 11 · raw

@address:String -> @port:U32 -> Config

def json source · line 57 · raw

@status:U32 -> @body:String -> Reply

def encoded_reply source · line 60 · raw

@status:U32 -> @result:0x2731c2a5d4185b57cf5353061639642e/src/json.EncodeResult -> IO(Reply)

def json_value source · line 67 · raw

@status:U32 -> @value:0x2731c2a5d4185b57cf5353061639642e/src/json.Json -> IO(Reply)

def with_header source · line 70 · raw

@name:String -> @value:String -> @reply:Reply -> Reply

def header_step source · line 76 · raw

@equal:Bool -> @value:String -> @rest:(@_:Unit -> Maybe<&1, String>) -> Maybe<&1, String>

Incoming field names are normalized to lowercase by the native boundary.

def header source · line 81 · raw

@+name:String -> @headers:List<&2, ServerHeader> -> Maybe<&1, String>

def stream_start_mode source · line 119 · raw

@id:U32 -> @status:U32 -> @headers:List<&2, ServerHeader> -> @connection:ConnectionMode -> IO(Replied)

def Server.stream_start source · line 125 · raw

@id:U32 -> @head:StreamHead -> IO(Replied)

Begin one bounded chunked response. Statuses that forbid bodies are rejected.

def sse_head source · line 136 · raw

@connection:ConnectionMode -> StreamHead

def finish_reply source · line 152 · raw

@id:U32 -> @result:Replied -> IO(Unit)

def dispatch_live source · line 161 · raw

@handler:(@_:Incoming -> IO(Reply)) -> @request:Incoming -> IO(Unit)

def discard_request source · line 170 · raw

@request:Incoming -> IO(Unit)

def dispatch_active source · line 174 · raw

@active:Bool -> @handler:(@_:Incoming -> IO(Reply)) -> @request:Incoming -> IO(Unit)

def dispatch source · line 179 · raw

@handler:(@_:Incoming -> IO(Reply)) -> @request:Incoming -> IO(Unit)

def serve_next source · line 185 · raw

@handler:(@_:Incoming -> IO(Reply)) -> @rest:(@_:Unit -> IO(Unit)) -> @next:Next -> IO(Unit)

def metrics_json source · line 206 · raw

@metrics:Metrics -> 0x2731c2a5d4185b57cf5353061639642e/src/json.Json