model

Dec 16, 2024

Changes in this version

+ type ApplyType struct

+ URI string

type MaskType

+ Apply ApplyType

Nov 20, 2024

Changes in this version

type ProcessPipeline

+ func (p *ProcessPipeline) Open() error

Sep 24, 2024

Changes in this version

type Sha3Type

+ MaxStrLen int

Sep 13, 2024

Changes in this version

type Dictionary

+ func (d Dictionary) Get(key string) Entry

+ func (d Dictionary) GetValue(key string) (Entry, bool)

+ func (d Dictionary) MarshalJSON() ([]byte, error)

Sep 3, 2024

Changes in this version

type Masking

+ PreserveL []Entry

Jul 30, 2024

Changes in this version

type ChoiceInCSVType

+ Identifier EmbeddedSha3Type

+ type EmbeddedSha3Type struct

+ Field string

type MaskType

+ Sha3 Sha3Type

+ type Sha3Type struct

+ Domain string

+ Length int

+ Resistance int

Jul 15, 2024

Changes in this version

type MaskType

+ Sequence SequenceType

+ type SequenceType struct

+ Format string

+ Varying string

Apr 11, 2024

Changes in this version

type MaskType

+ TimeLine TimeLineType

+ type TimeLineConstraintType struct

+ After string

+ Before string

+ Epsilon string

+ OnError string

+ type TimeLinePointType struct

+ Constraints []TimeLineConstraintType

+ Default string

+ From string

+ Max string

+ Min string

+ Name string

+ type TimeLineStartType struct

+ Name string

+ Value string

+ type TimeLineType struct

+ Epsilon string

+ Format string

+ MaxRetry *int

+ Points []TimeLinePointType

+ Start TimeLineStartType

type UniqueMemCache

+ func (mc *UniqueMemCache) Put(key Entry, value Entry)

Jan 24, 2024

Changes in this version

type MaskType

+ XML XMLType

+ type XMLType struct

+ InjectParent string

+ Masking []Masking

+ XPath string

Jan 12, 2024

Changes in this version

type Dictionary

+ func (d Dictionary) UnpackUnordered() Entry

+ func (d Dictionary) UnpackUntyped() interface{}

+ type ExactMatchType struct

+ CSV string

+ Entry string

+ type FindInCSVType struct

+ Comment string

+ ExactMatch ExactMatchType

+ Expected string

+ FieldsPerRecord int

+ Header bool

+ JaccardMatch ExactMatchType

+ Separator string

+ TrimSpace bool

+ URI string

type MaskType

+ FindInCSV FindInCSVType

Nov 20, 2023

Changes in this version

+ type CallableMapSource struct

+ func NewCallableMapSource() *CallableMapSource

+ func (source *CallableMapSource) Err() error

+ func (source *CallableMapSource) Next() bool

+ func (source *CallableMapSource) Open() error

+ func (source *CallableMapSource) SetValue(value Entry)

+ func (source *CallableMapSource) Value() Entry

Jul 6, 2023

Changes in this version

type Dictionary

+ func NewPackedDictionary() Dictionary

+ func (d Dictionary) CanUnpackAsDict() bool

+ func (d Dictionary) IsPacked() bool

+ func (d Dictionary) Pack() Dictionary

+ func (d Dictionary) TryUnpackAsDict() (Dictionary, bool)

+ func (d Dictionary) Unpack() Entry

+ func (d Dictionary) UnpackAsDict() Dictionary

type Entry

+ func Copy(other Entry) Entry

type FF1Type

+ Domain string

+ OnError *string

+ Preserve bool

+ type MsgLogger struct

+ func NewMsgLogger(filename string) *MsgLogger

+ func (logger *MsgLogger) Log(msg string) error

+ type PackProcess struct

+ func NewPackProcess() *PackProcess

+ func (pp *PackProcess) Open() error

+ func (pp *PackProcess) ProcessDictionary(dictionary Dictionary, out Collector) error

type Pipeline

+ Source func() Source

type ProcessPipeline

+ func (p *ProcessPipeline) Source() Source

