app

Documentation

Index

• type Config
  • func LoadConfig() *Config
• type LogsProviderTLS
• type MetricStoreClientTLS
• type MetricStoreMetricsTLS
• type NozzleApp
  • func NewNozzleApp(cfg *Config, log *logger.Logger) *NozzleApp
  • func (app *NozzleApp) MetricsAddr() string
  • func (app *NozzleApp) ProfilingAddr() string
  • func (app *NozzleApp) Run()
  • func (app *NozzleApp) Stop()

Types

type Config

type Config struct {
	LogProviderAddr string `env:"LOGS_PROVIDER_ADDR, required, report"`
	LogsProviderTLS LogsProviderTLS

	MetricStoreAddr       string `env:"METRIC_STORE_ADDR, required, report"`
	MetricStoreTLS        MetricStoreClientTLS
	MetricStoreMetricsTLS MetricStoreMetricsTLS

	IngressAddr           string `env:"INGRESS_ADDR, required, report"`
	MetricsAddr           string `env:"METRICS_ADDR, report"`
	ShardId               string `env:"SHARD_ID, required, report"`
	TimerRollupBufferSize uint   `env:"TIMER_ROLLUP_BUFFER_SIZE, report"`
	NodeIndex             int    `env:"NODE_INDEX, required, report"`

	LogLevel      string `env:"LOG_LEVEL, report"`
	ProfilingAddr string `env:"PROFILING_ADDR, report"`
}

func LoadConfig

func LoadConfig() *Config

LoadConfig creates Config object from environment variables

type LogsProviderTLS

type LogsProviderTLS struct {
	LogProviderCA   string `env:"LOGS_PROVIDER_CA_PATH, required, report"`
	LogProviderCert string `env:"LOGS_PROVIDER_CERT_PATH, required, report"`
	LogProviderKey  string `env:"LOGS_PROVIDER_KEY_PATH, required, report"`
}

type MetricStoreClientTLS

type MetricStoreClientTLS struct {
	CAPath   string `env:"METRIC_STORE_CLIENT_CA_PATH, required, report"`
	CertPath string `env:"METRIC_STORE_CLIENT_CERT_PATH, required, report"`
	KeyPath  string `env:"METRIC_STORE_CLIENT_KEY_PATH, required, report"`
}

type MetricStoreMetricsTLS

type MetricStoreMetricsTLS struct {
	CAPath   string `env:"METRIC_STORE_METRICS_CA_PATH, required, report"`
	CertPath string `env:"METRIC_STORE_METRICS_CERT_PATH, required, report"`
	KeyPath  string `env:"METRIC_STORE_METRICS_KEY_PATH, required, report"`
}

type NozzleApp

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

func NewNozzleApp

func NewNozzleApp(cfg *Config, log *logger.Logger) *NozzleApp

func (*NozzleApp) MetricsAddr

func (app *NozzleApp) MetricsAddr() string

func (*NozzleApp) ProfilingAddr

func (app *NozzleApp) ProfilingAddr() string

func (*NozzleApp) Run

func (app *NozzleApp) Run()

Run starts the Nozzle, this is a blocking method call.

func (*NozzleApp) Stop

func (app *NozzleApp) Stop()

Stop stops all the subprocesses for the application.