delete

Documentation

Index

• Variables
• func Register(m map[string]transformer.Transformer)
• type Delete
  • func (d *Delete) Apply(eventID string, data []byte) ([]byte, error)
  • func (d *Delete) InitStep() bool
  • func (d *Delete) New(key, value, separator string) transformer.Transformer
  • func (d *Delete) SetStorage(storage *storage.Storage)

Variables

var InitStep bool = false

InitStep is used to figure out if this operation should run before main Transformations. For example, Store operation needs to run first to load all Pipeline variables.

Functions

func Register

func Register(m map[string]transformer.Transformer)

Register adds this transformation to the map which will be used to create Transformation pipeline.

Types

type Delete

type Delete struct {
	Path      string
	Value     string
	Type      string
	Separator string
	// contains filtered or unexported fields
}

Delete object implements Transformer interface.

func (*Delete) Apply

func (d *Delete) Apply(eventID string, data []byte) ([]byte, error)

Apply is a main method of Transformation that removed any type of variables from existing JSON.

func (*Delete) InitStep

func (d *Delete) InitStep() bool

InitStep returns "true" if this Transformation should run as init step.

func (*Delete) New

func (d *Delete) New(key, value, separator string) transformer.Transformer

New returns a new instance of Delete object.

func (*Delete) SetStorage

func (d *Delete) SetStorage(storage *storage.Storage)

SetStorage sets a shared Storage with Pipeline variables.