executor

Documentation

Index

• func StartExecutor(ctx context.Context, logger *zap.Logger, functionNamespace string, ...) error
• type Executor
  • func MakeExecutor(ctx context.Context, logger *zap.Logger, cms *cms.ConfigSecretController, ...) (*Executor, error)
  • func (executor *Executor) GetHandler() http.Handler
  • func (executor *Executor) Serve(port int, openTracingEnabled bool)

Functions

func StartExecutor

func StartExecutor(ctx context.Context, logger *zap.Logger, functionNamespace string, envBuilderNamespace string, port int, openTracingEnabled bool) error

StartExecutor Starts executor and the executor components such as Poolmgr, deploymgr and potential future executor types

Types

type Executor

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

Executor defines a fission function executor.

func MakeExecutor

func MakeExecutor(ctx context.Context, logger *zap.Logger, cms *cms.ConfigSecretController,
	fissionClient *crd.FissionClient, types map[fv1.ExecutorType]executortype.ExecutorType,
	informers []k8sCache.SharedIndexInformer) (*Executor, error)

MakeExecutor returns an Executor for given ExecutorType(s).

func (*Executor) GetHandler

func (executor *Executor) GetHandler() http.Handler

GetHandler returns an http.Handler.

func (*Executor) Serve

func (executor *Executor) Serve(port int, openTracingEnabled bool)

Serve starts an HTTP server.