workerpb

type AdminActionCounters struct {
	Pause  int64 `protobuf:"varint,1,opt,name=pause,proto3" json:"pause,omitempty"`
	Resume int64 `protobuf:"varint,2,opt,name=resume,proto3" json:"resume,omitempty"`
	Replay int64 `protobuf:"varint,3,opt,name=replay,proto3" json:"replay,omitempty"`
	// contains filtered or unexported fields
}

type AdminServiceClient interface {
	GetHealth(ctx context.Context, in *GetHealthRequest, opts ...grpc.CallOption) (*GetHealthResponse, error)
	GetOverview(ctx context.Context, in *GetOverviewRequest, opts ...grpc.CallOption) (*GetOverviewResponse, error)
	ListQueues(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (*ListQueuesResponse, error)
	GetQueue(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*GetQueueResponse, error)
	UpdateQueueWeight(ctx context.Context, in *UpdateQueueWeightRequest, opts ...grpc.CallOption) (*UpdateQueueWeightResponse, error)
	ResetQueueWeight(ctx context.Context, in *ResetQueueWeightRequest, opts ...grpc.CallOption) (*ResetQueueWeightResponse, error)
	PauseQueue(ctx context.Context, in *PauseQueueRequest, opts ...grpc.CallOption) (*PauseQueueResponse, error)
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	ListJobEvents(ctx context.Context, in *ListJobEventsRequest, opts ...grpc.CallOption) (*ListJobEventsResponse, error)
	ListAuditEvents(ctx context.Context, in *ListAuditEventsRequest, opts ...grpc.CallOption) (*ListAuditEventsResponse, error)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
	UpsertJob(ctx context.Context, in *UpsertJobRequest, opts ...grpc.CallOption) (*UpsertJobResponse, error)
	DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*DeleteJobResponse, error)
	RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*RunJobResponse, error)
	ListScheduleFactories(ctx context.Context, in *ListScheduleFactoriesRequest, opts ...grpc.CallOption) (*ListScheduleFactoriesResponse, error)
	ListScheduleEvents(ctx context.Context, in *ListScheduleEventsRequest, opts ...grpc.CallOption) (*ListScheduleEventsResponse, error)
	ListSchedules(ctx context.Context, in *ListSchedulesRequest, opts ...grpc.CallOption) (*ListSchedulesResponse, error)
	CreateSchedule(ctx context.Context, in *CreateScheduleRequest, opts ...grpc.CallOption) (*CreateScheduleResponse, error)
	DeleteSchedule(ctx context.Context, in *DeleteScheduleRequest, opts ...grpc.CallOption) (*DeleteScheduleResponse, error)
	PauseSchedule(ctx context.Context, in *PauseScheduleRequest, opts ...grpc.CallOption) (*PauseScheduleResponse, error)
	RunSchedule(ctx context.Context, in *RunScheduleRequest, opts ...grpc.CallOption) (*RunScheduleResponse, error)
	PauseSchedules(ctx context.Context, in *PauseSchedulesRequest, opts ...grpc.CallOption) (*PauseSchedulesResponse, error)
	ListDLQ(ctx context.Context, in *ListDLQRequest, opts ...grpc.CallOption) (*ListDLQResponse, error)
	GetDLQEntry(ctx context.Context, in *GetDLQEntryRequest, opts ...grpc.CallOption) (*GetDLQEntryResponse, error)
	PauseDequeue(ctx context.Context, in *PauseDequeueRequest, opts ...grpc.CallOption) (*PauseDequeueResponse, error)
	ResumeDequeue(ctx context.Context, in *ResumeDequeueRequest, opts ...grpc.CallOption) (*ResumeDequeueResponse, error)
	ReplayDLQ(ctx context.Context, in *ReplayDLQRequest, opts ...grpc.CallOption) (*ReplayDLQResponse, error)
	ReplayDLQByID(ctx context.Context, in *ReplayDLQByIDRequest, opts ...grpc.CallOption) (*ReplayDLQByIDResponse, error)
}

