allocationstore

Documentation

Index

• type AllocationStore
  • func NewAllocationStore(clock clock.Clock, eventEmitter EventEmitter) *AllocationStore
  • func (a *AllocationStore) Allocate(logger lager.Logger, req *executor.AllocationRequest) (executor.Container, error)
  • func (a *AllocationStore) Deallocate(logger lager.Logger, guid string) bool
  • func (a *AllocationStore) Fail(logger lager.Logger, guid string, reason string) (executor.Container, error)
  • func (a *AllocationStore) Initialize(logger lager.Logger, req *executor.RunRequest) error
  • func (a *AllocationStore) List() []executor.Container
  • func (a *AllocationStore) Lookup(guid string) (executor.Container, error)
  • func (a *AllocationStore) RegistryPruner(logger lager.Logger, expirationTime time.Duration) ifrit.Runner
• type EventEmitter

Types

type AllocationStore

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

func NewAllocationStore

func NewAllocationStore(clock clock.Clock, eventEmitter EventEmitter) *AllocationStore

func (*AllocationStore) Allocate

func (a *AllocationStore) Allocate(logger lager.Logger, req *executor.AllocationRequest) (executor.Container, error)

func (*AllocationStore) Deallocate

func (a *AllocationStore) Deallocate(logger lager.Logger, guid string) bool

func (*AllocationStore) Fail

func (a *AllocationStore) Fail(logger lager.Logger, guid string, reason string) (executor.Container, error)

func (*AllocationStore) Initialize

func (a *AllocationStore) Initialize(logger lager.Logger, req *executor.RunRequest) error

func (*AllocationStore) List

func (a *AllocationStore) List() []executor.Container

func (*AllocationStore) Lookup

func (a *AllocationStore) Lookup(guid string) (executor.Container, error)

func (*AllocationStore) RegistryPruner

func (a *AllocationStore) RegistryPruner(logger lager.Logger, expirationTime time.Duration) ifrit.Runner

type EventEmitter

type EventEmitter interface {
	Emit(executor.Event)
}