authorizers

Documentation

Index

• func NewRateLimitAuthorizer(logger *zap.Logger, redisClient redis.UniversalClient, limits []RateLimit, ...) (gateway.AuthorizePublishFn, error)
• type RateLimit
• type RateLimitBuilder
  • func NewRateLimitBuilder() *RateLimitBuilder
  • func (r *RateLimitBuilder) Build() (gateway.AuthorizePublishFn, error)
  • func (r *RateLimitBuilder) MustBuild() gateway.AuthorizePublishFn
  • func (r *RateLimitBuilder) WithKeyPrefix(prefix string) *RateLimitBuilder
  • func (r *RateLimitBuilder) WithLimits(limits ...RateLimit) *RateLimitBuilder
  • func (r *RateLimitBuilder) WithLogger(logger *zap.Logger) *RateLimitBuilder
  • func (r *RateLimitBuilder) WithRedis(client redis.UniversalClient) *RateLimitBuilder

Functions

func NewRateLimitAuthorizer

func NewRateLimitAuthorizer(
	logger *zap.Logger,
	redisClient redis.UniversalClient,
	limits []RateLimit,
	keyPrefix string,
) (gateway.AuthorizePublishFn, error)

Types

type RateLimit

type RateLimit = ratelimiter.Limit

type RateLimitBuilder

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

func NewRateLimitBuilder

func NewRateLimitBuilder() *RateLimitBuilder

func (*RateLimitBuilder) Build

func (r *RateLimitBuilder) Build() (gateway.AuthorizePublishFn, error)

func (*RateLimitBuilder) MustBuild

func (r *RateLimitBuilder) MustBuild() gateway.AuthorizePublishFn

func (*RateLimitBuilder) WithKeyPrefix

func (r *RateLimitBuilder) WithKeyPrefix(prefix string) *RateLimitBuilder

func (*RateLimitBuilder) WithLimits

func (r *RateLimitBuilder) WithLimits(limits ...RateLimit) *RateLimitBuilder

func (*RateLimitBuilder) WithLogger

func (r *RateLimitBuilder) WithLogger(logger *zap.Logger) *RateLimitBuilder

func (*RateLimitBuilder) WithRedis

func (r *RateLimitBuilder) WithRedis(
	client redis.UniversalClient,
) *RateLimitBuilder