core

Documentation

Index

• Constants
• Variables
• func CheckAuthorization(login, password, ip string) bool
• func InitLogger(log *logger.Logger)
• func InitRateLimiter(config config.RateLimiterConfig)
• func ManageList(subnet string, listType string, add bool) bool
• func ResetBucket(login, ip string) bool
• type Bucket

Constants

const (
	Whitelist = "whitelist"
	Blacklist = "blacklist"
)

Variables

var BlacklistFunc = func(ip string) bool {
	appLogger.Debug("Entering BlacklistFunc")
	if !isValidCIDR(ip) {
		appLogger.Warnf("Invalid IP format: %s", ip)
		return false
	}

	inBlacklist, err := db.CheckInRedis(Blacklist, ip)
	if err != nil {
		appLogger.Warnf("Error checking blacklist for %s: %v", ip, err)
		return false
	}
	appLogger.Debugf("IP %s blacklisted: %v", ip, inBlacklist)
	return inBlacklist
}

var ManageListFunc = func(subnet string, listType string, add bool) bool {
	if !isValidCIDR(subnet) {
		appLogger.Warnf("Invalid subnet format: %s", subnet)
		return false
	}
	return db.UpdateRedis(listType, subnet, add)
}

var ResetBucketFunc = func(login, ip string) bool {
	if !isValidCIDR(ip) {
		appLogger.Warnf("Invalid IP format: %s", ip)
		return false
	}
	limiter.Delete(login)
	limiter.Delete(ip)
	return true
}

var WhitelistFunc = func(ip string) bool {
	appLogger.Debug("Entering WhitelistFunc")
	if !isValidCIDR(ip) {
		appLogger.Warnf("Invalid IP format: %s", ip)
		return false
	}

	inWhitelist, err := db.CheckInRedis(Whitelist, ip)
	if err != nil {
		appLogger.Warnf("Error checking whitelist for %s: %v", ip, err)
		return false
	}
	appLogger.Debugf("IP %s whitelisted: %v", ip, inWhitelist)
	return inWhitelist
}

Functions

func CheckAuthorization

func CheckAuthorization(login, password, ip string) bool

func InitLogger

func InitLogger(log *logger.Logger)

func InitRateLimiter

func InitRateLimiter(config config.RateLimiterConfig)

func ManageList

func ManageList(subnet string, listType string, add bool) bool

func ResetBucket

func ResetBucket(login, ip string) bool

Types

type Bucket

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