flotilla

Documentation

Index

• func NewRouter(ep endpoints) *muxtrace.Router
• type App
  • func NewApp(conf config.Config, log flotillaLog.Logger, eksLogsClient logs.Client, ...) (App, error)
  • func (app *App) Run() error

Functions

func NewRouter

func NewRouter(ep endpoints) *muxtrace.Router

NewRouter creates and returns a Mux Router

Types

type App

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

func NewApp

func NewApp(conf config.Config,
	log flotillaLog.Logger,
	eksLogsClient logs.Client,
	eksExecutionEngine engine.Engine,
	stateManager state.Manager,
	eksClusterClient cluster.Client,
	eksQueueManager queue.Manager,
	emrExecutionEngine engine.Engine,
	emrQueueManager queue.Manager,
	middlewareClient middleware.Client,
) (App, error)

Function to initialize a new Flotilla app.

func (*App) Run

func (app *App) Run() error

Start the Application.