app

Documentation

Index

• func InitializeAlerting(ctx context.Context, cfg *config.Config) (alert.Manager, error)
• func InitializeContext(ctx context.Context, ss state.Store, l1Client, l2Client client.EthClient, ...) context.Context
• func InitializeETL(ctx context.Context, transit chan core.HeuristicInput) pipeline.Manager
• func InitializeEngine(ctx context.Context, transit chan core.Alert) engine.Manager
• func InitializeMetrics(ctx context.Context, cfg *config.Config) (metrics.Metricer, func(), error)
• func InitializeServer(ctx context.Context, cfg *config.Config, m subsystem.Manager) (*server.Server, func(), error)
• type Application
  • func New(ctx context.Context, cfg *config.Config, sub subsystem.Manager, ...) *Application
  • func NewPessimismApp(ctx context.Context, cfg *config.Config) (*Application, func(), error)
  • func (a *Application) BootStrap(sessions []*BootSession) error
  • func (a *Application) End() <-chan os.Signal
  • func (a *Application) ListenForShutdown(stop func())
  • func (a *Application) Start() error
• type BootSession

Functions

func InitializeAlerting

func InitializeAlerting(ctx context.Context, cfg *config.Config) (alert.Manager, error)

InitializeAlerting ... Performs dependency injection to build alerting struct

func InitializeContext

func InitializeContext(ctx context.Context, ss state.Store,
	l1Client, l2Client client.EthClient, l2geth client.GethClient) context.Context

InitializeContext ... Performs dependency injection to build context struct

func InitializeETL

func InitializeETL(ctx context.Context, transit chan core.HeuristicInput) pipeline.Manager

InitializeETL ... Performs dependency injection to build etl struct

func InitializeEngine

func InitializeEngine(ctx context.Context, transit chan core.Alert) engine.Manager

InitializeEngine ... Performs dependency injection to build engine struct

func InitializeMetrics

func InitializeMetrics(ctx context.Context, cfg *config.Config) (metrics.Metricer, func(), error)

InitializeMetrics ... Performs dependency injection to build metrics struct

func InitializeServer

func InitializeServer(ctx context.Context, cfg *config.Config, m subsystem.Manager) (*server.Server, func(), error)

InitializeServer ... Performs dependency injection to build server struct

Types

type Application

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

Application ... Pessimism app struct

func New

func New(ctx context.Context, cfg *config.Config,
	sub subsystem.Manager, server *server.Server, stats metrics.Metricer) *Application

New ... Initializer

func NewPessimismApp

func NewPessimismApp(ctx context.Context, cfg *config.Config) (*Application, func(), error)

NewPessimismApp ... Performs dependency injection to build app struct

func (*Application) BootStrap

func (a *Application) BootStrap(sessions []*BootSession) error

BootStrap ... Bootstraps the application

func (*Application) End

func (a *Application) End() <-chan os.Signal

End ... Returns a channel that will receive an OS signal

func (*Application) ListenForShutdown

func (a *Application) ListenForShutdown(stop func())

ListenForShutdown ... Handles and listens for shutdown

func (*Application) Start

func (a *Application) Start() error

Start ... Starts the application

type BootSession

type BootSession = models.SessionRequestParams

BootSession ... Application wrapper for SessionRequestParams