app

Documentation

Index

• Constants
• 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()
• type OtelProviderTLS

Constants

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

All application metrics should have AppId or ApplicationGuid tags

Types

type Config

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

	OtelAddr        string `env:"OTEL_ADDR, required, report"`
	OtelProviderTLS OtelProviderTLS

	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"`
	FilterMetrics         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"`
	FirehoseEnabled       bool     `env:"FIREHOSE_ENABLED, required, 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.

type OtelProviderTLS

type OtelProviderTLS struct {
	CAPath   string `env:"OTEL_PROVIDER_CA_PATH, required, report"`
	CertPath string `env:"OTEL_PROVIDER_CERT_PATH, required, report"`
	KeyPath  string `env:"OTEL_PROVIDER_KEY_PATH, required, report"`
}