Function BlockService

core/node/core.go:38–52

BlockService creates new blockservice which provides an interface to fetch content-addressable blocks

(cfg *config.Config)

// BlockService creates new blockservice which provides an interface to fetch content-addressable blocks
func BlockService(cfg *config.Config) func(lc fx.Lifecycle, bs blockstore.Blockstore, rem exchange.Interface) blockservice.BlockService {
	return func(lc fx.Lifecycle, bs blockstore.Blockstore, rem exchange.Interface) blockservice.BlockService {
		bsvc := blockservice.New(bs, rem,
			blockservice.WriteThrough(cfg.Datastore.WriteThrough.WithDefault(config.DefaultWriteThrough)),
		)

		lc.Append(fx.Hook{
			OnStop: func(ctx context.Context) error {
				return shutdown.CloseWithCtx(ctx, "blockservice", bsvc.Close)
			},
		})

		return bsvc
	}
}

// Pinning builds the pinner that GC uses to decide which blocks to keep.
//