svc

Documentation

Index

• Variables
• func RegisterDrivers(svcCtx *ServiceContext)
• type DriverCenter
  • func (d *DriverCenter) GetDriver(id int64) (driver.Driver, error)
  • func (dc *DriverCenter) InitDriver(OutTime time.Duration, enabledStoreages []*storage_manager.StorageModel)
  • func (dc *DriverCenter) UpdataStorageStatus(scv *ServiceContext)
• type ServiceContext
  • func NewServiceContext(c config.Config) *ServiceContext

Variables

var TRYTIMES = 3

var WAITTIME = 10

Functions

func RegisterDrivers

func RegisterDrivers(svcCtx *ServiceContext)

Types

type DriverCenter

type DriverCenter struct {
	Total   int64
	Success int64

	Failed map[int64]error
	// contains filtered or unexported fields
}

func (*DriverCenter) GetDriver

func (d *DriverCenter) GetDriver(id int64) (driver.Driver, error)

func (*DriverCenter) InitDriver

func (dc *DriverCenter) InitDriver(OutTime time.Duration, enabledStoreages []*storage_manager.StorageModel)

func (*DriverCenter) UpdataStorageStatus

func (dc *DriverCenter) UpdataStorageStatus(scv *ServiceContext)

type ServiceContext

type ServiceContext struct {
	Config           config.Config
	StorageManageRpc storagemanager.StorageManager
	DriverCenter     DriverCenter
}

func NewServiceContext

func NewServiceContext(c config.Config) *ServiceContext