SubscribeQueryParams

data class SubscribeQueryParams(val wantedCollections: List<Nsid>? = null, val wantedDids: List<Did>? = null, val maxMessageSizeBytes: Long? = 0, val cursor: Long? = null, val compress: Boolean? = false, val requireHello: Boolean? = false)

Parameters

wantedCollections

Which records you receive on your stream (default empty = all collections).

wantedDids

Which records you receive on your stream (default empty = all repos).

maxMessageSizeBytes

The maximum size of a payload that this client would like to receive.

cursor

A unix microseconds timestamp cursor to begin playback from.

compress

Set to true to enable zstd compression.

requireHello

Set to true to pause replay/live-tail until the server receives a SubscribeOptionsUpdate.

Constructors

Link copied to clipboard
constructor(wantedCollections: List<Nsid>? = null, wantedDids: List<Did>? = null, maxMessageSizeBytes: Long? = 0, cursor: Long? = null, compress: Boolean? = false, requireHello: Boolean? = false)

Properties

Link copied to clipboard

Set to true to enable zstd compression.

Link copied to clipboard
val cursor: Long?

A unix microseconds timestamp cursor to begin playback from.

Link copied to clipboard

The maximum size of a payload that this client would like to receive.

Link copied to clipboard

Set to true to pause replay/live-tail until the server receives a SubscribeOptionsUpdate.

Link copied to clipboard

Which records you receive on your stream (default empty = all collections).

Link copied to clipboard

Which records you receive on your stream (default empty = all repos).

Functions

Link copied to clipboard