app

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{})

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 ...

func NewTemporalLogger

func NewTemporalLogger(coreLogger core.Logger) log.Logger

NewTemporalLogger 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 ...