route

Sep 18, 2019

Changes in this version

+ type MetricsResponse struct

+ Invalid int

+ Published int

+ ValidationErrors map[string]ValidationError

+ type ValidationError struct

+ Count int

+ ExampleIds []int

Nov 9, 2018

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 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

+ func NewCloudWatch(key, prefix, sub, regex, awsProfile, awsRegion, awsNamespace string, ...) (Route, error)

+ func NewPubSub(key, prefix, sub, regex, project, topic, format, codec string, ...) (Route, error)

Dec 15, 2017

Changes in this version

type Snapshot

+ Addr string

Feb 16, 2017

Changes in this version

+ func SetLogger(l *logging.Logger)

+ 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 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 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, broker, topic, codec, schemasFile, partitionBy 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

+ Dests []*dest.Destination

+ Key string

+ Matcher matcher.Matcher

+ Type string