apphandlers

Documentation

Index

• Variables
• func StartProcessor(clearDB *bool, enableProcessor bool, ...)
• func StartRouter(enableRouter bool, routerDB, batchRouterDB, procErrorDB *jobsdb.HandleT, ...)
• type AppHandler
  • func GetAppHandler(application app.Interface, appType string, ...) AppHandler
• type EmbeddedApp
  • func (embedded *EmbeddedApp) GetAppType() string
  • func (embedded *EmbeddedApp) HandleRecovery(options *app.Options)
  • func (embedded *EmbeddedApp) StartRudderCore(options *app.Options)
• type GatewayApp
  • func (gatewayApp *GatewayApp) GetAppType() string
  • func (gateway *GatewayApp) HandleRecovery(options *app.Options)
  • func (gatewayApp *GatewayApp) StartRudderCore(options *app.Options)
• type ProcessorApp
  • func (processor *ProcessorApp) GetAppType() string
  • func (processor *ProcessorApp) HandleRecovery(options *app.Options)
  • func (processor *ProcessorApp) StartRudderCore(options *app.Options)

Variables

var (
	ReadTimeout       time.Duration
	ReadHeaderTimeout time.Duration
	WriteTimeout      time.Duration
	IdleTimeout       time.Duration

	MaxHeaderBytes int
)

var (
	Diagnostics diagnostics.DiagnosticsI = diagnostics.Diagnostics
)

Functions

func StartProcessor

func StartProcessor(clearDB *bool, enableProcessor bool, gatewayDB, routerDB, batchRouterDB *jobsdb.HandleT, procErrorDB *jobsdb.HandleT, reporting types.ReportingI)

StartProcessor atomically starts processor process if not already started

func StartRouter

func StartRouter(enableRouter bool, routerDB, batchRouterDB, procErrorDB *jobsdb.HandleT, reporting types.ReportingI)

StartRouter atomically starts router process if not already started

Types

type AppHandler

type AppHandler interface {
	GetAppType() string
	HandleRecovery(*app.Options)
	StartRudderCore(*app.Options)
}

AppHandler to be implemented by different app type objects.

func GetAppHandler

func GetAppHandler(application app.Interface, appType string, versionHandler func(w http.ResponseWriter, r *http.Request)) AppHandler

type EmbeddedApp

type EmbeddedApp struct {
	App            app.Interface
	VersionHandler func(w http.ResponseWriter, r *http.Request)
}

EmbeddedApp is the type for embedded type implemention

func (*EmbeddedApp) GetAppType

func (embedded *EmbeddedApp) GetAppType() string

func (*EmbeddedApp) HandleRecovery

func (embedded *EmbeddedApp) HandleRecovery(options *app.Options)

func (*EmbeddedApp) StartRudderCore

func (embedded *EmbeddedApp) StartRudderCore(options *app.Options)

type GatewayApp

type GatewayApp struct {
	App            app.Interface
	VersionHandler func(w http.ResponseWriter, r *http.Request)
}

GatewayApp is the type for Gateway type implemention

func (*GatewayApp) GetAppType

func (gatewayApp *GatewayApp) GetAppType() string

func (*GatewayApp) HandleRecovery

func (gateway *GatewayApp) HandleRecovery(options *app.Options)

func (*GatewayApp) StartRudderCore

func (gatewayApp *GatewayApp) StartRudderCore(options *app.Options)

type ProcessorApp

type ProcessorApp struct {
	App            app.Interface
	VersionHandler func(w http.ResponseWriter, r *http.Request)
}

ProcessorApp is the type for Processor type implemention

func (*ProcessorApp) GetAppType

func (processor *ProcessorApp) GetAppType() string

func (*ProcessorApp) HandleRecovery

func (processor *ProcessorApp) HandleRecovery(options *app.Options)

func (*ProcessorApp) StartRudderCore

func (processor *ProcessorApp) StartRudderCore(options *app.Options)