type Selector

+ func NewPackedPathSelector(path string) Selector

type SimplePipeline

+ func (pipeline SimplePipeline) Source() Source

+ type UnpackProcess struct

+ func NewUnpackProcess() *UnpackProcess

+ func (up *UnpackProcess) Open() error

+ func (up *UnpackProcess) ProcessDictionary(dictionary Dictionary, out Collector) error

Jun 12, 2023

Changes in this version

+ type ChoiceInCSVType struct

+ Comment string

+ FieldsPerRecord int

+ Header bool

+ Separator string

+ TrimSpace bool

+ URI string

type Definition

+ func (conf *Definition) SetSeed(seedValue int64)

type MaskType

+ HashInCSV ChoiceInCSVType

+ RandomChoiceInCSV ChoiceInCSVType

Feb 7, 2023

Changes in this version

type Cache

+ SetLookupValue func(key Entry)

+ type LookupValueDiscarder struct

+ func (lvd *LookupValueDiscarder) Open() error

+ func (lvd *LookupValueDiscarder) ProcessDictionary(e Dictionary, c Collector) error

+ type LookupValueSetter struct

+ func (lvs *LookupValueSetter) Open() error

+ func (lvs *LookupValueSetter) ProcessDictionary(e Dictionary, c Collector) error

type MemCache

+ func (mc *MemCache) SetLookupValue(key Entry)

Oct 10, 2022

Changes in this version

+ func BuildFuncMap(funcs map[string]Function, fns tmpl.FuncMap) (tmpl.FuncMap, error)

type Definition

+ Functions map[string]Function

+ type Function struct

+ Body string

+ Params []Param

+ type MaskFactoryConfiguration struct

+ Cache map[string]Cache

+ Functions tmpl.FuncMap

+ Masking Masking

+ Seed int64

+ type Param struct

+ Name string

Jun 20, 2022

Changes in this version

+ type Class struct

+ Input string

+ Output string

type MaskType

+ Transcode *TranscodeType

type Masking

+ Seed SeedType

+ type SeedType struct

+ Field string

+ type Seeder func(Dictionary) (int64, bool, error)

+ func NewSeeder(conf Masking, seed int64) Seeder

+ type TranscodeType struct

+ Classes []Class

Mar 18, 2022

Changes in this version

+ func Untyped(inter interface{}) interface

type CacheDefinition

+ Reverse bool

type Definition

+ func LoadPipelineDefinitionFromFile(filename string) (Definition, error)

+ func LoadPipelineDefintionFromOneLiner(oneLine []string) (Definition, error)

type Dictionary

+ func (d Dictionary) Untyped() map[string]interface{}

+ type MarkovType struct

+ MaxSize int

+ Order int

+ Sample string

+ Separator string

type MaskType

+ Markov MarkovType

type Masking

+ Selectors []SelectorType

type Processor

+ func NewRepeaterUntilProcess(source *TempSource, text, mode string) (Processor, error)

+ type RepeaterUntilProcess struct

+ func (p RepeaterUntilProcess) Open() error

+ func (p RepeaterUntilProcess) ProcessDictionary(dictionary Dictionary, out Collector) error

type Source

+ func NewTempSource(sourceValue Source) Source

+ type TempSource struct

+ func (s *TempSource) Err() error

+ func (s *TempSource) Next() bool

+ func (s *TempSource) Open() error

+ func (s *TempSource) Value() Dictionary

Jan 3, 2022

Changes in this version

+ type MaskContextCacheEngine struct

+ Cache Cache

+ OriginalEngine MaskContextEngine

+ func NewMaskContextCacheEngine(cache Cache, original MaskContextEngine) MaskContextCacheEngine

+ func (mcce MaskContextCacheEngine) MaskContext(context Dictionary, key string, contexts ...Dictionary) (Dictionary, error)

type Masking

+ Preserve string

+ type UniqueMaskContextCacheEngine struct

+ func NewUniqueMaskContextCacheEngine(cache UniqueCache, original MaskContextEngine) UniqueMaskContextCacheEngine

