db

Documentation

Index

• Constants
• Variables
• type BoltDB
  • func (b *BoltDB) CreateWorkload(w *wltypes.RDTWorkLoad) error
  • func (b *BoltDB) DeleteWorkload(w *wltypes.RDTWorkLoad) error
  • func (b *BoltDB) GetAllWorkload() ([]wltypes.RDTWorkLoad, error)
  • func (b *BoltDB) GetWorkloadByID(id string) (wltypes.RDTWorkLoad, error)
  • func (b *BoltDB) GetWorkloadByUUID(id string) (wltypes.RDTWorkLoad, error)
  • func (b *BoltDB) Initialize(transport, dbname string) error
  • func (b *BoltDB) QueryWorkload(query map[string]interface{}) ([]wltypes.RDTWorkLoad, error)
  • func (b *BoltDB) UpdateWorkload(w *wltypes.RDTWorkLoad) error
  • func (b *BoltDB) ValidateWorkload(w *wltypes.RDTWorkLoad) error
• type DB
  • func NewDB() (DB, error)
• type MgoDB
  • func (m *MgoDB) CreateWorkload(w *wltypes.RDTWorkLoad) error
  • func (m *MgoDB) DeleteWorkload(w *wltypes.RDTWorkLoad) error
  • func (m *MgoDB) GetAllWorkload() ([]wltypes.RDTWorkLoad, error)
  • func (m *MgoDB) GetWorkloadByID(id string) (wltypes.RDTWorkLoad, error)
  • func (m *MgoDB) GetWorkloadByUUID(id string) (wltypes.RDTWorkLoad, error)
  • func (m *MgoDB) Initialize(transport, dbname string) error
  • func (m *MgoDB) QueryWorkload(query map[string]interface{}) ([]wltypes.RDTWorkLoad, error)
  • func (m *MgoDB) UpdateWorkload(w *wltypes.RDTWorkLoad) error
  • func (m *MgoDB) ValidateWorkload(w *wltypes.RDTWorkLoad) error

Constants

const MappingTableName = "mapping"

MappingTableName contains mapping between UUID and WorkloadID

const WorkloadTableName = "workload"

WorkloadTableName is the table name for workload

Variables

var Dbname string

Dbname is database name of mgodb

Types

type BoltDB

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

BoltDB connection

func (*BoltDB) CreateWorkload

func (b *BoltDB) CreateWorkload(w *wltypes.RDTWorkLoad) error

CreateWorkload creates workload in db

func (*BoltDB) DeleteWorkload

func (b *BoltDB) DeleteWorkload(w *wltypes.RDTWorkLoad) error

DeleteWorkload removes workload from db

func (*BoltDB) GetAllWorkload

func (b *BoltDB) GetAllWorkload() ([]wltypes.RDTWorkLoad, error)

GetAllWorkload returns all workloads in db

func (*BoltDB) GetWorkloadByID

func (b *BoltDB) GetWorkloadByID(id string) (wltypes.RDTWorkLoad, error)

GetWorkloadByID by ID

func (*BoltDB) GetWorkloadByUUID

func (b *BoltDB) GetWorkloadByUUID(id string) (wltypes.RDTWorkLoad, error)

GetWorkloadByUUID Returns workload specified by UUID (if such exists in DB)

func (*BoltDB) Initialize

func (b *BoltDB) Initialize(transport, dbname string) error

Initialize creates two buckets: for storing workloads and UUID-ID mapping

func (*BoltDB) QueryWorkload

func (b *BoltDB) QueryWorkload(query map[string]interface{}) ([]wltypes.RDTWorkLoad, error)

QueryWorkload with given params

func (*BoltDB) UpdateWorkload

func (b *BoltDB) UpdateWorkload(w *wltypes.RDTWorkLoad) error

UpdateWorkload updates

func (*BoltDB) ValidateWorkload

func (b *BoltDB) ValidateWorkload(w *wltypes.RDTWorkLoad) error

ValidateWorkload from data base view

type DB

type DB interface {
	Initialize(transport, dbname string) error
	CreateWorkload(w *wltypes.RDTWorkLoad) error
	DeleteWorkload(w *wltypes.RDTWorkLoad) error
	UpdateWorkload(w *wltypes.RDTWorkLoad) error
	GetAllWorkload() ([]wltypes.RDTWorkLoad, error)
	GetWorkloadByID(id string) (wltypes.RDTWorkLoad, error)
	GetWorkloadByUUID(id string) (wltypes.RDTWorkLoad, error)
	ValidateWorkload(w *wltypes.RDTWorkLoad) error
	QueryWorkload(query map[string]interface{}) ([]wltypes.RDTWorkLoad, error)
}

DB is the interface for a db engine

func NewDB

func NewDB() (DB, error)

NewDB return DB connection

type MgoDB

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

MgoDB is connection of mgodb

func (*MgoDB) CreateWorkload

func (m *MgoDB) CreateWorkload(w *wltypes.RDTWorkLoad) error

CreateWorkload creates workload in db

func (*MgoDB) DeleteWorkload

func (m *MgoDB) DeleteWorkload(w *wltypes.RDTWorkLoad) error

DeleteWorkload removes workload from db

func (*MgoDB) GetAllWorkload

func (m *MgoDB) GetAllWorkload() ([]wltypes.RDTWorkLoad, error)

GetAllWorkload returns all workloads in db

func (*MgoDB) GetWorkloadByID

func (m *MgoDB) GetWorkloadByID(id string) (wltypes.RDTWorkLoad, error)

GetWorkloadByID by ID

func (*MgoDB) GetWorkloadByUUID

func (m *MgoDB) GetWorkloadByUUID(id string) (wltypes.RDTWorkLoad, error)

GetWorkloadByUUID Returns workload specified by UUID (if such exists in DB)

func (*MgoDB) Initialize

func (m *MgoDB) Initialize(transport, dbname string) error

Initialize does initialize

func (*MgoDB) QueryWorkload

func (m *MgoDB) QueryWorkload(query map[string]interface{}) ([]wltypes.RDTWorkLoad, error)

QueryWorkload with given params

func (*MgoDB) UpdateWorkload

func (m *MgoDB) UpdateWorkload(w *wltypes.RDTWorkLoad) error

UpdateWorkload updates

func (*MgoDB) ValidateWorkload

func (m *MgoDB) ValidateWorkload(w *wltypes.RDTWorkLoad) error

ValidateWorkload from data base view