Calamity.Gateway.Shard

The shard logic

Documentation

data Shard

Constructors

Shard

Fields

• shardID :: Int
• shardCount :: Int
• gateway :: Text
• evtQueue :: TQueue DispatchMessage
• cmdQueue :: TQueue ControlMessage
• shardState :: TVar ShardState
• token :: Text

Instances

Generic Shard

Defined in Calamity.Gateway.Types

Associated Types

type Rep Shard :: Type -> Type

Methods

from :: Shard -> Rep Shard x

to :: Rep Shard x -> Shard

type Rep Shard

Defined in Calamity.Gateway.Types

type Rep Shard = D1 (MetaData "Shard" "Calamity.Gateway.Types" "calamity-0.1.0.0-inplace" False) (C1 (MetaCons "Shard" PrefixI True) ((S1 (MetaSel (Just "shardID") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int) :*: (S1 (MetaSel (Just "shardCount") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int) :*: S1 (MetaSel (Just "gateway") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text))) :*: ((S1 (MetaSel (Just "evtQueue") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (TQueue DispatchMessage)) :*: S1 (MetaSel (Just "cmdQueue") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (TQueue ControlMessage))) :*: (S1 (MetaSel (Just "shardState") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (TVar ShardState)) :*: S1 (MetaSel (Just "token") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))))

newShard :: Members '[LogEff, Embed IO, Final IO, Async] r => Text -> Int -> Int -> Token -> TQueue DispatchMessage -> Sem r (Shard, Async (Maybe ()))

Creates and launches a shard