Function ProcessDeleteNsRequest

worker/multi_tenancy.go:34–60

(ctx context.Context, ns uint64)

}

func ProcessDeleteNsRequest(ctx context.Context, ns uint64) error {
	// Update the membership state to get the latest mapping of groups to predicates.
	if err := UpdateMembershipState(ctx); err != nil {
		return errors.Wrapf(err, "Failed to update membership state while deleting namesapce")
	}

	state := GetMembershipState()
	g := new(errgroup.Group)

	for gid := range state.Groups {
		req := &pb.DeleteNsRequest{Namespace: ns, GroupId: gid}
		g.Go(func() error {
			return x.RetryUntilSuccess(10, 100*time.Millisecond, func() error {
				return proposeDeleteOrSend(ctx, req)
			})
		})
	}

	if err := g.Wait(); err != nil {
		return errors.Wrap(err, "Failed to process delete request")
	}

	// Now propose the change to zero.
	return x.RetryUntilSuccess(10, 100*time.Millisecond, func() error {
		return sendDeleteToZero(ctx, ns)
	})
}

func sendDeleteToZero(ctx context.Context, ns uint64) error {
	gr := groups()