reporter

Documentation

Index

• Variables
• type HTTPReportedMetric
• type HTTPReporter
  • func (r *HTTPReporter) Report(ch chan aura.Metric)
• type StreamReporter
  • func (r *StreamReporter) Report(ch chan aura.Metric)

Variables

var DefaultHTTPReporter = &HTTPReporter{
	client:         defaultHTTPClient,
	Urls:           []string{},
	Batch:          200,
	Ticker:         time.Tick(3 * time.Second),
	Timeout:        5 * time.Second,
	RetryCount:     3,
	MaxConcurrency: 3,
	DropEndpoint:   false,
}

var DefaultStreamReporter = &StreamReporter{
	Writer:         os.Stdout,
	Batch:          200,
	Ticker:         time.Tick(5 * time.Second),
	MaxConcurrency: 3,
}

Types

type HTTPReportedMetric

type HTTPReportedMetric struct {
	Endpoint  string      `json:"endpoint"`
	Metric    string      `json:"metric"`
	Step      uint32      `json:"step"`
	Value     interface{} `json:"value"`
	Type      string      `json:"counterType"`
	Tags      string      `json:"tags"`
	Timestamp int64       `json:"timestamp"`
}

type HTTPReporter

type HTTPReporter struct {
	Urls           []string
	Batch          int
	Ticker         <-chan time.Time
	Timeout        time.Duration
	RetryCount     int
	MaxConcurrency int
	DropEndpoint   bool
	// contains filtered or unexported fields
}

func (*HTTPReporter) Report

func (r *HTTPReporter) Report(ch chan aura.Metric)

type StreamReporter

type StreamReporter struct {
	Writer         io.Writer
	Batch          int
	Ticker         <-chan time.Time
	MaxConcurrency int
}

func (*StreamReporter) Report

func (r *StreamReporter) Report(ch chan aura.Metric)