apphandlers

Documentation

Index

• Variables
• func Init()
• func Init2()
• func NewRsourcesService(deploymentType deployment.Type) (rsources.JobService, error)
• type AppHandler
  • func GetAppHandler(application app.App, appType string, ...) AppHandler
• type EmbeddedApp
  • func (*EmbeddedApp) GetAppType() string
  • func (*EmbeddedApp) HandleRecovery(options *app.Options)
  • func (embedded *EmbeddedApp) StartRudderCore(ctx context.Context, options *app.Options) error
• type GatewayApp
  • func (*GatewayApp) GetAppType() string
  • func (*GatewayApp) HandleRecovery(options *app.Options)
  • func (gatewayApp *GatewayApp) StartRudderCore(ctx context.Context, options *app.Options) error
• type ProcessorApp
  • func (*ProcessorApp) GetAppType() string
  • func (*ProcessorApp) HandleRecovery(options *app.Options)
  • func (processor *ProcessorApp) StartRudderCore(ctx context.Context, options *app.Options) error

Variables

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

	MaxHeaderBytes int
)

var (
	Diagnostics diagnostics.DiagnosticsI
)

Functions

func Init

func Init()

func Init2

func Init2()

func NewRsourcesService

func NewRsourcesService(deploymentType deployment.Type) (rsources.JobService, error)

NewRsourcesService produces a rsources.JobService through environment configuration (env variables & config file)

Types

type AppHandler

type AppHandler interface {
	GetAppType() string
	HandleRecovery(*app.Options)
	StartRudderCore(context.Context, *app.Options) error
}

AppHandler to be implemented by different app type objects.

func GetAppHandler

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

type EmbeddedApp

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

EmbeddedApp is the type for embedded type implementation

func (*EmbeddedApp) GetAppType

func (*EmbeddedApp) GetAppType() string

func (*EmbeddedApp) HandleRecovery

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

func (*EmbeddedApp) StartRudderCore

func (embedded *EmbeddedApp) StartRudderCore(ctx context.Context, options *app.Options) error

type GatewayApp

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

GatewayApp is the type for Gateway type implementation

func (*GatewayApp) GetAppType

func (*GatewayApp) GetAppType() string

func (*GatewayApp) HandleRecovery

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

func (*GatewayApp) StartRudderCore

func (gatewayApp *GatewayApp) StartRudderCore(ctx context.Context, options *app.Options) error

type ProcessorApp

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

ProcessorApp is the type for Processor type implemention

func (*ProcessorApp) GetAppType

func (*ProcessorApp) GetAppType() string

func (*ProcessorApp) HandleRecovery

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

func (*ProcessorApp) StartRudderCore

func (processor *ProcessorApp) StartRudderCore(ctx context.Context, options *app.Options) error