cache

Documentation

Index

• func NewGoStore(authExpiration, aclExpiration, authJitter, aclJitter time.Duration, ...) *goStore
• func NewRedisClusterStore(password string, addresses []string, ...) *redisStore
• func NewSingleRedisStore(host, port, password string, db int, ...) *redisStore
• type Store

Functions

func NewGoStore

func NewGoStore(authExpiration, aclExpiration, authJitter, aclJitter time.Duration, refreshExpiration bool) *goStore

NewGoStore initializes a cache using go-cache as the store.

func NewRedisClusterStore

func NewRedisClusterStore(password string, addresses []string, authExpiration, aclExpiration, authJitter, aclJitter time.Duration, refreshExpiration bool) *redisStore

NewSingleRedisStore initializes a cache using a Redis Cluster as the store.

func NewSingleRedisStore

func NewSingleRedisStore(host, port, password string, db int, authExpiration, aclExpiration, authJitter, aclJitter time.Duration, refreshExpiration bool) *redisStore

NewSingleRedisStore initializes a cache using a single Redis instance as the store.

Types

type Store

type Store interface {
	SetAuthRecord(ctx context.Context, username, password, granted string) error
	CheckAuthRecord(ctx context.Context, username, password string) (bool, bool)
	SetACLRecord(ctx context.Context, username, topic, clientid string, acc int, granted string) error
	CheckACLRecord(ctx context.Context, username, topic, clientid string, acc int) (bool, bool)
	Connect(ctx context.Context, reset bool) bool
	Close()
}