app

Documentation

Index

• Constants
• func LivenessHandler(jobsDB jobsdb.JobsDB) http.HandlerFunc
• type App
  • func New(options *Options) App
• type ConfigEnvFeature
• type Features
• type Options
  • func LoadOptions(args []string) *Options
• type ReplayFeature
• type ReplayFeatureSetup
• type ReportingFeature
• type SuppressUserFeature

Constants

const (
	GATEWAY   = "GATEWAY"
	PROCESSOR = "PROCESSOR"
	EMBEDDED  = "EMBEDDED"
)

Functions

func LivenessHandler

func LivenessHandler(jobsDB jobsdb.JobsDB) http.HandlerFunc

LivenessHandler is the http handler for the Kubernetes liveness probe

Types

type App

type App interface {
	Setup()              // Initializes application
	Stop()               // Stop application
	Options() *Options   // Get this application's options
	Features() *Features // Get this application's enterprise features
}

App represents a rudder-server application

func New

func New(options *Options) App

New creates a new application instance

type ConfigEnvFeature

type ConfigEnvFeature interface {
	Setup() types.ConfigEnvI
}

ConfigEnvFeature handles override of config from ENV variables.

type Features

type Features struct {
	SuppressUser SuppressUserFeature
	ConfigEnv    ConfigEnvFeature
	Reporting    ReportingFeature
	Replay       ReplayFeature
}

Features contains optional implementations of Enterprise only features.

type Options

type Options struct {
	NormalMode      bool
	DegradedMode    bool
	ClearDB         bool
	Cpuprofile      string
	Memprofile      string
	VersionFlag     bool
	EnterpriseToken string
}

Options contains application's initialisation options

func LoadOptions

func LoadOptions(args []string) *Options

LoadOptions loads application's initialisation options based on command line flags and environment

type ReplayFeature

type ReplayFeature interface {
	Setup(ctx context.Context, replayDB, gwDB, routerDB, batchRouterDB *jobsdb.HandleT)
}

ReplayFeature handles inserting of failed jobs into respective gw/rt jobsdb

type ReplayFeatureSetup

type ReplayFeatureSetup func(App) ReplayFeature

ReplayFeatureSetup is a function that initializes a Replay feature

type ReportingFeature

type ReportingFeature interface {
	Setup(backendConfig backendconfig.BackendConfig) types.ReportingI
	GetReportingInstance() types.ReportingI
}

ReportingFeature handles reporting statuses / errors to reporting service

type SuppressUserFeature

type SuppressUserFeature interface {
	Setup(ctx context.Context, backendConfig backendconfig.BackendConfig) (types.UserSuppression, error)
}

SuppressUserFeature handles webhook event requests