diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-01-24 19:01:58 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-01-24 19:01:58 -0800 |
| commit | 00707ec00fb8016ac9ef8858a01a9784a6aee1a0 (patch) | |
| tree | dfe313d9fead4bcdf741e52f7b6316d2da00d71b /weed/filer | |
| parent | 2c5eac5705c12b4dc0930d0a27478a73924b9e16 (diff) | |
| download | seaweedfs-00707ec00fb8016ac9ef8858a01a9784a6aee1a0.tar.xz seaweedfs-00707ec00fb8016ac9ef8858a01a9784a6aee1a0.zip | |
mount: outsideContainerClusterMode proxy through filer
Running mount outside of the cluster would not need to expose all the volume servers to outside of the cluster. The chunk read and write will go through the filer.
Diffstat (limited to 'weed/filer')
| -rw-r--r-- | weed/filer/reader_at.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/filer/reader_at.go b/weed/filer/reader_at.go index 307224f35..41d177210 100644 --- a/weed/filer/reader_at.go +++ b/weed/filer/reader_at.go @@ -71,7 +71,7 @@ func LookupFn(filerClient filer_pb.FilerClient) wdclient.LookupFileIdFunctionTyp } for _, loc := range locations.Locations { - volumeServerAddress := filerClient.AdjustedUrl(loc) + volumeServerAddress := loc.Url targetUrl := fmt.Sprintf("http://%s/%s", volumeServerAddress, fileId) targetUrls = append(targetUrls, targetUrl) } @@ -85,11 +85,11 @@ func LookupFn(filerClient filer_pb.FilerClient) wdclient.LookupFileIdFunctionTyp } } -func NewChunkReaderAtFromClient(filerClient filer_pb.FilerClient, chunkViews []*ChunkView, chunkCache chunk_cache.ChunkCache, fileSize int64) *ChunkReadAt { +func NewChunkReaderAtFromClient(lookupFn wdclient.LookupFileIdFunctionType, chunkViews []*ChunkView, chunkCache chunk_cache.ChunkCache, fileSize int64) *ChunkReadAt { return &ChunkReadAt{ chunkViews: chunkViews, - lookupFileId: LookupFn(filerClient), + lookupFileId: lookupFn, chunkCache: chunkCache, fileSize: fileSize, } |
