Documentation
¶
Index ¶
- func DevLakePipelineWorkflow(ctx workflow.Context, configJson []byte, pipelineId uint64, ...) errors.Error
- func DevLakeTaskActivity(ctx context.Context, configJson []byte, taskId uint64, ...) errors.Error
- func NewTemporalLogger(coreLogger core.Logger) log.Logger
- type TemporalLogger
- func (l *TemporalLogger) Debug(msg string, keyvals ...interface{})
- func (l *TemporalLogger) Error(msg string, keyvals ...interface{})
- func (l *TemporalLogger) Info(msg string, keyvals ...interface{})
- func (l *TemporalLogger) Log(lv core.LogLevel, msg string, keyvals ...interface{})
- func (l *TemporalLogger) Warn(msg string, keyvals ...interface{})
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DevLakePipelineWorkflow ¶
func DevLakePipelineWorkflow(ctx workflow.Context, configJson []byte, pipelineId uint64, loggerConfig *core.LoggerConfig) errors.Error
DevLakePipelineWorkflow FIXME ...
func DevLakeTaskActivity ¶
func DevLakeTaskActivity(ctx context.Context, configJson []byte, taskId uint64, loggerConfig *core.LoggerConfig) errors.Error
DevLakeTaskActivity FIXME ...
Types ¶
type TemporalLogger ¶
type TemporalLogger struct {
// contains filtered or unexported fields
}
TemporalLogger FIXME ...
func (*TemporalLogger) Debug ¶
func (l *TemporalLogger) Debug(msg string, keyvals ...interface{})
Debug FIXME ...
func (*TemporalLogger) Error ¶
func (l *TemporalLogger) Error(msg string, keyvals ...interface{})
Error FIXME ...
func (*TemporalLogger) Info ¶
func (l *TemporalLogger) Info(msg string, keyvals ...interface{})
Info FIXME ...
func (*TemporalLogger) Log ¶
func (l *TemporalLogger) Log(lv core.LogLevel, msg string, keyvals ...interface{})
Log FIXME ...
func (*TemporalLogger) Warn ¶
func (l *TemporalLogger) Warn(msg string, keyvals ...interface{})
Warn FIXME ...
Source Files
Click to show internal directories.
Click to hide internal directories.