scheduler

Nov 6, 2018

Changes in this version

+ var ErrNotStopping = errors.New("not stopping")

+ type IPScheduler struct

+ func NewIPScheduler(config config.Config, etcd *clientv3.Client, storage models.Storage) *IPScheduler

+ func (s *IPScheduler) ConfiguredIPs(ctx context.Context) []api.IP

+ func (s *IPScheduler) GetIP(ctx context.Context, id string) *api.IP

+ func (s *IPScheduler) Start(ctx context.Context, ipAddr models.IP) (models.IP, error)

+ func (s *IPScheduler) Status(id string) string

+ func (s *IPScheduler) Stop(ctx context.Context, id string) error

+ func (s *IPScheduler) TryGetLock(ctx context.Context, id string) bool

+ type Scheduler interface

+ ConfiguredIPs func(ctx context.Context) []api.IP

+ GetIP func(ctx context.Context, id string) *api.IP

+ Start func(context.Context, models.IP) (models.IP, error)

+ Status func(string) string

+ Stop func(ctx context.Context, id string) error

+ TryGetLock func(ctx context.Context, id string) bool