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         acts_as_versioned(ignore=['last_changed', 'last_checked'])
  19
  20         @classmethod
  21         def by_hostname(cls, hostname):
  22                 return cls.query.filter_by(hostname=hostname).first()
  23
  24 class HistoryPCURecord(Entity):
  25         plc_pcuid = Field(Int,primary_key=True)
  26
  27         last_checked = Field(DateTime,default=datetime.now)
  28         last_changed = Field(DateTime,default=datetime.now)
  29         status = Field(String,default="unknown")
  30
  31         last_valid = Field(DateTime,default=None)
  32         valid  = Field(String,default="unknown")
  33
  34         acts_as_versioned(ignore=['last_changed', 'last_checked'])
  35
  36         @classmethod
  37         def by_pcuid(cls, pcuid):
  38                 return cls.query.filter_by(pcuid=pcuid).first()
  39
  40
  41 class HistorySiteRecord(Entity):
  42         loginbase = Field(String(250),primary_key=True)
  43
  44         last_checked = Field(DateTime,default=datetime.now)
  45         last_changed = Field(DateTime,default=datetime.now)
  46
  47         nodes_total = Field(Int,default=0)
  48         nodes_up = Field(Int,default=0)
  49         slices_total = Field(Int,default=0)
  50         slices_used = Field(Int,default=0)
  51
  52         # all nodes offline and never-contact.
  53         new = Field(Boolean,default=False)
  54
  55         enabled = Field(Boolean,default=False)
  56
  57         status = Field(String,default="unknown")
  58
  59         message_id = Field(Int, default=0)
  60         message_status = Field(String, default=None)
  61         message_queue = Field(String, default=None)
  62         message_created = Field(DateTime, default=None)
  63
  64         penalty_level   = Field(Int, default=0)
  65         penalty_applied = Field(Boolean, default=False)
  66         acts_as_versioned(ignore=['last_changed', 'last_checked'])
  67
  68         @classmethod
  69         def by_loginbase(cls, loginbase):
  70                 return cls.query.filter_by(loginbase=loginbase).first()
  71