storage

Documentation

Index

• Constants
• type AvoidNode
• type AvoidNodes
• type FavoriteNode
• type MeasureStorage
  • func NewMeasureStorage(path, filenamePrefix string) *MeasureStorage
  • func (s *MeasureStorage) AddAvoidNode(key string, val *AvoidNode)
  • func (s *MeasureStorage) AddFavoriteNode(key string, val *FavoriteNode) bool
  • func (s *MeasureStorage) ClearAvoidExpired() error
  • func (s *MeasureStorage) ClearFavoriteExpired() error
  • func (s *MeasureStorage) GetAvoidCIDR() []*net.IPNet
  • func (s *MeasureStorage) Load() error
  • func (s *MeasureStorage) SaveAvoidNodes() error
  • func (s *MeasureStorage) SaveFavoriteNodes() error
• type Storage
  • func NewStorage() *Storage
  • func (s *Storage) Add(key string, val interface{})
  • func (s *Storage) Delete(key string)
  • func (s *Storage) Get(key string) (interface{}, bool)
  • func (s *Storage) GetData() map[string]interface{}
  • func (s *Storage) Len() int

Constants

const (
	FavoriteFileSuffix = ".favorite-node.json"
	AvoidFileSuffix    = ".avoid-node.json"
)

Types

type AvoidNode

type AvoidNode struct {
	IP        string `json:"ip"`
	MaskSize  int32  `json:"maskSize"`
	Address   string `json:"address"`
	ExpiresAt int64  `json:"expiredAt"`
}

type AvoidNodes

type AvoidNodes = map[string]*AvoidNode

type FavoriteNode

type FavoriteNode struct {
	IP           string  `json:"ip"`
	Address      string  `json:"address"`
	Metadata     string  `json:"metadata"`
	Delay        float32 `json:"delay"`
	MinBandwidth float32 `json:"minBandwidth"`
	MaxBandwidth float32 `json:"maxBandwidth"`
	ExpiresAt    int64   `json:"expiredAt"`
}

type MeasureStorage

type MeasureStorage struct {
	FavoriteNodes *Storage

	AvoidNodes map[string]AvoidNodes
	// contains filtered or unexported fields
}

func NewMeasureStorage

func NewMeasureStorage(path, filenamePrefix string) *MeasureStorage

func (*MeasureStorage) AddAvoidNode

func (s *MeasureStorage) AddAvoidNode(key string, val *AvoidNode)

func (*MeasureStorage) AddFavoriteNode

func (s *MeasureStorage) AddFavoriteNode(key string, val *FavoriteNode) bool

func (*MeasureStorage) ClearAvoidExpired

func (s *MeasureStorage) ClearAvoidExpired() error

func (*MeasureStorage) ClearFavoriteExpired

func (s *MeasureStorage) ClearFavoriteExpired() error

func (*MeasureStorage) GetAvoidCIDR

func (s *MeasureStorage) GetAvoidCIDR() []*net.IPNet

func (*MeasureStorage) Load

func (s *MeasureStorage) Load() error

Load must be called before all other methods

func (*MeasureStorage) SaveAvoidNodes

func (s *MeasureStorage) SaveAvoidNodes() error

func (*MeasureStorage) SaveFavoriteNodes

func (s *MeasureStorage) SaveFavoriteNodes() error

type Storage

type Storage struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewStorage

func NewStorage() *Storage

func (*Storage) Add

func (s *Storage) Add(key string, val interface{})

func (*Storage) Delete

func (s *Storage) Delete(key string)

func (*Storage) Get

func (s *Storage) Get(key string) (interface{}, bool)

func (*Storage) GetData

func (s *Storage) GetData() map[string]interface{}

func (*Storage) Len

func (s *Storage) Len() int