route

package
v0.12.0 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2019 License: BSD-2-Clause-Views Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CloudWatch added in v0.11.0 

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

Publishes data points to the native AWS metrics service: CloudWatch

func (*CloudWatch) Add added in v0.11.0 

func (route *CloudWatch) Add(dest *dest.Destination)

func (*CloudWatch) DelDestination added in v0.11.0 

func (route *CloudWatch) DelDestination(index int) error

func (*CloudWatch) Dispatch added in v0.11.0 

func (r *CloudWatch) Dispatch(buf []byte)

Dispatch is called to submit metrics. They will be in graphite 'plain' format no matter how they arrived.

func (*CloudWatch) Flush added in v0.11.0 

func (r *CloudWatch) Flush() error

Flush is not currently implemented

func (*CloudWatch) GetDestination added in v0.11.0 

func (route *CloudWatch) GetDestination(index int) (*dest.Destination, error)

func (*CloudWatch) Key added in v0.11.0 

func (route *CloudWatch) Key() string

func (*CloudWatch) Match added in v0.11.0 

func (route *CloudWatch) Match(s []byte) bool

func (*CloudWatch) Shutdown added in v0.11.0 

func (r *CloudWatch) Shutdown() error

Shutdown stops the CloudWatch publisher and returns with the publisher has finished in-flight work

func (*CloudWatch) Snapshot added in v0.11.0 

func (r *CloudWatch) Snapshot() Snapshot

Snapshot clones the current config for update operations

func (*CloudWatch) Update added in v0.11.0 

func (route *CloudWatch) Update(opts map[string]string) error

func (*CloudWatch) UpdateDestination added in v0.11.0 

func (route *CloudWatch) UpdateDestination(index int, opts map[string]string) error

func (*CloudWatch) UpdateMatcher added in v0.11.0 

func (route *CloudWatch) UpdateMatcher(matcher matcher.Matcher)

type Config 

type Config interface {
	Matcher() *matcher.Matcher
	Dests() []*dest.Destination
}

type ConsistentHasher 

type ConsistentHasher struct {
	Ring hashRing
	// contains filtered or unexported fields
}

func NewConsistentHasher 

func NewConsistentHasher(destinations []*dest.Destination) ConsistentHasher

func NewConsistentHasherReplicaCount 

func NewConsistentHasherReplicaCount(destinations []*dest.Destination, replicaCount int) ConsistentHasher

func (*ConsistentHasher) AddDestination 

func (h *ConsistentHasher) AddDestination(d *dest.Destination)

func (*ConsistentHasher) GetDestinationIndex 

func (h *ConsistentHasher) GetDestinationIndex(key []byte) int

GetDestinationIndex returns the index of the destination corresponding to the provided key.

type ConsistentHashing 

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

func (*ConsistentHashing) Add 

func (route *ConsistentHashing) Add(dest *dest.Destination)

func (*ConsistentHashing) DelDestination 

func (route *ConsistentHashing) DelDestination(index int) error

func (*ConsistentHashing) Dispatch 

func (route *ConsistentHashing) Dispatch(buf []byte)

func (*ConsistentHashing) Flush 

func (route *ConsistentHashing) Flush() error

func (*ConsistentHashing) GetDestination 

func (route *ConsistentHashing) GetDestination(index int) (*dest.Destination, error)

func (*ConsistentHashing) Key 

func (route *ConsistentHashing) Key() string

func (*ConsistentHashing) Match 

func (route *ConsistentHashing) Match(s []byte) bool

func (*ConsistentHashing) Shutdown 

func (route *ConsistentHashing) Shutdown() error

func (*ConsistentHashing) Snapshot 

func (route *ConsistentHashing) Snapshot() Snapshot

func (*ConsistentHashing) Update 

func (route *ConsistentHashing) Update(opts map[string]string) error

func (*ConsistentHashing) UpdateDestination 

func (route *ConsistentHashing) UpdateDestination(index int, opts map[string]string) error

func (*ConsistentHashing) UpdateMatcher 

func (route *ConsistentHashing) UpdateMatcher(matcher matcher.Matcher)

type GrafanaNet 

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

func (*GrafanaNet) Add 

func (route *GrafanaNet) Add(dest *dest.Destination)

func (*GrafanaNet) DelDestination 

func (route *GrafanaNet) DelDestination(index int) error

func (*GrafanaNet) Dispatch 

func (route *GrafanaNet) Dispatch(buf []byte)

Dispatch takes in the requested buf or drops it if blocking mode and queue of the shard is full

func (*GrafanaNet) Flush 

func (route *GrafanaNet) Flush() error

func (*GrafanaNet) GetDestination 

func (route *GrafanaNet) GetDestination(index int) (*dest.Destination, error)