+ func (umcce UniqueMaskContextCacheEngine) MaskContext(context Dictionary, key string, contexts ...Dictionary) (Dictionary, error)

Dec 7, 2021

Changes in this version

+ type LuhnType struct

+ Universe string

type MaskType

+ Luhn *LuhnType

Sep 27, 2021

Changes in this version

+ type FunctionMaskContextEngine struct

+ Function func(Dictionary, string, ...Dictionary) (Dictionary, error)

+ func (fme FunctionMaskContextEngine) MaskContext(e Dictionary, key string, context ...Dictionary) (Dictionary, error)

+ type HasCleaner interface

+ GetCleaner func() FunctionMaskContextEngine

type MaskType

+ AddTransient Entry

type Masking

+ Masks []MaskType

Jul 2, 2021

Changes in this version

type MaskType

+ FromJSON string

Jul 2, 2021

Changes in this version

type MaskType

+ TemplateEach TemplateEachType

+ type TemplateEachType struct

+ Index string

+ Item string

+ Template string

Jun 8, 2021

Changes in this version

type Dictionary

+ func CleanDictionarySlice(dictSlice interface{}) []Dictionary

May 21, 2021

Changes in this version

+ func CleanTypes(inter interface{}) interface

+ func UnorderedTypes(inter interface{}) interface

type Dictionary

+ func CleanDictionary(dict Dictionary) Dictionary

+ func CopyDictionary(other Dictionary) Dictionary

+ func NewDictionary() Dictionary

+ func (d Dictionary) Copy() Dictionary

+ func (d Dictionary) String() string

+ func (d Dictionary) Unordered() map[string]Entry

+ func (d Dictionary) With(key string, value interface{}) Dictionary

May 11, 2021

Changes in this version

+ func InjectConfig(skipLineOnErrorValue bool, skipFieldOnErrorValue bool)

+ type CounterProcess struct

+ func (p CounterProcess) Open() error

+ func (p CounterProcess) ProcessDictionary(dictionary Dictionary, out Collector) error

type Processor

+ func NewCounterProcess(contextName string, initValue int) Processor

+ func NewCounterProcessWithCallback(contextName string, initValue int, updater func(int)) Processor

Apr 20, 2021

Changes in this version

+ const DELETE

+ const NOTHING

+ const WRITE

+ func BuildCaches(caches map[string]CacheDefinition, existing map[string]Cache) map[string]Cache

+ func InjectMaskContextFactories(factories []MaskContextFactory)

+ func InjectMaskFactories(factories []MaskFactory)

+ type Action uint

+ type Applier func(rootContext Dictionary, parentContext Dictionary, key string, value Entry) (Action, Entry)

+ type Cache interface

+ Get func(key Entry) (Entry, bool)

+ Iterate func() Source

+ Put func(key Entry, value Entry)

+ Subscribe func(key Entry, observer Observer)

+ func NewMemCache() Cache

+ type CacheDefinition struct

+ Unique bool

+ type Collector interface

+ Collect func(Dictionary)

+ type DateParserType struct

+ InputFormat string

+ OutputFormat string

+ type Definition struct

+ Caches map[string]CacheDefinition

+ Masking []Masking

+ Seed int64

+ Version string

+ func LoadPipelineDefinitionFromYAML(filename string) (Definition, error)

+ type DeleteMaskEngineProcess struct

+ func (dp *DeleteMaskEngineProcess) Open() (err error)

+ func (dp *DeleteMaskEngineProcess) ProcessDictionary(dictionary Dictionary, out Collector) error

+ type Dictionary map[string]Entry

+ func InterfaceToDictionary(inter interface{}) Dictionary

+ type Entry interface

+ type FF1Type struct

+ Decrypt bool

+ KeyFromEnv string

+ Radix uint

+ TweakField string

+ type FromCacheProcess struct

+ func (p *FromCacheProcess) Notify(key Entry, value Entry)

+ func (p *FromCacheProcess) Open() error

+ func (p *FromCacheProcess) ProcessDictionary(dictionary Dictionary, out Collector) error

