Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(49)

Side by Side Diff: common/api/logdog_coordinator/services/v1/service.proto

Issue 1863973002: LogDog: Update to archival V2. (Closed) Base URL: https://github.com/luci/luci-go@grpcutil-errors
Patch Set: Code review comments, use Pub/Sub, archival staging, quality of life. Created 4 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 syntax = "proto3"; 5 syntax = "proto3";
6 6
7 package logdog; 7 package logdog;
8 8
9 import "state.proto"; 9 import "state.proto";
10 import "github.com/luci/luci-go/common/proto/logdog/logpb/log.proto"; 10 import "github.com/luci/luci-go/common/proto/logdog/logpb/log.proto";
11 import "google/protobuf/duration.proto";
11 import "google/protobuf/empty.proto"; 12 import "google/protobuf/empty.proto";
12 13
13 // GetConfigResponse is the response structure for the user 14 // GetConfigResponse is the response structure for the user
14 // "GetConfig" endpoint. 15 // "GetConfig" endpoint.
15 message GetConfigResponse { 16 message GetConfigResponse {
16 // The API URL of the base "luci-config" service. If empty, the default 17 // The API URL of the base "luci-config" service. If empty, the default
17 // service URL will be used. 18 // service URL will be used.
18 string config_service_url = 1; 19 string config_service_url = 1;
19 20
20 // The name of the configuration set to load from. 21 // The name of the configuration set to load from.
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after
61 } 62 }
62 63
63 // The response message for the LoadStream RPC. 64 // The response message for the LoadStream RPC.
64 message LoadStreamResponse { 65 message LoadStreamResponse {
65 // The state of the requested log stream. 66 // The state of the requested log stream.
66 LogStreamState state = 1; 67 LogStreamState state = 1;
67 68
68 // If requested, the serialized log stream descriptor. The protobuf version 69 // If requested, the serialized log stream descriptor. The protobuf version
69 // of this descriptor will match the "proto_version" field in "state". 70 // of this descriptor will match the "proto_version" field in "state".
70 bytes desc = 2; 71 bytes desc = 2;
72
73 // The age of the log stream.
74 google.protobuf.Duration age = 3;
75
76 // The archival key of the log stream. If this key doesn't match the key in
77 // the archival request, the request is superfluous and should be deleted.
78 bytes archival_key = 4;
71 } 79 }
72 80
73 // TerminateStreamRequest is the set of caller-supplied data for the 81 // TerminateStreamRequest is the set of caller-supplied data for the
74 // TerminateStream service endpoint. 82 // TerminateStream service endpoint.
75 message TerminateStreamRequest { 83 message TerminateStreamRequest {
76 // The log stream's path. 84 // The log stream's path.
77 string path = 1; 85 string path = 1;
78 // The log stream's secret. 86 // The log stream's secret.
79 bytes secret = 2; 87 bytes secret = 2;
80 88
81 // The terminal index of the stream. 89 // The terminal index of the stream.
82 int64 terminal_index = 3; 90 int64 terminal_index = 3;
83 } 91 }
84 92
85 // ArchiveStreamRequest is the set of caller-supplied data for the ArchiveStream 93 // ArchiveStreamRequest is the set of caller-supplied data for the ArchiveStream
86 // service endpoint. 94 // service endpoint.
87 message ArchiveStreamRequest { 95 message ArchiveStreamRequest {
88 // The path of the log stream that was archived. 96 // The path of the log stream that was archived.
89 string path = 1; 97 string path = 1;
90 // If true, the archive includes the full set of log stream entries between 98 // The number of log entries that were archived.
91 // [0..terminal_index]. 99 int64 log_entry_count = 2;
92 bool complete = 2;
93 // The highest log stream index that was archived. 100 // The highest log stream index that was archived.
94 int64 terminal_index = 3; 101 int64 terminal_index = 3;
102 // If not empty, there was an archival error.
103 //
104 // This field serves to indivate that an error occured (being non-empty) and
iannucci 2016/04/19 00:55:28 indicate?
dnj 2016/04/20 18:15:10 indubitably.
105 // to supply an value that will show up in the Coordinator ArchiveStream
106 // endpoint logs.
107 string error = 4;
95 108
96 // The archive URL of the log stream's stream data. 109 // The archive URL of the log stream's stream data.
97 string stream_url = 10; 110 string stream_url = 10;
98 // The size of the log stream's stream data. 111 // The size of the log stream's stream data.
99 int64 stream_size = 11; 112 int64 stream_size = 11;
100 113
101 // The archive URL of the log stream's index data. 114 // The archive URL of the log stream's index data.
102 string index_url = 20; 115 string index_url = 20;
103 // The size of the log stream's index data. 116 // The size of the log stream's index data.
104 int64 index_size = 21; 117 int64 index_size = 21;
(...skipping 19 matching lines...) Expand all
124 137
125 // TerminateStream is an idempotent operation to update the stream's terminal 138 // TerminateStream is an idempotent operation to update the stream's terminal
126 // index. 139 // index.
127 rpc TerminateStream(TerminateStreamRequest) returns (google.protobuf.Empty); 140 rpc TerminateStream(TerminateStreamRequest) returns (google.protobuf.Empty);
128 141
129 // ArchiveStream is an idempotent operation to record a log stream's archival 142 // ArchiveStream is an idempotent operation to record a log stream's archival
130 // parameters. It is used by the Archivist service upon successful stream 143 // parameters. It is used by the Archivist service upon successful stream
131 // archival. 144 // archival.
132 rpc ArchiveStream(ArchiveStreamRequest) returns (google.protobuf.Empty); 145 rpc ArchiveStream(ArchiveStreamRequest) returns (google.protobuf.Empty);
133 } 146 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698