Versions in this module Expand all Collapse all v0 v0.0.1 May 2, 2023 Changes in this version + func InitDataCollector(config DataCollectorConfig) error + func RecordActionFailure(wfName string, flowId string, actionName string, actionId int, reson string) + func RecordActionSuccess(wfName string, flowId string, actionName string, actionId int, ...) + type DataCollectorConfig struct + CollectorType DataCollectorType + FileName string + type DataCollectorType string + const ELASTIC_DATA_COLLECTOR + const LOG_FILE_DATA_COLLECTOR + type LogFileDataCollector struct + func NewLogFileDataCollector(fileName string) (*LogFileDataCollector, error) + func (lc *LogFileDataCollector) RecordActionFailure(wfName string, flowId string, actionName string, actionId int, reson string) + func (lc *LogFileDataCollector) RecordActionSuccess(wfName string, flowId string, actionName string, actionId int, ...) + type WorkflowDataCollector interface + RecordActionFailure func(wfName string, flowId string, actionName string, actionId int, reson string) + RecordActionSuccess func(wfName string, flowId string, actionName string, actionId int, ...)