flumen

Documentation

Index

• Constants
• func FlumenProcessFlowController(tfmContext *flowcore.TrcFlowMachineContext, ...) error
• func GetTierceronFlowConfigurationIndexedPathExt(engine interface{}, rowDataMap map[string]interface{}, ...) (string, error)
• func GetTierceronFlowIdColName() string
• func GetTierceronTableNames() []string
• func ProcessFlows(pluginConfig map[string]interface{}, logger *log.Logger) error
• func ProcessTierceronFlows(tfmContext *flowcore.TrcFlowMachineContext, tfContext *flowcore.TrcFlowContext) error
• type TrcDBServerEventListener
  • func (t *TrcDBServerEventListener) ClientConnected()
  • func (tl *TrcDBServerEventListener) ClientDisconnected()
  • func (tl *TrcDBServerEventListener) QueryCompleted(query string, success bool, duration time.Duration)
  • func (tl *TrcDBServerEventListener) QueryStarted()

Constants

const (
	TierceronControllerFlow flowcore.FlowNameType = "TierceronFlow"
)

Functions

func FlumenProcessFlowController

func FlumenProcessFlowController(tfmContext *flowcore.TrcFlowMachineContext, trcFlowContext *flowcore.TrcFlowContext) error

func GetTierceronFlowConfigurationIndexedPathExt

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

func GetTierceronFlowIdColName

func GetTierceronFlowIdColName() string

func GetTierceronTableNames

func GetTierceronTableNames() []string

func ProcessFlows

func ProcessFlows(pluginConfig map[string]interface{}, logger *log.Logger) error

func ProcessTierceronFlows

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

Only pull from vault on init Listen to a change channel ->

Types

type TrcDBServerEventListener

type TrcDBServerEventListener struct {
	Log *log.Logger
}

func (*TrcDBServerEventListener) ClientConnected

func (t *TrcDBServerEventListener) ClientConnected()

func (*TrcDBServerEventListener) ClientDisconnected

func (tl *TrcDBServerEventListener) ClientDisconnected()

func (*TrcDBServerEventListener) QueryCompleted

func (tl *TrcDBServerEventListener) QueryCompleted(query string, success bool, duration time.Duration)

func (*TrcDBServerEventListener) QueryStarted

func (tl *TrcDBServerEventListener) QueryStarted()