package proto

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc GetConnectionToken (GetConnectionTokenRequest, GetConnectionTokenResponse)

  dpauth.proto:8

  message GetConnectionTokenRequest

  dpauth.proto:12

  (message has no fields)

  message GetConnectionTokenResponse

  dpauth.proto:30

  • oneof response

    • GetConnectionTokenSuccessResponse success_response = 1

    • ErrorResponse error_response = 2

• rpc GetWorkspaceToken (GetWorkspaceTokenRequest, GetWorkspaceTokenResponse)

  dpauth.proto:9

  message GetWorkspaceTokenRequest

  dpauth.proto:15

  (message has no fields)

  message GetWorkspaceTokenResponse

  dpauth.proto:37

  • string workspaceToken = 1

  • string service = 2

  • string instanceID = 3

• rpc Start (JobRequest, JobResponse)

  rudder-sources.proto:8

• rpc Stop (JobRequest, JobResponse)

  rudder-sources.proto:9

• rpc Info (InfoRequest, InfoResponse)

  rudder-sources.proto:10

  message InfoRequest

  rudder-sources.proto:21

  • string role = 1

  • string path = 2

  • string body = 3

  message InfoResponse

  rudder-sources.proto:27

  • string error = 1

  • string data = 2

• rpc GetHealth (google.protobuf.Empty, google.protobuf.BoolValue)

  warehouse.proto:11

• rpc GetWHUploads (WHUploadsRequest, WHUploadsResponse)

  warehouse.proto:12

  message WHUploadsResponse

  warehouse.proto:54

  • repeated WHUploadResponse uploads = 1

  • optional Pagination pagination = 2

• rpc GetWHUpload (WHUploadRequest, WHUploadResponse)

  warehouse.proto:13

• rpc TriggerWHUpload (WHUploadRequest, TriggerWhUploadsResponse)

  warehouse.proto:14

• rpc TriggerWHUploads (WHUploadsRequest, TriggerWhUploadsResponse)

  warehouse.proto:15

• rpc Validate (WHValidationRequest, WHValidationResponse)

  warehouse.proto:16

  message WHValidationRequest

  warehouse.proto:88

  • string role = 1

  • string path = 2

  • string step = 3

  • string body = 4

  message WHValidationResponse

  warehouse.proto:95

  • string error = 1

  • string data = 2

• rpc RetryWHUploads (RetryWHUploadsRequest, RetryWHUploadsResponse)

  warehouse.proto:17

• rpc CountWHUploadsToRetry (RetryWHUploadsRequest, RetryWHUploadsResponse)

  warehouse.proto:18

• rpc ValidateObjectStorageDestination (ValidateObjectStorageRequest, ValidateObjectStorageResponse)

  warehouse.proto:19

  message ValidateObjectStorageRequest

  warehouse.proto:116

  • string type = 1

  • optional google.protobuf.Struct config = 2

  message ValidateObjectStorageResponse

  warehouse.proto:121

  • bool isValid = 2

  • string error = 3

• rpc RetrieveFailedBatches (RetrieveFailedBatchesRequest, RetrieveFailedBatchesResponse)

  warehouse.proto:20

  message RetrieveFailedBatchesRequest

  warehouse.proto:137

  • string workspaceID = 1

  • string destinationID = 2

  • string start = 3

  • string end = 4

  message RetrieveFailedBatchesResponse

  warehouse.proto:144

  • repeated FailedBatchInfo failedBatches = 1

• rpc RetryFailedBatches (RetryFailedBatchesRequest, RetryFailedBatchesResponse)

  warehouse.proto:21

  message RetryFailedBatchesRequest

  warehouse.proto:148

  • string workspaceID = 1

  • string destinationID = 2

  • string start = 3

  • string end = 4

  • string errorCategory = 5

  • string sourceID = 6

  • string status = 7

  message RetryFailedBatchesResponse

  warehouse.proto:158

  • int64 retriedSyncsCount = 1

• rpc GetFirstAbortedUploadInContinuousAbortsByDestination (FirstAbortedUploadInContinuousAbortsByDestinationRequest, FirstAbortedUploadInContinuousAbortsByDestinationResponse)

  warehouse.proto:22

  message FirstAbortedUploadInContinuousAbortsByDestinationRequest

  warehouse.proto:162

  • string workspace_id = 1

  • string start = 2

  message FirstAbortedUploadInContinuousAbortsByDestinationResponse

  warehouse.proto:180

  • repeated FirstAbortedUploadResponse uploads = 1

