scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-10-07 03:17:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #472 from travisturner/option-messages

Browse source 
Pass all Index/Frame meta data to other nodes via messages
This commit is contained in:
Travis Turner 2017-04-25 12:29:08 -05:00 • committed by GitHub
commit 0fac826c69
1 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
server.go
View file

@ -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