Versions in this module Expand all Collapse all v0 v0.12.0 Sep 18, 2019 Changes in this version + type CloudWatch struct + func (r *CloudWatch) Dispatch(buf []byte) + func (r *CloudWatch) Flush() error + func (r *CloudWatch) Shutdown() error + func (r *CloudWatch) Snapshot() Snapshot + func (route *CloudWatch) Add(dest *dest.Destination) + func (route *CloudWatch) DelDestination(index int) error + func (route *CloudWatch) GetDestination(index int) (*dest.Destination, error) + func (route *CloudWatch) Key() string + func (route *CloudWatch) Match(s []byte) bool + func (route *CloudWatch) Update(opts map[string]string) error + func (route *CloudWatch) UpdateDestination(index int, opts map[string]string) error + func (route *CloudWatch) UpdateMatcher(matcher matcher.Matcher) + type Config interface + Dests func() []*dest.Destination + Matcher func() *matcher.Matcher + type ConsistentHasher struct + Ring hashRing + func NewConsistentHasher(destinations []*dest.Destination) ConsistentHasher + func NewConsistentHasherReplicaCount(destinations []*dest.Destination, replicaCount int) ConsistentHasher + func (h *ConsistentHasher) AddDestination(d *dest.Destination) + func (h *ConsistentHasher) GetDestinationIndex(key []byte) int + type ConsistentHashing struct + func (route *ConsistentHashing) Add(dest *dest.Destination) + func (route *ConsistentHashing) DelDestination(index int) error + func (route *ConsistentHashing) Dispatch(buf []byte) + func (route *ConsistentHashing) Flush() error + func (route *ConsistentHashing) GetDestination(index int) (*dest.Destination, error) + func (route *ConsistentHashing) Key() string + func (route *ConsistentHashing) Match(s []byte) bool + func (route *ConsistentHashing) Shutdown() error + func (route *ConsistentHashing) Snapshot() Snapshot + func (route *ConsistentHashing) Update(opts map[string]string) error + func (route *ConsistentHashing) UpdateDestination(index int, opts map[string]string) error + func (route *ConsistentHashing) UpdateMatcher(matcher matcher.Matcher) + type GrafanaNet struct + func (route *GrafanaNet) Add(dest *dest.Destination) + func (route *GrafanaNet) DelDestination(index int) error + func (route *GrafanaNet) Dispatch(buf []byte) + func (route *GrafanaNet) Flush() error + func (route *GrafanaNet) GetDestination(index int) (*dest.Destination, error) + func (route *GrafanaNet) Key() string + func (route *GrafanaNet) Match(s []byte) bool + func (route *GrafanaNet) Shutdown() error + func (route *GrafanaNet) Snapshot() Snapshot + func (route *GrafanaNet) Update(opts map[string]string) error + func (route *GrafanaNet) UpdateDestination(index int, opts map[string]string) error + func (route *GrafanaNet) UpdateMatcher(matcher matcher.Matcher) + type KafkaMdm struct + func (r *KafkaMdm) Dispatch(buf []byte) + func (r *KafkaMdm) Flush() error + func (r *KafkaMdm) Shutdown() error + func (r *KafkaMdm) Snapshot() Snapshot + func (route *KafkaMdm) Add(dest *dest.Destination) + func (route *KafkaMdm) DelDestination(index int) error + func (route *KafkaMdm) GetDestination(index int) (*dest.Destination, error) + func (route *KafkaMdm) Key() string + func (route *KafkaMdm) Match(s []byte) bool + func (route *KafkaMdm) Update(opts map[string]string) error + func (route *KafkaMdm) UpdateDestination(index int, opts map[string]string) error + func (route *KafkaMdm) UpdateMatcher(matcher matcher.Matcher) + type MetricsResponse struct + Invalid int + Published int + ValidationErrors map[string]ValidationError + type PubSub struct + func (r *PubSub) Dispatch(buf []byte) + func (r *PubSub) Flush() error + func (r *PubSub) Shutdown() error + func (r *PubSub) Snapshot() Snapshot + func (route *PubSub) Add(dest *dest.Destination) + func (route *PubSub) DelDestination(index int) error + func (route *PubSub) GetDestination(index int) (*dest.Destination, error) + func (route *PubSub) Key() string + func (route *PubSub) Match(s []byte) bool + func (route *PubSub) Update(opts map[string]string) error + func (route *PubSub) UpdateDestination(index int, opts map[string]string) error + func (route *PubSub) UpdateMatcher(matcher matcher.Matcher) + type Route interface + DelDestination func(index int) error + Dispatch func(buf []byte) + Flush func() error + GetDestination func(index int) (*dest.Destination, error) + Key func() string + Match func(s []byte) bool + Shutdown func() error + Snapshot func() Snapshot + Update func(opts map[string]string) error + UpdateDestination func(index int, opts map[string]string) error + func NewCloudWatch(key, prefix, sub, regex, awsProfile, awsRegion, awsNamespace string, ...) (Route, error) + func NewConsistentHashing(key, prefix, sub, regex string, destinations []*dest.Destination) (Route, error) + func NewGrafanaNet(key, prefix, sub, regex, addr, apiKey, schemasFile string, ...) (Route, error) + func NewKafkaMdm(key, prefix, sub, regex, topic, codec, schemasFile, partitionBy string, ...) (Route, error) + func NewPubSub(key, prefix, sub, regex, project, topic, format, codec string, ...) (Route, error) + func NewSendAllMatch(key, prefix, sub, regex string, destinations []*dest.Destination) (Route, error) + func NewSendFirstMatch(key, prefix, sub, regex string, destinations []*dest.Destination) (Route, error) + type SendAllMatch struct + func (route *SendAllMatch) Add(dest *dest.Destination) + func (route *SendAllMatch) DelDestination(index int) error + func (route *SendAllMatch) Dispatch(buf []byte) + func (route *SendAllMatch) Flush() error + func (route *SendAllMatch) GetDestination(index int) (*dest.Destination, error) + func (route *SendAllMatch) Key() string + func (route *SendAllMatch) Match(s []byte) bool + func (route *SendAllMatch) Shutdown() error + func (route *SendAllMatch) Snapshot() Snapshot + func (route *SendAllMatch) Update(opts map[string]string) error + func (route *SendAllMatch) UpdateDestination(index int, opts map[string]string) error + func (route *SendAllMatch) UpdateMatcher(matcher matcher.Matcher) + type SendFirstMatch struct + func (route *SendFirstMatch) Add(dest *dest.Destination) + func (route *SendFirstMatch) DelDestination(index int) error + func (route *SendFirstMatch) Dispatch(buf []byte) + func (route *SendFirstMatch) Flush() error + func (route *SendFirstMatch) GetDestination(index int) (*dest.Destination, error) + func (route *SendFirstMatch) Key() string + func (route *SendFirstMatch) Match(s []byte) bool + func (route *SendFirstMatch) Shutdown() error + func (route *SendFirstMatch) Snapshot() Snapshot + func (route *SendFirstMatch) Update(opts map[string]string) error + func (route *SendFirstMatch) UpdateDestination(index int, opts map[string]string) error + func (route *SendFirstMatch) UpdateMatcher(matcher matcher.Matcher) + type Snapshot struct + Addr string + Dests []*dest.Destination + Key string + Matcher matcher.Matcher + Type string + type ValidationError struct + Count int + ExampleIds []int