scheduler

Apr 18, 2020

Changes in this version

+ const JobBackoff

+ type AntidoteScheduler struct

+ BuildInfo map[string]string

+ Client kubernetes.Interface

+ ClientCrd kubernetesCrd.Interface

+ ClientExt kubernetesExt.Interface

+ Config config.AntidoteConfig

+ Db db.DataManager

+ HealthChecker LessonHealthChecker

+ KubeConfig *rest.Config

+ NC *nats.Conn

+ func (s *AntidoteScheduler) PruneOrphanedNamespaces() error

+ func (s *AntidoteScheduler) PurgeOldLessons(sc ot.SpanContext) ([]string, error)

+ func (s *AntidoteScheduler) PurgeOldSessions(sc ot.SpanContext) error

+ func (s *AntidoteScheduler) Start() error

Aug 7, 2019

Changes in this version

type KubeLab

+ HealthyTests int

+ TotalTests int

type LessonScheduleRequest

+ Lesson *pb.Lesson

type LessonScheduleResult

+ Lesson *pb.Lesson

type LessonScheduler

+ BuildInfo map[string]string

+ Curriculum *pb.Curriculum

Apr 19, 2019

Changes in this version

type LessonScheduler

+ DisableGC bool

+ func (ls *LessonScheduler) PurgeOldLessons() ([]string, error)

Apr 15, 2019

Changes in this version

+ type LessonHealthCheck struct

+ type LessonHealthChecker interface

type LessonScheduler

+ Client kubernetes.Interface

+ ClientCrd kubernetesCrd.Interface

+ ClientExt kubernetesExt.Interface

+ HealthChecker LessonHealthCheck

+ type NetworkCrdClient interface

+ Create func(obj *networkcrd.NetworkAttachmentDefinition) (*networkcrd.NetworkAttachmentDefinition, error)

+ Delete func(name string, options *meta_v1.DeleteOptions) error

+ Get func(name string) (*networkcrd.NetworkAttachmentDefinition, error)

+ List func(opts meta_v1.ListOptions) (*networkcrd.NetworkList, error)

+ Update func(obj *networkcrd.NetworkAttachmentDefinition) (*networkcrd.NetworkAttachmentDefinition, error)

+ UpdateNamespace func(string)

Mar 15, 2019

Changes in this version

type KubeLab

+ CurrentStage int32

+ func (kl *KubeLab) ToProtoKubeLab() *pb.KubeLab

type LessonScheduler

+ KubeLabs map[string]*KubeLab

+ KubeLabsMu *sync.Mutex

type OperationType

+ var OperationType_VERIFY OperationType = 5

Jan 24, 2019

Changes in this version

type KubeLab

+ ReachableEndpoints []string

+ Status pb.Status

type LessonScheduler

+ GcWhiteList map[string]*pb.Session

+ GcWhiteListMu *sync.Mutex

Jan 8, 2019

Changes in this version

+ func HasDevices(ld *pb.LessonDef) bool

+ type Endpoint interface

+ GetImage func() string

+ GetName func() string

+ GetPorts func() []int32

+ GetSshpassword func() string

+ GetSshuser func() string

type LessonScheduleRequest

+ Created time.Time

type LessonScheduleResult

+ ProvisioningTime int

Nov 15, 2018

Changes in this version

type KubeLab

+ Ingresses map[string]*v1beta1.Ingress

Oct 28, 2018

Changes in this version

type LessonScheduler

+ SyringeConfig *config.SyringeConfig

Oct 17, 2018

Changes in this version

+ type KubeLab struct

+ CreateRequest *LessonScheduleRequest

+ LabConnections map[string]string

+ Namespace *corev1.Namespace

+ NetPolicy *netv1.NetworkPolicy

+ Networks map[string]*crd.NetworkAttachmentDefinition

+ Pods map[string]*corev1.Pod

+ Services map[string]*corev1.Service

+ func (kl *KubeLab) ToLiveLesson() *pb.LiveLesson

+ type LessonScheduleRequest struct

+ LessonDef *def.LessonDefinition

+ Operation OperationType

+ Session string

+ Stage int32

+ Uuid string

+ type LessonScheduleResult struct

+ GCLessons []string

+ KubeLab *KubeLab

+ LessonDef *def.LessonDefinition

+ Message string

+ Operation OperationType

+ Session string

+ Stage int32

+ Success bool

+ Uuid string

+ type LessonScheduler struct

+ KubeConfig *rest.Config

+ LessonDefs map[int32]*def.LessonDefinition

+ Requests chan *LessonScheduleRequest

+ Results chan *LessonScheduleResult

+ func (ls *LessonScheduler) Start() error

+ type OperationType int32

+ var OperationType_BOOP OperationType = 3

+ var OperationType_CREATE OperationType = 0

+ var OperationType_DELETE OperationType = 1

+ var OperationType_GC OperationType = 4

+ var OperationType_MODIFY OperationType = 2