Clients interact with S2 at its publicDocumentation Index
Fetch the complete documentation index at: https://s2.dev/docs/llms.txt
Use this file to discover all available pages before exploring further.
https endpoints, primarily with JSON bodies conforming to its OpenAPI spec.
Authentication
The API requires aBearer access token to authenticate requests.
S2 SDKs take care of supplying it automatically. If you are using curl, you can provide it with -H "Authorization: Bearer ${S2_ACCESS_TOKEN}".
The first usage of an access token on a connection may experience a latency overhead for verification, typically tens of milliseconds. Subsequent requests will not incur such an overhead.
Compression
To optimize network usage, S2 supports compressed request and response bodies with the following algorithms:zstdpreferredgzip
Content-Encoding and Accept-Encoding apply.
Data Plane
There are 3 core data operations on a stream:Append records
POST /streams/{stream}/recordsRead records
GET /streams/{stream}/records?seq_num=42&count=100Check the tail
GET /streams/{stream}/records/tailData in JSON
The following pieces of record data are stored as bytes:- Header name
- Header value
- Body
s2-format is used to indicate the desired encoding of these bytes when records are represented in JSON.
raw
s2-format: raw or omit header.Use when your record data is valid Unicode. Zero overhead, human-readable. Cannot handle binary data safely.base64
s2-format: base64Use when you are working with arbitrary bytes. Always safe. 33% overhead over the wire.Protobuf messages
Data plane endpoints toappend and read records also support protobuf bodies. This helps avoid the base64 encoding tax compared to binary data in JSON messages.
To send and receive protobuf:
- Set the
Content-Typeheader toapplication/protobufand send a protobuf-encoded payload. - Set the
Acceptheader toapplication/protobufto receive a protobuf-encoded response. The response will include theContent-Type: application/protobufheader if the server returns a protobuf.
Sending
Accept: application/protobuf request header only guarantees a protobuf response in case of a success (HTTP 200). Other status codes are always accompanied by JSON bodies.Sessions
S2S (S2-Session) is a minimal binary protocol used by S2 SDKs to encapsulate streaming append and read session semantics over , at the same endpoints as βunaryβ calls.
It is meant for S2 SDKs, but documented for the adventurous.
S2S spec
S2S spec
Setup
Content-Type: s2s/protosignals that a session is being requested.Accept-Encodingsignals which compression algorithms are supported (service supportszstdandgzip).Content-Encodingis not sent as message-level compression is used.200 OKresponse establishes a session.
Message framing
All integers use big-endian byte order. Messages smaller than 1KiB should not be compressed.Length prefix (3 bytes): Total message length (flag + body)Flag byte (1 byte):[T][CC][RRRRR]T(bit 7): Terminal flag (1= stream ends after this message)CC(bits 6-5): Compression (00=none,01=zstd,10=gzip)RRRRR(bits 4-0): Reserved
- Regular message is a Protobuf
- Terminal message contains a 2-byte status code, followed by JSON error information (corresponding to unary response behavior)
Data flow
Append sessions are a bi-directional stream ofAppendInput messages from Client β Server, and AppendAck messages from Server β Client.Read sessions are a uni-directional stream of ReadBatch messages from Server β Client. When waiting for new records, an empty batch is sent as a heartbeat at least every 15 seconds.
