diff options
| author | Chris Lu <chris.lu@uber.com> | 2019-03-19 05:19:37 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@uber.com> | 2019-03-19 05:19:37 -0700 |
| commit | eb4a54d9fe865eafb4de12db96b3e668b333fd1a (patch) | |
| tree | 1b98cca002c99c2e74abc5cc46a51e61b982df89 /weed/wdclient/masterclient.go | |
| parent | ece9d133122fd15faa4efd1b4cec34974e3b37d0 (diff) | |
| download | seaweedfs-eb4a54d9fe865eafb4de12db96b3e668b333fd1a.tar.xz seaweedfs-eb4a54d9fe865eafb4de12db96b3e668b333fd1a.zip | |
refactoring
Diffstat (limited to 'weed/wdclient/masterclient.go')
| -rw-r--r-- | weed/wdclient/masterclient.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/weed/wdclient/masterclient.go b/weed/wdclient/masterclient.go index b3b277c74..5f147e594 100644 --- a/weed/wdclient/masterclient.go +++ b/weed/wdclient/masterclient.go @@ -116,3 +116,9 @@ func withMasterClient(ctx context.Context, master string, grpcDialOption grpc.Di return fn(ctx, client) } + +func (mc *MasterClient) WithClient(ctx context.Context, fn func(ctx context.Context, client master_pb.SeaweedClient) error) error { + return withMasterClient(ctx, mc.currentMaster, mc.grpcDialOption, func(ctx context.Context, client master_pb.SeaweedClient) error { + return fn(ctx, client) + }) +} |