filters

Documentation

Index

• func IsNonZero(val interface{}) (bool, interface{})
• func New(ctx activity.InitContext) (activity.Activity, error)
• type Activity
  • func (a *Activity) Eval(ctx activity.Context) (done bool, err error)
  • func (a *Activity) Metadata() *activity.Metadata
• type Filter
• type Input
• type NonZeroFilter
  • func (*NonZeroFilter) FilterOut(val interface{}) (bool, interface{})
• type Output
• type Settings

Functions

func IsNonZero

func IsNonZero(val interface{}) (bool, interface{})

func New

func New(ctx activity.InitContext) (activity.Activity, error)

Associates the filter name to the filter

Types

type Activity

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

Activity ... Activity is an activity that is used to filter a message to the console

func (*Activity) Eval

func (a *Activity) Eval(ctx activity.Context) (done bool, err error)

Eval implements api.Activity.Eval - Filters the Message

func (*Activity) Metadata

func (a *Activity) Metadata() *activity.Metadata

Metadata returns activity's metadata

type Filter

type Filter interface {
	FilterOut(val interface{}) (bool, interface{})
}

type Input

type Input struct {
	Value interface{} `md:"value"`
}

type NonZeroFilter

type NonZeroFilter struct{}

func (*NonZeroFilter) FilterOut

func (*NonZeroFilter) FilterOut(val interface{}) (bool, interface{})

type Output

type Output struct {
	Filtered bool        `md:"filtered"`
	Value    interface{} `md:"value"`
}

type Settings

type Settings struct {
	Type              string `md:"type,allowed(non-zero)"`
	ProceedOnlyOnEmit bool
}