Documentation ¶
Index ¶
- type ApprovalConfig
- type BlockSyncerConfig
- type BucketConfig
- type ChainConfig
- type Customize
- type EndpointConfig
- type ExecutorConfig
- type GatewayConfig
- type GfSpConfig
- type LogConfig
- type ManagerConfig
- type MetadataConfig
- type MonitorConfig
- type Option
- func CustomizeConsensus(consensus consensus.Consensus) Option
- func CustomizeGfSpDB(db spdb.SPDB) Option
- func CustomizePieceOp(op piecestore.PieceOp) Option
- func CustomizePieceStore(store piecestore.PieceStore) Option
- func CustomizeRcLimiter(limiter corercmgr.Limiter) Option
- func CustomizeRcmgr(rcmgr corercmgr.ResourceManager) Option
- func CustomizeStrategyTQueue(newFunc coretaskqueue.NewTQueueOnStrategy) Option
- func CustomizeStrategyTQueueWithLimit(newFunc coretaskqueue.NewTQueueOnStrategyWithLimit) Option
- func CustomizeTQueue(newFunc coretaskqueue.NewTQueue) Option
- func CustomizeTQueueWithLimit(newFunc coretaskqueue.NewTQueueWithLimit) Option
- type P2PConfig
- type ParallelConfig
- type RcmgrConfig
- type SpAccountConfig
- type TaskConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApprovalConfig ¶
type BlockSyncerConfig ¶
type BucketConfig ¶
type ChainConfig ¶
type ChainConfig struct { ChainID string ChainAddress []string SealGasLimit uint64 SealFeeAmount uint64 RejectSealGasLimit uint64 RejectSealFeeAmount uint64 DiscontinueBucketGasLimit uint64 DiscontinueBucketFeeAmount uint64 CreateGlobalVirtualGroupGasLimit uint64 CreateGlobalVirtualGroupFeeAmount uint64 CompleteMigrateBucketGasLimit uint64 CompleteMigrateBucketFeeAmount uint64 }
type Customize ¶
type Customize struct { GfSpDB spdb.SPDB PieceStore piecestore.PieceStore PieceOp piecestore.PieceOp Rcmgr corercmgr.ResourceManager RcLimiter corercmgr.Limiter Consensus consensus.Consensus NewTQueueFunc coretaskqueue.NewTQueue NewTQueueWithLimit coretaskqueue.NewTQueueWithLimit NewStrategyTQueueFunc coretaskqueue.NewTQueueOnStrategy NewStrategyTQueueWithLimitFunc coretaskqueue.NewTQueueOnStrategyWithLimit NewVirtualGroupManagerFunc vgmgr.NewVirtualGroupManager }
Customize defines the interface for developer to customize own implement, the GfSp base app will call the customized implement.
type EndpointConfig ¶
type ExecutorConfig ¶
type GatewayConfig ¶
type GfSpConfig ¶
type GfSpConfig struct { Env string AppID string Server []string GRPCAddress string Customize *Customize SpDB storeconfig.SQLDBConfig BsDB storeconfig.SQLDBConfig BsDBBackup storeconfig.SQLDBConfig PieceStore storage.PieceStoreConfig Chain ChainConfig SpAccount SpAccountConfig Endpoint EndpointConfig Approval ApprovalConfig Bucket BucketConfig Gateway GatewayConfig Executor ExecutorConfig P2P P2PConfig Parallel ParallelConfig Task TaskConfig Monitor MonitorConfig Rcmgr RcmgrConfig Log LogConfig Metadata MetadataConfig BlockSyncer BlockSyncerConfig APIRateLimiter localhttp.RateLimiterConfig Manager ManagerConfig }
GfSpConfig defines the GfSp configuration.
func (*GfSpConfig) Apply ¶
func (cfg *GfSpConfig) Apply(opts ...Option) error
Apply sets the customized implement to the GfSp configuration, it will be called before init GfSp base app.
func (*GfSpConfig) String ¶
func (cfg *GfSpConfig) String() string
String returns the detail GfSp configuration.
type ManagerConfig ¶
type MetadataConfig ¶
type MonitorConfig ¶
type Option ¶
type Option = func(cfg *GfSpConfig) error
func CustomizeConsensus ¶
func CustomizeGfSpDB ¶
func CustomizePieceOp ¶
func CustomizePieceOp(op piecestore.PieceOp) Option
func CustomizePieceStore ¶
func CustomizePieceStore(store piecestore.PieceStore) Option
func CustomizeRcLimiter ¶
func CustomizeRcmgr ¶
func CustomizeRcmgr(rcmgr corercmgr.ResourceManager) Option
func CustomizeStrategyTQueue ¶
func CustomizeStrategyTQueue(newFunc coretaskqueue.NewTQueueOnStrategy) Option
func CustomizeStrategyTQueueWithLimit ¶
func CustomizeStrategyTQueueWithLimit(newFunc coretaskqueue.NewTQueueOnStrategyWithLimit) Option
func CustomizeTQueue ¶
func CustomizeTQueue(newFunc coretaskqueue.NewTQueue) Option
func CustomizeTQueueWithLimit ¶
func CustomizeTQueueWithLimit(newFunc coretaskqueue.NewTQueueWithLimit) Option
type ParallelConfig ¶
type ParallelConfig struct { GlobalCreateBucketApprovalParallel int GlobalCreateObjectApprovalParallel int GlobalMaxUploadingParallel int // upload + replicate + seal GlobalUploadObjectParallel int // only upload GlobalReplicatePieceParallel int GlobalSealObjectParallel int GlobalReceiveObjectParallel int GlobalGCObjectParallel int GlobalGCZombieParallel int GlobalGCMetaParallel int GlobalRecoveryPieceParallel int GlobalMigrateGVGParallel int GlobalDownloadObjectTaskCacheSize int GlobalChallengePieceTaskCacheSize int GlobalBatchGcObjectTimeInterval int GlobalGcObjectBlockInterval uint64 GlobalGcObjectSafeBlockDistance uint64 GlobalSyncConsensusInfoInterval uint64 UploadObjectParallelPerNode int ReceivePieceParallelPerNode int DownloadObjectParallelPerNode int ChallengePieceParallelPerNode int AskReplicateApprovalParallelPerNode int QuerySPParallelPerNode int64 DiscontinueBucketEnabled bool DiscontinueBucketTimeInterval int DiscontinueBucketKeepAliveDays int LoadReplicateTimeout int64 LoadSealTimeout int64 }
type RcmgrConfig ¶
type RcmgrConfig struct { DisableRcmgr bool GfSpLimiter *gfsplimit.GfSpLimiter }
type SpAccountConfig ¶
type TaskConfig ¶
type TaskConfig struct { UploadTaskSpeed int64 DownloadTaskSpeed int64 ReplicateTaskSpeed int64 ReceiveTaskSpeed int64 SealObjectTaskTimeout int64 GcObjectTaskTimeout int64 GcZombieTaskTimeout int64 GcMetaTaskTimeout int64 SealObjectTaskRetry int64 ReplicateTaskRetry int64 ReceiveConfirmTaskRetry int64 GcObjectTaskRetry int64 GcZombieTaskRetry int64 GcMetaTaskRetry int64 }
Click to show internal directories.
Click to hide internal directories.