blob: 66c23c1f4c8c40b0ac675ff3a886812cec41b2b3 (
plain) (
blame)
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
|
syntax = "proto3";
package yandex.cloud.datatransfer.v1.endpoint;
option go_package = "github.com/yandex-cloud/go-genproto/yandex/cloud/datatransfer/v1/endpoint;endpoint";
option java_package = "yandex.cloud.api.datatransfer.v1.endpoint";
option csharp_namespace = "Yandex.Cloud.Datatransfer.V1.EndPoint"; // there is a clash with class Endpoint in namespace Yandex.Cloud.Datatransfer.V1
import "yandex/cloud/datatransfer/v1/endpoint/parsers.proto";
import "yandex/cloud/datatransfer/v1/endpoint/serializers.proto";
enum YdsCompressionCodec {
YDS_COMPRESSION_CODEC_UNSPECIFIED = 0;
YDS_COMPRESSION_CODEC_RAW = 1;
YDS_COMPRESSION_CODEC_GZIP = 2;
YDS_COMPRESSION_CODEC_ZSTD = 4;
}
message YDSSource {
reserved 3 to 7, 12 to 19, 21 to 29, 31 to 33;
// Database
string database = 1;
// Stream
string stream = 2;
// SA which has read access to the stream.
string service_account_id = 8;
// Compression codec
repeated YdsCompressionCodec supported_codecs = 9;
// Data parsing rules
Parser parser = 10;
// Should continue working, if consumer read lag exceed TTL of topic
// False: stop the transfer in error state, if detected lost data. True: continue
// working with losing part of data
bool allow_ttl_rewind = 11;
// for dedicated db
string endpoint = 20;
// Network interface for endpoint. If none will assume public ipv4
string subnet_id = 30;
// Security groups
repeated string security_groups = 34;
// for important streams
string consumer = 35;
}
message YDSTarget {
reserved 5 to 7, 9 to 19, 21 to 29, 31 to 33;
// Database
string database = 1;
// Stream
string stream = 2;
// SA which has read access to the stream.
string service_account_id = 3;
// Save transaction order
// Not to split events queue into separate per-table queues.
// Incompatible with setting Topic prefix, only with Topic full name.
bool save_tx_order = 4;
// Data serialization format
Serializer serializer = 8;
// for dedicated db
string endpoint = 20;
// Network interface for endpoint. If none will assume public ipv4
string subnet_id = 30;
// Security groups
repeated string security_groups = 34;
}
|
