tag_and_denormalize

Documentation

Overview

Package tag_and_denormalize contains definition of the custom processor tag_and_denormalize

Index

• Constants
• type TagAndDenormalizeProcessorDef
  • func (procDef *TagAndDenormalizeProcessorDef) Deserialize(raw json.RawMessage, _ json.RawMessage, scriptType sc.ScriptType, ...) error
  • func (procDef *TagAndDenormalizeProcessorDef) GetFieldRefs() *sc.FieldRefs
  • func (procDef *TagAndDenormalizeProcessorDef) GetUsedInTargetExpressionsFields() *sc.FieldRefs
  • func (procDef *TagAndDenormalizeProcessorDef) Run(_ *l.CapiLogger, _ *ctx.MessageProcessingContext, rsIn *proc.Rowset, ...) error

Constants

const ProcessorTagAndDenormalizeName string = "tag_and_denormalize"

Types

type TagAndDenormalizeProcessorDef

type TagAndDenormalizeProcessorDef struct {
	TagFieldName         string            `json:"tag_field_name"`
	RawTagCriteria       map[string]string `json:"tag_criteria"`
	RawTagCriteriaUrl    string            `json:"tag_criteria_url"`
	ParsedTagCriteria    map[string]ast.Expr
	UsedInCriteriaFields sc.FieldRefs
}

All processor settings, stored in Capillaries script, root values coming from node

func (*TagAndDenormalizeProcessorDef) Deserialize

func (procDef *TagAndDenormalizeProcessorDef) Deserialize(raw json.RawMessage, _ json.RawMessage, scriptType sc.ScriptType, caPath string, privateKeys map[string]string) error

func (*TagAndDenormalizeProcessorDef) GetFieldRefs

func (procDef *TagAndDenormalizeProcessorDef) GetFieldRefs() *sc.FieldRefs

func (*TagAndDenormalizeProcessorDef) GetUsedInTargetExpressionsFields

func (procDef *TagAndDenormalizeProcessorDef) GetUsedInTargetExpressionsFields() *sc.FieldRefs

func (*TagAndDenormalizeProcessorDef) Run

func (procDef *TagAndDenormalizeProcessorDef) Run(_ *l.CapiLogger, _ *ctx.MessageProcessingContext, rsIn *proc.Rowset, flushVarsArray func(varsArray []*eval.VarValuesMap, varsArrayCount int) error) error