storage

Documentation

Index

• func RegisterStorageUser(user StorageUser)
• type ForEachContainerTemplateCB
• type ForEachJobCB
• type MaestroDBInstance
  • func GetStorage() (ret *MaestroDBInstance)
  • func InitStorage(path string) (ret *MaestroDBInstance, err error)
  • func (this *MaestroDBInstance) Close()
  • func (this *MaestroDBInstance) DeleteContainerTemplate(byname string) error
  • func (this *MaestroDBInstance) DeleteJob(byname string) error
  • func (this *MaestroDBInstance) ForEachContainerTemplate(cb ForEachContainerTemplateCB) error
  • func (this *MaestroDBInstance) ForEachJob(cb ForEachJobCB) error
  • func (this *MaestroDBInstance) GetContainerTemplateByName(byname string) (templ maestroSpecs.ContainerTemplate, err error)
  • func (this *MaestroDBInstance) GetDb() *bolt.DB
  • func (this *MaestroDBInstance) GetDbName() string
  • func (this *MaestroDBInstance) GetJobByName(byname string) (job maestroSpecs.JobDefinition, err error)
  • func (this *MaestroDBInstance) GetStatsConfig() (ret maestroSpecs.StatsConfig, err error)
  • func (this *MaestroDBInstance) SetStatsConfig(obj maestroSpecs.StatsConfig) error
  • func (this *MaestroDBInstance) UpsertContainerTemplate(obj maestroSpecs.ContainerTemplate) error
  • func (this *MaestroDBInstance) UpsertJob(obj maestroSpecs.JobDefinition) error
  • func (this *MaestroDBInstance) UpsertJobAsPayload(obj *maestroSpecs.JobDefinitionPayload) error
• type MaestroDBStorageInterface
• type StorageReadyCB
• type StorageUser

Functions

func RegisterStorageUser

func RegisterStorageUser(user StorageUser)

Types

type ForEachContainerTemplateCB

type ForEachContainerTemplateCB func(job maestroSpecs.ContainerTemplate)

type ForEachJobCB

type ForEachJobCB func(job maestroSpecs.JobDefinition)

type MaestroDBInstance

type MaestroDBInstance struct {
	//	db *leveldb.DB
	Db *bolt.DB
	// contains filtered or unexported fields
}

func GetStorage

func GetStorage() (ret *MaestroDBInstance)

func InitStorage

func InitStorage(path string) (ret *MaestroDBInstance, err error)

func (*MaestroDBInstance) Close

func (this *MaestroDBInstance) Close()

func (*MaestroDBInstance) DeleteContainerTemplate

func (this *MaestroDBInstance) DeleteContainerTemplate(byname string) error

func (*MaestroDBInstance) DeleteJob

func (this *MaestroDBInstance) DeleteJob(byname string) error

func (*MaestroDBInstance) ForEachContainerTemplate

func (this *MaestroDBInstance) ForEachContainerTemplate(cb ForEachContainerTemplateCB) error

func (*MaestroDBInstance) ForEachJob

func (this *MaestroDBInstance) ForEachJob(cb ForEachJobCB) error

func (*MaestroDBInstance) GetContainerTemplateByName

func (this *MaestroDBInstance) GetContainerTemplateByName(byname string) (templ maestroSpecs.ContainerTemplate, err error)

func (*MaestroDBInstance) GetDb

func (this *MaestroDBInstance) GetDb() *bolt.DB

func (*MaestroDBInstance) GetDbName

func (this *MaestroDBInstance) GetDbName() string

func (*MaestroDBInstance) GetJobByName

func (this *MaestroDBInstance) GetJobByName(byname string) (job maestroSpecs.JobDefinition, err error)

func (*MaestroDBInstance) GetStatsConfig

func (this *MaestroDBInstance) GetStatsConfig() (ret maestroSpecs.StatsConfig, err error)

func (*MaestroDBInstance) SetStatsConfig

func (this *MaestroDBInstance) SetStatsConfig(obj maestroSpecs.StatsConfig) error

func (*MaestroDBInstance) UpsertContainerTemplate

func (this *MaestroDBInstance) UpsertContainerTemplate(obj maestroSpecs.ContainerTemplate) error

func (*MaestroDBInstance) UpsertJob

func (this *MaestroDBInstance) UpsertJob(obj maestroSpecs.JobDefinition) error

func (*MaestroDBInstance) UpsertJobAsPayload

func (this *MaestroDBInstance) UpsertJobAsPayload(obj *maestroSpecs.JobDefinitionPayload) error

type MaestroDBStorageInterface

type MaestroDBStorageInterface interface {
	GetDb() *bolt.DB
	GetDbName() string
}

type StorageReadyCB

type StorageReadyCB func(instance *MaestroDBInstance)

type StorageUser

type StorageUser interface {
	// called when the DB is open and ready
	StorageReady(instance MaestroDBStorageInterface)
	// called when the DB is initialized
	StorageInit(instance MaestroDBStorageInterface)
	// called when storage is closed
	StorageClosed(instance MaestroDBStorageInterface)
}

type StorageUser interface {
	// called when the DB is open and ready
	StorageReady(instance *MaestroDBInstance)
	// called when the DB is initialized
	StorageInit(instance *MaestroDBInstance)
	// called when storage is closed
	StorageClosed(instance *MaestroDBInstance)
}