mongo

Documentation

Index

• Variables
• func New(parameters types.Parameters) (driver.StorageDriver, error)
• type D
• type Engine
  • func NewEngine(configs MgoConfigs) *Engine
  • func (engine *Engine) Close()
  • func (engine *Engine) Open() error
  • func (engine *Engine) SetConfigParameters(configs MgoConfigs) error
• type M
• type MgoConfigs
• type MongoStorageDriver
  • func (driver *MongoStorageDriver) Close()
  • func (driver *MongoStorageDriver) GetGroupJobs(groupid string) []*models.Job
  • func (driver *MongoStorageDriver) GetJob(jobid string) *models.Job
  • func (driver *MongoStorageDriver) GetJobs() []*models.Job
  • func (driver *MongoStorageDriver) GetLocation(location string) *models.WorkLocation
  • func (driver *MongoStorageDriver) GetLocationJobs(location string) []*models.Job
  • func (driver *MongoStorageDriver) GetLocationSimpleJobs(location string) []*models.SimpleJob
  • func (driver *MongoStorageDriver) GetLocationsName() []string
  • func (driver *MongoStorageDriver) GetSimpleJob(jobid string) *models.SimpleJob
  • func (driver *MongoStorageDriver) GetStateJobs(state int) []*models.Job
  • func (driver *MongoStorageDriver) Open() error
  • func (driver *MongoStorageDriver) SetConfigParameters(parameters types.Parameters)
  • func (driver *MongoStorageDriver) SetJob(job *models.Job)
  • func (driver *MongoStorageDriver) SetJobLog(joblog *models.JobLog)

Variables

var (
	//ErrMongoStorageDriverHostsInvalid is exported, parameters map not has 'hosts' key error.
	ErrMongoStorageDriverHostsInvalid = errors.New("mongo storage driver hosts invalid")
	//ErrMongoStorageDriverDataBaseInvalid is exported, parameters map not has 'database' key error.
	ErrMongoStorageDriverDataBaseInvalid = errors.New("mongo storage driver database invalid")
)

Functions

func New

func New(parameters types.Parameters) (driver.StorageDriver, error)

New is exported

Types

type D

type D bson.D

D is exported

type Engine

type Engine struct {
	MgoConfigs
	// contains filtered or unexported fields
}

Engine is exported

func NewEngine

func NewEngine(configs MgoConfigs) *Engine

NewEngine is exported

func (*Engine) Close

func (engine *Engine) Close()

Close is exported

func (*Engine) Open

func (engine *Engine) Open() error

Open is exported

func (*Engine) SetConfigParameters

func (engine *Engine) SetConfigParameters(configs MgoConfigs) error

SetConfigParameters is exported

type M

type M bson.M

M is exported mongo bson map type define.

type MgoConfigs

type MgoConfigs struct {
	Hosts    string
	DataBase string
	Auth     map[string]string
	Options  []string
}

MgoConfigs is exported

type MongoStorageDriver

type MongoStorageDriver struct {
	sync.RWMutex
	driver.StorageDriver
	// contains filtered or unexported fields
}

MongoStorageDriver is exported

func (*MongoStorageDriver) Close

func (driver *MongoStorageDriver) Close()

Close is exported

func (*MongoStorageDriver) GetGroupJobs

func (driver *MongoStorageDriver) GetGroupJobs(groupid string) []*models.Job

GetGroupJobs is exported

func (*MongoStorageDriver) GetJob

func (driver *MongoStorageDriver) GetJob(jobid string) *models.Job

GetJob is exported

func (*MongoStorageDriver) GetJobs

func (driver *MongoStorageDriver) GetJobs() []*models.Job

GetJobs is exported

func (*MongoStorageDriver) GetLocation

func (driver *MongoStorageDriver) GetLocation(location string) *models.WorkLocation

GetLocation is exported

func (*MongoStorageDriver) GetLocationJobs

func (driver *MongoStorageDriver) GetLocationJobs(location string) []*models.Job

GetLocationJobs is exported

func (*MongoStorageDriver) GetLocationSimpleJobs

func (driver *MongoStorageDriver) GetLocationSimpleJobs(location string) []*models.SimpleJob

GetLocationSimpleJobs is exported

func (*MongoStorageDriver) GetLocationsName

func (driver *MongoStorageDriver) GetLocationsName() []string

GetLocationsName is exported

func (*MongoStorageDriver) GetSimpleJob

func (driver *MongoStorageDriver) GetSimpleJob(jobid string) *models.SimpleJob

GetSimpleJob is exported

func (*MongoStorageDriver) GetStateJobs

func (driver *MongoStorageDriver) GetStateJobs(state int) []*models.Job

GetStateJobs is exported

func (*MongoStorageDriver) Open

func (driver *MongoStorageDriver) Open() error

Open is exported

func (*MongoStorageDriver) SetConfigParameters

func (driver *MongoStorageDriver) SetConfigParameters(parameters types.Parameters)

SetConfigParameters is exported

func (*MongoStorageDriver) SetJob

func (driver *MongoStorageDriver) SetJob(job *models.Job)

SetJob is exported

func (*MongoStorageDriver) SetJobLog

func (driver *MongoStorageDriver) SetJobLog(joblog *models.JobLog)

SetJobLog is exported