Jido.Chat.Telegram.PollingWorker (Jido Chat Telegram v1.0.0)

Copy Markdown View Source

Bridge-ingress polling worker for Telegram getUpdates.

This worker is adapter-owned and runtime-agnostic. It emits raw update payloads via sink_mfa so host runtimes can route through their own ingress pipelines.

Summary

Types

sink_mfa()
state()

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

start_link(opts)

Types

sink_mfa()

@type sink_mfa() :: {module(), atom(), [term()]}

state()

@type state() :: %{
  bridge_id: String.t(),
  sink_mfa: sink_mfa(),
  sink_opts: keyword(),
  token: String.t(),
  transport: module(),
  transport_opts: keyword(),
  timeout_s: pos_integer(),
  poll_interval_ms: pos_integer(),
  max_backoff_ms: pos_integer(),
  backoff_ms: pos_integer(),
  allowed_updates: [String.t()] | nil,
  offset: integer() | nil
}

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(opts)

@spec start_link(keyword()) :: GenServer.on_start()