Method Inform

worker/groups.go:484–531

(preds []string)

}

func (g *groupi) Inform(preds []string) ([]*pb.Tablet, error) {
	unknownPreds := make([]*pb.Tablet, 0)
	tablets := make([]*pb.Tablet, 0)
	g.RLock()
	for _, p := range preds {
		if len(p) == 0 {
			continue
		}

		if tab, ok := g.tablets[p]; !ok {
			unknownPreds = append(unknownPreds, &pb.Tablet{GroupId: g.groupId(), Predicate: p})
		} else {
			tablets = append(tablets, tab)
		}
	}
	g.RUnlock()

	if len(unknownPreds) == 0 {
		return nil, nil
	}

	pl := g.connToZeroLeader()
	zc := pb.NewZeroClient(pl.Get())
	out, err := zc.Inform(g.Ctx(), &pb.TabletRequest{
		Tablets: unknownPreds,
		GroupId: g.groupId(),
	})
	if err != nil {
		glog.Errorf("Error while Inform grpc call %v", err)
		return nil, err
	}

	// Do not store tablets with group ID 0, as they are just dummy tablets for
	// predicates that do no exist.
	g.Lock()
	for _, t := range out.Tablets {
		if t.GroupId > 0 {
			g.tablets[t.GetPredicate()] = t
			tablets = append(tablets, t)
		}

		if t.GroupId == groups().groupId() {
			glog.Infof("Serving tablet for: %v\n", t.GetPredicate())
		}
	}
	g.Unlock()
	return tablets, nil
}

// Do not modify the returned Tablet
func (g *groupi) Tablet(key string) (*pb.Tablet, error) {