|
@ -84,8 +84,6 @@ func (fs *FilerServer) Ping(ctx context.Context, req *filer_pb.PingRequest) (res |
|
|
|
|
|
|
|
|
func (fs *FilerServer) GetFilerConfiguration(ctx context.Context, req *filer_pb.GetFilerConfigurationRequest) (resp *filer_pb.GetFilerConfigurationResponse, err error) { |
|
|
func (fs *FilerServer) GetFilerConfiguration(ctx context.Context, req *filer_pb.GetFilerConfigurationRequest) (resp *filer_pb.GetFilerConfigurationResponse, err error) { |
|
|
|
|
|
|
|
|
clusterId, _ := fs.filer.Store.KvGet(context.Background(), []byte("clusterId")) |
|
|
|
|
|
|
|
|
|
|
|
t := &filer_pb.GetFilerConfigurationResponse{ |
|
|
t := &filer_pb.GetFilerConfigurationResponse{ |
|
|
Masters: fs.option.Masters.GetInstancesAsStrings(), |
|
|
Masters: fs.option.Masters.GetInstancesAsStrings(), |
|
|
Collection: fs.option.Collection, |
|
|
Collection: fs.option.Collection, |
|
@ -97,7 +95,6 @@ func (fs *FilerServer) GetFilerConfiguration(ctx context.Context, req *filer_pb. |
|
|
MetricsAddress: fs.metricsAddress, |
|
|
MetricsAddress: fs.metricsAddress, |
|
|
MetricsIntervalSec: int32(fs.metricsIntervalSec), |
|
|
MetricsIntervalSec: int32(fs.metricsIntervalSec), |
|
|
Version: util.Version(), |
|
|
Version: util.Version(), |
|
|
ClusterId: string(clusterId), |
|
|
|
|
|
FilerGroup: fs.option.FilerGroup, |
|
|
FilerGroup: fs.option.FilerGroup, |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|