logic

Documentation

Index

• type MqueueScheduler
  • func NewCronScheduler(ctx context.Context, svcCtx *svc.ServiceContext) *MqueueScheduler
  • func (l *MqueueScheduler) AddFlowScheduler()
  • func (l *MqueueScheduler) Register()

Types

type MqueueScheduler

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

func NewCronScheduler

func NewCronScheduler(ctx context.Context, svcCtx *svc.ServiceContext) *MqueueScheduler

func (*MqueueScheduler) AddFlowScheduler

func (l *MqueueScheduler) AddFlowScheduler()

scheduler job ------> go-zero-looklook/app/mqueue/cmd/job/internal/logic/AddFlowSchedule.go.

func (*MqueueScheduler) Register

func (l *MqueueScheduler) Register()