package peloton.private.jobmgr

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc GetThrottledPods (GetThrottledPodsRequest, GetThrottledPodsResponse)

  jobmgrsvc.proto:103

  Get the list of throttled tasks in the system

  message GetThrottledPodsRequest

  jobmgrsvc.proto:16

  Request message for JobService.GetThrottledPods method.

  (message has no fields)

  message GetThrottledPodsResponse

  jobmgrsvc.proto:19

  Response message for JobService.GetThrottledPods method.

  • repeated api.v1alpha.peloton.PodName throttled_pods = 1

• rpc RefreshJob (RefreshJobRequest, RefreshJobResponse)

  jobmgrsvc.proto:107

  RefreshJob allows user to load job runtime status from the database and re-execute the action associated with current state.

  message RefreshJobRequest

  jobmgrsvc.proto:24

  Request message for JobService.RefreshJob method.

  • optional api.v1alpha.peloton.JobID job_id = 1

    The job ID to look up the job.

  message RefreshJobResponse

  jobmgrsvc.proto:63

  Response message for JobService.RefreshJob method. Return errors: NOT_FOUND: if the job ID is not found.

  (message has no fields)

• rpc GetJobCache (GetJobCacheRequest, GetJobCacheResponse)

  jobmgrsvc.proto:110

  GetJobCache gets the job state in the cache.

  message GetJobCacheRequest

  jobmgrsvc.proto:66

  Request message for JobService.GetJobCache method.

  • optional api.v1alpha.peloton.JobID job_id = 1

    The job ID to look up the job.

  message GetJobCacheResponse

  jobmgrsvc.proto:74

  Response message for JobService.GetJobCache method. Return errors: NOT_FOUND: if the job ID is not found.

  • optional api.v1alpha.job.stateless.JobSpec spec = 1

    The job configuration in cache of the matching job.

  • optional api.v1alpha.job.stateless.JobStatus status = 2

    The job runtime in cache of the matching job.

• rpc QueryJobCache (QueryJobCacheRequest, QueryJobCacheResponse)

  jobmgrsvc.proto:113

  QueryJobCache queries jobs in the cache

  message QueryJobCacheRequest

  jobmgrsvc.proto:30

  Request message for JobService.QueryJobCache method.

  • optional QueryJobCacheRequest.CacheQuerySpec spec = 1

    spec used to query job cache

  message QueryJobCacheResponse

  jobmgrsvc.proto:48

  Response message for JobService.QueryJobCache method.

  • repeated QueryJobCacheResponse.JobCache result = 1

    List of job cache query result returned by server.

• rpc GetInstanceAvailabilityInfoForJob (GetInstanceAvailabilityInfoForJobRequest, GetInstanceAvailabilityInfoForJobResponse)

  jobmgrsvc.proto:117

  GetInstanceAvailabilityInfoForJob gets instance availability information for the job.

  message GetInstanceAvailabilityInfoForJobRequest

  jobmgrsvc.proto:83

  Request message for JobManagerService.GetInstanceAvailabilityInfoForJob

  • optional api.v1alpha.peloton.JobID job_id = 1

    The job ID to look up the job.

  • repeated uint32 instances = 2

    optional field instance ids to filter. If no instances are specified then instance availability information for all instances of the job would be returned.

  message GetInstanceAvailabilityInfoForJobResponse

  jobmgrsvc.proto:96

  Response message for JobManagerService.GetInstanceAvailabilityInfoForJob Return errors: NOT_FOUND: if the job ID is not found.

  • map<uint32, string> instance_availability_map = 1

    map of instance id to instance availability type.

CacheQuerySpec specifies the list of query criteria for jobs, which can be served by cache directly

Used in: QueryJobCacheRequest

• repeated api.v1alpha.peloton.Label labels = 1

  List of labels to query the jobs. Will match all jobs if the list is empty.

• string name = 2

  Query jobs by name. This is case sensitive and will look for jobs with name matching the name string. Will match all jobs if name is unset.

Used in: QueryJobCacheResponse

• optional api.v1alpha.peloton.JobID job_id = 1

  The job identifier of the result.

• string name = 2

  The name of the job