Documentation
¶
Index ¶
Constants ¶
const ( GATEWAY = "GATEWAY" PROCESSOR = "PROCESSOR" EMBEDDED = "EMBEDDED" )
Variables ¶
This section is empty.
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 struct {
// contains filtered or unexported fields
}
App holds the main application's configuration and state
type ConfigEnvFeature ¶
type ConfigEnvFeature interface {
Setup() types.ConfigEnvI
}
ConfigEnvFeature handles override of config from ENV variables.
type Features ¶
type Features struct {
Migrator MigratorFeature
SuppressUser SuppressUserFeature
ConfigEnv ConfigEnvFeature
Reporting ReportingFeature
Replay ReplayFeature
}
Features contains optional implementations of Enterprise only features.
type Interface ¶
type Interface interface {
Setup() // Initializes application
Stop() // Stop application
Options() *Options // Get this application's options
Features() *Features // Get this application's enterprise features
}
Interface of a rudder-server application
type MigratorFeature ¶
type MigratorFeature interface {
Run(context.Context, *jobsdb.HandleT, *jobsdb.HandleT, *jobsdb.HandleT, func(), func())
PrepareJobsdbsForImport(*jobsdb.HandleT, *jobsdb.HandleT, *jobsdb.HandleT)
}
MigratorFeature handles migration of nodes during cluster's scale up/down.
type MigratorFeatureSetup ¶
type MigratorFeatureSetup func(Interface) MigratorFeature
MigratorFeatureSetup is a function that initializes a Migrator feature, based on application instance
type Options ¶
type Options struct {
NormalMode bool
DegradedMode bool
MigrationMode string
ClearDB bool
Cpuprofile string
Memprofile string
VersionFlag bool
EnterpriseToken string
}
Options contains application's initialisation options
func LoadOptions ¶
func LoadOptions() *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(Interface) 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(backendConfig backendconfig.BackendConfig) (types.SuppressUserI, error)
}
SuppressUserFeature handles webhook event requests
Source Files
Directories