scale

README

A framework for building high-performance plugin systems into any application, all powered by WebAssembly.

With Scale Functions your users can write fully typed plugins in any language they choose, and your application can easily and safely run those plugins with the Scale Runtime, which provides state-of-the-art sandboxing, low startup times, and extremely high performance.

Currently, guest plugins can be written in Golang, Rust, and Typescript, with the Runtime supporting Golang and Typescript host applications.

Usage and Documentation

Usage instructions and documentation for Scale is available at https://scale.sh/docs.

Contributing

Bug reports and pull requests are welcome on GitHub at https://github.com/loopholelabs/scale. For more contribution information check out the contribution guide.

License

The Scale project is available as open source under the terms of the Apache License, Version 2.0.

Code of Conduct

Everyone interacting in the Scale project’s codebases, issue trackers, chat rooms and mailing lists is expected to follow the CNCF Code of Conduct.

Project Managed By:

Documentation

Overview

Package scale implements the Scale Runtime in Go.

Index

• Variables
• type Config
  • func NewConfig[T interfaces.Signature](newSignature interfaces.New[T]) *Config[T]
  • func (c *Config[T]) WithContext(ctx context.Context) *Config[T]
  • func (c *Config[T]) WithExtension(e extension.Extension) *Config[T]
  • func (c *Config[T]) WithFunction(function *scalefunc.V1BetaSchema, env ...map[string]string) *Config[T]
  • func (c *Config[T]) WithFunctions(function []*scalefunc.V1BetaSchema, env ...map[string]string) *Config[T]
  • func (c *Config[T]) WithRawOutput(rawOutput bool) *Config[T]
  • func (c *Config[T]) WithSignature(newSignature interfaces.New[T]) *Config[T]
  • func (c *Config[T]) WithStderr(w io.Writer) *Config[T]
  • func (c *Config[T]) WithStdout(w io.Writer) *Config[T]
• type Instance
  • func (i *Instance[T]) Run(ctx context.Context, signature T) error
• type Next
• type Parsed
  • func Parse(name string) *Parsed
• type Scale
  • func New[T interfaces.Signature](config *Config[T]) (*Scale[T], error)
  • func (r *Scale[T]) Clear()
  • func (r *Scale[T]) Instance(next ...Next[T]) (*Instance[T], error)

Variables

var (
	ErrNoConfig        = errors.New("no config provided")
	ErrNoFunctions     = errors.New("no functions provided")
	ErrInvalidFunction = errors.New("invalid function")
	ErrInvalidEnv      = errors.New("invalid environment variable")
)

Types

type Config

type Config[T interfaces.Signature] struct {
	// contains filtered or unexported fields
}

Config is the configuration for a Scale Runtime

func NewConfig

func NewConfig[T interfaces.Signature](newSignature interfaces.New[T]) *Config[T]

NewConfig returns a new Scale Runtime Config

func (*Config[T]) WithContext

func (c *Config[T]) WithContext(ctx context.Context) *Config[T]

func (*Config[T]) WithExtension

func (c *Config[T]) WithExtension(e extension.Extension) *Config[T]

func (*Config[T]) WithFunction

func (c *Config[T]) WithFunction(function *scalefunc.V1BetaSchema, env ...map[string]string) *Config[T]

func (*Config[T]) WithFunctions

func (c *Config[T]) WithFunctions(function []*scalefunc.V1BetaSchema, env ...map[string]string) *Config[T]

func (*Config[T]) WithRawOutput

func (c *Config[T]) WithRawOutput(rawOutput bool) *Config[T]

func (*Config[T]) WithSignature

func (c *Config[T]) WithSignature(newSignature interfaces.New[T]) *Config[T]

func (*Config[T]) WithStderr

func (c *Config[T]) WithStderr(w io.Writer) *Config[T]

func (*Config[T]) WithStdout

func (c *Config[T]) WithStdout(w io.Writer) *Config[T]

type Instance

type Instance[T interfaces.Signature] struct {
	// contains filtered or unexported fields
}

Instance is a single instance of a Scale Function chain

func (*Instance[T]) Run

func (i *Instance[T]) Run(ctx context.Context, signature T) error

type Next

type Next[T interfaces.Signature] func(ctx T) (T, error)

Next is the next function in the middleware chain. It's meant to be implemented by whatever adapter is being used.

type Parsed

type Parsed struct {
	Organization string
	Name         string
	Tag          string
}

func Parse

func Parse(name string) *Parsed

Parse parses a function or signature name of the form <org>/<name>:<tag> into its organization, name, and tag

type Scale

type Scale[T interfaces.Signature] struct {
	TraceDataCallback func(data string)
	// contains filtered or unexported fields
}

Scale is the Scale Runtime. It is responsible for initializing and managing the WASM runtime as well as the scale function chain.

func New

func New[T interfaces.Signature](config *Config[T]) (*Scale[T], error)

func (*Scale[T]) Clear

func (r *Scale[T]) Clear()

func (*Scale[T]) Instance

func (r *Scale[T]) Instance(next ...Next[T]) (*Instance[T], error)

Instance returns a new instance of a Scale Function chain with the provided and optional next function.