sharding

type Config struct {
	Logger            log.Logger
	CustomShards      bool
	Shards            *IntSet
	ShardCount        int
	GatewayCreateFunc func(token string, url string, shardID int, shardCount int, eventHandlerFunc gateway.EventHandlerFunc, config *gateway.Config) gateway.Gateway
	GatewayConfig     *gateway.Config
	RateLimiter       srate2.Limiter
	RateLimiterConfig *srate2.Config
}

type ConfigOpt func(config *Config)

type IntSet struct {
	sync.RWMutex
	Set map[int]struct{}
}

type ShardManager interface {
	Logger() log.Logger
	Config() Config
	RateLimiter() srate.Limiter

	Open(ctx context.Context) error
	ReOpen(ctx context.Context) error
	Close(ctx context.Context) error

	OpenShard(ctx context.Context, shardID int) error
	ReOpenShard(ctx context.Context, shardID int) error
	CloseShard(ctx context.Context, shardID int) error

	GetGuildShard(guildId snowflake.Snowflake) gateway.Gateway

	Shard(shardID int) gateway.Gateway
	Shards() *ShardsMap
}

type ShardsMap struct {
	sync.RWMutex
	Shards map[int]gateway.Gateway
}