[scheduler]: ACLs phase 1 - per Job ACL specification and enforcement.

scheduler/appengine/apiservers/scheduler.go

Index: scheduler/appengine/apiservers/scheduler.go
diff --git a/scheduler/appengine/apiservers/scheduler.go b/scheduler/appengine/apiservers/scheduler.go
index 64500e61a26573447abe896b2396a39c09263416..6beadcdb5f27e41d449e7434668f89be8277ae8e 100644
--- a/scheduler/appengine/apiservers/scheduler.go
+++ b/scheduler/appengine/apiservers/scheduler.go
@@ -46,9 +46,9 @@ func (s SchedulerServer) GetJobs(ctx context.Context, in *scheduler.JobsRequest)
 	var ejobs []*engine.Job
 	var err error
 	if in.GetProject() == "" {
-		ejobs, err = s.Engine.GetAllJobs(ctx)
+		ejobs, err = s.Engine.GetAllJobsRA(ctx)
 	} else {
-		ejobs, err = s.Engine.GetProjectJobs(ctx, in.GetProject())
+		ejobs, err = s.Engine.GetProjectJobsRA(ctx, in.GetProject())
 	}
 	if err != nil {
 		return nil, grpc.Errorf(codes.Internal, "datastore error: %s", err)
@@ -76,7 +76,7 @@ func (s SchedulerServer) GetJobs(ctx context.Context, in *scheduler.JobsRequest)
 }
 
 func (s SchedulerServer) GetInvocations(ctx context.Context, in *scheduler.InvocationsRequest) (*scheduler.InvocationsReply, error) {
-	ejob, err := s.Engine.GetJob(ctx, getJobId(in.GetJobRef()))
+	ejob, err := s.Engine.GetJobRA(ctx, getJobId(in.GetJobRef()))
 	if err != nil {
 		return nil, grpc.Errorf(codes.Internal, "datastore error: %s", err)
 	}