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 DataflowApiExtensions
• 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 DataflowApiExtensions

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

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
	Consent              bool
	Provenance           bool
	AdminAPI             bool
	ConsentAPI           bool
	WorkflowAPI          bool
	HTTPGateway          bool
	InvocationAPI        bool
	Metrics              bool
	Debug                bool
	UseNats              bool
	ProvNats             bool
	ConsentNats          bool
	MaxParallel          int
}

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