Packages

nostrum

0.10.4
0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.1 0.9.0 0.9.0-rc1 0.9.0-alpha2 0.9.0-alpha1 0.8.0 0.8.0-beta1 0.8.0-alpha1 0.7.0 0.7.0-rc2 0.7.0-rc1 0.6.1 0.6.0 0.5.1 0.5.0 0.5.0-rc2 0.5.0-rc1 0.4.6 0.4.5 0.4.3 0.4.2 0.4.1 0.4.0 0.3.2 0.3.1 0.2.1 0.2.0

An Elixir Discord library

HexDocs

Current section

Files

Jump to
Readme
32 Versions
6 Dependencies
Dependants
Files
Activity
nostrum lib nostrum shard.ex
Raw

lib/nostrum/shard.ex 

defmodule Nostrum.Shard do

  @moduledoc false



  use Supervisor, restart: :transient



  alias Nostrum.Shard.Session



  def start_link({:connect, [_, shard_num, _total]} = opts) do

    Supervisor.start_link(__MODULE__, opts, name: :"Nostrum.Shard-#{shard_num}")

  end



  def start_link(

        {:reconnect,

         %{

           shard_num: shard_num,

           total_shards: _total_shards,

           gateway: _gateway,

           resume_gateway: _resume_gateway,

           seq: _seq,

           session: _session

         }} =

          opts

      ) do

    Supervisor.start_link(__MODULE__, opts, name: :"Nostrum.Shard-#{shard_num}")

  end



  def start_link([_, _shard_num, _total] = opts) do

    start_link({:connect, opts})

  end



  def init(opts) do

    children = [

      {Session, opts}

      # TODO: Add per shard ratelimiter

      # TODO: Add per shard cache

    ]



    Supervisor.init(children,

      strategy: :one_for_all,

      max_restarts: 3,

      max_seconds: 60,

      auto_shutdown: :any_significant

    )

  end

end