tasks

Documentation

Index

• Constants
• type LogMonitor
  • func (m *LogMonitor) Start(ctx context.Context) error
• type Task
  • func NewLogMonitor(lg *zap.Logger, name string, cfg config.EventMonitorConfig, ...) Task

Constants

const (
	TaskBaseLogMonitor = "base-log-monitor"
)

Types

type LogMonitor

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

func (*LogMonitor) Start

func (m *LogMonitor) Start(ctx context.Context) error

type Task

type Task interface {
	Start(ctx context.Context) error
}

func NewLogMonitor

func NewLogMonitor(lg *zap.Logger, name string, cfg config.EventMonitorConfig, repo repository.Repository, chain chain.Chain) Task