escheduler

Sep 7, 2023

Changes in this version

type Master

+ HashBalancer balancer.Balancer

+ RoundRobinBalancer balancer.Balancer

+ func (m *Master) Campaign(ctx context.Context) (err error)

+ func (s *Master) ElectionKey() string

Aug 22, 2023

Changes in this version

+ const WorkerStatusRegistered

type Node

+ MaxNumNodes int

+ func (n *Node) Validate() error

type Worker

+ func (w *Worker) Add(task Task)

+ func (w *Worker) Del(id string)

+ func (w *Worker) IsAllRunning() bool

+ func (w *Worker) SetStatus(status string)

Mar 24, 2023

Changes in this version

type Task

+ P float64

+ type WorkerTask struct

Feb 26, 2023

Changes in this version

+ func ParseTaskIDFromTaskKey(rootName, key string) (string, error)

+ func ParseWorkerIDFromTaskKey(rootName, key string) (string, error)

+ func ParseWorkerIDFromWorkerKey(rootName, key string) (string, error)

Feb 18, 2023

Changes in this version

+ type Master interface

+ NotifySchedule func(string)

+ Start func()

+ Stop func()

+ func NewMaster(config MasterConfig, node Node) (Master, error)

+ type MasterConfig struct

+ Generator Generator

+ Interval time.Duration

+ ReBalanceWait time.Duration

+ Timeout time.Duration

+ func (sc MasterConfig) Validation() error

Feb 10, 2023

Changes in this version

type SchedulerConfig

+ Timeout time.Duration

Jan 9, 2023

Changes in this version

type Task

+ func ParseTaskFromValue(value []byte) (task Task, err error)

Nov 21, 2022

Changes in this version

type Node

+ Name string

+ func (n Node) GetDefaultName() (string, error)

Oct 25, 2022

Changes in this version

+ type Assigner struct

+ func (a *Assigner) GetBalancer(key, group string) (balancer.Balancer, error)

+ func (a *Assigner) GetReBalanceResult(workerList []string, taskMap map[string]Task, taskPathResp []*mvccpb.KeyValue) (toDeleteWorkerTaskKey map[string]struct{}, toDeleteTaskKey []string, ...)

type Task

+ Group string

+ ID string

Sep 23, 2022

Changes in this version

+ type Watcher struct

+ Blocking bool

+ EventChan <-chan *clientv3.Event

+ IncipientKVs []*mvccpb.KeyValue

+ func NewWatcher(ctx context.Context, client *clientv3.Client, pathPrefix string) (*Watcher, error)

Sep 20, 2022

Changes in this version

+ const WorkerValueRunning

Aug 5, 2022

Changes in this version

type Worker

+ Tasks func(ctx context.Context) (map[string]struct{}, error)

Jul 14, 2022

Changes in this version

+ func GetWorkerBarrierLeftKey(rootName string) string

Jul 5, 2022

Changes in this version

+ const WorkerStatusRegister

+ var ErrWorkerNumExceedMaximum = errors.New("worker num exceed maximum")

+ func GetWorkerBarrierStatusKey(rootName string) string

type Node

+ CustomName string

Jul 1, 2022

Changes in this version

type Task

+ Pr uint16

type TaskChange

+ func (t TaskChange) String() string

Jun 30, 2022

Changes in this version

+ const WorkerStatusDead

+ const WorkerStatusInBarrier

+ const WorkerStatusLeftBarrier

+ const WorkerStatusNew

+ var ErrWorkerStatusNotInBarrier = errors.New("worker status is not runnable")

type Worker

+ Status func() string

+ TryLeaveBarrier func() error

+ WatchStatus func(chan<- string)

+ WatchTask func() <-chan WatchEvent

Jun 30, 2022

Changes in this version

type TaskChange

+ func (t TaskChange) CreatedTask() Task

+ func (t TaskChange) DeletedTask() string

+ type WatchEvent interface

+ CreatedTask func() Task

+ DeletedTask func() string

Jun 28, 2022

Changes in this version

+ const ReasonFirstSchedule

+ func GetSchedulerBarrierName(rootName string) string

+ func GetWorkerBarrierName(rootName string) string

+ func ParseTaskAbbrFromTaskKey(key string) (string, error)

+ type Generator func(ctx context.Context) ([]Task, error)

type Node

+ MaxNum int

type Task

+ Abbr string

+ func ParseTaskFromKV(key []byte, value []byte) (task Task, err error)

+ type WorkerConfig struct

Jun 27, 2022

Changes in this version

+ const ActionDeleted

+ const ActionNew

+ var ErrSchedulerClosed = errors.New("scheduler was closed")

+ func Debounce(d time.Duration, fn func()) func()

+ func GetLocalIP() (ipv4 string, err error)

+ func ParseWorkerFromTaskKey(key string) string

+ func ParseWorkerFromWorkerKey(key string) (string, error)

+ func PeriodSchedule(ctx context.Context, interval time.Duration) func(ctx context.Context) error

+ type Node struct

+ EtcdConfig clientv3.Config

+ RootName string

+ TTL int64

+ func (n *Node) Validation() error

+ type RawData []byte

+ func ParseTaskFromTaskKey(key string) (RawData, error)

+ type Scheduler interface

+ NotifySchedule func(string)

+ Start func(ctx context.Context) error

+ Stop func()

+ func NewScheduler(config SchedulerConfig, node Node) (Scheduler, error)

+ type SchedulerConfig struct

+ ExpectedWorkerNum int

+ Generator func(ctx context.Context) ([]Task, error)

+ Interval time.Duration

+ ReBalanceWait time.Duration

+ func (sc SchedulerConfig) Validation() error

+ type Task struct

+ Key string

+ Raw RawData

+ type TaskChange struct

+ Action int

+ Task RawData

+ type Worker interface

+ Start func(ctx context.Context) (chan TaskChange, error)

+ Stop func()

+ func NewWorker(node Node) (Worker, error)