Package org.apache.aurora.gen

Examples of org.apache.aurora.gen.Response

703
704
705
706
707
708
709
710
711
712
713
      final SessionKey session) {

    requireNonNull(mutableQuery);
    requireNonNull(session);

    final Response response = emptyResponse();

    if (mutableQuery.getJobName() != null && StringUtils.isBlank(mutableQuery.getJobName())) {
      return addMessage(
          response,
          INVALID_REQUEST,
View Full Code Here
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
    IJobKey jobKey = JobKeys.assertValid(IJobKey.build(mutableJobKey));
    checkNotBlank(shardIds);
    requireNonNull(session);

    Response response = Util.emptyResponse();
    SessionContext context;
    try {
      context = sessionValidator.checkAuthenticated(session, ImmutableSet.of(jobKey.getRole()));
    } catch (AuthFailedException e) {
      return addMessage(response, AUTH_FAILED, e);
    }

    try {
      lockManager.validateIfLocked(
          ILockKey.build(LockKey.job(jobKey.newBuilder())),
          Optional.fromNullable(mutableLock).transform(ILock.FROM_BUILDER));
      schedulerCore.restartShards(jobKey, shardIds, context.getIdentity());
      response.setResponseCode(OK);
    } catch (LockException e) {
      addMessage(response, LOCK_ERROR, e);
    } catch (ScheduleException e) {
      addMessage(response, INVALID_REQUEST, e);
    }
View Full Code Here
827
828
829
830
831
832
833
834
835
836
837
838
839
    checkNotBlank(ownerRole);
    requireNonNull(resourceAggregate);
    requireNonNull(session);

    Response response = Util.emptyResponse();
    try {
      quotaManager.saveQuota(ownerRole, IResourceAggregate.build(resourceAggregate));
      return response.setResponseCode(OK);
    } catch (QuotaException e) {
      return addMessage(response, INVALID_REQUEST, e);
    }
  }
View Full Code Here
872
873
874
875
876
877
878
879
880
881
882
  public Response forceTaskState(String taskId, ScheduleStatus status, SessionKey session) {
    checkNotBlank(taskId);
    requireNonNull(status);
    requireNonNull(session);

    Response response = Util.emptyResponse();
    SessionContext context;
    try {
      // TODO(Sathya): Remove this after AOP-style session validation passes in a SessionContext.
      context = sessionValidator.checkAuthorized(session, Capability.ROOT, AuditCheck.REQUIRED);
    } catch (AuthFailedException e) {
View Full Code Here
900
901
902
903
904
905
906
907
908
909
910
        .setBackups(recovery.listBackups())));
  }

  @Override
  public Response stageRecovery(String backupId, SessionKey session) {
    Response response = okEmptyResponse();
    try {
      recovery.stage(backupId);
    } catch (RecoveryException e) {
      addMessage(response, ERROR, e);
      LOG.log(Level.WARNING, "Failed to stage recovery: " + e, e);
View Full Code Here
913
914
915
916
917
918
919
920
921
922
923
924
925
    return response;
  }

  @Override
  public Response queryRecovery(TaskQuery query, SessionKey session) {
    Response response = Util.emptyResponse();
    try {
      response.setResponseCode(OK)
          .setResult(Result.queryRecoveryResult(new QueryRecoveryResult()
              .setTasks(IScheduledTask.toBuildersSet(recovery.query(Query.arbitrary(query))))));
    } catch (RecoveryException e) {
      addMessage(response, ERROR, e);
      LOG.log(Level.WARNING, "Failed to query recovery: " + e, e);
View Full Code Here
928
929
930
931
932
933
934
935
936
937
938
    return response;
  }

  @Override
  public Response deleteRecoveryTasks(TaskQuery query, SessionKey session) {
    Response response = okEmptyResponse();
    try {
      recovery.deleteTasks(Query.arbitrary(query));
    } catch (RecoveryException e) {
      addMessage(response, ERROR, e);
      LOG.log(Level.WARNING, "Failed to delete recovery tasks: " + e, e);
View Full Code Here
941
942
943
944
945
946
947
948
949
950
951
    return response;
  }

  @Override
  public Response commitRecovery(SessionKey session) {
    Response response = okEmptyResponse();
    try {
      recovery.commit();
    } catch (RecoveryException e) {
      addMessage(response, ERROR, e);
    }
View Full Code Here
959
960
961
962
963
964
965
966
967
968
969
970
971
972
    return okEmptyResponse();
  }

  @Override
  public Response snapshot(SessionKey session) {
    Response response = Util.emptyResponse();
    try {
      storage.snapshot();
      return response.setResponseCode(OK);
    } catch (Storage.StorageException e) {
      LOG.log(Level.WARNING, "Requested snapshot failed.", e);
      return addMessage(response, ERROR, e);
    }
  }
View Full Code Here
1002
1003
1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
          if (error.isPresent()) {
            errors.add(error.get());
          }
        }

        Response resp = emptyResponse();
        if (errors.isEmpty()) {
          resp.setResponseCode(OK);
        } else {
          for (String error : errors) {
            addMessage(resp, WARNING, error);
          }
        }
View Full Code Here
TOP

Related Classes of org.apache.aurora.gen.Response

  • org.apache.aurora.scheduler.http.api.ApiBetaTest
  • org.apache.aurora.scheduler.http.ServletFilterTest
  • org.apache.aurora.scheduler.thrift.aop.AopModuleTest
  • org.apache.aurora.scheduler.thrift.aop.FeatureToggleInterceptorTest
  • org.apache.aurora.scheduler.thrift.aop.ServerInfoInterceptor
  • org.apache.aurora.scheduler.thrift.aop.ServerInfoInterceptorTest
  • org.apache.aurora.scheduler.thrift.aop.ThriftStatsExporterInterceptorTest
  • org.apache.aurora.scheduler.thrift.SchedulerThriftInterface
  • org.apache.aurora.scheduler.thrift.SchedulerThriftInterfaceTest
  • org.apache.aurora.scheduler.thrift.Util
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.