disk

Documentation

Index

• Constants
• func GetEscapedPath(dataDir string, fname string) string
• type FileLock
  • func NewFileLock(lockPath string) (*FileLock, error)
  • func (l *FileLock) Close() error
  • func (l *FileLock) Lock() error
  • func (l *FileLock) Unlock() error
• type Store
  • func New(network, dataDir string) (*Store, error)
  • func (s *Store) FindByID(id string, ifname string) bool
  • func (s *Store) FindByKey(match string) (bool, error)
  • func (s *Store) GetByID(id string, ifname string) []net.IP
  • func (s *Store) LastReservedIP(rangeID string) (net.IP, error)
  • func (s *Store) ReleaseByID(id string, ifname string) error
  • func (s *Store) ReleaseByKey(match string) (bool, error)
  • func (s *Store) Reserve(id string, ifname string, ip net.IP, rangeID string) (bool, error)

Constants

const (
	LineBreak = "\r\n"
)

Functions

func GetEscapedPath

func GetEscapedPath(dataDir string, fname string) string

Types

type FileLock

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

FileLock wraps os.File to be used as a lock using flock

func NewFileLock

func NewFileLock(lockPath string) (*FileLock, error)

NewFileLock opens file/dir at path and returns unlocked FileLock object

func (*FileLock) Close

func (l *FileLock) Close() error

func (*FileLock) Lock

func (l *FileLock) Lock() error

Lock acquires an exclusive lock

func (*FileLock) Unlock

func (l *FileLock) Unlock() error

Unlock releases the lock

type Store

type Store struct {
	*FileLock
	// contains filtered or unexported fields
}

Store is a simple disk-backed store that creates one file per IP address in a given directory. The contents of the file are the container ID.

func New

func New(network, dataDir string) (*Store, error)

func (*Store) FindByID

func (s *Store) FindByID(id string, ifname string) bool

func (*Store) FindByKey

func (s *Store) FindByKey(match string) (bool, error)

func (*Store) GetByID

func (s *Store) GetByID(id string, ifname string) []net.IP

GetByID returns the IPs which have been allocated to the specific ID

func (*Store) LastReservedIP

func (s *Store) LastReservedIP(rangeID string) (net.IP, error)

LastReservedIP returns the last reserved IP if exists

func (*Store) ReleaseByID

func (s *Store) ReleaseByID(id string, ifname string) error

N.B. This function eats errors to be tolerant and release as much as possible

func (*Store) ReleaseByKey

func (s *Store) ReleaseByKey(match string) (bool, error)

func (*Store) Reserve

func (s *Store) Reserve(id string, ifname string, ip net.IP, rangeID string) (bool, error)