+ type FunctionMaskEngine struct

+ Function func(Entry, ...Dictionary) (Entry, error)

+ func (fme FunctionMaskEngine) Mask(e Entry, context ...Dictionary) (Entry, error)

+ type IncrementalType struct

+ Increment int

+ Start int

+ type MapProcess struct

+ func (mp MapProcess) Open() error

+ func (mp MapProcess) ProcessDictionary(dictionary Dictionary, out Collector) error

+ type Mapper func(Dictionary) (Dictionary, error)

+ type MaskCacheEngine struct

+ Cache Cache

+ OriginalEngine MaskEngine

+ func NewMaskCacheEngine(cache Cache, original MaskEngine) MaskCacheEngine

+ func (mce MaskCacheEngine) Mask(e Entry, context ...Dictionary) (Entry, error)

+ type MaskContextEngine interface

+ MaskContext func(Dictionary, string, ...Dictionary) (Dictionary, error)

+ type MaskContextEngineProcess struct

+ func (mcep *MaskContextEngineProcess) Open() error

+ func (mcep *MaskContextEngineProcess) ProcessDictionary(dictionary Dictionary, out Collector) (ret error)

+ type MaskContextFactory func(Masking, int64, map[string]Cache) (MaskContextEngine, bool, error)

+ type MaskEngine interface

+ Mask func(Entry, ...Dictionary) (Entry, error)

+ type MaskEngineProcess struct

+ func (mep *MaskEngineProcess) Open() error

+ func (mep *MaskEngineProcess) ProcessDictionary(dictionary Dictionary, out Collector) (ret error)

+ type MaskFactory func(Masking, int64, map[string]Cache) (MaskEngine, bool, error)

+ type MaskType struct

+ Add Entry

+ Command string

+ Constant Entry

+ DateParser DateParserType

+ Duration string

+ FF1 FF1Type

+ FluxURI string

+ FromCache string

+ Hash []Entry

+ HashInURI string

+ Incremental IncrementalType

+ Pipe PipeType

+ RandDate RandDateType

+ RandomChoice []Entry

+ RandomChoiceInURI string

+ RandomDecimal RandomDecimalType

+ RandomDuration RandomDurationType

+ RandomInt RandIntType

+ RangeMask int

+ Regex string

+ Remove bool

+ Replacement string

+ Template string

+ WeightedChoice []WeightedChoiceType

+ type Masking struct

+ Cache string

+ Mask MaskType

+ Selector SelectorType

+ type MemCache struct

+ func (mc *MemCache) Get(key Entry) (Entry, bool)

+ func (mc *MemCache) Iterate() Source

+ func (mc *MemCache) Put(key Entry, value Entry)

+ func (mc *MemCache) Subscribe(key Entry, observer Observer)

+ type Observer interface

+ Notify func(key Entry, value Entry)

+ type PipeType struct

+ DefinitionFile string

+ InjectParent string

+ InjectRoot string

+ Masking []Masking

+ type Pipeline interface

+ AddSink func(SinkProcess) SinkedPipeline

+ Process func(Processor) Pipeline

+ WithSource func(Source) Pipeline

+ func BuildPipeline(pipeline Pipeline, conf Definition, caches map[string]Cache) (Pipeline, map[string]Cache, error)

+ func NewPipeline(source Source) Pipeline

+ func NewPipelineFromSlice(dictionaries []Dictionary) Pipeline

+ func NewProcessPipeline(source Source, process Processor) Pipeline

+ type ProcessPipeline struct

+ func (p *ProcessPipeline) AddSink(sink SinkProcess) SinkedPipeline

+ func (p *ProcessPipeline) Err() error

+ func (p *ProcessPipeline) Next() bool

+ func (p *ProcessPipeline) Process(process Processor) Pipeline

+ func (p *ProcessPipeline) Value() Dictionary

+ func (p *ProcessPipeline) WithSource(source Source) Pipeline

+ type Processor interface

+ Open func() error

+ ProcessDictionary func(Dictionary, Collector) error

+ func NewDeleteMaskEngineProcess(selector Selector) Processor

