ratelimit

package

v2.3.4+incompatible Latest Latest Go to latest Published: Sep 26, 2018 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var ErrRateLimited = errors.New("rate limit reached")

ErrRateLimited is returned if the rate limit has been reached

This section is empty.

type Limits struct {
	Uplink   int
	Downlink int
	Status   int
}

Limits per minute

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

RateLimit uplink, downlink and status messages per gateway

func NewRateLimit(conf Limits) *RateLimit

NewRateLimit returns a middleware that rate-limits uplink, downlink and status messages per gateway

func NewRedisRateLimit(client *redis.Client, conf Limits) *RateLimit

NewRedisRateLimit returns a middleware that rate-limits uplink, downlink and status messages per gateway

func (l *RateLimit) HandleConnect(ctx middleware.Context, msg *types.ConnectMessage) error

HandleConnect initializes the rate limiter

func (l *RateLimit) HandleDisconnect(ctx middleware.Context, msg *types.DisconnectMessage) error

HandleDisconnect cleans up

func (l *RateLimit) HandleDownlink(ctx middleware.Context, msg *types.DownlinkMessage) error

HandleDownlink rate-limits downlink messages

func (l *RateLimit) HandleStatus(ctx middleware.Context, msg *types.StatusMessage) error

HandleStatus rate-limits status messages

func (l *RateLimit) HandleUplink(ctx middleware.Context, msg *types.UplinkMessage) error

HandleUplink rate-limits status messages