• rpc GetSyncLatency (SyncLatencyRequest, SyncLatencyResponse)

  warehouse.proto:23

  message SyncLatencyRequest

  warehouse.proto:184

  • string destination_id = 1

  • string workspace_id = 2

  • string start_time = 3

  • string aggregation_minutes = 4

  • string source_id = 5

  message SyncLatencyResponse

  warehouse.proto:192

  • repeated LatencyTimeSeriesDataPoint time_series_data_points = 1

• rpc SyncWHSchema (SyncWHSchemaRequest, google.protobuf.Empty)

  warehouse.proto:24

  message SyncWHSchemaRequest

  warehouse.proto:167

  • string destination_id = 1

Used in: GetConnectionTokenResponse

• string error = 1

Used in: EventSchemaMessage

• string writeKey = 1

• string eventType = 2

• string eventIdentifier = 3

• string workspaceID = 1

• optional EventSchemaKey key = 2

• map<string, string> schema = 3

• optional google.protobuf.Timestamp observedAt = 4

• bytes sample = 5

• bytes correlationID = 6

• string hash = 7

• int64 batchCount = 8

Used in: RetrieveFailedBatchesResponse

• string error = 1

• string errorCategory = 2

• string sourceID = 3

• int64 failedEventsCount = 4

• int64 failedSyncsCount = 5

• optional google.protobuf.Timestamp lastHappened = 6

• optional google.protobuf.Timestamp firstHappened = 7

• string status = 8

Used in: FirstAbortedUploadInContinuousAbortsByDestinationResponse

• int64 id = 1

• string source_id = 2

• string destination_id = 3

• optional google.protobuf.Timestamp created_at = 4

• optional google.protobuf.Timestamp first_event_at = 5

• optional google.protobuf.Timestamp last_event_at = 6

Used in: GetConnectionTokenResponse

• string connectionToken = 1

• string service = 2

• string instanceID = 3

• string tokenType = 4

• map<string, string> labels = 5

Used as request type in: JobService.Start, JobService.Stop

• string jobID = 1

Used as response type in: JobService.Start, JobService.Stop

• string error = 1

Used in: SyncLatencyResponse

• optional google.protobuf.DoubleValue timestamp_millis = 1

• optional google.protobuf.DoubleValue latency_seconds = 2

Used in: WHUploadsResponse

• int32 total = 1

• int32 limit = 2

• int32 offset = 3

Used as request type in: Warehouse.CountWHUploadsToRetry, Warehouse.RetryWHUploads

• string workspaceId = 1

• string sourceId = 2

• string destinationId = 3

• string destinationType = 4

• int64 intervalInHours = 5

• repeated int64 uploadIds = 6

• bool forceRetry = 7

Used as response type in: Warehouse.CountWHUploadsToRetry, Warehouse.RetryWHUploads

• string message = 1

• int64 count = 2

• int32 status_code = 3

Used as response type in: Warehouse.TriggerWHUpload, Warehouse.TriggerWHUploads

• string message = 1

• int32 status_code = 2

Used in: WHUploadResponse

• int64 id = 1

• int64 upload_id = 2

• string name = 3

• string status = 4

• string error = 5

• optional google.protobuf.Timestamp last_exec_at = 6

• int32 count = 7

• int32 duration = 8

Used as request type in: Warehouse.GetWHUpload, Warehouse.TriggerWHUpload

• int64 upload_id = 1

• string workspace_id = 2

Used as response type in: Warehouse.GetWHUpload

Used as field type in: WHUploadsResponse

• int64 id = 1

• string source_id = 2

• string destination_id = 3

• string destination_type = 4

• string namespace = 5

• string error = 6

• int32 attempt = 7

• string status = 8

• optional google.protobuf.Timestamp created_at = 9

• optional google.protobuf.Timestamp first_event_at = 10

• optional google.protobuf.Timestamp last_event_at = 11

• optional google.protobuf.Timestamp last_exec_at = 12

• optional google.protobuf.Timestamp next_retry_time = 13

• int32 duration = 14

• repeated WHTable tables = 15

• bool isArchivedUpload = 16

Used as request type in: Warehouse.GetWHUploads, Warehouse.TriggerWHUploads

• string source_id = 1

• string destination_id = 2

• string destination_type = 3

• string status = 4

• int32 limit = 5

• int32 offset = 6

• string workspace_id = 7