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

Pass all Index/Frame meta data to other nodes via messages

Browse source
This commit is contained in:
Travis 2017-04-24 15:56:07 -05:00
parent 03aa9447a8
commit dfd17b38a4
No known key found for this signature in database
GPG key ID: 7F08008DFD9314C9
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