manager

Documentation

Index

• Variables
• type GCWorker
  • func (w *GCWorker) Start()
  • func (w *GCWorker) Stop()
• type Manager
  • func NewManagerService(cfg *ManagerConfig) (*Manager, error)
  • func (m *Manager) Name() string
  • func (m *Manager) Start(ctx context.Context) error
  • func (m *Manager) Stop(ctx context.Context) error
• type ManagerConfig

Variables

var (
	// RefreshSPInfoAndStorageParamsTimer define the period of refresh sp info and storage params
	RefreshSPInfoAndStorageParamsTimer = 5 * 60
)

Types

type GCWorker

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

GCWorker is responsible for releasing the space occupied by the deleted object in the piece-store. TODO: Will be refactored into task-node in the future.

func (*GCWorker) Start

func (w *GCWorker) Start()

Start is a non-blocking function that starts a goroutine execution logic internally.

func (*GCWorker) Stop

func (w *GCWorker) Stop()

Stop is responsible for stop gc.

type Manager

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

Manager module is responsible for implementing internal management functions. Currently, it supports periodic update of sp info list and storage params information in sp-db. TODO: support gc and configuration management, etc.

func NewManagerService

func NewManagerService(cfg *ManagerConfig) (*Manager, error)

NewManagerService returns an instance of manager

func (*Manager) Name

func (m *Manager) Name() string

Name return the manager service name

func (*Manager) Start

func (m *Manager) Start(ctx context.Context) error

Start function start background goroutine to execute refresh sp meta

func (*Manager) Stop

func (m *Manager) Stop(ctx context.Context) error

Stop manager background goroutine

type ManagerConfig

type ManagerConfig struct {
	SpOperatorAddress   string
	ChainConfig         *gnfd.GreenfieldChainConfig
	SpDBConfig          *config.SQLDBConfig
	MetadataGrpcAddress string
	PieceStoreConfig    *storage.PieceStoreConfig
}

ManagerConfig defines manager service config