routers

package
v0.9.21 Latest Latest
Warning

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

 Go to latest Published: Feb 19, 2019 License: Apache-2.0 Imports: 3 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type KafkaRoute 

type KafkaRoute struct {
	RouteMatchers
	DMLTargetTopic string
}

func NewKafkaRoutes 

func NewKafkaRoutes(configData []map[string]interface{}) ([]*KafkaRoute, error)

type KafkaRouter added in v0.9.17 

type KafkaRouter []*KafkaRoute

func (KafkaRouter) Exists added in v0.9.17 

func (r KafkaRouter) Exists(msg *core.Msg) bool

type MySQLRoute 

type MySQLRoute struct {
	RouteMatchers
	TargetSchema string
	TargetTable  string
}

func NewMySQLRoutes 

func NewMySQLRoutes(configData []map[string]interface{}) ([]*MySQLRoute, error)

func (*MySQLRoute) GetTarget 

func (route *MySQLRoute) GetTarget(msgSchema string, msgTable string) (string, string)

type MySQLRouter added in v0.9.17 

type MySQLRouter []*MySQLRoute

func (MySQLRouter) Exists added in v0.9.17 

func (r MySQLRouter) Exists(msg *core.Msg) bool

type RouteMatchers 

type RouteMatchers struct {
	AllMatchers []core.IMatcher
}

func (RouteMatchers) Match 

func (r RouteMatchers) Match(msg *core.Msg) bool

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.