Method Inform

dgraph/cmd/zero/zero.go:407–470

(ctx context.Context, req *pb.TabletRequest)

}

func (s *Server) Inform(ctx context.Context, req *pb.TabletRequest) (*pb.TabletResponse, error) {
	ctx, span := otel.Tracer("").Start(ctx, "Zero.Inform")
	defer span.End()
	if req == nil || len(req.Tablets) == 0 {
		return nil, errors.Errorf("Tablets are empty in %+v", req)
	}

	if req.GroupId == 0 {
		return nil, errors.Errorf("Group ID is Zero in %+v", req)
	}

	tablets := make([]*pb.Tablet, 0)
	unknownTablets := make([]*pb.Tablet, 0)
	for _, t := range req.Tablets {
		tab := s.ServingTablet(t.Predicate)
		span.SetAttributes(attribute.String("tablet_predicate", t.Predicate))
		switch {
		case tab != nil && !t.Force:
			tablets = append(tablets, t)
		case t.ReadOnly:
			tablets = append(tablets, &pb.Tablet{})
		default:
			unknownTablets = append(unknownTablets, t)
		}
	}

	if len(unknownTablets) == 0 {
		return &pb.TabletResponse{
			Tablets: tablets,
		}, nil
	}

	// Set the tablet to be served by this server's group.
	var proposal pb.ZeroProposal
	proposal.Tablets = make([]*pb.Tablet, 0)
	for _, t := range unknownTablets {
		if x.IsReservedPredicate(t.Predicate) {
			// Force all the reserved predicates to be allocated to group 1.
			// This is to make it easier to stream ACL updates to all alpha servers
			// since they only need to open one pipeline to receive updates for all
			// ACL predicates.
			// This will also make it easier to restore the reserved predicates after
			// a DropAll operation.
			t.GroupId = 1
		}
		proposal.Tablets = append(proposal.Tablets, t)
	}

	if err := s.Node.proposeAndWait(ctx, &proposal); err != nil && err != errTabletAlreadyServed {
		span.AddEvent(fmt.Sprintf("Error proposing tablet: %+v. Error: %v", &proposal, err))
		return nil, err
	}

	for _, t := range unknownTablets {
		tab := s.ServingTablet(t.Predicate)
		x.AssertTrue(tab != nil)
		span.AddEvent(fmt.Sprintf("Tablet served: %+v", tab))
		tablets = append(tablets, tab)