models

package

Go to main page

Versions in this module

v0

v0.3.7

Feb 3, 2022

v0.3.6

Feb 3, 2022

v0.3.5

Feb 3, 2022

Changes in this version

+ func CreateScheduledJob(name string, handler string, args string, addToQueueAt time.Time) error

+ func InitializeTestDb() error

type Job

+ AddToQueueAt time.Time

+ EnqueuedAt time.Time

+ func FirstJob(status string, claimed bool) (*Job, error)

+ func FirstScheduledJobToBeQueued() (*Job, error)

type Probe

+ MaxRetries int

+ WaitTimeInMinutes int

+ func FetchPendingProbesWithElapsedWait() ([]Probe, error)

+ func (probe *Probe) Update(data map[string]interface{}) error

type ProbeSetting

+ MaxRetries int

+ WaitTimeInMinutes int

v0.3.4

Jan 11, 2022

Changes in this version

+ const MAX_PAGE_SIZE

+ const MIN_PAGE_SIZE

+ var ErrDuplicateContactEmail = errors.New("contact with the same 'email' already exist")

+ var ErrDuplicateContactNumber = errors.New("contact with the same 'phone_number' already exist")

+ var ErrDuplicateUserEmail = errors.New("user with the same 'email' already exist")

+ var ErrDuplicateUserNumber = errors.New("user with the same 'phone_number' already exist")

+ func FetchJobs(page int) ([]Job, *Paging, error)

+ func FetchJobsByStatus(status string, page int) ([]Job, *Paging, error)

+ func FetchProbes(page int, query interface{}, args ...interface{}) ([]Probe, *Paging, error)

+ func FetchProbesByStatus(status, order string, page int) ([]Probe, *Paging, error)

+ func FetchUsers(page int) ([]User, *Paging, error)

type Job

+ JobStatus *JobStatus

+ type Paging struct

+ Page int64

+ Pages int64

+ Total int64

type Probe

+ ProbeStatus *ProbeStatus

type User

+ func (user *User) FetchContacts(page int) ([]Contact, *Paging, error)

v0.3.3

Dec 24, 2021

v0.3.2

Dec 24, 2021

Changes in this version

type User

+ func AllUsersWithProbeSettings() ([]User, error)

+ func (user *User) LoadProbeSettings() error

v0.3.1

Dec 23, 2021

v0.3.0

Dec 23, 2021

Changes in this version

+ const ADMIN_USER_ROLE

+ const BAD_PROBE

+ const BASIC_USER_ROLE

+ const CANCELLED_PROBE

+ const DB_NAME

+ const DEAD_JOB

+ const DEFAULT_PROBE_CRON_DAY

+ const DEFAULT_PROBE_CRON_HOUR

+ const DEFAULT_PROBE_CRON_MINUTE

+ const ENQUEUED_JOB

+ const GOOD_PROBE

+ const IN_PROGRESS_JOB

+ const PENDING_PROBE

+ const SCHEDULED_JOB

+ const SUCCESSFUL_JOB

+ const UNAVAILABLE_PROBE

+ var CRON_DAY_MAPPINGS = map[string]string

+ var DEFAULT_PROBE_CRON_EXPRESSION = fmt.Sprintf("%v %v * * %v", DEFAULT_PROBE_CRON_MINUTE, DEFAULT_PROBE_CRON_HOUR, ...)

+ var ErrDuplicateJob = errors.New("job with the given name already exists in queue")

+ var JobStatusNameMap = map[string]bool

+ var ProbeStatusMapToResponse = map[string]map[string]bool

+ var ProbeStatusNameMap = map[string]bool

+ func AtLeastOneUserExists() (bool, error)

+ func CreateEmergencyProbe(probeID, contactID interface{}) error

+ func CreateProbe(userID interface{}) error

+ func CreateUniqueJobByName(name string, handler string, args string) error

+ func CreateUser(user *User) error

