subsystem

Documentation

Index

• type Config
  • func (cfg *Config) GetPollInterval(n core.Network) (time.Duration, error)
• type Manager
  • func NewManager(ctx context.Context, cfg *Config, etl pipeline.Manager, eng engine.Manager, ...) Manager

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