flows

Documentation

Index

• func GetDataFlowDeleteTrigger(databaseName string, tableName string, iden1 string, iden2 string, ...) string
• func GetDataFlowInsertTrigger(databaseName string, tableName string, iden1 string, iden2 string, ...) string
• func GetDataFlowUpdateTrigger(databaseName string, tableName string, iden1 string, iden2 string, ...) string
• func GetDataflowStatIndexedPathExt(engine interface{}, rowDataMap map[string]interface{}, ...) (string, error)
• func KickOffTimedRefresh(tfContext *flowcore.TrcFlowContext, ...) bool
• func ProcessDataFlowStatConfigurations(tfmContext *flowcore.TrcFlowMachineContext, tfContext *flowcore.TrcFlowContext) error

Functions

func GetDataFlowDeleteTrigger

func GetDataFlowDeleteTrigger(databaseName string, tableName string, iden1 string, iden2 string, iden3 string) string

func GetDataFlowInsertTrigger

func GetDataFlowInsertTrigger(databaseName string, tableName string, iden1 string, iden2 string, iden3 string) string

func GetDataFlowUpdateTrigger

func GetDataFlowUpdateTrigger(databaseName string, tableName string, iden1 string, iden2 string, iden3 string) string

func GetDataflowStatIndexedPathExt

func GetDataflowStatIndexedPathExt(engine interface{}, rowDataMap map[string]interface{}, indexColumnNames interface{}, databaseName string, tableName string, dbCallBack func(interface{}, map[string]interface{}) (string, []string, [][]interface{}, error)) (string, error)

func KickOffTimedRefresh

func KickOffTimedRefresh(tfContext *flowcore.TrcFlowContext, stateUpdateChannel chan flowcorehelper.FlowStateUpdate, timing string) bool

func ProcessDataFlowStatConfigurations

func ProcessDataFlowStatConfigurations(tfmContext *flowcore.TrcFlowMachineContext, tfContext *flowcore.TrcFlowContext) error