blob: d89d2c3e0041e77c9285e38cf573ecb18f493c9b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
syntax = "proto3";
package gitaly;
option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb";
import "lint.proto";
import "shared.proto";
service PraefectInfoService {
option (intercepted) = true;
rpc RepositoryReplicas(RepositoryReplicasRequest) returns (RepositoryReplicasResponse);
// DatalossCheck checks for unavailable repositories.
rpc DatalossCheck(DatalossCheckRequest) returns (DatalossCheckResponse);
// SetAuthoritativeStorage sets the authoritative storage for a repository on a given virtual storage.
// This causes the current version of the repository on the authoritative storage to be considered the
// latest and overwrite any other version on the virtual storage.
rpc SetAuthoritativeStorage(SetAuthoritativeStorageRequest) returns (SetAuthoritativeStorageResponse);
// SetReplicationFactor assigns or unassigns host nodes from the repository to meet the desired replication factor.
// SetReplicationFactor returns an error when trying to set a replication factor that exceeds the storage node count
// in the virtual storage. An error is also returned when trying to set a replication factor below one. The primary node
// won't be unassigned as it needs a copy of the repository to accept writes. Likewise, the primary is the first storage
// that gets assigned when setting a replication factor for a repository. Assignments of unconfigured storages are ignored.
// This might cause the actual replication factor to be higher than desired if the replication factor is set during an upgrade
// from a Praefect node that does not yet know about a new node. As assignments of unconfigured storages are ignored, replication
// factor of repositories assigned to a storage node removed from the cluster is effectively decreased.
rpc SetReplicationFactor(SetReplicationFactorRequest) returns (SetReplicationFactorResponse);
}
// SetReplicationFactorRequest sets the desired replication factor for a repository.
message SetReplicationFactorRequest {
// virtual_storage is the virtual storage the repository is located in
string virtual_storage = 1;
// relative_path is the relative path of the repository
string relative_path = 2;
// replication_factor is the desired replication factor. Replication must be equal or greater than 1.
int32 replication_factor = 3;
}
// SetReplicationFactorResponse returns the assigned hosts after setting the desired replication factor.
message SetReplicationFactorResponse {
// storages are the storages assigned to host the repository.
repeated string storages = 1;
}
message SetAuthoritativeStorageRequest {
string virtual_storage = 1;
string relative_path = 2;
string authoritative_storage = 3;
}
message SetAuthoritativeStorageResponse {}
message DatalossCheckRequest {
string virtual_storage = 1;
// include_partially_unavailable indicates whether to include repositories which are available but
// are unavailable on some assigned storages.
bool include_partially_replicated = 2;
}
message DatalossCheckResponse {
message Repository {
message Storage {
// name of the storage
string name = 1;
// behind_by indicates how many generations this storage is behind.
int64 behind_by = 2;
// assigned indicates whether the storage is assigned to host the repository.
bool assigned = 3;
// healthy indicates whether the storage is considered healthy by the consensus of Praefect nodes.
bool healthy = 4;
// valid_primary indicates whether the storage is ready to act as the primary if necessary.
bool valid_primary = 5;
}
// relative path of the repository with outdated replicas
string relative_path = 1;
// storages on which the repository is outdated
repeated Storage storages = 2;
// unavailable indicates whether the repository is in unavailable.
bool unavailable = 3;
// current primary storage of the repository
string primary = 4;
}
// repositories with data loss
repeated Repository repositories = 2;
}
message RepositoryReplicasRequest{
Repository repository = 1;
}
message RepositoryReplicasResponse{
message RepositoryDetails {
Repository repository = 1;
string checksum = 2;
};
RepositoryDetails primary = 1;
repeated RepositoryDetails replicas = 2;
}
|