atc

Documentation

Index

• Constants
• func DisableSignalHandling(config *server.Config)
• func NewServerService(serv *server.Server, servicesToWaitFor func() []services.Service) services.Service
• type Atc
  • func New(cfg Config) (*Atc, error)
  • func (t *Atc) Run() error
• type Config

Constants

const (
	API        string = "api"
	Autoscaler string = "autoscaler"
	Consul     string = "consul"
	Deployer   string = "deployer"
	EventSink  string = "event_sink"
	Forwarder  string = "forwarder"
	Nomad      string = "nomad"
	Server     string = "server"
	Radar      string = "radar"
	Redirecter string = "redirecter"
	All        string = "all"
)

Functions

func DisableSignalHandling

func DisableSignalHandling(config *server.Config)

DisableSignalHandling puts a dummy signal handler

func NewServerService

func NewServerService(serv *server.Server, servicesToWaitFor func() []services.Service) services.Service

NewServerService constructs service from Server component. servicesToWaitFor is called when server is stopping, and should return all services that need to terminate before server actually stops. N.B.: this function is NOT Cortex specific, please let's keep it that way. Passed server should not react on signals. Early return from Run function is considered to be an error.

Types

type Atc

type Atc struct {
	Cfg Config

	Server *server.Server

	Autoscaler *autoscaler.Autoscaler
	Deployer   *deployer.Deployer
	EventSink  *event_sink.EventSink
	Forwarder  *forwarder.Forwarder
	Radar      *radar.Radar
	Redirecter *redirecter.Redirecter

	// set during initialization
	ServiceMap    map[string]services.Service
	ModuleManager *modules.Manager
	// contains filtered or unexported fields
}

func New

func New(cfg Config) (*Atc, error)

func (*Atc) Run

func (t *Atc) Run() error

type Config

type Config struct {
	Name   string                 `yaml:"service"`
	Server server.Config          `yaml:"server"`
	Target flagext.StringSliceCSV `yaml:"target"`
}