+ func DbDirectory(dbRootDir string) (string, error)

+ func DeleteUser(id interface{}) error

+ func FindUserPassword(email string) (string, error)

+ func InitialiazeDb(passPhrase string, dbRootDir string, storage *gstorage.GStorage) error

+ func SetProbeStatus(probeID interface{}, status string) error

+ type BaseModel struct

+ CreatedAt time.Time

+ ID uint

+ UpdatedAt time.Time

+ type Contact struct

+ Email string

+ EmergencyProbes []EmergencyProbe

+ FirstName string

+ IsEmergencyContact bool

+ LastName string

+ PhoneNumber string

+ UserID uint

+ type EmergencyProbe struct

+ ContactID uint

+ ProbeID uint

+ type Job struct

+ Args string

+ Claimed bool

+ Fails int

+ Handler string

+ JobStatusID uint

+ LastError string

+ Name string

+ func JobsByStatus(status string) ([]Job, error)

+ func LastJob(status string, claimed bool) (*Job, error)

+ func LastJobLastUpdated(minutesAgo uint, status string) (*Job, error)

+ func (job *Job) MarkAsClaimed() (bool, error)

+ func (job *Job) Update(data map[string]interface{}) error

+ type JobStatus struct

+ Jobs []Job

+ Name string

+ func FindJobStatus(name string) (*JobStatus, error)

+ type JobsStats struct

+ DeadJobCount int64

+ EnueuedJobCount int64

+ InProgressJobCount int64

+ SuccessfulJobCount int64

+ func CurrentJobsStats() (*JobsStats, error)

+ type Probe struct

+ EmergencyProbe EmergencyProbe

+ LastResponse string

+ ProbeStatusID uint

+ RetryCount int

+ UserID uint

+ func FindProbe(id interface{}) (*Probe, error)

+ func ProbesByStatus(status, order string) ([]Probe, error)

+ func (probe *Probe) IsPending() (bool, error)

+ func (probe *Probe) Save() error

+ func (probe *Probe) StatusFromLastResponse() string

+ type ProbeSetting struct

+ Active bool

+ CronExpression string

+ UserID uint

+ func FindProbeSettings(userID interface{}) (*ProbeSetting, error)

+ type ProbeStats struct

+ BadProbeCount int64

+ CancelledProbeCount int64

+ GoodProbeCount int64

+ PendingProbeCount int64

+ UnavailableProbeCount int64

+ func CurrentProbeStats() (*ProbeStats, error)

+ type ProbeStatus struct

+ Name string

+ Probes []Probe

+ func FindProbeStatus(name string) (*ProbeStatus, error)

+ type Role struct

+ Name string

+ Users []User

+ func FindRole(name string) (*Role, error)

+ type User struct

+ Contacts []Contact

+ Email string

+ FirstName string

+ LastName string

+ Password string

+ PhoneNumber string

+ ProbeSettings *ProbeSetting

+ Probes []Probe

+ RoleID uint

+ func FindUserBy(field string, value interface{}) (*User, error)

+ func FindUserWithProbeSettiings(userID interface{}) (*User, error)

+ func UsersWithActiveProbe() ([]User, error)

+ func (user *User) AddContact(contact *Contact) error

+ func (user *User) CancelAllPendingProbes() error

+ func (user *User) DeleteContact(id interface{}) error

+ func (user *User) DisableLivlinessProbe() error

+ func (user *User) EmergencyContact() (*Contact, error)

+ func (user *User) IsAdmin() (bool, error)

+ func (user *User) IsProbeEnabled() (bool, error)

+ func (user *User) LastProbe() (*Probe, error)

+ func (user *User) LoadContacts() error

+ func (user *User) Update(data map[string]interface{}) error

+ func (user *User) UpdateContact(contactID string, data map[string]interface{}) error

+ func (user *User) UpdateProbSettings(data map[string]interface{}) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL