diff --git a/schedulers/base.go b/schedulers/base.go new file mode 100644 index 0000000..544ae5b --- /dev/null +++ b/schedulers/base.go @@ -0,0 +1,51 @@ +package schedulers + +import ( + mesos "github.com/mesos/mesos-go/mesosproto" + sched "github.com/mesos/mesos-go/scheduler" + "log" +) + +type base struct { +} + +func (s *base) OfferRescinded(_ sched.SchedulerDriver, offerID *mesos.OfferID) { + log.Printf("Offer %s rescinded", offerID) +} +func (s *base) SlaveLost(_ sched.SchedulerDriver, slaveID *mesos.SlaveID) { + log.Printf("Slave %s lost", slaveID) +} +func (s *base) ExecutorLost(_ sched.SchedulerDriver, + executorID *mesos.ExecutorID, + slaveID *mesos.SlaveID, status int) { + log.Printf("Executor %s on slave %s was lost", executorID, slaveID) +} + +func (s *base) Error(_ sched.SchedulerDriver, err string) { + log.Printf("Receiving an error: %s", err) +} + +func (s *base) FrameworkMessage( + driver sched.SchedulerDriver, + executorID *mesos.ExecutorID, + slaveID *mesos.SlaveID, + message string) { + + log.Println("Getting a framework message: ", message) + log.Printf("Received a framework message from some unknown source: %s", *executorID.Value) +} + +func (s *base) Registered( + _ sched.SchedulerDriver, + frameworkID *mesos.FrameworkID, + masterInfo *mesos.MasterInfo) { + log.Printf("Framework %s registered with master %s", frameworkID, masterInfo) +} + +func (s *base) Reregistered(_ sched.SchedulerDriver, masterInfo *mesos.MasterInfo) { + log.Printf("Framework re-registered with master %s", masterInfo) +} + +func (s *base) Disconnected(sched.SchedulerDriver) { + log.Println("Framework disconnected with master") +}