Documentation
¶
Index ¶
- Constants
- type MetricsInitializer
- type Nozzle
- type NozzleOption
- func WithNozzleDialOpts(opts ...grpc.DialOption) NozzleOption
- func WithNozzleLogger(l *log.Logger) NozzleOption
- func WithNozzleMetrics(m MetricsInitializer) NozzleOption
- func WithNozzleTimerRollup(interval time.Duration, metricName string, tags []string) NozzleOption
- func WithNozzleTimerRollupBufferSize(size uint) NozzleOption
- type StreamConnector
Constants ¶
View Source
const ( BATCH_FLUSH_INTERVAL = 500 * time.Millisecond BATCH_CHANNEL_SIZE = 512 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetricsInitializer ¶
type MetricsInitializer interface {
NewCounter(name string) func(delta uint64)
NewGauge(name, unit string) func(value float64)
NewSummary(name, unit string) func(value float64)
}
Metrics registers Counter and Gauge metrics.
type Nozzle ¶
type Nozzle struct {
// contains filtered or unexported fields
}
Nozzle reads envelopes and writes points to metric-store.
func NewNozzle ¶
func NewNozzle(c StreamConnector, metricStoreAddr string, shardId string, nodeIndex int, opts ...NozzleOption) *Nozzle
type NozzleOption ¶
type NozzleOption func(*Nozzle)
func WithNozzleDialOpts ¶
func WithNozzleDialOpts(opts ...grpc.DialOption) NozzleOption
WithNozzleDialOpts returns a NozzleOption that configures the dial options for dialing the metric-store. It defaults to grpc.WithInsecure().
func WithNozzleLogger ¶
func WithNozzleLogger(l *log.Logger) NozzleOption
WithNozzleLogger returns a NozzleOption that configures a nozzle's logger. It defaults to silent logging.
func WithNozzleMetrics ¶
func WithNozzleMetrics(m MetricsInitializer) NozzleOption
WithNozzleMetrics returns a NozzleOption that configures the metrics for the Nozzle. It will add metrics to the given map.
func WithNozzleTimerRollup ¶
func WithNozzleTimerRollup(interval time.Duration, metricName string, tags []string) NozzleOption
func WithNozzleTimerRollupBufferSize ¶
func WithNozzleTimerRollupBufferSize(size uint) NozzleOption
type StreamConnector ¶
type StreamConnector interface {
// Stream creates a EnvelopeStream for the given request.
Stream(ctx context.Context, req *loggregator_v2.EgressBatchRequest) loggregator.EnvelopeStream
}
StreamConnector reads envelopes from the the logs provider.
Source Files
Click to show internal directories.
Click to hide internal directories.