parent
							
								
									76da6290b0
								
							
						
					
					
						commit
						228bafca0b
					
				| 
						 | 
					@ -476,11 +476,11 @@ func New(params DriverParameters) (*Driver, error) {
 | 
				
			||||||
	// }
 | 
						// }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	d := &driver{
 | 
						d := &driver{
 | 
				
			||||||
		S3:                          s3obj,
 | 
							S3:        s3obj,
 | 
				
			||||||
		Bucket:                      params.Bucket,
 | 
							Bucket:    params.Bucket,
 | 
				
			||||||
		ChunkSize:                   params.ChunkSize,
 | 
							ChunkSize: params.ChunkSize,
 | 
				
			||||||
		Encrypt:                     params.Encrypt,
 | 
							Encrypt:   params.Encrypt,
 | 
				
			||||||
		KeyID:                       params.KeyID,
 | 
							KeyID:     params.KeyID,
 | 
				
			||||||
		MultipartCopyChunkSize:      params.MultipartCopyChunkSize,
 | 
							MultipartCopyChunkSize:      params.MultipartCopyChunkSize,
 | 
				
			||||||
		MultipartCopyMaxConcurrency: params.MultipartCopyMaxConcurrency,
 | 
							MultipartCopyMaxConcurrency: params.MultipartCopyMaxConcurrency,
 | 
				
			||||||
		MultipartCopyThresholdSize:  params.MultipartCopyThresholdSize,
 | 
							MultipartCopyThresholdSize:  params.MultipartCopyThresholdSize,
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -312,14 +312,14 @@ func (lbs *linkedBlobStore) newBlobUpload(ctx context.Context, uuid, path string
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	bw := &blobWriter{
 | 
						bw := &blobWriter{
 | 
				
			||||||
		ctx:                    ctx,
 | 
							ctx:        ctx,
 | 
				
			||||||
		blobStore:              lbs,
 | 
							blobStore:  lbs,
 | 
				
			||||||
		id:                     uuid,
 | 
							id:         uuid,
 | 
				
			||||||
		startedAt:              startedAt,
 | 
							startedAt:  startedAt,
 | 
				
			||||||
		digester:               digest.Canonical.Digester(),
 | 
							digester:   digest.Canonical.Digester(),
 | 
				
			||||||
		fileWriter:             fw,
 | 
							fileWriter: fw,
 | 
				
			||||||
		driver:                 lbs.driver,
 | 
							driver:     lbs.driver,
 | 
				
			||||||
		path:                   path,
 | 
							path:       path,
 | 
				
			||||||
		resumableDigestEnabled: lbs.resumableDigestEnabled,
 | 
							resumableDigestEnabled: lbs.resumableDigestEnabled,
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -161,8 +161,8 @@ type mockBlobDescriptorServiceFactory struct {
 | 
				
			||||||
func (f *mockBlobDescriptorServiceFactory) BlobAccessController(svc distribution.BlobDescriptorService) distribution.BlobDescriptorService {
 | 
					func (f *mockBlobDescriptorServiceFactory) BlobAccessController(svc distribution.BlobDescriptorService) distribution.BlobDescriptorService {
 | 
				
			||||||
	return &mockBlobDescriptorService{
 | 
						return &mockBlobDescriptorService{
 | 
				
			||||||
		BlobDescriptorService: svc,
 | 
							BlobDescriptorService: svc,
 | 
				
			||||||
		t:                     f.t,
 | 
							t:     f.t,
 | 
				
			||||||
		stats:                 f.stats,
 | 
							stats: f.stats,
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue