routes

Documentation

Index

• type PreProcessor
• type Route
  • func (r *Route) DisplayTopics(sep ...string) string
  • func (r *Route) ExecutePreprocessor(in string) (string, error)
  • func (r *Route) HasPreprocessor() bool
  • func (r *Route) Match(topic string) bool
  • func (r *Route) PreparePreProcessor() error
• type Specification
  • func Parse(r io.Reader) (*Specification, error)
• type Template
• type VariableFields

Types

type PreProcessor

type PreProcessor struct {
	Type      string   `yaml:"type"`
	Delimiter string   `yaml:"delimiter"`
	TrimSpace bool     `yaml:"trimspace"`
	Fields    []string `yaml:"fields"`
	// contains filtered or unexported fields
}

type Route

type Route struct {
	Name         string        `yaml:"name"`
	Disable      bool          `yaml:"disable"`
	Topics       []string      `yaml:"topics"`
	Skip         bool          `yaml:"skip"`
	Template     Template      `yaml:"template"`
	PreProcessor *PreProcessor `yaml:"preprocessor,omitempty"`
}

func (*Route) DisplayTopics

func (r *Route) DisplayTopics(sep ...string) string

func (*Route) ExecutePreprocessor

func (r *Route) ExecutePreprocessor(in string) (string, error)

func (*Route) HasPreprocessor

func (r *Route) HasPreprocessor() bool

func (*Route) Match

func (r *Route) Match(topic string) bool

match takes the topic string of the published message and does a basic compare to the string of the current Route, if they match it returns true

func (*Route) PreparePreProcessor

func (r *Route) PreparePreProcessor() error

type Specification

type Specification struct {
	Disable bool    `yaml:"disable"`
	Routes  []Route `yaml:"routes"`
}

func Parse

func Parse(r io.Reader) (*Specification, error)

type Template

type Template struct {
	Type  string `yaml:"type"`
	Value string `yaml:"value"`
	Path  string `yaml:"path"`
}

type VariableFields

type VariableFields struct {
	Fields []string `yaml:"fields"`
}