ratelimiter

Documentation

Index

• Variables
• func New() instance.RateLimiter
• type RateLimit
• type RateLimiter
  • func (r *RateLimiter) RequestJoin(ctx context.Context, channel *pb.Channel) error
  • func (r *RateLimiter) Start()

Variables

var VerifiedJoinChannel = RateLimit{
	Count: 1800,
	Time:  time.Second * 12,
}

Functions

func New

func New() instance.RateLimiter

Types

type RateLimit

type RateLimit struct {
	Count int
	Time  time.Duration
}

type RateLimiter

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

func (*RateLimiter) RequestJoin

func (r *RateLimiter) RequestJoin(ctx context.Context, channel *pb.Channel) error

func (*RateLimiter) Start

func (r *RateLimiter) Start()