app

Documentation

Index

• func DevLakePipelineWorkflow(ctx workflow.Context, configJson []byte, pipelineId uint64) error
• func DevLakeTaskActivity(ctx context.Context, configJson []byte, taskId uint64) error
• func NewTemporalLogger(log 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) error

func DevLakeTaskActivity

func DevLakeTaskActivity(ctx context.Context, configJson []byte, taskId uint64) error

func NewTemporalLogger

func NewTemporalLogger(log core.Logger) log.Logger

Types

type TemporalLogger

type TemporalLogger struct {
	// contains filtered or unexported fields
}

func (*TemporalLogger) Debug

func (l *TemporalLogger) Debug(msg string, keyvals ...interface{})

func (*TemporalLogger) Error

func (l *TemporalLogger) Error(msg string, keyvals ...interface{})

func (*TemporalLogger) Info

func (l *TemporalLogger) Info(msg string, keyvals ...interface{})

func (*TemporalLogger) Log

func (l *TemporalLogger) Log(lv core.LogLevel, msg string, keyvals ...interface{})

func (*TemporalLogger) Warn

func (l *TemporalLogger) Warn(msg string, keyvals ...interface{})