executor

Documentation

Index

• Constants
• func ExecuteHandler(ctx context.Context, content interface{}, encode wire.EncoderFunc) error
• func NewFlavour(config Config) run.FlavourFunc
• func RunDockerContainerHandler(ctx context.Context, content interface{}, encode wire.EncoderFunc) error
• type Config
• type EmbeddedFunc
• type HandlerFunc
  • func NewInflateDockerImageHandler() HandlerFunc
  • func NewRunEmbeddedFunctionHandler(funcs map[string]EmbeddedFunc) HandlerFunc
• type Router
  • func NewRouter() Router
  • func (r Router) Handler(content interface{}) (HandlerFunc, error)
  • func (r Router) RegisterHandler(content interface{}, handler HandlerFunc) Router
  • func (r Router) Types() []interface{}

Constants

const DefaultArg = "isolator"

DefaultArg is the default CLI arg for starting the executor server.

Functions

func ExecuteHandler

func ExecuteHandler(ctx context.Context, content interface{}, encode wire.EncoderFunc) error

ExecuteHandler is a standard handler handling Execute command.

func NewFlavour

func NewFlavour(config Config) run.FlavourFunc

NewFlavour returns a flavour catching a request to start the executor server. If command is not related, then the standard application function is called.

func RunDockerContainerHandler

func RunDockerContainerHandler(ctx context.Context, content interface{}, encode wire.EncoderFunc) error

RunDockerContainerHandler is a standard handler for RunDockerContainer command.

Types

type Config

type Config struct {
	// Roouter provide handlers for commands.
	Router Router

	// ExecutorArg is the CLI arg on calling binary which starts the executor server.
	// See `executor.Catch`.
	ExecutorArg string
}

Config is the config of executor server.

type EmbeddedFunc

type EmbeddedFunc func(ctx context.Context, args []string) error

EmbeddedFunc defines embedded function.

type HandlerFunc

type HandlerFunc func(ctx context.Context, content interface{}, encode wire.EncoderFunc) error

HandlerFunc defines handler for content.

func NewInflateDockerImageHandler

func NewInflateDockerImageHandler() HandlerFunc

NewInflateDockerImageHandler creates new standard handler for InflateDockerImage command.

func NewRunEmbeddedFunctionHandler

func NewRunEmbeddedFunctionHandler(funcs map[string]EmbeddedFunc) HandlerFunc

NewRunEmbeddedFunctionHandler returns new handler running embedded function.

type Router

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

Router maps content type to its handler.

func NewRouter

func NewRouter() Router

NewRouter returns new router.

func (Router) Handler

func (r Router) Handler(content interface{}) (HandlerFunc, error)

Handler returns handler for the content type.

func (Router) RegisterHandler

func (r Router) RegisterHandler(content interface{}, handler HandlerFunc) Router

RegisterHandler registers new handler for the content type.

func (Router) Types

func (r Router) Types() []interface{}

Types returns registered types.