reset

Documentation

Index

• Constants
• type SchedulerService
• type Service
  • func NewResetService(etcdClient *clientv3.Client, k8sClient clientset.Interface, ...) (*Service, error)
  • func (s *Service) Reset(ctx context.Context) error

Constants

const EtcdPrefix = "/kube-scheduler-simulator"

Types

type SchedulerService

type SchedulerService interface {
	ResetScheduler() error
}

type Service

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

Service cleans up resources stored in etcd.

func NewResetService

func NewResetService(
	etcdClient *clientv3.Client,
	k8sClient clientset.Interface,
	schedService SchedulerService,
) (*Service, error)

NewResetService initializes Service. ResetService always tries to restore the cluster to the initial state.

func (*Service) Reset

func (s *Service) Reset(ctx context.Context) error

Reset resets all resources and scheduler configuration to the initial state.