daemon

Oct 4, 2017

Changes in this version

+ type ControlService struct

+ func NewControlService(d *Daemon) *ControlService

+ func (s *ControlService) DriverInstanceStates() ([]*protocol.DriverInstanceState, error)

+ func (s *ControlService) DriverPoolStates() map[string]*protocol.DriverPoolState

type Daemon

+ ControlServer *grpc.Server

+ func (d *Daemon) Current() map[string]*DriverPool

type Driver

+ ID func() string

+ State func() (*protocol.DriverInstanceState, error)

type DriverInstance

+ func (i *DriverInstance) ID() string

+ func (i *DriverInstance) State() (*protocol.DriverInstanceState, error)

type DriverPool

+ func (dp *DriverPool) Current() []Driver

+ func (dp *DriverPool) State() *protocol.DriverPoolState

+ type Service struct

+ func NewService(d *Daemon) *Service

+ func (d *Service) NativeParse(req *sdk.NativeParseRequest) *sdk.NativeParseResponse

+ func (d *Service) Parse(req *sdk.ParseRequest) *sdk.ParseResponse

+ func (d *Service) Version(req *sdk.VersionRequest) *sdk.VersionResponse

Oct 3, 2017

Changes in this version

+ const ConnectionTimeout

+ const DriverBinary

+ const GRPCSocket

+ const TmpPathPattern

+ var DefaultMaxInstancesPerDriver = runtime.NumCPU()

+ var DefaultPoolTimeout = 5 * time.Second

+ var ErrAlreadyInstalled = errors.NewKind("driver already installed: %s (image reference: %s)")

+ var ErrMissingDriver = errors.NewKind("missing driver for language %s")

+ var ErrNegativeInstances = errors.NewKind("cannot set instances to negative number")

+ var ErrPoolClosed = errors.NewKind("driver pool already closed")

+ var ErrPoolTimeout = errors.NewKind("timeout, all drivers are busy")

+ var ErrRuntime = errors.NewKind("runtime failure")

+ var ErrUnexpected = errors.NewKind("unexpected error")

+ func GetLanguage(filename string, content []byte) string

+ type Daemon struct

+ Overrides map[string]string

+ Transport string

+ func NewDaemon(version string, r *runtime.Runtime) *Daemon

+ func (d *Daemon) AddDriver(language string, img string) error

+ func (d *Daemon) DriverPool(language string) (*DriverPool, error)

+ func (d *Daemon) NativeParse(req *protocol.NativeParseRequest) *protocol.NativeParseResponse

+ func (d *Daemon) Parse(req *protocol.ParseRequest) *protocol.ParseResponse

+ func (d *Daemon) Stop() error

+ func (d *Daemon) Version(req *protocol.VersionRequest) *protocol.VersionResponse

+ type Driver interface

+ Service func() protocol.ProtocolServiceClient

+ Start func() error

+ Status func() (libcontainer.Status, error)

+ Stop func() error

+ type DriverInstance struct

+ Container runtime.Container

+ Image runtime.DriverImage

+ Language string

+ Process *runtime.Process

+ func NewDriverInstance(r *runtime.Runtime, lang string, i runtime.DriverImage, o *Options) (*DriverInstance, error)

+ func (i *DriverInstance) Service() protocol.ProtocolServiceClient

+ func (i *DriverInstance) Start() error

+ func (i *DriverInstance) Status() (libcontainer.Status, error)

+ func (i *DriverInstance) Stop() error

+ type DriverPool struct

+ Logger server.Logger

+ ScalingPolicy ScalingPolicy

+ Timeout time.Duration

+ func NewDriverPool(factory FactoryFunction) *DriverPool

+ func (dp *DriverPool) Execute(c Function) error

+ func (dp *DriverPool) Start() error

+ func (dp *DriverPool) Stop() error

+ type FactoryFunction func() (Driver, error)

+ type Function func(d Driver) error

+ type Options struct

+ LogFormat string

+ LogLevel string

+ type ScalingPolicy interface

+ Scale func(total, load int) int

+ func AIMD(add int, mul float64) ScalingPolicy

+ func DefaultScalingPolicy() ScalingPolicy

+ func MinMax(min, max int, p ScalingPolicy) ScalingPolicy

+ func MovingAverage(window int, p ScalingPolicy) ScalingPolicy