bundle

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

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

type FissionOptions struct {
	ExecutorAddress string
	ControllerAddr  string
	RouterAddr      string
}

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

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 interface {
	io.Closer
	Run() error
}

type Processes []Process

type SchedulerPolicy string