store

package
v0.1.32 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 2, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var InitStep bool = true

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 Store

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

Store object implements Transformer interface.

func (*Store) Apply

func (s *Store) Apply(eventID string, data []byte) ([]byte, error)

Apply is a main method of Transformation that stores JSON values into variables that can be used by other Transformations in a pipeline.

func (*Store) InitStep

func (s *Store) InitStep() bool

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

func (*Store) New

func (s *Store) New(key, value, separator string) transformer.Transformer

New returns a new instance of Store object.

func (*Store) SetStorage

func (s *Store) SetStorage(storage *storage.Storage)

SetStorage sets a shared Storage with Pipeline variables.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL