mongo

Documentation

Index

• type MongoStatistics
  • func NewMongoStatistics(conn string, databaseName string, logger *log.Logger) (*MongoStatistics, error)
  • func (m *MongoStatistics) Available() bool
  • func (m *MongoStatistics) DeletedJobs() float64
  • func (m *MongoStatistics) EnqueuedJobs() float64
  • func (m *MongoStatistics) FailedJobs() float64
  • func (m *MongoStatistics) FetchedJobs() float64
  • func (m *MongoStatistics) ProcessingJobs() float64
  • func (m *MongoStatistics) Queues() float64
  • func (m *MongoStatistics) RecurringJobs() float64
  • func (m *MongoStatistics) ScheduledJobs() float64
  • func (m *MongoStatistics) Servers() float64
  • func (m *MongoStatistics) SucceededJobs() float64

Types

type MongoStatistics

type MongoStatistics struct {
	// contains filtered or unexported fields
}

MongoStatistics is a MongoDB implementation to get hangfire statistics

func NewMongoStatistics

func NewMongoStatistics(conn string, databaseName string, logger *log.Logger) (*MongoStatistics, error)

NewMongoStatistics creates a new MongoStatistics

func (*MongoStatistics) Available

func (m *MongoStatistics) Available() bool

Available checks if the hangfire database is reachable

func (*MongoStatistics) DeletedJobs

func (m *MongoStatistics) DeletedJobs() float64

DeletedJobs gets the total number of deleted jobs

func (*MongoStatistics) EnqueuedJobs

func (m *MongoStatistics) EnqueuedJobs() float64

EnqueuedJobs gets the current number of enqueued jobs

func (*MongoStatistics) FailedJobs

func (m *MongoStatistics) FailedJobs() float64

FailedJobs gets the total number of failed jobs

func (*MongoStatistics) FetchedJobs

func (m *MongoStatistics) FetchedJobs() float64

FetchedJobs gets the current number of fetched jobs

func (*MongoStatistics) ProcessingJobs

func (m *MongoStatistics) ProcessingJobs() float64

ProcessingJobs gets the current number of processing jobs

func (*MongoStatistics) Queues

func (m *MongoStatistics) Queues() float64

Queues gets the current number of queues

func (*MongoStatistics) RecurringJobs

func (m *MongoStatistics) RecurringJobs() float64

RecurringJobs gets the current number of recurring jobs

func (*MongoStatistics) ScheduledJobs

func (m *MongoStatistics) ScheduledJobs() float64

ScheduledJobs gets the current nubmer of scheduled jobs

func (*MongoStatistics) Servers

func (m *MongoStatistics) Servers() float64

Servers gets the number of registered servers on hangfire database

func (*MongoStatistics) SucceededJobs

func (m *MongoStatistics) SucceededJobs() float64

SucceededJobs gets the total number of succeeded jobs