ipam

Documentation

Index

• Constants
• type Allocator
  • func NewAllocator(ourName router.PeerName, ourUID router.PeerUID, ourNickname string, ...) *Allocator
  • func (alloc *Allocator) AdminTakeoverRanges(peerNameOrNickname string) error
  • func (alloc *Allocator) Allocate(ident string, r address.Range, hasBeenCancelled func() bool) (address.Address, error)
  • func (alloc *Allocator) Claim(ident string, addr address.Address, noErrorOnUnknown bool) error
  • func (alloc *Allocator) ContainerDied(ident string)
  • func (alloc *Allocator) ContainerStarted(ident string)
  • func (alloc *Allocator) Delete(ident string) error
  • func (alloc *Allocator) Encode() []byte
  • func (alloc *Allocator) Free(ident string, addrToFree address.Address) error
  • func (alloc *Allocator) Gossip() router.GossipData
  • func (alloc *Allocator) HandleHTTP(router *mux.Router, defaultSubnet address.CIDR, dockerCli *docker.Client)
  • func (alloc *Allocator) Lookup(ident string, r address.Range) (address.Address, error)
  • func (alloc *Allocator) OnGossip(msg []byte) (router.GossipData, error)
  • func (alloc *Allocator) OnGossipBroadcast(sender router.PeerName, 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()
• type ClaimStatus
• type EntryStatus
• type Status
  • func NewStatus(allocator *Allocator, defaultSubnet address.CIDR) *Status

Constants

const (
	MinSubnetSize = 4 // first and last addresses are excluded, so 2 would be too small
)

Kinds of message we can unicast to other peers

Types

type Allocator

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

Allocator brings together Ring and space.Set, and does the necessary plumbing. Runs as a single-threaded Actor, so no locks are used around data structures.

func NewAllocator

func NewAllocator(ourName router.PeerName, ourUID router.PeerUID, ourNickname string, universe address.Range, quorum uint) *Allocator

NewAllocator creates and initialises a new Allocator

func (*Allocator) AdminTakeoverRanges

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

AdminTakeoverRanges (Sync) - take over the ranges owned by a given peer. Only done on adminstrator command.

func (*Allocator) Allocate

func (alloc *Allocator) Allocate(ident string, r address.Range, hasBeenCancelled func() bool) (address.Address, error)

Allocate (Sync) - get new IP address for container with given name in range if there isn't any space in that range we block indefinitely

func (*Allocator) Claim

func (alloc *Allocator) Claim(ident string, addr address.Address, noErrorOnUnknown bool) error

Claim an address that we think we should own (Sync)

func (*Allocator) ContainerDied

func (alloc *Allocator) ContainerDied(ident string)

ContainerDied is provided to satisfy the updater interface; does a 'Delete' underneath. Sync.

func (*Allocator) ContainerStarted

func (alloc *Allocator) ContainerStarted(ident string)

func (*Allocator) Delete

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

Delete (Sync) - release all IP addresses for container with given name

func (*Allocator) Encode

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

Encode (Sync)

func (*Allocator) Free

func (alloc *Allocator) Free(ident string, addrToFree address.Address) error

Free (Sync) - release single IP address for container

func (*Allocator) Gossip

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

Gossip returns a GossipData implementation, which in this case always returns the latest ring state (and does nothing on merge)

func (*Allocator) HandleHTTP

func (alloc *Allocator) HandleHTTP(router *mux.Router, defaultSubnet address.CIDR, dockerCli *docker.Client)

HandleHTTP wires up ipams HTTP endpoints to the provided mux.

func (*Allocator) Lookup

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

Lookup (Sync) - get existing IP address for container with given name in range

func (*Allocator) OnGossip

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

OnGossip (Sync)

func (*Allocator) OnGossipBroadcast

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

OnGossipBroadcast (Sync)

func (*Allocator) OnGossipUnicast

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

OnGossipUnicast (Sync)

func (*Allocator) SetInterfaces

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

SetInterfaces gives the allocator two interfaces for talking to the outside world

func (*Allocator) Shutdown

func (alloc *Allocator) Shutdown()

Shutdown (Sync)

func (*Allocator) Start

func (alloc *Allocator) Start()

Start runs the allocator goroutine

func (*Allocator) Stop

func (alloc *Allocator) Stop()

Stop makes the actor routine exit, for test purposes ONLY because any calls after this is processed will hang. Async.

type ClaimStatus

type ClaimStatus struct {
	Ident   string
	Address address.Address
}

type EntryStatus

type EntryStatus struct {
	Token   string
	Peer    string
	Version uint32
}

type Status

type Status struct {
	Paxos            *paxos.Status
	Range            string
	DefaultSubnet    string
	Entries          []EntryStatus
	PendingClaims    []ClaimStatus
	PendingAllocates []string
}

func NewStatus

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