metrics

Documentation

Index

• type AggregationSpec
• type Aggregator
  • func NewAggregator(opts AggregatorOptions, incoming <-chan *tracer.EventData, ...) (*Aggregator, error)
  • func (a *Aggregator) Stop()
• type AggregatorOptions
• type Channel
• type ChannelKind
• type EventSpec
• type Function
• type GrpcHandler
• type Output
• type SendEvent
  • func (e SendEvent) String(tracerCtx tracer.Context) string

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