app

type Config struct {
	UseRFC3339           bool          `env:"USE_RFC3339, report"`
	APIURL               string        `env:"API_URL,              required, report"`
	APICAFile            string        `env:"API_CA_FILE_PATH,     required, report"`
	APICertFile          string        `env:"API_CERT_FILE_PATH,   required, report"`
	APIKeyFile           string        `env:"API_KEY_FILE_PATH,    required, report"`
	APICommonName        string        `env:"API_COMMON_NAME,      required, report"`
	APIPollingInterval   time.Duration `env:"API_POLLING_INTERVAL, report"`
	APIBatchSize         int           `env:"API_BATCH_SIZE, report"`
	APIDisableKeepAlives bool          `env:"API_DISABLE_KEEP_ALIVES, report"`
	CipherSuites         []string      `env:"CIPHER_SUITES, report"`
	AggregateDrainsFile  string        `env:"AGGREGATE_DRAINS_FILE, report"`

	CacheCAFile     string `env:"CACHE_CA_FILE_PATH,     required, report"`
	CacheCertFile   string `env:"CACHE_CERT_FILE_PATH,   required, report"`
	CacheKeyFile    string `env:"CACHE_KEY_FILE_PATH,    required, report"`
	CacheCommonName string `env:"CACHE_COMMON_NAME,      required, report"`

	CachePort int `env:"CACHE_PORT, required, report"`

	MetricsServer config.MetricsServer

	GRPC      GRPC
	Blacklist blacklist.BlacklistRanges `env:"BLACKLISTED_SYSLOG_RANGES, report"`

	WarnOnInvalidDrains bool `env:"WARN_ON_INVALID_DRAINS,    report"`
}

type GRPC struct {
	Host         string   `env:"LOGGREGATOR_AGENT_HOST,                     report"`
	Port         int      `env:"LOGGREGATOR_AGENT_PORT,                     report"`
	CAFile       string   `env:"LOGGREGATOR_AGENT_CA_FILE_PATH,   required, report"`
	CertFile     string   `env:"LOGGREGATOR_AGENT_CERT_FILE_PATH, required, report"`
	KeyFile      string   `env:"LOGGREGATOR_AGENT_KEY_FILE_PATH,  required, report"`
	CipherSuites []string `env:"LOGGREGATOR_AGENT_CIPHER_SUITES,            report"`
}

type IPChecker interface {
	ResolveAddr(host string) (net.IP, error)
	CheckBlacklist(ip net.IP) error
}

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

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