ipam

Jun 20, 2016

Changes in this version

type Allocator

+ func (alloc *Allocator) PeerGone(peerName mesh.PeerName)

+ func (alloc *Allocator) PruneOwned(ids []string)

type Config

+ Tracker tracker.LocalRangeTracker

May 26, 2016

Changes in this version

+ func ParseCIDRSubnet(cidrStr string) (cidr address.CIDR, err error)

Apr 19, 2016

Changes in this version

type Allocator

+ func (alloc *Allocator) AllContainerIDs(ids []string)

+ func (alloc *Allocator) ContainerDestroyed(ident string)

+ func (alloc *Allocator) Prime()

type ClaimStatus

+ CIDR address.CIDR

+ type Config struct

+ Db db.DB

+ IsKnownPeer func(name mesh.PeerName) bool

+ IsObserver bool

+ OurName mesh.PeerName

+ OurNickname string

+ OurUID mesh.PeerUID

+ Quorum func() uint

+ Seed []mesh.PeerName

+ Universe address.Range

Dec 17, 2015

Changes in this version

type EntryStatus

+ IsKnownPeer bool

+ Nickname string

+ Size uint32

type Status

+ RangeNumIPs int

Oct 22, 2015

Changes in this version

type Allocator

+ func (alloc *Allocator) ContainerStarted(ident string)

Sep 7, 2015

Changes in this version

+ type ClaimStatus struct

+ Address address.Address

+ Ident string

+ type EntryStatus struct

+ Peer string

+ Token string

+ Version uint32

+ type Status struct

+ DefaultSubnet string

+ Entries []EntryStatus

+ Paxos *paxos.Status

+ PendingAllocates []string

+ PendingClaims []ClaimStatus

+ Range string

+ func NewStatus(allocator *Allocator, defaultSubnet address.CIDR) *Status

Jun 18, 2015

Changes in this version

+ const MinSubnetSize

type Allocator

+ func (alloc *Allocator) Delete(ident string) error

+ func (alloc *Allocator) Lookup(ident string, r address.Range) (address.Address, error)

May 26, 2015

Changes in this version

+ var ErrMixedConfig = errors.New("Mixed IPAM/non-IPAM configuration not supported")

+ type Allocator struct

+ func NewAllocator(ourName router.PeerName, ourUID router.PeerUID, ourNickname string, ...) (*Allocator, error)

+ func (alloc *Allocator) AdminTakeoverRanges(peerNameOrNickname string) error

+ func (alloc *Allocator) Allocate(ident string, cancelChan <-chan bool) (address.Address, error)

+ func (alloc *Allocator) Claim(ident string, addr address.Address, cancelChan <-chan bool) error

+ func (alloc *Allocator) ContainerDied(ident string) error

+ func (alloc *Allocator) Encode() []byte

+ func (alloc *Allocator) Free(ident string) error

+ func (alloc *Allocator) Gossip() router.GossipData

+ func (alloc *Allocator) HandleHTTP(router *mux.Router)

+ func (alloc *Allocator) OnGossip(msg []byte) (router.GossipData, error)

+ func (alloc *Allocator) OnGossipBroadcast(msg []byte) (router.GossipData, error)

+ func (alloc *Allocator) OnGossipUnicast(sender router.PeerName, msg []byte) error

+ func (alloc *Allocator) SetInterfaces(gossip router.Gossip)

+ func (alloc *Allocator) Shutdown()

+ func (alloc *Allocator) Start()

+ func (alloc *Allocator) Stop()

+ func (alloc *Allocator) String() string

+ type DummyAllocator struct

+ func (alloc *DummyAllocator) Encode() []byte

+ func (alloc *DummyAllocator) Gossip() router.GossipData

+ func (alloc *DummyAllocator) OnGossip(msg []byte) (router.GossipData, error)

+ func (alloc *DummyAllocator) OnGossipBroadcast(msg []byte) (router.GossipData, error)

+ func (alloc *DummyAllocator) OnGossipUnicast(sender router.PeerName, msg []byte) error