sinks

package
v1.9.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 12, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package sinks ... Copyright 2019 New Relic Corporation. All rights reserved. SPDX-License-Identifier: Apache-2.0

Package sinks ... Copyright 2019 New Relic Corporation. All rights reserved. SPDX-License-Identifier: Apache-2.0

Package sinks ... Copyright 2019 New Relic Corporation. All rights reserved. SPDX-License-Identifier: Apache-2.0

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Create added in v1.9.2 

func Create(configs []SinkConfig, integrationVersion string) (map[string]Sink, error)

Create takes a slice of SinkConfigs and attempts to initialize the sink handlers.

Types

type Sink added in v1.9.2 

type Sink interface {
	HandleEvent(kubeEvent common.KubeEvent) error
}

Sink receives events from the router, process and publish them to a certain destination (stdout, NewRelic platform, etc.).

type SinkConfig 

type SinkConfig struct {
	Name   string
	Config map[string]string
}

SinkConfig defines the name and config map of an `Sink`

func (SinkConfig) GetDurationOr 

func (s SinkConfig) GetDurationOr(name string, fallback time.Duration) time.Duration

GetDurationOr returns the duration variable by the given name. It will return the fallback in case the duration is not found. Invalid durations in configuration are not accepted.

func (SinkConfig) MustGetString 

func (s SinkConfig) MustGetString(name string) string

MustGetString returns the string variable by the given name. If it's not present, an error will given and the application will stop.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.