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, caPath string, ...) error
- func (procDef *TagAndDenormalizeProcessorDef) GetFieldRefs() *sc.FieldRefs
- func (procDef *TagAndDenormalizeProcessorDef) GetUsedInTargetExpressionsFields() *sc.FieldRefs
- func (procDef *TagAndDenormalizeProcessorDef) Run(logger *l.CapiLogger, _ *ctx.MessageProcessingContext, rsIn *proc.Rowset, ...) error
Constants ¶
View Source
const ProcessorTagAndDenormalizeName string = "tag_and_denormalize"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TagAndDenormalizeProcessorDef ¶
type TagAndDenormalizeProcessorDef struct {
TagFieldName string `json:"tag_field_name"`
RawTagCriteria map[string]string `json:"tag_criteria"`
RawTagCriteriaUri string `json:"tag_criteria_uri"`
ParsedTagCriteria map[string]ast.Expr
UsedInCriteriaFields sc.FieldRefs
}
func (*TagAndDenormalizeProcessorDef) Deserialize ¶
func (procDef *TagAndDenormalizeProcessorDef) Deserialize(raw json.RawMessage, _ json.RawMessage, 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(logger *l.CapiLogger, _ *ctx.MessageProcessingContext, rsIn *proc.Rowset, flushVarsArray func(varsArray []*eval.VarValuesMap, varsArrayCount int) error) error
Source Files
Click to show internal directories.
Click to hide internal directories.