templates

Documentation

Index

• Constants
• Variables
• func EnrichedFuncMap(extraVars map[string]interface{}) template.FuncMap
• func NewGoTemplateExecutor(name string, expression string, extraFunctions template.FuncMap) (*goTemplateExecutor, error)
• func SetScriptFactory(newScriptFactory script.Factory)
• func ToJSONorStringBytes(responseObject interface{}) ([]byte, error)
• func ToString(responseObject interface{}, allowArray bool, allowObject bool, ...) string
• type DestinationPlugin
  • func (p *DestinationPlugin) String() string
• type Expression
  • func (e Expression) String() string
• type NodeExecutor
  • func NewScriptExecutor(nodeScript nodeScript, variables map[string]interface{}, includes ...string) (*NodeExecutor, error)
  • func (e *NodeExecutor) Expression() string
  • func (e *NodeExecutor) Format() string
  • func (e *NodeExecutor) ProcessEvent(event events.Event, listener script.Listener) (interface{}, error)
  • func (e *NodeExecutor) Validate() error
• type SourceExecutor
  • func NewSourceExecutor(sourcePlugin *SourcePlugin) (*SourceExecutor, error)
  • func (e *SourceExecutor) Catalog() (interface{}, error)
  • func (e *SourceExecutor) Spec() map[string]interface{}
  • func (e *SourceExecutor) Stream(streamName string, configuration interface{}, state interface{}, ...) (interface{}, error)
  • func (e *SourceExecutor) Validate() error
• type SourcePlugin
  • func (s *SourcePlugin) String() string
• type TemplateExecutor
  • func SmartParse(name string, expression string, extraFunctions template.FuncMap) (TemplateExecutor, error)

Constants

const TableNameParameter = "JITSU_TABLE_NAME"

const TransformDefaultTemplate = "return $"

Variables

var JSONSerializeFuncs = template.FuncMap{
	"json": func(v interface{}) (string, error) {
		return marshal(v, false, false)
	},

	"json_indent": func(v interface{}) (string, error) {
		return marshal(v, true, false)
	},

	"json_indent_quote": func(v interface{}) (string, error) {
		return marshal(v, true, true)
	},

	"get": func(v interface{}, path string, defaultValue interface{}) (interface{}, error) {
		return get_impl(v, path, defaultValue)
	},

	"TABLE_NAME": TableNameParameter,
}

JSONSerializeFuncs are additional funcs for using from text/template. for example for embedding whole object as JSON into another JSON

Functions

func EnrichedFuncMap

func EnrichedFuncMap(extraVars map[string]interface{}) template.FuncMap

func NewGoTemplateExecutor

func NewGoTemplateExecutor(name string, expression string, extraFunctions template.FuncMap) (*goTemplateExecutor, error)

func SetScriptFactory

func SetScriptFactory(newScriptFactory script.Factory)

func ToJSONorStringBytes

func ToJSONorStringBytes(responseObject interface{}) ([]byte, error)

func ToString

func ToString(responseObject interface{}, allowArray bool, allowObject bool, truncateDate bool) string

Types

type DestinationPlugin

type DestinationPlugin struct {
	Package string
	ID      string
	Type    string
	Config  map[string]interface{}
	// contains filtered or unexported fields
}

func (*DestinationPlugin) String

func (p *DestinationPlugin) String() string

type Expression

type Expression string

func (Expression) String

func (e Expression) String() string

type NodeExecutor

type NodeExecutor struct {
	script.Interface
	// contains filtered or unexported fields
}

func NewScriptExecutor

func NewScriptExecutor(nodeScript nodeScript, variables map[string]interface{}, includes ...string) (*NodeExecutor, error)

func (*NodeExecutor) Expression

func (e *NodeExecutor) Expression() string

func (*NodeExecutor) Format

func (e *NodeExecutor) Format() string

func (*NodeExecutor) ProcessEvent

func (e *NodeExecutor) ProcessEvent(event events.Event, listener script.Listener) (interface{}, error)

func (*NodeExecutor) Validate

func (e *NodeExecutor) Validate() error

type SourceExecutor

type SourceExecutor struct {
	script.Interface
	*SourcePlugin
}

func NewSourceExecutor

func NewSourceExecutor(sourcePlugin *SourcePlugin) (*SourceExecutor, error)

func (*SourceExecutor) Catalog

func (e *SourceExecutor) Catalog() (interface{}, error)

func (*SourceExecutor) Spec

func (e *SourceExecutor) Spec() map[string]interface{}

func (*SourceExecutor) Stream

func (e *SourceExecutor) Stream(streamName string, configuration interface{}, state interface{}, listener script.Listener) (interface{}, error)

func (*SourceExecutor) Validate

func (e *SourceExecutor) Validate() error

type SourcePlugin

type SourcePlugin struct {
	Package string
	ID      string
	Type    string
	Config  map[string]interface{}
	// contains filtered or unexported fields
}

func (*SourcePlugin) String

func (s *SourcePlugin) String() string

type TemplateExecutor

type TemplateExecutor interface {
	ProcessEvent(events.Event, script.Listener) (interface{}, error)
	Format() string
	Expression() string
	Close()
}

func SmartParse

func SmartParse(name string, expression string, extraFunctions template.FuncMap) (TemplateExecutor, error)

SmartParse is a factory method that returns TemplateExecutor implementation based on provided expression language