Side by Side Diff: common/api/dm/service/v1/claim_execution.proto
Issue 1537883002 :
Initial distributor implementation (Closed)
Patch Set: fix imports and make dummy.go a real file
Use n/p to move between diff chunks;
N/P to move between comments.
Draft comments are only viewable by you.
Jump to:
appengine/cmd/dm/deps/activate_execution.go
appengine/cmd/dm/deps/activate_execution_test.go
appengine/cmd/dm/deps/add_deps_test.go
appengine/cmd/dm/deps/common_test.go
appengine/cmd/dm/deps/ensure_attempt_test.go
appengine/cmd/dm/deps/ensure_graph_data.go
appengine/cmd/dm/deps/ensure_quests_test.go
appengine/cmd/dm/deps/finish_attempt.go
appengine/cmd/dm/deps/finish_attempt_test.go
appengine/cmd/dm/deps/service.go
appengine/cmd/dm/deps/tmp_get_execution.go
appengine/cmd/dm/deps/walk_graph.go
appengine/cmd/dm/deps/walk_graph_test.go
appengine/cmd/dm/distributor/config.go
appengine/cmd/dm/distributor/distributor.go
appengine/cmd/dm/distributor/fake/fake.go
appengine/cmd/dm/distributor/handlers.go
appengine/cmd/dm/distributor/notify_execution.go
appengine/cmd/dm/distributor/pubsub.go
appengine/cmd/dm/distributor/registry.go
appengine/cmd/dm/distributor/task_description.go
appengine/cmd/dm/distributor/test_registry.go
appengine/cmd/dm/distributor/tq_handler.go
appengine/cmd/dm/doc.go
appengine/cmd/dm/frontend/app.yaml
appengine/cmd/dm/frontend/cron.yaml
appengine/cmd/dm/frontend/doc.go
appengine/cmd/dm/frontend/index.yaml
appengine/cmd/dm/frontend/init.go
appengine/cmd/dm/model/attempt.go
appengine/cmd/dm/model/attempt_test.go
appengine/cmd/dm/model/execution.go
appengine/cmd/dm/model/execution_test.go
appengine/cmd/dm/model/keys.go
appengine/cmd/dm/model/quest.go
appengine/cmd/dm/model/quest_test.go
appengine/cmd/dm/mutate/ack_fwd_dep.go
appengine/cmd/dm/mutate/ack_fwd_dep_test.go
appengine/cmd/dm/mutate/activate_execution.go
appengine/cmd/dm/mutate/add_backdep.go
appengine/cmd/dm/mutate/add_backdep_test.go
appengine/cmd/dm/mutate/add_deps.go
appengine/cmd/dm/mutate/add_deps_test.go
appengine/cmd/dm/mutate/add_finished_deps.go
appengine/cmd/dm/mutate/add_finished_deps_test.go
appengine/cmd/dm/mutate/ensure_attempt.go
appengine/cmd/dm/mutate/ensure_attempt_test.go
appengine/cmd/dm/mutate/ensure_quest_attempts.go
appengine/cmd/dm/mutate/ensure_quest_attempts_test.go
appengine/cmd/dm/mutate/finish_attempt.go
appengine/cmd/dm/mutate/finish_attempt_test.go
appengine/cmd/dm/mutate/finish_execution.go
appengine/cmd/dm/mutate/merge_quest.go
appengine/cmd/dm/mutate/merge_quest_test.go
appengine/cmd/dm/mutate/record_completion.go
appengine/cmd/dm/mutate/record_completion_test.go
appengine/cmd/dm/mutate/schedule_execution.go
appengine/cmd/dm/mutate/schedule_execution_test.go
appengine/cmd/dm/mutate/timeout_execution.go
appengine/cmd/dm/notes
appengine/cmd/dm/static/dummy.go
common/api/dm/distributor/distributor.proto
common/api/dm/distributor/distributor.pb.go
common/api/dm/distributor/gen.go
common/api/dm/service/v1/activate_execution.pb.go
common/api/dm/service/v1/activate_execution_normalize.go
common/api/dm/service/v1/attempt_data.go
common/api/dm/service/v1/attempt_state_evolve.go
common/api/dm/service/v1/attempt_state_evolve_test.go
common/api/dm/service/v1/claim_execution.proto
common/api/dm/service/v1/claim_execution.pb.go
common/api/dm/service/v1/datastore_embed.go
common/api/dm/service/v1/datastore_embed_test.go
common/api/dm/service/v1/depsserver_dec.go
common/api/dm/service/v1/ensure_graph_data.pb.go
common/api/dm/service/v1/ensure_graph_data_normalize.go
common/api/dm/service/v1/execution_data.go
common/api/dm/service/v1/execution_state_evolve.go
common/api/dm/service/v1/execution_state_evolve_test.go
common/api/dm/service/v1/finish_attempt.pb.go
common/api/dm/service/v1/finish_attempt_normalize.go
common/api/dm/service/v1/gen.go
common/api/dm/service/v1/graph_data.proto
common/api/dm/service/v1/graph_data.pb.go
common/api/dm/service/v1/graph_data_abnormal_finish.go
common/api/dm/service/v1/graph_data_purge_timestamps.go
common/api/dm/service/v1/graph_query.pb.go
common/api/dm/service/v1/pb.discovery.go
common/api/dm/service/v1/proto_gae.gen.go
common/api/dm/service/v1/quest_desc_normalize.go
common/api/dm/service/v1/service.proto
common/api/dm/service/v1/service.pb.go
common/api/dm/service/v1/types.pb.go
common/api/dm/service/v1/walk_graph.proto
common/api/dm/service/v1/walk_graph.pb.go
common/api/dm/service/v1/walk_graph_normalize.go
common/gcloud/pubsub/topic.go