csi-driver-lvm

• https://kubernetes-csi.github.io/docs/api/volume-snapshot.html 참고중

• yaml 추가

// values
snapshotter: registry.k8s.io/sig-storage/csi-snapshotter:v5.0.1

// daemonset (코드 수정 필요)
224           {{- if .Values.image.csi.csiSnapshotter }}
225           image: {{ .Values.image.csi.csiSnapshotter }} 
226           {{- else }}     
227           image: "{{ .Values.image.repository }}:{{ default .Chart.AppVersion .Values.image.tag }}"
228           {{- end }}          
229           {{- with .Values.image.pullPolicy }}  
230           imagePullPolicy: {{ . }}   
231           {{- end }}   
232           securityContext:   
233             allowPrivilegeEscalation: false  
234             capabilities:     
235               drop:      
236                 - ALL                     
237           {{- with .Values.resources.csi_snapshotter }}
238           resources: {{ toYaml . | nindent 12 }}     
239           {{- end }}     
240           {{- with .Values.env.csi_snapshotter }}  
241           env: {{- toYaml . | nindent 12 }}   
242           {{- end }}        
243           command:     
244             - /csi-snapshotter          
245             - --csi-address=/run/topolvm/csi-topolvm.sock 
246             {{- if .Values.controller.leaderElection.enabled }}                 
247             - --leader-election
248             - --leader-election-namespace={{ .Release.Namespace }}              
249             {{- end }}    
250             - --http-endpoint=:9811   
251           ports:            
252             - containerPort: 9811  
253               name: csi-snapshotter  
254           volumeMounts:       
255             - name: socket-dir    
256               mountPath: /run/topolvm  
257         {{- end }} 

• capa

// Capabilities
581 func (s controllerServerNoLocked) ControllerGetCapabilities(context.Context, *csi.ControllerGetCapabi    litiesRequest) (*csi.ControllerGetCapabilitiesResponse, error) {
582 >---capabilities := []csi.ControllerServiceCapability_RPC_Type{                 
583 >--->---csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME, 
584 >--->---// csi.ControllerServiceCapability_RPC_CLONE_VOLUME,  
585 >--->---csi.ControllerServiceCapability_RPC_GET_CAPACITY, 
586 >--->---csi.ControllerServiceCapability_RPC_EXPAND_VOLUME, 
587 >--->---csi.ControllerServiceCapability_RPC_CREATE_DELETE_SNAPSHOT,  
588 >---}           
589                  
590 >---csiCaps := make([]*csi.ControllerServiceCapability, len(capabilities))      
591 >---for i, capability := range capabilities {    
592 >--->---csiCaps[i] = &csi.ControllerServiceCapability{ 
593 >--->--->---Type: &csi.ControllerServiceCapability_Rpc{ 
594 >--->--->--->---Rpc: &csi.ControllerServiceCapability_RPC{ 
595 >--->--->--->--->---Type: capability,    
596 >--->--->--->---},    
597 >--->--->---},       
598 >--->---}             
599 >---}                
600                        
601 >---return &csi.ControllerGetCapabilitiesResponse{  
602 >--->---Capabilities: csiCaps,   
603 >---}, nil        
604 }

• 함수

// 스냅샷 생성
341 // CreateSnapshot creates a logical volume snapshot.
342 func (s controllerServerNoLocked) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest)     (*csi.CreateSnapshotResponse, error) {
...
352 >---if req.GetSourceVolumeId() == "" {      
353 >--->---return nil, status.Error(codes.InvalidArgument, "missing source volume id")
354 >---}                                       
355                                             
356 >---if req.GetName() == "" {                
357 >--->---return nil, status.Error(codes.InvalidArgument, "missing name")         
358 >---}    

...      

360 >---name := strings.ToLower(req.GetName())  
361 >---sourceVolID := req.GetSourceVolumeId()  
362 >---sourceVol, err := s.lvService.GetVolume(ctx, sourceVolID)                   
363 >---if err != nil {
364 >--->---if errors.Is(err, k8s.ErrVolumeNotFound) {
365 >--->--->---return nil, status.Error(codes.NotFound, "failed to find source volumes")
366 >--->---}                                 
367 >--->---return nil, status.Error(codes.Internal, err.Error())                   
368 >---}                                     
369 >---snapTimeStamp := &timestamp.Timestamp{
370 >--->---Seconds: time.Now().Unix(),
371 >--->---Nanos:   0,      
372 >---}    

...

378 >---snapshot, err := s.lvService.CreateSnapshot(ctx, node, deviceClass, sourceVolName, name, accessTy    pe, *currentSize)
379 >---if err != nil {                   
380 >--->---_, ok := status.FromError(err)
381 >--->---if !ok {       
382 >--->--->---return nil, status.Error(codes.Internal, err.Error())               
383 >--->---}              
384 >--->---return nil, err      
385 >---}  

...

387 >---return &csi.CreateSnapshotResponse{
388 >--->---Snapshot: &csi.Snapshot{
389 >--->--->---SizeBytes:      snapshot.Status.CurrentSize.Value(),                
390 >--->--->---SnapshotId:     snapshot.Status.VolumeID, 
391 >--->--->---SourceVolumeId: sourceVolID,
392 >--->--->---CreationTime:   snapTimeStamp,
393 >--->--->---ReadyToUse:     true,  
394 >--->---},     
395 >---}, nil   


// 스냅샷 삭제
398 // DeleteSnapshot deletes an existing logical volume snapshot.                  
399 func (s controllerServerNoLocked) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest)     (*csi.DeleteSnapshotResponse, error) {
400 >---ctrlLogger.Info("DeleteSnapshot called",   
401 >--->---"snapshot_id", req.GetSnapshotId(),  
402 >--->---"num_secrets", len(req.GetSecrets()))        
403                    
404 >---if req.GetSnapshotId() == "" {          
405 >--->---return nil, status.Error(codes.InvalidArgument, "missing snapshot id")  
406 >---}                 
407                 
408 >---if err := s.lvService.DeleteVolume(ctx, req.GetSnapshotId()); err != nil {  
409 >--->---ctrlLogger.Error(err, "DeleteSnapshot failed", "snapshot_id", req.GetSnapshotId())
410 >--->---_, ok := status.FromError(err)        
411 >--->---if !ok {         
412 >--->--->---return nil, status.Error(codes.Internal, err.Error())               
413 >--->---}         
414 >--->---return nil, err     
415 >---}            
416                   
417 >---return &csi.DeleteSnapshotResponse{}, nil                
418 } 

• snapshot restore

CreateVolume
source := req.GetVolumeContentSource() // 참고

추가 필요 조사사항¶

• 스냅샷 생성, 복구 yaml 정의 예제