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 (n *NozzleApp) DebugAddr() string
  • func (n *NozzleApp) Run()
  • func (n *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"`
	HealthPort            int    `env:"HEALTH_PORT, report"`
	ShardId               string `env:"SHARD_ID, required, report"`
	TimerRollupBufferSize uint   `env:"TIMER_ROLLUP_BUFFER_SIZE, report"`
	NodeIndex             int    `env:"NODE_INDEX, report"`

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

Config is the configuration for a MetricStore.

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"`
}

LogsProviderTLS is the LogsProviderTLS configuration for a MetricStore.

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) DebugAddr

func (n *NozzleApp) DebugAddr() string

DebugAddr returns the address (host and port) that the debug server is bound to. If the debug server has not been started an empty string will be returned.

func (*NozzleApp) Run

func (n *NozzleApp) Run()

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

func (*NozzleApp) Stop

func (n *NozzleApp) Stop()

Stop stops all the subprocesses for the application.