executor

Documentation

Index

• func StartExecutor(ctx context.Context, logger *zap.Logger, port int) 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(ctx context.Context, port int)

Functions

func StartExecutor

func StartExecutor(ctx context.Context, logger *zap.Logger, port int) 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 versioned.Interface, 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(ctx context.Context, port int)

Serve starts an HTTP server.