filter

Documentation

Index

• Constants
• func FirstIDFromMsgBatch(batch *p_buff.MessageGroupBatch) *p_buff.MessageID
• func FirstIDFromMsgGroup(group *p_buff.MessageGroup) *p_buff.MessageID
• func IDFromAnyMsg(msg *p_buff.AnyMessage) *p_buff.MessageID
• type Strategy

Constants

const (
	SessionAliasKey = "session_alias"
	MessageTypeKey  = "message_type"
	DirectionKey    = "direction"
	ProtocolKey     = "protocol"
)

Functions

func FirstIDFromMsgBatch

func FirstIDFromMsgBatch(batch *p_buff.MessageGroupBatch) *p_buff.MessageID

func FirstIDFromMsgGroup

func FirstIDFromMsgGroup(group *p_buff.MessageGroup) *p_buff.MessageID

func IDFromAnyMsg

func IDFromAnyMsg(msg *p_buff.AnyMessage) *p_buff.MessageID

Types

type Strategy

type Strategy interface {
	Verify(messages *p_buff.MessageGroupBatch, filters []mqFilter.FilterConfiguration) bool
}

var Default Strategy = defaultFilterStrategy{/* contains filtered or unexported fields */}