nozzle

package

v1.6.1 Latest Latest Go to latest Published: Feb 26, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cloudfoundry/metric-store-release

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Nozzle
- func NewNozzle(c StreamConnector, ingressAddr string, tlsConfig *tls.Config, shardId string, ...) *Nozzle
- func (n *Nozzle) Start()
type Option
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 Nozzle ¶

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

Nozzle reads envelopes and writes points to metric-store.

func NewNozzle ¶

func NewNozzle(c StreamConnector, ingressAddr string, tlsConfig *tls.Config, shardId string, nodeIndex int, enableEnvelopeSelector bool, envelopSelectorTags []string, opts ...Option) *Nozzle

func (*Nozzle) Start ¶

func (n *Nozzle) Start()

Start() starts reading envelopes from the logs provider and writes them to metric-store.

type Option ¶ added in v1.4.3

type Option func(*Nozzle)

func WithNozzleDebugRegistrar ¶

func WithNozzleDebugRegistrar(m metrics.Registrar) Option

func WithNozzleLogger ¶

func WithNozzleLogger(l *logger.Logger) Option

WithNozzleLogger returns a Option that configures a nozzle's logger. It defaults to silent logging.

func WithNozzleTimerRollup ¶

func WithNozzleTimerRollup(interval time.Duration, totalRollupTags, durationRollupTags []string) Option

func WithNozzleTimerRollupBufferSize ¶

func WithNozzleTimerRollupBufferSize(size uint) Option

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 ¶

View all Source files

nozzle.go

Directories ¶

Path	Synopsis
rollup

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL