subscriptions

Documentation

Index

• func RouteIncludesTopic(route, topic string) bool
• type Filter
  • func MakeFilter(topicFilter regexp.Regexp, topicAssembler template.Template, ...) Filter
  • func (filter *Filter) Apply(topic string, value []byte) (string, []byte, bool)

Functions

func RouteIncludesTopic

func RouteIncludesTopic(route, topic string) bool

Types

type Filter

type Filter struct {
	// contains filtered or unexported fields
}

func MakeFilter

func MakeFilter(
	topicFilter regexp.Regexp,
	topicAssembler template.Template,
	valMap map[string]template.Template,
	valFilter *regexp.Regexp,
	valAssembler *template.Template) Filter

func (*Filter) Apply

func (filter *Filter) Apply(topic string, value []byte) (string, []byte, bool)