type AdminServiceServer interface {
	GetHealth(context.Context, *GetHealthRequest) (*GetHealthResponse, error)
	GetOverview(context.Context, *GetOverviewRequest) (*GetOverviewResponse, error)
	ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error)
	GetQueue(context.Context, *GetQueueRequest) (*GetQueueResponse, error)
	UpdateQueueWeight(context.Context, *UpdateQueueWeightRequest) (*UpdateQueueWeightResponse, error)
	ResetQueueWeight(context.Context, *ResetQueueWeightRequest) (*ResetQueueWeightResponse, error)
	PauseQueue(context.Context, *PauseQueueRequest) (*PauseQueueResponse, error)
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	ListJobEvents(context.Context, *ListJobEventsRequest) (*ListJobEventsResponse, error)
	ListAuditEvents(context.Context, *ListAuditEventsRequest) (*ListAuditEventsResponse, error)
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
	UpsertJob(context.Context, *UpsertJobRequest) (*UpsertJobResponse, error)
	DeleteJob(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)
	RunJob(context.Context, *RunJobRequest) (*RunJobResponse, error)
	ListScheduleFactories(context.Context, *ListScheduleFactoriesRequest) (*ListScheduleFactoriesResponse, error)
	ListScheduleEvents(context.Context, *ListScheduleEventsRequest) (*ListScheduleEventsResponse, error)
	ListSchedules(context.Context, *ListSchedulesRequest) (*ListSchedulesResponse, error)
	CreateSchedule(context.Context, *CreateScheduleRequest) (*CreateScheduleResponse, error)
	DeleteSchedule(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error)
	PauseSchedule(context.Context, *PauseScheduleRequest) (*PauseScheduleResponse, error)
	RunSchedule(context.Context, *RunScheduleRequest) (*RunScheduleResponse, error)
	PauseSchedules(context.Context, *PauseSchedulesRequest) (*PauseSchedulesResponse, error)
	ListDLQ(context.Context, *ListDLQRequest) (*ListDLQResponse, error)
	GetDLQEntry(context.Context, *GetDLQEntryRequest) (*GetDLQEntryResponse, error)
	PauseDequeue(context.Context, *PauseDequeueRequest) (*PauseDequeueResponse, error)
	ResumeDequeue(context.Context, *ResumeDequeueRequest) (*ResumeDequeueResponse, error)
	ReplayDLQ(context.Context, *ReplayDLQRequest) (*ReplayDLQResponse, error)
	ReplayDLQByID(context.Context, *ReplayDLQByIDRequest) (*ReplayDLQByIDResponse, error)
}

type AuditEvent struct {
	AtMs        int64             `protobuf:"varint,1,opt,name=at_ms,json=atMs,proto3" json:"at_ms,omitempty"`
	Actor       string            `protobuf:"bytes,2,opt,name=actor,proto3" json:"actor,omitempty"`
	RequestId   string            `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Action      string            `protobuf:"bytes,4,opt,name=action,proto3" json:"action,omitempty"`
	Target      string            `protobuf:"bytes,5,opt,name=target,proto3" json:"target,omitempty"`
	Status      string            `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	PayloadHash string            `protobuf:"bytes,7,opt,name=payload_hash,json=payloadHash,proto3" json:"payload_hash,omitempty"`
	Detail      string            `protobuf:"bytes,8,opt,name=detail,proto3" json:"detail,omitempty"`
	Metadata    map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CancelTaskRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type CancelTaskResponse struct {
	// contains filtered or unexported fields
}

type CoordinationStatus struct {
	GlobalRateLimit string `protobuf:"bytes,1,opt,name=global_rate_limit,json=globalRateLimit,proto3" json:"global_rate_limit,omitempty"`
	LeaderLock      string `protobuf:"bytes,2,opt,name=leader_lock,json=leaderLock,proto3" json:"leader_lock,omitempty"`
	Lease           string `protobuf:"bytes,3,opt,name=lease,proto3" json:"lease,omitempty"`
	Paused          bool   `protobuf:"varint,4,opt,name=paused,proto3" json:"paused,omitempty"`
	// contains filtered or unexported fields
}

type CreateScheduleRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Spec    string `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	Durable bool   `protobuf:"varint,3,opt,name=durable,proto3" json:"durable,omitempty"`
	// contains filtered or unexported fields
}

type CreateScheduleResponse struct {
	Schedule *ScheduleEntry `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// contains filtered or unexported fields
}

type DLQEntry struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Queue    string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	Handler  string `protobuf:"bytes,3,opt,name=handler,proto3" json:"handler,omitempty"`
	Attempts int32  `protobuf:"varint,4,opt,name=attempts,proto3" json:"attempts,omitempty"`
	AgeMs    int64  `protobuf:"varint,5,opt,name=age_ms,json=ageMs,proto3" json:"age_ms,omitempty"`
	// contains filtered or unexported fields
}

