resource_pool

Documentation

Index

• Variables
• type FilterProvider
• type LinuxResourcePool
  • func New(logger lager.Logger, binPath, depotPath string, sysconfig sysconfig.Config, ...) *LinuxResourcePool
  • func (p *LinuxResourcePool) Acquire(spec garden.ContainerSpec) (linux_backend.LinuxContainerSpec, error)
  • func (p *LinuxResourcePool) MaxContainers() int
  • func (p *LinuxResourcePool) Prune(keep map[string]bool) error
  • func (p *LinuxResourcePool) Release(container linux_backend.LinuxContainerSpec) error
  • func (p *LinuxResourcePool) Restore(snapshot io.Reader) (linux_backend.LinuxContainerSpec, error)
  • func (p *LinuxResourcePool) Setup() error
• type MkdirChowner
• type Remover
• type RootFSCleaner
• type RootFSProvider
• type SubnetPool

Variables

var (
	ErrUnknownRootFSProvider = errors.New("unknown rootfs provider")
)

Types

type FilterProvider

type FilterProvider interface {
	ProvideFilter(containerId string) network.Filter
}

type LinuxResourcePool

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

func New

func New(
	logger lager.Logger,
	binPath, depotPath string,
	sysconfig sysconfig.Config,
	rootFSProvider RootFSProvider,
	rootFSCleaner RootFSCleaner,
	mappingList rootfs_provider.MappingList,
	externalIP net.IP,
	mtu int,
	subnetPool SubnetPool,
	bridges bridgemgr.BridgeManager,
	iptablesMgr linux_container.IPTablesManager,
	filterProvider FilterProvider,
	defaultChain iptables.Chain,
	portPool linux_container.PortPool,
	denyNetworks, allowNetworks []string,
	runner command_runner.CommandRunner,
	quotaManager linux_container.QuotaManager,
	currentContainerVersion semver.Version,
	mkdirChowner MkdirChowner,
) *LinuxResourcePool

func (*LinuxResourcePool) Acquire

func (p *LinuxResourcePool) Acquire(spec garden.ContainerSpec) (linux_backend.LinuxContainerSpec, error)

func (*LinuxResourcePool) MaxContainers

func (p *LinuxResourcePool) MaxContainers() int

func (*LinuxResourcePool) Prune

func (p *LinuxResourcePool) Prune(keep map[string]bool) error

func (*LinuxResourcePool) Release

func (p *LinuxResourcePool) Release(container linux_backend.LinuxContainerSpec) error

func (*LinuxResourcePool) Restore

func (p *LinuxResourcePool) Restore(snapshot io.Reader) (linux_backend.LinuxContainerSpec, error)

func (*LinuxResourcePool) Setup

func (p *LinuxResourcePool) Setup() error

type MkdirChowner

type MkdirChowner interface {
	MkdirChown(path string, uid, gid uint32, mode os.FileMode) error
}

type Remover

type Remover interface {
	Remove(id layercake.ID) error
}

type RootFSCleaner

type RootFSCleaner interface {
	Clean(log lager.Logger, path string) error
}

type RootFSProvider

type RootFSProvider interface {
	Create(log lager.Logger, id string, spec rootfs_provider.Spec) (mountpoint string, envvar []string, err error)
	Destroy(log lager.Logger, id string) error
	GC(log lager.Logger) error
}

type SubnetPool

type SubnetPool interface {
	Acquire(subnet subnets.SubnetSelector, ip subnets.IPSelector, logger lager.Logger) (*linux_backend.Network, error)
	Release(network *linux_backend.Network, logger lager.Logger) error
	Remove(network *linux_backend.Network, logger lager.Logger) error
	Capacity() int
}