server

Documentation

Index

• type Config
  • func (c *Config) ApplyOverrides(o *Override, log logrus.FieldLogger) error
  • func (c *Config) Validate() error
• type Override
• type Xatu
  • func NewXatu(ctx context.Context, log logrus.FieldLogger, conf *Config, o *Override) (*Xatu, error)
  • func (x *Xatu) Start(ctx context.Context) error

Types

type Config

type Config struct {
	// The address to listen on.
	Addr string `yaml:"addr" default:":8080"`
	// PreStopSleepSeconds is the number of seconds to sleep before stopping.
	// Useful for giving kubernetes time to drain connections.
	// This sleep will happen after a SIGTERM is received, and will
	// delay the shutdown of the server and all of it's components.
	// Note: Do not set this to a value greater than the kubernetes
	// terminationGracePeriodSeconds.
	PreStopSleepSeconds int `yaml:"preStopSleepSeconds" default:"0"`
	// MetricsAddr is the address to listen on for metrics.
	MetricsAddr string `yaml:"metricsAddr" default:":9090"`
	// PProfAddr is the address to listen on for pprof.
	PProfAddr *string `yaml:"pprofAddr"`
	// LoggingLevel is the logging level to use.
	LoggingLevel string `yaml:"logging" default:"info"`

	// NTP Server to use for clock drift correction
	NTPServer string `yaml:"ntpServer" default:"time.google.com"`

	// Store is the cache configuration.
	Persistence persistence.Config `yaml:"persistence"`
	// Store is the cache configuration.
	Store store.Config `yaml:"store"`
	// GeoIP is the geoip provider configuration.
	GeoIP geoip.Config `yaml:"geoip"`

	// Services is the list of services to run.
	Services service.Config `yaml:"services"`

	// Tracing configuration
	Tracing observability.TracingConfig `yaml:"tracing"`
}

func (*Config) ApplyOverrides

func (c *Config) ApplyOverrides(o *Override, log logrus.FieldLogger) error

func (*Config) Validate

func (c *Config) Validate() error

type Override

type Override struct {
	// EventIngesterBasicAuth configures basic authentication for the event ingester.
	EventIngesterBasicAuth struct {
		Username string
		Password string
	}
	// CoordinatorAuth configures the authentication for the coordinator.
	CoordinatorAuth struct {
		Enabled    bool
		AuthSecret string
	}
}

type Xatu

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

func NewXatu

func NewXatu(ctx context.Context, log logrus.FieldLogger, conf *Config, o *Override) (*Xatu, error)

func (*Xatu) Start

func (x *Xatu) Start(ctx context.Context) error