mongo

Documentation

Index

• Constants
• type TaskScheduler
  • func NewTaskScheduler(database *mgo.DbClient, col string, partID int16, ...) *TaskScheduler
  • func (ts *TaskScheduler) Close(ctx context.Context) error
  • func (ts *TaskScheduler) NewStageID(ctx context.Context, taskKey string) (stageID int64, err error)
  • func (ts *TaskScheduler) ReadTask(ctx context.Context, taskKey string) (*task.Task, error)
  • func (ts *TaskScheduler) RemoveTaskSchedule(ctx context.Context, tk task.Task) error
  • func (ts *TaskScheduler) ScheduleTask(ctx context.Context, tk task.Task, cover bool) error
  • func (ts *TaskScheduler) WaitTaskAwaken(ctx context.Context) (awaken task.Awaken, err error)

Constants

const (
	PartVarPartitionIDField = "taskPartId"
)

Types

type TaskScheduler

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

func NewTaskScheduler

func NewTaskScheduler(database *mgo.DbClient, col string, partID int16, hashPartition func(taskKey string) int16) *TaskScheduler

func (*TaskScheduler) Close

func (ts *TaskScheduler) Close(ctx context.Context) error

func (*TaskScheduler) NewStageID

func (ts *TaskScheduler) NewStageID(ctx context.Context, taskKey string) (stageID int64, err error)

func (*TaskScheduler) ReadTask

func (ts *TaskScheduler) ReadTask(ctx context.Context, taskKey string) (*task.Task, error)

func (*TaskScheduler) RemoveTaskSchedule

func (ts *TaskScheduler) RemoveTaskSchedule(ctx context.Context, tk task.Task) error

func (*TaskScheduler) ScheduleTask

func (ts *TaskScheduler) ScheduleTask(ctx context.Context, tk task.Task, cover bool) error

func (*TaskScheduler) WaitTaskAwaken

func (ts *TaskScheduler) WaitTaskAwaken(ctx context.Context) (awaken task.Awaken, err error)