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, 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
  • 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, 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"`
}