-
Notifications
You must be signed in to change notification settings - Fork 0
/
token.go
46 lines (37 loc) · 1023 Bytes
/
token.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
package ratelimiter
import (
"time"
"github.com/segmentio/ksuid"
)
// token factory function creates a new token
type tokenFactory func() *Token
// Token represents a Rate Limit Token
type Token struct {
// The unique token ID
ID string
// The time at which the token was created
CreatedAt time.Time
// Defines the min amount of time the token must live before being released
ExpiresAt time.Time
}
// NewToken creates a new token
func NewToken() *Token {
return &Token{
ID: ksuid.New().String(),
CreatedAt: time.Now().UTC(),
ExpiresAt: time.Time{}, // defaults to zero time
}
}
// IsExpired returns true if current time is greater than expiration time
func (t *Token) IsExpired() bool {
now := time.Now().UTC()
return t.ExpiresAt.Before(now)
}
// NeedReset returns true if elapsed time since token was created
// is greater than provided reset duration
func (t *Token) NeedReset(resetAfter time.Duration) bool {
if time.Since(t.CreatedAt) >= resetAfter {
return true
}
return false
}