lib

Apr 22, 2022

Changes in this version

+ func Generate429(resp *http.ResponseWriter)

Apr 13, 2022

Changes in this version

+ func EnvGetBool(name string, defaultVal bool) bool

+ type GlobalHook struct

+ func (h *GlobalHook) Fire(e *logrus.Entry) error

+ func (h *GlobalHook) Levels() []logrus.Level

Apr 12, 2022

Changes in this version

type QueueManager

+ func (m *QueueManager) GetRequestRoutingInfo(req *http.Request, token string) (routingHash uint64, path string, queueType QueueType)

+ type QueueType int64

+ const Bearer

+ const Bot

+ const NoAuth

Feb 14, 2022

Changes in this version

+ var RequestsRoutedError = promauto.NewCounter(prometheus.CounterOpts{ ... })

+ var RequestsRoutedRecv = promauto.NewCounter(prometheus.CounterOpts{ ... })

+ var RequestsRoutedSent = promauto.NewCounter(prometheus.CounterOpts{ ... })

+ func CopyResponseToResponseWriter(resp *http.Response, respWriter *http.ResponseWriter) error

+ func InitMemberList(knownMembers []string, port int, proxyPort string, manager *QueueManager) *memberlist.Memberlist

+ type ClusterGlobalRateLimiter struct

+ func NewClusterGlobalRateLimiter() *ClusterGlobalRateLimiter

+ func (c *ClusterGlobalRateLimiter) FireGlobalRequest(ctx context.Context, addr string, botHash uint64, botLimit uint) error

+ func (c *ClusterGlobalRateLimiter) Take(botHash uint64, botLimit uint)

+ type NirnDelegate struct

+ func (d NirnDelegate) GetBroadcasts(overhead int, limit int) [][]byte

+ func (d NirnDelegate) LocalState(join bool) []byte

+ func (d NirnDelegate) MergeRemoteState(buf []byte, join bool)

+ func (d NirnDelegate) NodeMeta(limit int) []byte

+ func (d NirnDelegate) NotifyMsg(msg []byte)

+ type NirnEvents struct

+ OnJoin func(node *memberlist.Node)

+ OnLeave func(node *memberlist.Node)

+ func (d NirnEvents) NotifyJoin(node *memberlist.Node)

+ func (d NirnEvents) NotifyLeave(node *memberlist.Node)

+ func (d NirnEvents) NotifyUpdate(node *memberlist.Node)

+ type QueueManager struct

+ func NewQueueManager(bufferSize int) *QueueManager

+ func (m *QueueManager) CreateMux() *http.ServeMux

+ func (m *QueueManager) DiscordRequestHandler(resp http.ResponseWriter, req *http.Request)

+ func (m *QueueManager) Generate429(resp *http.ResponseWriter)

+ func (m *QueueManager) GetEventDelegate() *NirnEvents

+ func (m *QueueManager) HandleGlobal(w http.ResponseWriter, r *http.Request)

+ func (m *QueueManager) SetCluster(cluster *memberlist.Memberlist, proxyPort string)

+ func (m *QueueManager) Shutdown()

Jan 13, 2022

Changes in this version

+ const EpochDiscord

+ const MajorChannels

+ const MajorGuilds

+ const MajorInteractions

+ const MajorInvites

+ const MajorUnknown

+ const MajorWebhooks

+ var ConnectionsOpen = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var ErrorCounter = promauto.NewCounter(prometheus.CounterOpts{ ... })

+ var RequestHistogram = prometheus.NewHistogramVec(prometheus.HistogramOpts{ ... }, []string{ ... })

+ func ConfigureDiscordHTTPClient(ip string, timeout time.Duration)

+ func EnvGet(name string, defaultVal string) string

+ func EnvGetInt(name string, defaultVal int) int

+ func EnvMustGet(name string) string

+ func GetBotGlobalLimit(token string) (uint, error)

+ func GetBotId(token string) string

+ func GetMetricsPath(route string) string

+ func GetOptimisticBucketPath(url string, method string) string

+ func GetSnowflakeCreatedAt(snowflake string) (time.Time, error)

+ func HashCRC64(data string) uint64

+ func IsNumericInput(str string) bool

+ func IsSnowflake(str string) bool

+ func ProcessRequest(ctx context.Context, item *QueueItem) (*http.Response, error)

+ func SetLogger(l *logrus.Logger)

+ func StartMetrics(addr string)

+ func StartProfileServer()

+ type BotGatewayResponse struct

+ SessionStartLimit map[string]int

+ type BotUserResponse struct

+ Discrim string

+ Id string

+ Username string

+ func GetBotUser(token string) (*BotUserResponse, error)

+ type QueueChannel struct

+ type QueueItem struct

+ Req *http.Request

+ Res *http.ResponseWriter

+ type RequestQueue struct

+ func NewRequestQueue(processor func(ctx context.Context, item *QueueItem) (*http.Response, error), ...) *RequestQueue

+ func (q *RequestQueue) Queue(req *http.Request, res *http.ResponseWriter) (string, *http.Response, error)