Documentation ¶
Index ¶
- func NewCollector(logger lager.Logger, refreshInterval time.Duration, ...) *metricCollector
- func NewEnvelopeProcessor(logger lager.Logger, collectInterval time.Duration, clock clock.Clock, ...) *envelopeProcessor
- func NewServer(logger lager.Logger, serverConfig *ServerConfig, query MetricQueryFunc, ...) (ifrit.Runner, error)
- func NewWSMessageHandler(logger lager.Logger, envelopeChannels []chan *loggregator_v2.Envelope, ...) *wsMessageHandler
- func NewWSServer(logger lager.Logger, tls models.TLSCerts, port int, keepAlive time.Duration, ...) (ifrit.Runner, error)
- type EnvelopeProcessor
- type KeepAlive
- type MetricCollector
- type MetricHandler
- type MetricQueryFunc
- type ServerConfig
- type VarsFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCollector ¶
func NewCollector(logger lager.Logger, refreshInterval time.Duration, collectInterval time.Duration, PersistMetrics bool, saveInterval time.Duration, nodeIndex, nodeNum int, metricCacheSizePerApp int, policyDb db.PolicyDB, instancemetricsDb db.InstanceMetricsDB, cclock clock.Clock, metricsChan <-chan *models.AppInstanceMetric) *metricCollector
func NewEnvelopeProcessor ¶
func NewServer ¶
func NewServer(logger lager.Logger, serverConfig *ServerConfig, query MetricQueryFunc, httpStatusCollector healthendpoint.HTTPStatusCollector) (ifrit.Runner, error)
func NewWSMessageHandler ¶
func NewWSServer ¶
func NewWSServer(logger lager.Logger, tls models.TLSCerts, port int, keepAlive time.Duration, envelopeChannels []chan *loggregator_v2.Envelope, httpStatusCollector healthendpoint.HTTPStatusCollector) (ifrit.Runner, error)
Types ¶
type EnvelopeProcessor ¶
type EnvelopeProcessor interface { Start() Stop() }
type KeepAlive ¶
type KeepAlive struct {
// contains filtered or unexported fields
}
func NewKeepAlive ¶
type MetricCollector ¶
type MetricHandler ¶
type MetricHandler struct {
// contains filtered or unexported fields
}
func NewMetricHandler ¶
func NewMetricHandler(logger lager.Logger, nodeIndex int, nodeAdds []string, query MetricQueryFunc) *MetricHandler
func (*MetricHandler) GetMetricHistories ¶
func (h *MetricHandler) GetMetricHistories(w http.ResponseWriter, r *http.Request, vars map[string]string)
type MetricQueryFunc ¶
type ServerConfig ¶
type ServerConfig struct { Port int `yaml:"port"` TLS models.TLSCerts `yaml:"tls"` NodeAddrs []string `yaml:"node_addrs"` NodeIndex int `yaml:"node_index"` }
ServerConfig a type to wrap both the config.ServerConfig and config.Config data.
func FromConfig ¶
func FromConfig(config *config.Config) ServerConfig
Click to show internal directories.
Click to hide internal directories.