metrics

package
v0.0.0-...-98208a5 Latest Latest
Warning

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

Go to latest
Published: Jul 24, 2020 License: Apache-2.0 Imports: 11 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AggregationSpec

type AggregationSpec struct {
	Channels []Channel   `json:"channels" yaml:"channels"`
	Events   []EventSpec `json:"events" yaml:"events"`
}

type Aggregator

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

func NewAggregator

func NewAggregator(opts AggregatorOptions, incoming <-chan *tracer.EventData, spec AggregationSpec, tracerCtx tracer.Context) (*Aggregator, error)

func (*Aggregator) Stop

func (a *Aggregator) Stop()

type AggregatorOptions

type AggregatorOptions struct {
	DialInsecure bool
}

type Channel

type Channel struct {
	Id   string `json:"id" yaml:"id"`
	Type string `json:"type" yaml:"type"`
	Path string `json:"path" yaml:"path"`
}

type ChannelKind

type ChannelKind int
const (
	File ChannelKind = iota
	Grpc
)

type EventSpec

type EventSpec struct {
	Name      string   `json:"name" yaml:"name"`
	ChannelId string   `json:"channel" yaml:"channel"`
	Stream    string   `json:"stream" yaml:"stream"`
	Group     string   `json:"group" yaml:"group"`
	Rule      string   `json:"rule" yaml:"rule"`
	F         Function `json:"function" yaml:"function"`
	O         Output   `json:"output" yaml:"output"`
}

type Function

type Function struct {
	Id         string `json:"id" yaml:"id"`
	Parameters string `json:"parameters" yaml:"parameters"`
	// contains filtered or unexported fields
}

type GrpcHandler

type GrpcHandler struct {
	Conn   *grpc.ClientConn
	Client tracer.MetricCollectorClient
}

type Output

type Output struct {
	Metrics string `json:"metrics" yaml:"metrics"`
	Format  string `json:"format" yaml:"format"`
	// contains filtered or unexported fields
}

type SendEvent

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

func (SendEvent) String

func (e SendEvent) String(tracerCtx tracer.Context) string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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