route

Documentation

Index

• func SetLogger(l *logging.Logger)
• type Config
• type ConsistentHasher
  • 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
  • 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
  • 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
  • func (route *KafkaMdm) Add(dest *dest.Destination)
  • func (route *KafkaMdm) DelDestination(index int) error
  • func (r *KafkaMdm) Dispatch(buf []byte)
  • func (r *KafkaMdm) Flush() error
  • func (route *KafkaMdm) GetDestination(index int) (*dest.Destination, error)
  • func (route *KafkaMdm) Key() string
  • func (route *KafkaMdm) Match(s []byte) bool
  • func (r *KafkaMdm) Shutdown() error
  • func (r *KafkaMdm) Snapshot() Snapshot
  • 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
  • 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 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
  • 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
  • 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

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, topic, codec, schemasFile, partitionBy string, brokers []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"`
}