ratelimit

Documentation

Index

• type MappedRateLimiter
  • func NewMappedRateLimiter(c *config.RateLimitConfig) (*MappedRateLimiter, error)
  • func (m *MappedRateLimiter) RateLimit(subscriber mangos.Socket, publisher mangos.Socket)
• type RateLimiter

Types

type MappedRateLimiter

type MappedRateLimiter struct {
	// contains filtered or unexported fields
}

func NewMappedRateLimiter

func NewMappedRateLimiter(c *config.RateLimitConfig) (*MappedRateLimiter, error)

func (*MappedRateLimiter) RateLimit

func (m *MappedRateLimiter) RateLimit(subscriber mangos.Socket, publisher mangos.Socket)

type RateLimiter

type RateLimiter interface {
	RateLimit(subscriber mangos.Socket, publisher mangos.Socket)
}