tinymq/filter.go

package tinymq

import (
	"regexp"
	"strings"
)

// 匹配所有的频道
func AllChannelFilter() FilterFunc {
	return func(conn *Line) (ok bool) {
		return true
	}
}

// 正则频道过滤器
func RegChannelFilter(channel *regexp.Regexp) FilterFunc {
	return func(conn *Line) (ok bool) {
		return channel.MatchString(conn.channel)
	}
}

// 字符串频道过滤器
func StrChannelFilter(channel string) FilterFunc {
	return func(conn *Line) (ok bool) {
		return strings.Contains(conn.channel, channel)
	}
}

// 连接过滤器
func LineLinkFilter(line *Line) FilterFunc {
	return func(conn *Line) (ok bool) {
		return line == conn
	}
}