Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Builder ¶
type Builder[T any] interface { Action(func(EgressVisitor[T], *Action) error) Builder[T] Amqp(func(EgressVisitor[T], *amqp.Amqp) error) Builder[T] Metric(f func(EgressVisitor[T], *Metric) error) Builder[T] Publish(f func(EgressVisitor[T], *Publish) error) Builder[T] Script(func(EgressVisitor[T], *Script) error) Builder[T] Build() EgressVisitor[T] }
func NewBuilder ¶
type EgressVisitor ¶
type Marshaller ¶
type Metric ¶
type Metric struct { Pos lexer.Position Metrics []string `parser:"'metric' (@String | 'in' '(' @String (',' @String)* ')' )"` Statement *script.Statements `parser:"(@@)?"` Publish []*Publish `parser:"'publish' (@@)+"` }
Metric on receipt
type MetricFilter ¶
type Publish ¶
type Publish struct { Pos lexer.Position Amqp string `parser:"( 'amqp' @String"` Console bool `parser:"| @'console' )"` As *PublishType `parser:"(@@)?"` }
type PublishType ¶
type PublishType struct { Pos lexer.Position Bytes bool `parser:"'as' ( @'bytes'"` Json bool `parser:"| @'json'"` String bool `parser:"| @('string' | 'text')"` Xml bool `parser:"| @'xml'"` Yaml bool `parser:"| @'yaml' )"` }
func (*PublishType) Marshaller ¶
func (p *PublishType) Marshaller() Marshaller
type Script ¶
type State ¶
type State struct {
// contains filtered or unexported fields
}
func (*State) GetAmqpNames ¶
func (*State) GetMetrics ¶
Click to show internal directories.
Click to hide internal directories.