route

package
v0.8.5 Latest Latest
Warning

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

Go to latest
Published: Feb 16, 2017 License: BSD-2-Clause-Views Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SetLogger

func SetLogger(l *logging.Logger)

Types

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)

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 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 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 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, broker, topic, codec, schemasFile, partitionBy string, bufSize, orgId, flushMaxNum, flushMaxWait, timeout int) (Route, error)

NewKafkaMdm creates a special route that writes to a grafana.net datastore 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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL