processing

Documentation

Index

• func FromConnectionContext(dbConnection drivers.DBDriver, tx interface{}, modelName string, ...) template.FuncMap
• type Asset
  • func InitSQLModelAsset(descriptor *models.SQLModelDescriptor) Asset
• type SQLModelAsset
  • func (s *SQLModelAsset) Execute(input map[string]interface{}) (interface{}, error)
  • func (s *SQLModelAsset) GetDownstreams() []string
  • func (s *SQLModelAsset) GetName() string
  • func (s *SQLModelAsset) GetUpstreams() []string

Functions

func FromConnectionContext

func FromConnectionContext(dbConnection drivers.DBDriver, tx interface{}, modelName string, inPlaceFunctions template.FuncMap) template.FuncMap

Types

type Asset

type Asset interface {
	Execute(input map[string]interface{}) (interface{}, error)
	GetUpstreams() []string
	GetDownstreams() []string
	GetName() string
}

func InitSQLModelAsset

func InitSQLModelAsset(descriptor *models.SQLModelDescriptor) Asset

type SQLModelAsset

type SQLModelAsset struct {
	// contains filtered or unexported fields
}

func (*SQLModelAsset) Execute

func (s *SQLModelAsset) Execute(input map[string]interface{}) (interface{}, error)

Execute implements Asset.

func (*SQLModelAsset) GetDownstreams

func (s *SQLModelAsset) GetDownstreams() []string

GetDownstrem implements Asset.

func (*SQLModelAsset) GetName

func (s *SQLModelAsset) GetName() string

GetName implements Asset.

func (*SQLModelAsset) GetUpstreams

func (s *SQLModelAsset) GetUpstreams() []string

GetUpstream implements Asset.