server

package module
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 2, 2017 License: GPL-3.0 Imports: 16 Imported by: 0

README

server

License

GPLv3, see LICENSE

Documentation

Index

Constants

View Source
const (
	DefaultTransport = "docker"
)

Variables

View Source
var (
	ErrMissingDriver    = errors.NewKind("missing driver for language %s")
	ErrRuntime          = errors.NewKind("runtime failure")
	ErrAlreadyInstalled = errors.NewKind("driver already installed: %s (image reference: %s)")
)
View Source
var (
	// DefaultPoolTimeout is the time a request to the DriverPool can wait
	// before getting a driver assigned.
	DefaultPoolTimeout = time.Second * 5
)

Functions

func DefaultDriverImageReference

func DefaultDriverImageReference(transport, lang string) string

DefaultDriverImageReference returns the default image reference for a driver given a language.

func GetLanguage

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

GetLanguage detects the language of a file and returns it in a normalized form.

Types

type Driver

type Driver interface {
	protocol.Parser
	io.Closer
}

Driver is a client to communicate with a driver. It provides the parser interface and is closeable.

func ExecDriver

func ExecDriver(r *runtime.Runtime, img runtime.DriverImage) (Driver, error)

ExecDriver executes a new driver using the given runtime and driver image and returns a Driver instance for it. The Driver instance returned by this method is not thread-safe.

type DriverPool

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

DriverPool controls a pool of drivers and balances requests among them, ensuring each driver does not get concurrent requests. The number of driver instances in the driver pool is controlled by a ScalingPolicy.

func StartDriverPool

func StartDriverPool(scaling ScalingPolicy, timeout time.Duration, new func() (Driver, error)) (*DriverPool, error)

StartDriverPool creates and starts a new DriverPool. It takes as parameters the ScalingPolicy, the timeout for requests before getting a driver assigned, and a function to create driver instances.

func (*DriverPool) Close

func (dp *DriverPool) Close() error

Close closes the driver pool, including all its underlying driver instances.

func (*DriverPool) ParseUAST

ParseUAST processes a ParseUASTRequest. It gets a driver from the pool and forwards the request to it. If all drivers are busy, it will return an error after the timeout passes. If the DriverPool is closed, an error will be returned.

type ScalingPolicy

type ScalingPolicy interface {
	// Scale takes the number of total instances and the load. The load is
	// the number of request waiting or, there is none, it is a negative
	// value indicating how many instances are ready.
	Scale(total, load int) int
}

ScalingPolicy specifies whether instances should be started or stopped to cope with load.

func AIMD

func AIMD(add int, mul float64) ScalingPolicy

AIMD returns a ScalingPolicy of additive increase / multiplicative decrease. Increases are of min(add, load). Decreases are of (ready / mul).

func DefaultScalingPolicy

func DefaultScalingPolicy() ScalingPolicy

DefaultScalingPolicy returns a new instance of the default scaling policy. Instances returned by this function should not be reused.

func MinMax

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

MinMax wraps a ScalingPolicy and applies a minimum and maximum to the number of instances.

func MovingAverage

func MovingAverage(window int, p ScalingPolicy) ScalingPolicy

MovingAverage computes a moving average of the load and forwards it to the underlying scaling policy. This policy is stateful and not thread-safe, do not reuse its instances for multiple pools.

type Server

type Server struct {
	// Transport to use to fetch driver images. Defaults to "docker".
	// Useful transports:
	// - docker: uses Docker registries (docker.io by default).
	// - docker-daemon: gets images from a local Docker daemon.
	Transport string
	// contains filtered or unexported fields
}

Server is a Babelfish server.

func NewServer

func NewServer(r *runtime.Runtime) *Server

func (*Server) AddDriver

func (s *Server) AddDriver(lang string, img string) error

func (*Server) Close

func (s *Server) Close() error

func (*Server) Driver

func (s *Server) Driver(lang string) (Driver, error)

func (*Server) ParseUAST

func (*Server) Serve

func (s *Server) Serve(listener net.Listener) error

Directories

Path Synopsis
cmd
Package runtime provide the runtime environment to execute the bblfsh drivers The runtime is based on libcontainer allowing to the runtime run the drivers inside of a isolated lightweight container.
Package runtime provide the runtime environment to execute the bblfsh drivers The runtime is based on libcontainer allowing to the runtime run the drivers inside of a isolated lightweight container.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL