job

Documentation

Index

• func MergeInvertedIndexDay2Month(ctx context.Context) (err error)
• func MergeInvertedIndexMonth2Season(ctx context.Context) (err error)
• func RegisterJob(ctx context.Context)
• type Command
  • func (cmd *Command) Run()

Functions

func MergeInvertedIndexDay2Month

func MergeInvertedIndexDay2Month(ctx context.Context) (err error)

MergeInvertedIndexDay2Month 增量合并全量, 合并到这个月，这周的数据就会删掉，下一个周增量又开始了

func MergeInvertedIndexMonth2Season

func MergeInvertedIndexMonth2Season(ctx context.Context) (err error)

MergeInvertedIndexMonth2Season 增量合并全量, 合并完就会删掉原有的，合并到这个季度

func RegisterJob

func RegisterJob(ctx context.Context)

Types

type Command

type Command struct {
	Name    string
	Exec    func(ctx context.Context) error
	Context context.Context
	// contains filtered or unexported fields
}

func (*Command) Run

func (cmd *Command) Run()