From dfd17b38a434ee18bbd8e136645dba0e1870775d Mon Sep 17 00:00:00 2001 From: Travis Date: Mon, 24 Apr 2017 15:56:07 -0500 Subject: [PATCH] Pass all Index/Frame meta data to other nodes via messages --- server.go | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/server.go b/server.go index 336d76b54..1b2f3fb87 100644 --- a/server.go +++ b/server.go @@ -247,7 +247,10 @@ func (s *Server) ReceiveMessage(pb proto.Message) error { } idx.SetRemoteMaxSlice(obj.Slice) case *internal.CreateIndexMessage: - opt := IndexOptions{ColumnLabel: obj.Meta.ColumnLabel} + opt := IndexOptions{ + ColumnLabel: obj.Meta.ColumnLabel, + TimeQuantum: TimeQuantum(obj.Meta.TimeQuantum), + } _, err := s.Holder.CreateIndex(obj.Index, opt) if err != nil { return err @@ -258,7 +261,13 @@ func (s *Server) ReceiveMessage(pb proto.Message) error { } case *internal.CreateFrameMessage: index := s.Holder.Index(obj.Index) - opt := FrameOptions{RowLabel: obj.Meta.RowLabel} + opt := FrameOptions{ + RowLabel: obj.Meta.RowLabel, + InverseEnabled: obj.Meta.InverseEnabled, + CacheType: obj.Meta.CacheType, + CacheSize: obj.Meta.CacheSize, + TimeQuantum: TimeQuantum(obj.Meta.TimeQuantum), + } _, err := index.CreateFrame(obj.Frame, opt) if err != nil { return err