func (*GrafanaNet) Key 

func (route *GrafanaNet) Key() string

func (*GrafanaNet) Match 

func (route *GrafanaNet) Match(s []byte) bool

func (*GrafanaNet) Shutdown 

func (route *GrafanaNet) Shutdown() error

func (*GrafanaNet) Snapshot 

func (route *GrafanaNet) Snapshot() Snapshot

func (*GrafanaNet) Update 

func (route *GrafanaNet) Update(opts map[string]string) error

func (*GrafanaNet) UpdateDestination 

func (route *GrafanaNet) UpdateDestination(index int, opts map[string]string) error

func (*GrafanaNet) UpdateMatcher 

func (route *GrafanaNet) UpdateMatcher(matcher matcher.Matcher)

type KafkaMdm 

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

func (*KafkaMdm) Add 

func (route *KafkaMdm) Add(dest *dest.Destination)

func (*KafkaMdm) DelDestination 

func (route *KafkaMdm) DelDestination(index int) error

func (*KafkaMdm) Dispatch 

func (r *KafkaMdm) Dispatch(buf []byte)

func (*KafkaMdm) Flush 

func (r *KafkaMdm) Flush() error

func (*KafkaMdm) GetDestination 

func (route *KafkaMdm) GetDestination(index int) (*dest.Destination, error)

func (*KafkaMdm) Key 

func (route *KafkaMdm) Key() string

func (*KafkaMdm) Match 

func (route *KafkaMdm) Match(s []byte) bool

func (*KafkaMdm) Shutdown 

func (r *KafkaMdm) Shutdown() error

func (*KafkaMdm) Snapshot 

func (r *KafkaMdm) Snapshot() Snapshot

func (*KafkaMdm) Update 

func (route *KafkaMdm) Update(opts map[string]string) error

func (*KafkaMdm) UpdateDestination 

func (route *KafkaMdm) UpdateDestination(index int, opts map[string]string) error

func (*KafkaMdm) UpdateMatcher 

func (route *KafkaMdm) UpdateMatcher(matcher matcher.Matcher)

type MetricsResponse added in v0.12.0 

type MetricsResponse struct {
	Invalid          int
	Published        int
	ValidationErrors map[string]ValidationError
}

type PubSub added in v0.11.0 

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

PubSub publishes metrics to a Google PubSub topic

func (*PubSub) Add added in v0.11.0 

func (route *PubSub) Add(dest *dest.Destination)

func (*PubSub) DelDestination added in v0.11.0 

func (route *PubSub) DelDestination(index int) error

func (*PubSub) Dispatch added in v0.11.0 

func (r *PubSub) Dispatch(buf []byte)

Dispatch is called to submit metrics. They will be in graphite 'plain' format no matter how they arrived.

func (*PubSub) Flush added in v0.11.0 

func (r *PubSub) Flush() error

Flush is not currently implemented

func (*PubSub) GetDestination added in v0.11.0 

func (route *PubSub) GetDestination(index int) (*dest.Destination, error)

func (*PubSub) Key added in v0.11.0 

func (route *PubSub) Key() string

func (*PubSub) Match added in v0.11.0 

func (route *PubSub) Match(s []byte) bool

func (*PubSub) Shutdown added in v0.11.0 

func (r *PubSub) Shutdown() error

Shutdown stops the pubsub publisher and returns with the publisher has finished in-flight work

func (*PubSub) Snapshot added in v0.11.0 

func (r *PubSub) Snapshot() Snapshot

Snapshot clones the current config for update operations

func (*PubSub) Update added in v0.11.0 

func (route *PubSub) Update(opts map[string]string) error

func (*PubSub) UpdateDestination added in v0.11.0 

func (route *PubSub) UpdateDestination(index int, opts map[string]string) error

func (*PubSub) UpdateMatcher added in v0.11.0 

func (route *PubSub) UpdateMatcher(matcher matcher.Matcher)

type Route 

type Route interface {
	Dispatch(buf []byte)
	Match(s []byte) bool
	Snapshot() Snapshot
	Key() string
	Flush() error
	Shutdown() error
	GetDestination(index int) (*dest.Destination, error)
	DelDestination(index int) error
	UpdateDestination(index int, opts map[string]string) error
	Update(opts map[string]string) error
}

func NewCloudWatch added in v0.11.0 

func NewCloudWatch(key, prefix, sub, regex, awsProfile, awsRegion, awsNamespace string, awsDimensions [][]string, bufSize, flushMaxSize, flushMaxWait int, storageResolution int64, blocking bool) (Route, error)

NewCloudWatch creates a route that writes metrics to the AWS service CloudWatch We will automatically run the route and the destination

func NewConsistentHashing 

