gardenstore

Documentation

Index

• Constants
• Variables
• type ContainerLookupError
  • func (err ContainerLookupError) Error() string
• type EventEmitter
• type Exchanger
  • func NewExchanger(containerOwnerName string, containerMaxCPUShares uint64, ...) Exchanger
• type GardenClient
• type GardenStore
  • func NewGardenStore(gardenClient garden.Client, containerOwnerName string, ...) (*GardenStore, error)
  • func (store *GardenStore) Create(logger lager.Logger, container executor.Container) (executor.Container, error)
  • func (store *GardenStore) Destroy(logger lager.Logger, guid string) error
  • func (store *GardenStore) GetFiles(logger lager.Logger, guid, sourcePath string) (io.ReadCloser, error)
  • func (store *GardenStore) List(logger lager.Logger, tags executor.Tags) ([]executor.Container, error)
  • func (store *GardenStore) Lookup(logger lager.Logger, guid string) (executor.Container, error)
  • func (store *GardenStore) Metrics(logger lager.Logger, containerGuids []string) (map[string]executor.ContainerMetrics, error)
  • func (store *GardenStore) Ping() error
  • func (store *GardenStore) Run(logger lager.Logger, container executor.Container) error
  • func (store *GardenStore) Stop(logger lager.Logger, guid string) error
• type InvalidJSONError
  • func (err InvalidJSONError) Error() string
• type InvalidStateError
  • func (err InvalidStateError) Error() string
• type MalformedPropertyError
  • func (err MalformedPropertyError) Error() string

Constants

const (
	ContainerOwnerProperty         = executorPropertyPrefix + "owner"
	ContainerStateProperty         = executorPropertyPrefix + "state"
	ContainerAllocatedAtProperty   = executorPropertyPrefix + "allocated-at"
	ContainerRootfsProperty        = executorPropertyPrefix + "rootfs"
	ContainerLogProperty           = executorPropertyPrefix + "log-config"
	ContainerMetricsConfigProperty = executorPropertyPrefix + "metrics-config"
	ContainerResultProperty        = executorPropertyPrefix + "result"
	ContainerMemoryMBProperty      = executorPropertyPrefix + "memory-mb"
	ContainerDiskMBProperty        = executorPropertyPrefix + "disk-mb"
	ContainerCPUWeightProperty     = executorPropertyPrefix + "cpu-weight"
	ContainerStartTimeoutProperty  = executorPropertyPrefix + "start-timeout"
)

Variables

var ErrIPRangeConversionFailed = errors.New("failed to convert destination to ip range")

Types

type ContainerLookupError

type ContainerLookupError struct {
	Handle    string
	LookupErr error
}

func (ContainerLookupError) Error

func (err ContainerLookupError) Error() string

type EventEmitter

type EventEmitter interface {
	Emit(executor.Event)
}

type Exchanger

type Exchanger interface {
	Infos(lager.Logger, garden.Client, []garden.Container) ([]executor.Container, error)
	Info(lager.Logger, garden.Container) (executor.Container, error)
	CreateInGarden(lager.Logger, GardenClient, executor.Container) (executor.Container, error)
}

func NewExchanger

func NewExchanger(
	containerOwnerName string,
	containerMaxCPUShares uint64,
	containerInodeLimit uint64,
) Exchanger

type GardenClient

type GardenClient interface {
	Create(garden.ContainerSpec) (garden.Container, error)
	Destroy(handle string) error
	Containers(garden.Properties) ([]garden.Container, error)
	Lookup(handle string) (garden.Container, error)
}

type GardenStore

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

func NewGardenStore

func NewGardenStore(
	gardenClient garden.Client,
	containerOwnerName string,
	containerMaxCPUShares uint64,
	containerInodeLimit uint64,
	healthyMonitoringInterval time.Duration,
	unhealthyMonitoringInterval time.Duration,
	transformer *transformer.Transformer,
	clock clock.Clock,
	eventEmitter EventEmitter,
	healthCheckWorkPoolSize int,
	postSetupHook []string,
	postSetupUser string,
) (*GardenStore, error)

func (*GardenStore) Create

func (store *GardenStore) Create(logger lager.Logger, container executor.Container) (executor.Container, error)

func (*GardenStore) Destroy

func (store *GardenStore) Destroy(logger lager.Logger, guid string) error

func (*GardenStore) GetFiles

func (store *GardenStore) GetFiles(logger lager.Logger, guid, sourcePath string) (io.ReadCloser, error)

func (*GardenStore) List

func (store *GardenStore) List(logger lager.Logger, tags executor.Tags) ([]executor.Container, error)

func (*GardenStore) Lookup

func (store *GardenStore) Lookup(logger lager.Logger, guid string) (executor.Container, error)

func (*GardenStore) Metrics

func (store *GardenStore) Metrics(logger lager.Logger, containerGuids []string) (map[string]executor.ContainerMetrics, error)

func (*GardenStore) Ping

func (store *GardenStore) Ping() error

func (*GardenStore) Run

func (store *GardenStore) Run(logger lager.Logger, container executor.Container) error

func (*GardenStore) Stop

func (store *GardenStore) Stop(logger lager.Logger, guid string) error

type InvalidJSONError

type InvalidJSONError struct {
	Property     string
	Value        string
	UnmarshalErr error
}

func (InvalidJSONError) Error

func (err InvalidJSONError) Error() string

type InvalidStateError

type InvalidStateError struct {
	State string
}

func (InvalidStateError) Error

func (err InvalidStateError) Error() string

type MalformedPropertyError

type MalformedPropertyError struct {
	Property string
	Value    string
}

func (MalformedPropertyError) Error

func (err MalformedPropertyError) Error() string