def apply_mds(self, spec):
# type: (orchestrator.ServiceSpec) -> RookCompletion
- num = spec.count
+ num = spec.placement.count
return write_completion(
lambda: self.rook_cluster.update_mds_count(spec.service_id, num),
"Updating MDS server count in {0} to {1}".format(spec.service_id, num),
def apply_nfs(self, spec):
# type: (orchestrator.NFSServiceSpec) -> RookCompletion
- num = spec.count
+ num = spec.placement.count
return write_completion(
lambda: self.rook_cluster.update_nfs_count(spec.service_id, num),
"Updating NFS server count in {0} to {1}".format(spec.service_id, num),
),
spec=cfs.Spec(
metadataServer=cfs.MetadataServer(
- activeCount=spec.count,
+ activeCount=spec.placement.count,
activeStandby=True
)
)
pool=spec.pool
),
server=cnfs.Server(
- active=spec.count
+ active=spec.placement.count
)
)
)
gateway=cos.Gateway(
type='s3',
port=spec.rgw_frontend_port if spec.rgw_frontend_port is not None else 80,
- instances=spec.count
+ instances=spec.placement.count
)
)
)