type DLQEntryDetail struct {
	Id          string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Queue       string            `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	Handler     string            `protobuf:"bytes,3,opt,name=handler,proto3" json:"handler,omitempty"`
	Attempts    int32             `protobuf:"varint,4,opt,name=attempts,proto3" json:"attempts,omitempty"`
	AgeMs       int64             `protobuf:"varint,5,opt,name=age_ms,json=ageMs,proto3" json:"age_ms,omitempty"`
	FailedAtMs  int64             `protobuf:"varint,6,opt,name=failed_at_ms,json=failedAtMs,proto3" json:"failed_at_ms,omitempty"`
	UpdatedAtMs int64             `protobuf:"varint,7,opt,name=updated_at_ms,json=updatedAtMs,proto3" json:"updated_at_ms,omitempty"`
	LastError   string            `protobuf:"bytes,8,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
	PayloadSize int64             `protobuf:"varint,9,opt,name=payload_size,json=payloadSize,proto3" json:"payload_size,omitempty"`
	Metadata    map[string]string `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DeleteJobRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteJobResponse struct {
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

type DeleteScheduleRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteScheduleResponse struct {
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

type DurableTask struct {
	Name           string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description    string               `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Priority       int32                `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	Retries        int32                `protobuf:"varint,4,opt,name=retries,proto3" json:"retries,omitempty"`
	RetryDelay     *durationpb.Duration `protobuf:"bytes,5,opt,name=retry_delay,json=retryDelay,proto3" json:"retry_delay,omitempty"`
	Payload        *anypb.Any           `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`                                     // the typed input for `name`
	IdempotencyKey string               `protobuf:"bytes,7,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"` // dedupe on the server/handler
	Metadata       map[string]string    ``                                                                                                        // free-form tags
	/* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetDLQEntryRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type GetDLQEntryResponse struct {
	Entry *DLQEntryDetail `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

type GetHealthRequest struct {
	// contains filtered or unexported fields
}

type GetHealthResponse struct {
	Status    string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Version   string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Commit    string `protobuf:"bytes,3,opt,name=commit,proto3" json:"commit,omitempty"`
	BuildTime string `protobuf:"bytes,4,opt,name=build_time,json=buildTime,proto3" json:"build_time,omitempty"`
	GoVersion string `protobuf:"bytes,5,opt,name=go_version,json=goVersion,proto3" json:"go_version,omitempty"`
	// contains filtered or unexported fields
}

type GetJobRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

type GetOverviewRequest struct {
	// contains filtered or unexported fields
}

type GetOverviewResponse struct {
	Stats        *OverviewStats       `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	Coordination *CoordinationStatus  `protobuf:"bytes,2,opt,name=coordination,proto3" json:"coordination,omitempty"`
	Actions      *AdminActionCounters `protobuf:"bytes,3,opt,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

type GetQueueRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetQueueResponse struct {
	Queue *QueueSummary `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type GetTaskRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type GetTaskResponse struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Output string `protobuf:"bytes,4,opt,name=output,proto3" json:"output,omitempty"`
	Error  string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type Job struct {
	Spec        *JobSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	CreatedAtMs int64    `protobuf:"varint,2,opt,name=created_at_ms,json=createdAtMs,proto3" json:"created_at_ms,omitempty"`
	UpdatedAtMs int64    `protobuf:"varint,3,opt,name=updated_at_ms,json=updatedAtMs,proto3" json:"updated_at_ms,omitempty"`
	// contains filtered or unexported fields
}

type JobEvent struct {
	TaskId       string            `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Name         string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Status       string            `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Queue        string            `protobuf:"bytes,4,opt,name=queue,proto3" json:"queue,omitempty"`
	Repo         string            `protobuf:"bytes,5,opt,name=repo,proto3" json:"repo,omitempty"`
	Tag          string            `protobuf:"bytes,6,opt,name=tag,proto3" json:"tag,omitempty"`
	Path         string            `protobuf:"bytes,7,opt,name=path,proto3" json:"path,omitempty"`
	Dockerfile   string            `protobuf:"bytes,8,opt,name=dockerfile,proto3" json:"dockerfile,omitempty"`
	Command      string            `protobuf:"bytes,9,opt,name=command,proto3" json:"command,omitempty"`
	ScheduleName string            `protobuf:"bytes,10,opt,name=schedule_name,json=scheduleName,proto3" json:"schedule_name,omitempty"`
	ScheduleSpec string            `protobuf:"bytes,11,opt,name=schedule_spec,json=scheduleSpec,proto3" json:"schedule_spec,omitempty"`
	StartedAtMs  int64             `protobuf:"varint,12,opt,name=started_at_ms,json=startedAtMs,proto3" json:"started_at_ms,omitempty"`
	FinishedAtMs int64             `protobuf:"varint,13,opt,name=finished_at_ms,json=finishedAtMs,proto3" json:"finished_at_ms,omitempty"`
	DurationMs   int64             `protobuf:"varint,14,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	Result       string            `protobuf:"bytes,15,opt,name=result,proto3" json:"result,omitempty"`
	Error        string            `protobuf:"bytes,16,opt,name=error,proto3" json:"error,omitempty"`
	Metadata     map[string]string `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

type JobSpec struct {
	Name           string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description    string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Repo           string   `protobuf:"bytes,3,opt,name=repo,proto3" json:"repo,omitempty"`
	Tag            string   `protobuf:"bytes,4,opt,name=tag,proto3" json:"tag,omitempty"`
	Path           string   `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
	Dockerfile     string   `protobuf:"bytes,6,opt,name=dockerfile,proto3" json:"dockerfile,omitempty"`
	Command        []string `protobuf:"bytes,7,rep,name=command,proto3" json:"command,omitempty"`
	Env            []string `protobuf:"bytes,8,rep,name=env,proto3" json:"env,omitempty"`
	Queue          string   `protobuf:"bytes,9,opt,name=queue,proto3" json:"queue,omitempty"`
	Retries        int32    `protobuf:"varint,10,opt,name=retries,proto3" json:"retries,omitempty"`
	TimeoutSeconds int32    `protobuf:"varint,11,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	Source         string   `protobuf:"bytes,12,opt,name=source,proto3" json:"source,omitempty"`
	TarballUrl     string   `protobuf:"bytes,13,opt,name=tarball_url,json=tarballUrl,proto3" json:"tarball_url,omitempty"`
	TarballPath    string   `protobuf:"bytes,14,opt,name=tarball_path,json=tarballPath,proto3" json:"tarball_path,omitempty"`
	TarballSha256  string   `protobuf:"bytes,15,opt,name=tarball_sha256,json=tarballSha256,proto3" json:"tarball_sha256,omitempty"`
	// contains filtered or unexported fields
}

type ListAuditEventsRequest struct {
	Action string `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Limit  int32  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type ListAuditEventsResponse struct {
	Events []*AuditEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type ListDLQRequest struct {
	Limit   int32  `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset  int32  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Queue   string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Handler string `protobuf:"bytes,4,opt,name=handler,proto3" json:"handler,omitempty"`
	Query   string `protobuf:"bytes,5,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

type ListDLQResponse struct {
	Entries []*DLQEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	Total   int64       `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

type ListJobEventsRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Limit int32  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type ListJobEventsResponse struct {
	Events []*JobEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type ListJobsRequest struct {
	// contains filtered or unexported fields
}

type ListJobsResponse struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

type ListQueuesRequest struct {
	// contains filtered or unexported fields
}

type ListQueuesResponse struct {
	Queues []*QueueSummary `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
	// contains filtered or unexported fields
}

type ListScheduleEventsRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Limit int32  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type ListScheduleEventsResponse struct {
	Events []*ScheduleEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type ListScheduleFactoriesRequest struct {
	// contains filtered or unexported fields
}

type ListScheduleFactoriesResponse struct {
	Factories []*ScheduleFactory `protobuf:"bytes,1,rep,name=factories,proto3" json:"factories,omitempty"`
	// contains filtered or unexported fields
}

type ListSchedulesRequest struct {
	// contains filtered or unexported fields
}

type ListSchedulesResponse struct {
	Schedules []*ScheduleEntry `protobuf:"bytes,1,rep,name=schedules,proto3" json:"schedules,omitempty"`
	// contains filtered or unexported fields
}

type OverviewStats struct {
	ActiveWorkers int32 `protobuf:"varint,1,opt,name=active_workers,json=activeWorkers,proto3" json:"active_workers,omitempty"`
	QueuedTasks   int64 `protobuf:"varint,2,opt,name=queued_tasks,json=queuedTasks,proto3" json:"queued_tasks,omitempty"`
	Queues        int32 `protobuf:"varint,3,opt,name=queues,proto3" json:"queues,omitempty"`
	AvgLatencyMs  int64 `protobuf:"varint,4,opt,name=avg_latency_ms,json=avgLatencyMs,proto3" json:"avg_latency_ms,omitempty"`
	P95LatencyMs  int64 `protobuf:"varint,5,opt,name=p95_latency_ms,json=p95LatencyMs,proto3" json:"p95_latency_ms,omitempty"`
	// contains filtered or unexported fields
}

type PauseDequeueRequest struct {
	// contains filtered or unexported fields
}

type PauseDequeueResponse struct {
	Paused bool `protobuf:"varint,1,opt,name=paused,proto3" json:"paused,omitempty"`
	// contains filtered or unexported fields
}

type PauseQueueRequest struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Paused bool   `protobuf:"varint,2,opt,name=paused,proto3" json:"paused,omitempty"`
	// contains filtered or unexported fields
}

type PauseQueueResponse struct {
	Queue *QueueSummary `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type PauseScheduleRequest struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Paused bool   `protobuf:"varint,2,opt,name=paused,proto3" json:"paused,omitempty"`
	// contains filtered or unexported fields
}