app

type BindingManager interface {
	Run()
	GetDrains(string) []egress.Writer
}

type Cache struct {
	URL             string                   `env:"CACHE_URL,                 report"`
	CAFile          string                   `env:"CACHE_CA_FILE_PATH,        report"`
	CertFile        string                   `env:"CACHE_CERT_FILE_PATH,      report"`
	KeyFile         string                   `env:"CACHE_KEY_FILE_PATH,       report"`
	CommonName      string                   `env:"CACHE_COMMON_NAME,         report"`
	PollingInterval time.Duration            `env:"CACHE_POLLING_INTERVAL,    report"`
	Blacklist       bindings.BlacklistRanges `env:"BLACKLISTED_SYSLOG_RANGES, report"`
}

type Config struct {
	UseRFC3339           bool          `env:"USE_RFC3339"`
	BindingsPerAppLimit  int           `env:"BINDING_PER_APP_LIMIT,  report"`
	DrainSkipCertVerify  bool          `env:"DRAIN_SKIP_CERT_VERIFY, report"`
	DrainCipherSuites    string        `env:"DRAIN_CIPHER_SUITES,    report"`
	DrainTrustedCAFile   string        `env:"DRAIN_TRUSTED_CA_FILE,  report"`
	DefaultDrainMetadata bool          `env:"DEFAULT_DRAIN_METADATA, report"`
	IdleDrainTimeout     time.Duration `env:"IDLE_DRAIN_TIMEOUT, report"`
	WarnOnInvalidDrains  bool          `env:"WARN_ON_INVALID_DRAINS,    report"`

	GRPC          GRPC
	Cache         Cache
	MetricsServer config.MetricsServer

	AggregateConnectionRefreshInterval time.Duration `env:"AGGREGATE_CONNECTION_REFRESH_INTERVAL, report"`
	AggregateDrainURLs                 []string      `env:"AGGREGATE_DRAIN_URLS,                  report"`
}

type GRPC struct {
	Port         int      `env:"AGENT_PORT,                     report"`
	CAFile       string   `env:"AGENT_CA_FILE_PATH,   required, report"`
	CertFile     string   `env:"AGENT_CERT_FILE_PATH, required, report"`
	KeyFile      string   `env:"AGENT_KEY_FILE_PATH,  required, report"`
	CipherSuites []string `env:"AGENT_CIPHER_SUITES,            report"`
}

type Metrics interface {
	NewGauge(name, helpText string, options ...metrics.MetricOption) metrics.Gauge
	NewCounter(name, helpText string, options ...metrics.MetricOption) metrics.Counter
	RegisterDebugMetrics()
}

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