scheduler

Documentation

Index

• Variables
• type IPScheduler
  • 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

Variables

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

Types

type IPScheduler

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

func NewIPScheduler

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

func (*IPScheduler) ConfiguredIPs

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

func (*IPScheduler) GetIP

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

func (*IPScheduler) Start

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

func (*IPScheduler) Status

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

func (*IPScheduler) Stop

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

func (*IPScheduler) TryGetLock

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

type Scheduler

type Scheduler interface {
	Start(context.Context, models.IP) (models.IP, error)
	Stop(ctx context.Context, id string) error
	Status(string) string
	ConfiguredIPs(ctx context.Context) []api.IP
	GetIP(ctx context.Context, id string) *api.IP
	TryGetLock(ctx context.Context, id string) bool
}