+ func NewFromCacheProcess(selector Selector, cache Cache) Processor

+ func NewMapProcess(mapper Mapper) Processor

+ func NewMaskContextEngineProcess(selector Selector, mask MaskContextEngine) Processor

+ func NewMaskEngineProcess(selector Selector, mask MaskEngine) Processor

+ func NewRepeaterProcess(times int) Processor

+ type QueueCollector struct

+ func NewCollector() *QueueCollector

+ func (c *QueueCollector) Collect(dictionary Dictionary)

+ func (c *QueueCollector) Err() error

+ func (c *QueueCollector) Next() bool

+ func (c *QueueCollector) Open() error

+ func (c *QueueCollector) Value() Dictionary

+ type RandDateType struct

+ DateMax time.Time

+ DateMin time.Time

+ type RandIntType struct

+ Max int

+ Min int

+ type RandomDecimalType struct

+ Max float64

+ Min float64

+ Precision int

+ type RandomDurationType struct

+ Max string

+ Min string

+ type RepeaterProcess struct

+ func (p RepeaterProcess) Open() error

+ func (p RepeaterProcess) ProcessDictionary(dictionary Dictionary, out Collector) error

+ type Selector interface

+ Apply func(Dictionary, ...Applier) bool

+ ApplyContext func(Dictionary, ...Applier) bool

+ Delete func(Dictionary) Dictionary

+ Read func(Dictionary) (Entry, bool)

+ ReadContext func(Dictionary) (Dictionary, string, bool)

+ Write func(Dictionary, Entry) Dictionary

+ WriteContext func(Dictionary, Entry) Dictionary

+ func NewPathSelector(path string) Selector

+ type SelectorType struct

+ Jsonpath string

+ type SimplePipeline struct

+ func (pipeline SimplePipeline) AddSink(sink SinkProcess) SinkedPipeline

+ func (pipeline SimplePipeline) Err() error

+ func (pipeline SimplePipeline) Next() bool

+ func (pipeline SimplePipeline) Open() error

+ func (pipeline SimplePipeline) Process(process Processor) Pipeline

+ func (pipeline SimplePipeline) Value() Dictionary

+ func (pipeline SimplePipeline) WithSource(source Source) Pipeline

+ type SimpleSinkedPipeline struct

+ func (pipeline SimpleSinkedPipeline) Run() (err error)

+ type SinkProcess interface

+ Open func() error

+ ProcessDictionary func(Dictionary) error

+ func NewSinkToCache(cache Cache) SinkProcess

+ func NewSinkToSlice(dictionaries *[]Dictionary) SinkProcess

+ type SinkToCache struct

+ func (sink *SinkToCache) Open() error

+ func (sink *SinkToCache) ProcessDictionary(dictionary Dictionary) error

+ type SinkToSlice struct

+ func (sink *SinkToSlice) Open() error

+ func (sink *SinkToSlice) ProcessDictionary(dictionary Dictionary) error

+ type SinkedPipeline interface

+ Run func() error

+ type Source interface

+ Err func() error

+ Next func() bool

+ Open func() error

+ Value func() Dictionary

+ func NewSourceFromSlice(dictionaries []Dictionary) Source

+ type SourceFromSlice struct

+ func (source *SourceFromSlice) Err() error

+ func (source *SourceFromSlice) Next() bool

+ func (source *SourceFromSlice) Open() error

+ func (source *SourceFromSlice) Value() Dictionary

+ type UniqueCache interface

+ PutUnique func(key Entry, value Entry) bool

+ func NewUniqueMemCache() UniqueCache

+ type UniqueMaskCacheEngine struct

+ func NewUniqueMaskCacheEngine(cache UniqueCache, original MaskEngine) UniqueMaskCacheEngine

+ func (umce UniqueMaskCacheEngine) Mask(e Entry, context ...Dictionary) (Entry, error)

+ type UniqueMemCache struct

+ func (mc *UniqueMemCache) PutUnique(key Entry, value Entry) bool

+ type WeightedChoiceType struct

+ Choice Entry

+ Weight uint