Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Filter ¶
type Filter interface {
Filter(m *types.Message) *errors.DispatchError
Name() string
}
func NewLastFilter ¶
func NewLastFilter(pools map[string]*goroutinepool.GoroutinePool, subscribers map[string]subscriber.Subscriber) Filter
func NewRegisterFilter ¶
func NewUnifyLabelsFilter ¶
func NewUnifyLabelsFilter() Filter
func NewWebhookFilter ¶
type LastFilter ¶
type LastFilter struct {
// contains filtered or unexported fields
}
Filter的最后一个，实际上用来做后续对 message 的操作
func (*LastFilter) Filter ¶
func (l *LastFilter) Filter(m *types.Message) *errors.DispatchError
func (*LastFilter) Name ¶
func (l *LastFilter) Name() string
type RegisterFilter ¶
type RegisterFilter struct {
// contains filtered or unexported fields
}
func (*RegisterFilter) Filter ¶
func (r *RegisterFilter) Filter(m *types.Message) *errors.DispatchError
func (*RegisterFilter) Name ¶
func (*RegisterFilter) Name() string
type UnifyLabelsFilter ¶
type UnifyLabelsFilter struct{}
func (*UnifyLabelsFilter) Filter ¶
func (*UnifyLabelsFilter) Filter(m *types.Message) *errors.DispatchError
func (*UnifyLabelsFilter) Name ¶
func (*UnifyLabelsFilter) Name() string
type WebhookFilter ¶
type WebhookFilter struct {
// contains filtered or unexported fields
}
func (*WebhookFilter) Filter ¶
func (w *WebhookFilter) Filter(m *types.Message) *errors.DispatchError
func (*WebhookFilter) Name ¶
func (*WebhookFilter) Name() string
Source Files
Click to show internal directories.
Click to hide internal directories.