func NewConsistentHashing(key, prefix, sub, regex string, destinations []*dest.Destination) (Route, error)

func NewGrafanaNet 

func NewGrafanaNet(key, prefix, sub, regex, addr, apiKey, schemasFile string, spool, sslVerify, blocking bool, bufSize, flushMaxNum, flushMaxWait, timeout, concurrency, orgId int) (Route, error)

NewGrafanaNet creates a special route that writes to a grafana.net datastore We will automatically run the route and the destination ignores spool for now

func NewKafkaMdm 

func NewKafkaMdm(key, prefix, sub, regex, topic, codec, schemasFile, partitionBy string, brokers []string, bufSize, orgId, flushMaxNum, flushMaxWait, timeout int, blocking bool) (Route, error)

NewKafkaMdm creates a special route that writes to a grafana.net datastore We will automatically run the route and the destination

func NewPubSub added in v0.11.0 

func NewPubSub(key, prefix, sub, regex, project, topic, format, codec string, bufSize, flushMaxSize, flushMaxWait int, blocking bool) (Route, error)

NewPubSub creates a route that writes metrics to a Google PubSub topic We will automatically run the route and the destination

func NewSendAllMatch 

func NewSendAllMatch(key, prefix, sub, regex string, destinations []*dest.Destination) (Route, error)

NewSendAllMatch creates a sendAllMatch route. We will automatically run the route and the given destinations

func NewSendFirstMatch 

func NewSendFirstMatch(key, prefix, sub, regex string, destinations []*dest.Destination) (Route, error)

NewSendFirstMatch creates a sendFirstMatch route. We will automatically run the route and the given destinations

type SendAllMatch 

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

func (*SendAllMatch) Add 

func (route *SendAllMatch) Add(dest *dest.Destination)

func (*SendAllMatch) DelDestination 

func (route *SendAllMatch) DelDestination(index int) error

func (*SendAllMatch) Dispatch 

func (route *SendAllMatch) Dispatch(buf []byte)

func (*SendAllMatch) Flush 

func (route *SendAllMatch) Flush() error

func (*SendAllMatch) GetDestination 

func (route *SendAllMatch) GetDestination(index int) (*dest.Destination, error)

func (*SendAllMatch) Key 

func (route *SendAllMatch) Key() string

func (*SendAllMatch) Match 

func (route *SendAllMatch) Match(s []byte) bool

func (*SendAllMatch) Shutdown 

func (route *SendAllMatch) Shutdown() error

func (*SendAllMatch) Snapshot 

func (route *SendAllMatch) Snapshot() Snapshot

func (*SendAllMatch) Update 

func (route *SendAllMatch) Update(opts map[string]string) error

func (*SendAllMatch) UpdateDestination 

func (route *SendAllMatch) UpdateDestination(index int, opts map[string]string) error

func (*SendAllMatch) UpdateMatcher 

func (route *SendAllMatch) UpdateMatcher(matcher matcher.Matcher)

type SendFirstMatch 

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

func (*SendFirstMatch) Add 

func (route *SendFirstMatch) Add(dest *dest.Destination)

func (*SendFirstMatch) DelDestination 

func (route *SendFirstMatch) DelDestination(index int) error

func (*SendFirstMatch) Dispatch 

func (route *SendFirstMatch) Dispatch(buf []byte)

func (*SendFirstMatch) Flush 

func (route *SendFirstMatch) Flush() error

func (*SendFirstMatch) GetDestination 

func (route *SendFirstMatch) GetDestination(index int) (*dest.Destination, error)

func (*SendFirstMatch) Key 

func (route *SendFirstMatch) Key() string

func (*SendFirstMatch) Match 

func (route *SendFirstMatch) Match(s []byte) bool

func (*SendFirstMatch) Shutdown 

func (route *SendFirstMatch) Shutdown() error

func (*SendFirstMatch) Snapshot 

func (route *SendFirstMatch) Snapshot() Snapshot

func (*SendFirstMatch) Update 

func (route *SendFirstMatch) Update(opts map[string]string) error

func (*SendFirstMatch) UpdateDestination 

func (route *SendFirstMatch) UpdateDestination(index int, opts map[string]string) error

func (*SendFirstMatch) UpdateMatcher 

func (route *SendFirstMatch) UpdateMatcher(matcher matcher.Matcher)

type Snapshot 

type Snapshot struct {
	Matcher matcher.Matcher     `json:"matcher"`
	Dests   []*dest.Destination `json:"destination"`
	Type    string              `json:"type"`
	Key     string              `json:"key"`
	Addr    string              `json:"addr,omitempty"`
}

type ValidationError added in v0.12.0 

type ValidationError struct {
	Count      int
	ExampleIds []int
}

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.