diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-11-14 14:26:08 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-11-14 14:26:08 -0800 |
| commit | 442e092995011653f2ed2f2b1b83bf4777a35c26 (patch) | |
| tree | e0fb7b77d8d37a07fcf37ffa9ca99aac93cb22cc | |
| parent | b2a72630da29b66d056f1666da97db1a7c679425 (diff) | |
| download | seaweedfs-442e092995011653f2ed2f2b1b83bf4777a35c26.tar.xz seaweedfs-442e092995011653f2ed2f2b1b83bf4777a35c26.zip | |
filer watch "/etc" folder for configuration changes
| -rw-r--r-- | weed/filer/filer_on_meta_event.go | 21 | ||||
| -rw-r--r-- | weed/filer/meta_aggregator.go | 3 |
2 files changed, 24 insertions, 0 deletions
diff --git a/weed/filer/filer_on_meta_event.go b/weed/filer/filer_on_meta_event.go new file mode 100644 index 000000000..70b62a974 --- /dev/null +++ b/weed/filer/filer_on_meta_event.go @@ -0,0 +1,21 @@ +package filer + +import ( + "github.com/chrislusf/seaweedfs/weed/glog" + "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" +) + +const ( + DirectoryEtc = "/etc" +) + +// onMetadataChangeEvent is triggered after filer processed change events from local or remote filers +func (f *Filer) onMetadataChangeEvent(event *filer_pb.SubscribeMetadataResponse) { + if DirectoryEtc != event.Directory { + return + } + + glog.V(0).Infof("procesing %v", event) + + +} diff --git a/weed/filer/meta_aggregator.go b/weed/filer/meta_aggregator.go index b90457339..9437e9992 100644 --- a/weed/filer/meta_aggregator.go +++ b/weed/filer/meta_aggregator.go @@ -141,6 +141,9 @@ func (ma *MetaAggregator) subscribeToOneFiler(f *Filer, self string, peer string return fmt.Errorf("process %v: %v", resp, err) } lastTsNs = resp.TsNs + + f.onMetadataChangeEvent(resp) + } }) if err != nil { |
