Versions in this module Expand all Collapse all v2 v2.0.0 Dec 24, 2025 Changes in this version + const STAGENAME_ADD_FIELD + const STAGENAME_ADD_META + const STAGENAME_ADD_TAG + const STAGENAME_CHANGE_UNIT_PREFIX + const STAGENAME_DELETE_FIELD + const STAGENAME_DELETE_META + const STAGENAME_DELETE_TAG + const STAGENAME_DROP_BY_NAME + const STAGENAME_DROP_BY_TYPE + const STAGENAME_DROP_IF + const STAGENAME_MOVE_FIELD_META + const STAGENAME_MOVE_FIELD_TAG + const STAGENAME_MOVE_META_FIELD + const STAGENAME_MOVE_META_TAG + const STAGENAME_MOVE_TAG_FIELD + const STAGENAME_MOVE_TAG_META + const STAGENAME_NORMALIZE_UNIT + const STAGENAME_RENAME_BY_NAME + const STAGENAME_RENAME_IF + var StageNames = []string + type MessageLocation int + const MESSAGE_LOCATION_FIELDS + const MESSAGE_LOCATION_META + const MESSAGE_LOCATION_TAGS + type MessageProcessor interface + AddAddMetaByCondition func(condition, key, value string) error + AddAddTagsByCondition func(condition, key, value string) error + AddBaseEnv func(env map[string]interface{}) error + AddChangeUnitPrefix func(condition string, prefix string) error + AddDeleteMetaByCondition func(condition, key, value string) error + AddDeleteTagsByCondition func(condition, key, value string) error + AddDropMessagesByCondition func(condition string) error + AddDropMessagesByName func(name string) error + AddMoveFieldToMeta func(condition, key, value string) error + AddMoveFieldToTags func(condition, key, value string) error + AddMoveMetaToFields func(condition, key, value string) error + AddMoveMetaToTags func(condition, key, value string) error + AddMoveTagToFields func(condition, key, value string) error + AddMoveTagToMeta func(condition, key, value string) error + AddRenameMetricByCondition func(condition string, name string) error + AddRenameMetricByName func(from, to string) error + DefaultStages func() []string + FromConfigJSON func(config json.RawMessage) error + ProcessMessage func(m lp.CCMessage) (lp.CCMessage, error) + RemoveAddMetaByCondition func(condition string) + RemoveAddTagsByCondition func(condition string) + RemoveChangeUnitPrefix func(condition string) + RemoveDeleteMetaByCondition func(condition string) + RemoveDeleteTagsByCondition func(condition string) + RemoveDropMessagesByCondition func(condition string) + RemoveDropMessagesByName func(name string) + RemoveMoveFieldToMeta func(condition string) + RemoveMoveFieldToTags func(condition string) + RemoveMoveMetaToFields func(condition string) + RemoveMoveMetaToTags func(condition string) + RemoveMoveTagToFields func(condition string) + RemoveMoveTagToMeta func(condition string) + RemoveRenameMetricByCondition func(condition string) + RemoveRenameMetricByName func(from string) + SetNormalizeUnits func(settings bool) + SetStages func([]string) error + func NewMessageProcessor() (MessageProcessor, error) Other modules containing this package github.com/ClusterCockpit/cc-lib