monitor/database/info/history.py

   1 from elixir import Entity, Field, OneToMany, ManyToOne, ManyToMany
   2 from elixir import options_defaults, using_options, setup_all
   3 from elixir import String, Integer as Int, DateTime, Boolean
   4 from elixir.ext.versioned import *
   5
   6 from datetime import datetime,timedelta
   7
   8 from monitor.database.dborm import mon_metadata, mon_session
   9 __metadata__ = mon_metadata
  10 __session__  = mon_session
  11
  12 # your data model
  13 class HistoryNodeRecord(Entity):
  14         hostname = Field(String(250),primary_key=True)
  15         last_checked = Field(DateTime,default=datetime.now)
  16         last_changed = Field(DateTime,default=datetime.now)
  17         status = Field(String,default="unknown")
  18         haspcu = Field(Boolean,default=False)
  19         acts_as_versioned(ignore=['last_changed', 'last_checked'])
  20
  21         @classmethod
  22         def by_hostname(cls, hostname):
  23                 return cls.query.filter_by(hostname=hostname).first()
  24
  25 class HistoryPCURecord(Entity):
  26         plc_pcuid = Field(Int,primary_key=True)
  27
  28         last_checked = Field(DateTime,default=datetime.now)
  29         last_changed = Field(DateTime,default=datetime.now)
  30         status = Field(String,default="unknown")
  31
  32         last_valid = Field(DateTime,default=None)
  33         valid  = Field(String,default="unknown")
  34
  35         acts_as_versioned(ignore=['last_changed', 'last_checked'])
  36
  37         @classmethod
  38         def by_pcuid(cls, pcuid):
  39                 return cls.query.filter_by(pcuid=pcuid).first()
  40
  41
  42 class HistorySiteRecord(Entity):
  43         loginbase = Field(String(250),primary_key=True)
  44
  45         last_checked = Field(DateTime,default=datetime.now)
  46         last_changed = Field(DateTime,default=datetime.now)
  47
  48         nodes_total = Field(Int,default=0)
  49         nodes_up = Field(Int,default=0)
  50         slices_total = Field(Int,default=0)
  51         slices_used = Field(Int,default=0)
  52
  53         # all nodes offline and never-contact.
  54         new = Field(Boolean,default=False)
  55
  56         enabled = Field(Boolean,default=False)
  57
  58         status = Field(String,default="unknown")
  59
  60         message_id = Field(Int, default=0)
  61         message_status = Field(String, default=None)
  62         message_queue = Field(String, default=None)
  63         message_created = Field(DateTime, default=None)
  64
  65         penalty_level   = Field(Int, default=0)
  66         penalty_applied = Field(Boolean, default=False)
  67         acts_as_versioned(ignore=['last_changed', 'last_checked'])
  68
  69         @classmethod
  70         def by_loginbase(cls, loginbase):
  71                 return cls.query.filter_by(loginbase=loginbase).first()
  72