object DiscordShard
- Source
- DiscordShard.scala
- Alphabetic
- By Inheritance
- DiscordShard
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- sealed trait Command extends AnyRef
- case class FetchWSGatewayBotInfo(gateway: Uri, shards: Int, sessionStartLimits: SessionStartLimits) extends Product with Serializable
- case class Parameters(gatewayUri: Uri, settings: GatewaySettings, events: Events, context: ActorContext[Command], timers: TimerScheduler[Command], log: Logger) extends Product with Serializable
- case class SessionStartLimits(total: Int, remaining: Int, resetAfter: Duration, maxConcurrency: Int) extends Product with Serializable
- case class State(gatewayHandler: ActorRef[gateway.GatewayHandler.Command], isShuttingDown: Boolean = false, isRestarting: Boolean = false) extends Product with Serializable
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def apply(wsUri: Uri, settings: GatewaySettings, events: Events): Behavior[Command]
The core actor that controls all the other used actors of AckCord
The core actor that controls all the other used actors of AckCord
- wsUri
The gateway websocket uri
- settings
The settings to use
- events
The events instance to use for this shard
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def fetchWsGateway(implicit system: ActorSystem[Nothing]): Future[Uri]
Fetch the websocket gateway.
Fetch the websocket gateway.
- system
The actor system to use.
- returns
An URI with the websocket gateway uri.
- def fetchWsGatewayWithShards(token: String)(implicit system: ActorSystem[Nothing]): Future[FetchWSGatewayBotInfo]
Fetch the websocket gateway with information about how many shards should be used.
Fetch the websocket gateway with information about how many shards should be used.
- system
The actor system to use.
- returns
An URI with the websocket gateway uri.
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def many(wsUri: Uri, shardTotal: Int, settings: GatewaySettings, events: Events): Seq[Behavior[Command]]
Create many shard actors, given the needed arguments.
Create many shard actors, given the needed arguments.
- wsUri
The websocket gateway uri.
- shardTotal
The amount of shards to create.
- settings
The settings to use.
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def startShards(shards: Seq[ActorRef[Command]])(implicit system: ActorSystem[Nothing]): Future[Done]
Sends a login message to all the shards in the sequence, while obeying IDENTIFY ratelimits.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- case object RestartShard extends Command with Product with Serializable
Send this to log out and log in again this shard.
- case object StartShard extends Command with Product with Serializable
Send this to the client to log in.
- case object StopShard extends Command with Product with Serializable
Send this to the client to log out and stop gracefully.