app

Documentation

Index

• Constants
• func HealthHandler(w http.ResponseWriter, r *http.Request, jobsDB jobsdb.JobsDB)
• func Init()
• func RegisterConfigEnvFeature(f ConfigEnvFeatureSetup)
• func RegisterMigratorFeature(f MigratorFeatureSetup)
• func RegisterReplayFeature(f ReplayFeatureSetup)
• func RegisterReportingFeature(f ReportingFeatureSetup)
• func RegisterSuppressUserFeature(f SuppressUserFeatureSetup)
• type App
  • func (a *App) Features() *Features
  • func (a *App) Options() *Options
  • func (a *App) Setup()
  • func (a *App) Stop()
• type ConfigEnvFeature
• type ConfigEnvFeatureSetup
• type Features
• type Interface
  • func New(options *Options) Interface
• type MigratorFeature
• type MigratorFeatureSetup
• type Options
  • func LoadOptions() *Options
• type ReplayFeature
• type ReplayFeatureSetup
• type ReportingFeature
• type ReportingFeatureSetup
• type SuppressUserFeature
• type SuppressUserFeatureSetup

Constants

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

Functions

func HealthHandler

func HealthHandler(w http.ResponseWriter, r *http.Request, jobsDB jobsdb.JobsDB)

HealthHandler is the http handler for health endpoint

func Init

func Init()

func RegisterConfigEnvFeature

func RegisterConfigEnvFeature(f ConfigEnvFeatureSetup)

RegisterConfigEnvFeature registers a config env feature implementation

func RegisterMigratorFeature

func RegisterMigratorFeature(f MigratorFeatureSetup)

RegisterMigratorFeature registers a Migration implementation

func RegisterReplayFeature

func RegisterReplayFeature(f ReplayFeatureSetup)

RegisterReplayFeature registers a config env feature implementation

func RegisterReportingFeature

func RegisterReportingFeature(f ReportingFeatureSetup)

RegisterReportingFeature registers a config env feature implementation

func RegisterSuppressUserFeature

func RegisterSuppressUserFeature(f SuppressUserFeatureSetup)

RegisterSuppressUserFeature registers a suppress user feature implementation

Types

type App

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

App holds the main application's configuration and state

func (*App) Features

func (a *App) Features() *Features

Features returns this application's enterprise features

func (*App) Options

func (a *App) Options() *Options

Options returns this application's options

func (*App) Setup

func (a *App) Setup()

Setup initializes application

func (*App) Stop

func (a *App) Stop()

Stop stops application

type ConfigEnvFeature

type ConfigEnvFeature interface {
	Setup() types.ConfigEnvI
}

ConfigEnvFeature handles override of config from ENV variables.

type ConfigEnvFeatureSetup

type ConfigEnvFeatureSetup func(Interface) ConfigEnvFeature

ConfigEnvFeatureSetup is a function that initializes a ConfigEnv feature

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

func New

func New(options *Options) Interface

New creates a new application instance

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
}

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(replayDB, gwDB, routerDB, batchRouterDB *jobsdb.HandleT)
}

ReplayFeature handles inserting of failed jobs into repsective 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 ReportingFeatureSetup

type ReportingFeatureSetup func(Interface) ReportingFeature

ReportingFeatureSetup is a function that initializes a Reporting feature

type SuppressUserFeature

type SuppressUserFeature interface {
	Setup(backendConfig backendconfig.BackendConfig) types.SuppressUserI
}

SuppressUserFeature handles webhook event requests

type SuppressUserFeatureSetup

type SuppressUserFeatureSetup func(Interface) SuppressUserFeature

SuppressUserFeatureSetup is a function that initializes a Webhook feature, based on application instance