mongodb

Documentation

Index

• type Connector
  • func New(c *Connector) (*Connector, error)
  • func (c *Connector) DeleteJobCollection(name string)
  • func (c *Connector) GetJobCollection() ([]JobCollection, error)
  • func (c *Connector) GetOneJobCollection(name string) (JobCollection, error)
  • func (c *Connector) GetTasks(id primitive.ObjectID) ([]TaskCollection, error)
  • func (c *Connector) InsertJobCollection(payload *JobCollection) (primitive.ObjectID, error)
  • func (c *Connector) InsertTask(id primitive.ObjectID, params ...interface{}) error
  • func (c *Connector) Ping() error
  • func (c *Connector) UpdateJobCollection(id primitive.ObjectID, payload *JobCollection, e int)
• type JobCollection
• type TaskCollection

Types

type Connector

type Connector struct {
	DB     string // The MongoDB uri
	DBName string // Database name from MongoDB
	// contains filtered or unexported fields
}

Connector mongodb instance

func New

func New(c *Connector) (*Connector, error)

New to create a new Mongodb connection

func (*Connector) DeleteJobCollection

func (c *Connector) DeleteJobCollection(name string)

func (*Connector) GetJobCollection

func (c *Connector) GetJobCollection() ([]JobCollection, error)

func (*Connector) GetOneJobCollection

func (c *Connector) GetOneJobCollection(name string) (JobCollection, error)

func (*Connector) GetTasks

func (c *Connector) GetTasks(id primitive.ObjectID) ([]TaskCollection, error)

func (*Connector) InsertJobCollection

func (c *Connector) InsertJobCollection(payload *JobCollection) (primitive.ObjectID, error)

func (*Connector) InsertTask

func (c *Connector) InsertTask(id primitive.ObjectID, params ...interface{}) error

func (*Connector) Ping

func (c *Connector) Ping() error

Ping to check connection status

func (*Connector) UpdateJobCollection

func (c *Connector) UpdateJobCollection(id primitive.ObjectID, payload *JobCollection, e int)

type JobCollection

type JobCollection struct {
	ID          primitive.ObjectID `bson:"_id"`
	JobName     string             `bson:"job_name"`
	FuncName    string             `bson:"func_name"`
	CronFormat  []string           `bson:"cron_format"`
	NextDate    time.Time          `bson:"next_date"`
	TotalTask   int                `bson:"total_task"`
	TotalRun    int                `bson:"total_run"`
	TotalError  int                `bson:"total_error"`
	SuccessRate float64            `bson:"success_rate"`
	ErrorRate   float64            `bson:"error_rate"`
}

type TaskCollection

type TaskCollection struct {
	JobId  primitive.ObjectID `bson:"job_id"`
	Params []interface{}      `bson:"params"`
}