handlers

type Condition ¶

type Condition struct {
	dag.Operation
	// contains filtered or unexported fields
}

func NewCondition(id string) *Condition

func (e *Condition) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

func (e *Condition) SetConditions(conditions map[string]dag.Condition)

type DataHandler ¶

type DataHandler struct {
	dag.Operation
}

DataHandler handles miscellaneous data operations

func NewDataHandler(id string) *DataHandler

func (h *DataHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type FieldHandler ¶

type FieldHandler struct {
	dag.Operation
}

FieldHandler handles field manipulation operations (filter, add, remove, rename, etc.)

func NewFieldHandler(id string) *FieldHandler

func (h *FieldHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type FlattenHandler ¶

type FlattenHandler struct {
	dag.Operation
}

FlattenHandler handles flattening array of objects to single objects

func NewFlattenHandler(id string) *FlattenHandler

func (h *FlattenHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type FormatHandler ¶

type FormatHandler struct {
	dag.Operation
}

FormatHandler handles data formatting operations

func NewFormatHandler(id string) *FormatHandler

func (h *FormatHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type GroupHandler ¶

type GroupHandler struct {
	dag.Operation
}

GroupHandler handles data grouping operations with aggregation

func NewGroupHandler(id string) *GroupHandler

func (h *GroupHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type JSONHandler ¶

type JSONHandler struct {
	dag.Operation
}

JSONHandler handles JSON parsing and stringifying operations

func NewJSONHandler(id string) *JSONHandler

func (h *JSONHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type JoinHandler ¶

type JoinHandler struct {
	dag.Operation
}

JoinHandler handles string join operations

func NewJoinHandler(id string) *JoinHandler

func (h *JoinHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type LogHandler ¶

type LogHandler struct {
	dag.Operation
}

func NewLogHandler(id string) *LogHandler

func (p *LogHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type Loop ¶

type Loop struct {
	dag.Operation
}

func NewLoop(id string) *Loop

func (e *Loop) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type OutputHandler ¶

type OutputHandler struct {
	dag.Operation
}

func NewOutputHandler(id string) *OutputHandler

func (e *OutputHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type PrintHandler ¶

type PrintHandler struct {
	dag.Operation
}

func NewPrintHandler(id string) *PrintHandler

func (e *PrintHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type RenderHTMLNode ¶

type RenderHTMLNode struct {
	dag.Operation
	// contains filtered or unexported fields
}

func NewRenderHTMLNode(id string) *RenderHTMLNode

func (c *RenderHTMLNode) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type SplitHandler ¶

type SplitHandler struct {
	dag.Operation
}

SplitHandler handles string split operations

func NewSplitHandler(id string) *SplitHandler

func (h *SplitHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type StartHandler ¶

type StartHandler struct {
	dag.Operation
}

func NewStartHandler(id string) *StartHandler

func (e *StartHandler) ProcessTask(ctx context.Context, task *mq.Task) mq.Result