bundle

Documentation

Index

• Constants
• func ParseSchedulerConfig(c *cli.Context) (scheduler.Policy, error)
• func Run(ctx context.Context, opts *Options) error
• func SetupScheduler(policy scheduler.Policy) *scheduler.InvocationScheduler
• type App
  • func (app *App) Close() error
  • func (app *App) RegisterCloser(name string, closer io.Closer)
• type FissionOptions
• type FissionProxyConfig
  • func ParseFissionProxyConfig(ctx *cli.Context) (*FissionProxyConfig, error)
  • func (c *FissionProxyConfig) Close() error
  • func (c *FissionProxyConfig) Run() error
• type Options
• type Process
• type Processes
  • func (p Processes) Close() error
  • func (p *Processes) Register(process Process)
  • func (p Processes) Start() error
• type SchedulerPolicy

Constants

const (
	WorkflowsCacheSize   = 10000
	InvocationsCacheSize = 100000
)

const (
	FlagSchedulerPolicy            = "scheduler.policy"
	FlagSchedulerColdStartDuration = "scheduler.coldstart"
)

Functions

func ParseSchedulerConfig

func ParseSchedulerConfig(c *cli.Context) (scheduler.Policy, error)

func Run

func Run(ctx context.Context, opts *Options) error

Run serves enabled components in a blocking way

func SetupScheduler

func SetupScheduler(policy scheduler.Policy) *scheduler.InvocationScheduler

Types

type App

type App struct {
	*Options
	// contains filtered or unexported fields
}

func (*App) Close

func (app *App) Close() error

func (*App) RegisterCloser

func (app *App) RegisterCloser(name string, closer io.Closer)

type FissionOptions

type FissionOptions struct {
	ExecutorAddress string
	ControllerAddr  string
	RouterAddr      string
}

type FissionProxyConfig

type FissionProxyConfig struct {
	DefaultTimeout time.Duration
	ProxyAddr      string
	WorkflowsAddr  string
	ExposeMetrics  bool
	// contains filtered or unexported fields
}

func ParseFissionProxyConfig

func ParseFissionProxyConfig(ctx *cli.Context) (*FissionProxyConfig, error)

func (*FissionProxyConfig) Close

func (c *FissionProxyConfig) Close() error

func (*FissionProxyConfig) Run

func (c *FissionProxyConfig) Run() error

type Options

type Options struct {
	NATS                 *nats.Config
	Scheduler            scheduler.Policy
	Fission              *FissionOptions
	FissionProxy         *FissionProxyConfig
	InternalRuntime      bool
	InvocationController bool
	WorkflowController   bool
	AdminAPI             bool
	WorkflowAPI          bool
	HTTPGateway          bool
	InvocationAPI        bool
	Metrics              bool
	Debug                bool
}

type Process

type Process interface {
	io.Closer
	Run() error
}

type Processes

type Processes []Process

func (Processes) Close

func (p Processes) Close() error

func (*Processes) Register

func (p *Processes) Register(process Process)

func (Processes) Start

func (p Processes) Start() error

type SchedulerPolicy

type SchedulerPolicy string