subsystem

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 30, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	MaxPipelineCount int
	L1PollInterval   int
	L2PollInterval   int
}

Config ... Used to store necessary API service config values

func (*Config) GetPollInterval 

func (cfg *Config) GetPollInterval(n core.Network) (time.Duration, error)

GetPollInterval ... Returns config poll-interval for network type

type Manager 

type Manager interface {
	BuildDeployCfg(pConfig *core.PipelineConfig, sConfig *core.SessionConfig) (*heuristic.DeployConfig, error)
	BuildPipelineCfg(params *models.SessionRequestParams) (*core.PipelineConfig, error)
	RunSession(cfg *heuristic.DeployConfig) (core.SUUID, error)
	// Orchestration
	StartEventRoutines(ctx context.Context)
	Shutdown() error
}

Manager ... Subsystem manager interface

func NewManager 

func NewManager(ctx context.Context, cfg *Config, etl pipeline.Manager, eng engine.Manager,
	a alert.Manager,
) Manager

NewManager ... Initializer for the subsystem manager

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.