goose

Types

AccountData

pub type AccountData {
  AccountData(active: Bool, did: String, seq: Int, time: String)
}

Constructors

AccountData(active: Bool, did: String, seq: Int, time: String)

CommitData

</>

pub type CommitData {
  CommitData(
    rev: String,
    operation: String,
    collection: String,
    rkey: String,
    record: option.Option(dynamic.Dynamic),
    cid: option.Option(String),
  )
}

Constructors

CommitData(
  rev: String,
  operation: String,
  collection: String,
  rkey: String,
  record: option.Option(dynamic.Dynamic),
  cid: option.Option(String),
)

IdentityData

</>

pub type IdentityData {
  IdentityData(
    did: String,
    handle: String,
    seq: Int,
    time: String,
  )
}

Constructors

IdentityData(did: String, handle: String, seq: Int, time: String)

JetstreamConfig

</>

Configuration for Jetstream consumer

pub type JetstreamConfig {
  JetstreamConfig(
    endpoint: String,
    wanted_collections: List(String),
    wanted_dids: List(String),
    cursor: option.Option(Int),
    max_message_size_bytes: option.Option(Int),
    compress: Bool,
    require_hello: Bool,
  )
}

Constructors

JetstreamConfig(
  endpoint: String,
  wanted_collections: List(String),
  wanted_dids: List(String),
  cursor: option.Option(Int),
  max_message_size_bytes: option.Option(Int),
  compress: Bool,
  require_hello: Bool,
)

JetstreamEvent

</>

Jetstream event types

pub type JetstreamEvent {
  CommitEvent(did: String, time_us: Int, commit: CommitData)
  IdentityEvent(
    did: String,
    time_us: Int,
    identity: IdentityData,
  )
  AccountEvent(did: String, time_us: Int, account: AccountData)
  UnknownEvent(raw: String)
}

Constructors

CommitEvent(did: String, time_us: Int, commit: CommitData)

IdentityEvent(did: String, time_us: Int, identity: IdentityData)

AccountEvent(did: String, time_us: Int, account: AccountData)

```
UnknownEvent(raw: String)
```

Values

build_url

</>

pub fn build_url(config: JetstreamConfig) -> String

Build the WebSocket URL with query parameters

connect

</>

pub fn connect(
  url: String,
  handler_pid: process.Pid,
  compress: Bool,
) -> Result(process.Pid, dynamic.Dynamic)

Connect to Jetstream WebSocket using Erlang gun library

default_config

</>

pub fn default_config() -> JetstreamConfig

Create a default configuration for US East endpoint

parse_event

</>

pub fn parse_event(json_string: String) -> JetstreamEvent

Parse a JSON event string into a JetstreamEvent

start_consumer

</>

pub fn start_consumer(
  config: JetstreamConfig,
  on_event: fn(String) -> Nil,
) -> Nil

Start consuming the Jetstream feed