Versions in this module Expand all Collapse all v1 v1.1.1 Feb 3, 2022 v1.1.0 May 17, 2021 v1.0.0 May 16, 2021 Changes in this version + type Model int + const Normal + const Stream + type Scheduler struct + Enabled bool + ID string + LastHeartbeat int64 + func (s *Scheduler) String() string + type Statistics struct + ExecuteFailCount int64 + ExecuteSpendTime int64 + ExecuteSuccCount int64 + LastFetchTime int64 + OtherCompareCount int64 + SelectCount int64 + SelectItemCount int64 + func (s *Statistics) Execute(succ bool, cost int64) + func (s *Statistics) Select(cnt int64) + type Strategy struct + Bind string + CronBegin string + CronEnd string + Enabled bool + Extra map[string]string + ID string + IPList []string + Kind StrategyKind + MaxOnSingleScheduler int + Parameter string + Total int + func (s *Strategy) String() string + type StrategyKind int + const FuncKind + const SimpleKind + const TaskKind + const UnknownKind + type StrategyRuntime struct + CreateAt int64 + Num int + RequestedNum int + SchedulerID string + StrategyID string + func (s *StrategyRuntime) String() string + type Task struct + BatchCount int + Bind string + DeathTimeout int + ExecutorCount int + FetchCount int + HeartbeatInterval int + ID string + Interval int + IntervalNoData int + Items []TaskItem + MaxTaskItems int + Model Model + Parameter string + func (t *Task) String() string + type TaskAssignment struct + ItemID string + Parameter string + RequestedRuntimeID string + RuntimeID string + StrategyID string + TaskID string + func (assign *TaskAssignment) String() string + type TaskItem struct + ID string + Parameter string + func (item *TaskItem) String() string + type TaskRuntime struct + Bind string + Createtime int64 + ExecutorCount int + Hostname string + ID string + IP string + LastHeartbeat int64 + NextRunnable int64 + OwnSign string + SchedulerID string + Statistics Statistics + StrategyID string + TaskID string + Version int64
Go to main page