app

package
v1.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 26, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source
const (
	AppId           = "app_id"
	ApplicationGuid = "applicationGuid"
)

All application metrics should have AppId or ApplicationGuid tags

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

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

	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"`
	EnableEnvelopeSelector bool     `env:"ENABLE_ENVELOPE_SELECTOR, required, report"`
	EnvelopSelectorTags    []string `env:"ENVELOP_SELECTOR_TAGS, 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 added in v1.3.0

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 added in v1.4.3

func (app *NozzleApp) MetricsAddr() string

func (*NozzleApp) ProfilingAddr added in v1.4.3

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL