false true true maxThreads 100 = domain service-dal-use1-1.nonprd.pluto.tv = port 50051 = protoPath /home/ubuntu/tests/ = deadline 30000 Deadline for gRPC request = true false continue ${__tstFeedback(bzm-timer,1,${maxThreads},10)} ${__P(test.duration)} S 5 4000 180 5000 5000 3600 1 false 1 ThroughputController.percentThroughput 100.0 0.0 true import io.grpc.ClientInterceptor; import io.grpc.Metadata; import io.grpc.stub.MetadataUtils; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; import tv.pluto.ip.dal.language.LanguageManagerGrpc; import static tv.pluto.ip.dal.language.LanguageManagerGrpc.LanguageManagerBlockingStub; import tv.pluto.ip.dal.language.Languages.GetLanguagesRequest; import tv.pluto.ip.dal.language.Languages.GetLanguagesResponse; Metadata getMetadata() { // create a custom header Metadata header = new Metadata(); Metadata.Key<String> key = Metadata.Key.of("app_name", Metadata.ASCII_STRING_MARSHALLER); header.put(key, "performance_tests"); return header; } int maxInboundMessageSize = 1024 * 1024 * 1024; // 1GB ManagedChannel channel = ManagedChannelBuilder.forTarget(vars.get("domain") + ":" + vars.get("port")) .maxInboundMessageSize(maxInboundMessageSize) .build(); ClientInterceptor CLIENT_INTERCEPTOR = MetadataUtils.newAttachHeadersInterceptor(getMetadata()); LanguageManagerBlockingStub blockingStub; blockingStub = LanguageManagerGrpc.newBlockingStub(channel); blockingStub = blockingStub.withInterceptors(CLIENT_INTERCEPTOR); try { blockingStub.getLanguages(GetLanguagesRequest.newBuilder().build()); } finally { channel.shutdown(); } groovy true import io.grpc.ClientInterceptor; import io.grpc.Metadata; import io.grpc.stub.MetadataUtils; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; import tv.pluto.ip.dal.channels.ChannelManagerGrpc; import static tv.pluto.ip.dal.channels.ChannelManagerGrpc.ChannelManagerBlockingStub; import tv.pluto.ip.dal.channels.Channels.GetByIdRequest; import tv.pluto.ip.dal.channels.Channels.GetByIdResponse; Metadata getMetadata() { // create a custom header Metadata header = new Metadata(); Metadata.Key<String> key = Metadata.Key.of("app_name", Metadata.ASCII_STRING_MARSHALLER); header.put(key, "performance_tests"); return header; } int maxInboundMessageSize = 1024 * 1024 * 1024; // 1GB ManagedChannel channel = ManagedChannelBuilder.forTarget(vars.get("domain") + ":" + vars.get("port")) .maxInboundMessageSize(maxInboundMessageSize) .build(); ClientInterceptor CLIENT_INTERCEPTOR = MetadataUtils.newAttachHeadersInterceptor(getMetadata()); ChannelManagerBlockingStub blockingStub; blockingStub = ChannelManagerGrpc.newBlockingStub(channel); blockingStub = blockingStub.withInterceptors(CLIENT_INTERCEPTOR); String id = "51c75f7bb6f26ba1cd000009"; GetByIdRequest request = GetByIdRequest.newBuilder() .setId(id) .build(); try { if (!blockingStub.getById(request).getDocument().getId().equals(id)) { throw new RuntimeException("Wrong channel returned"); } } finally { channel.shutdown(); } groovy true import io.grpc.ClientInterceptor; import io.grpc.Metadata; import io.grpc.stub.MetadataUtils; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; import tv.pluto.ip.dal.clip.ClipManagerGrpc; import static tv.pluto.ip.dal.clip.ClipManagerGrpc.ClipManagerBlockingStub; import tv.pluto.ip.dal.clip.Clips.GetByIdRequest; import tv.pluto.ip.dal.clip.Clips.GetByIdResponse; Metadata getMetadata() { // create a custom header Metadata header = new Metadata(); Metadata.Key<String> key = Metadata.Key.of("app_name", Metadata.ASCII_STRING_MARSHALLER); header.put(key, "performance_tests"); return header; } int maxInboundMessageSize = 1024 * 1024 * 1024; // 1GB ManagedChannel channel = ManagedChannelBuilder.forTarget(vars.get("domain") + ":" + vars.get("port")) .maxInboundMessageSize(maxInboundMessageSize) .build(); ClientInterceptor CLIENT_INTERCEPTOR = MetadataUtils.newAttachHeadersInterceptor(getMetadata()); ClipManagerBlockingStub blockingStub; blockingStub = ClipManagerGrpc.newBlockingStub(channel); blockingStub = blockingStub.withInterceptors(CLIENT_INTERCEPTOR); String id = "51c75f7bb6f26ba1cd000042"; GetByIdRequest request = GetByIdRequest.newBuilder() .setId(id) .build(); try { if (!blockingStub.getById(request).getDocument().getId().equals(id)) { throw new RuntimeException("Wrong channel returned"); } } finally { channel.shutdown(); } groovy true import io.grpc.ClientInterceptor; import io.grpc.Metadata; import io.grpc.stub.MetadataUtils; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; import tv.pluto.ip.dal.device.DeviceManagerGrpc; import tv.pluto.ip.dal.device.DeviceManagerGrpc.DeviceManagerBlockingStub; import tv.pluto.ip.dal.device.Devices.GetByIdRequest; Metadata getMetadata() { // create a custom header Metadata header = new Metadata(); Metadata.Key<String> key = Metadata.Key.of("app_name", Metadata.ASCII_STRING_MARSHALLER); header.put(key, "performance_tests"); return header; } int maxInboundMessageSize = 1024 * 1024 * 1024; // 1GB ManagedChannel channel = ManagedChannelBuilder.forTarget(vars.get("domain") + ":" + vars.get("port")) .maxInboundMessageSize(maxInboundMessageSize) .build(); ClientInterceptor CLIENT_INTERCEPTOR = MetadataUtils.newAttachHeadersInterceptor(getMetadata()); DeviceManagerBlockingStub blockingStub; blockingStub = DeviceManagerGrpc.newBlockingStub(channel); blockingStub = blockingStub.withInterceptors(CLIENT_INTERCEPTOR); String id = "56a824b8ab8c066403d9135a"; GetByIdRequest request = GetByIdRequest.newBuilder() .setId(id) .build(); try { if (!blockingStub.getById(request).getDocument().getId().equals(id)) { throw new RuntimeException("Wrong channel returned"); } } finally { channel.shutdown(); } groovy true import io.grpc.ClientInterceptor; import io.grpc.Metadata; import io.grpc.stub.MetadataUtils; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; import tv.pluto.ip.dal.episode.EpisodeManagerGrpc; import tv.pluto.ip.dal.episode.EpisodeManagerGrpc.EpisodeManagerBlockingStub; import tv.pluto.ip.dal.episode.Episodes.GetByIdRequest; Metadata getMetadata() { // create a custom header Metadata header = new Metadata(); Metadata.Key<String> key = Metadata.Key.of("app_name", Metadata.ASCII_STRING_MARSHALLER); header.put(key, "performance_tests"); return header; } int maxInboundMessageSize = 1024 * 1024 * 1024; // 1GB ManagedChannel channel = ManagedChannelBuilder.forTarget(vars.get("domain") + ":" + vars.get("port")) .maxInboundMessageSize(maxInboundMessageSize) .build(); ClientInterceptor CLIENT_INTERCEPTOR = MetadataUtils.newAttachHeadersInterceptor(getMetadata()); EpisodeManagerBlockingStub blockingStub; blockingStub = EpisodeManagerGrpc.newBlockingStub(channel); blockingStub = blockingStub.withInterceptors(CLIENT_INTERCEPTOR); String id = "521d673119f6a0cf6d000553"; GetByIdRequest request = GetByIdRequest.newBuilder() .setId(id) .build(); try { if (!blockingStub.getById(request).getDocument().getId().equals(id)) { throw new RuntimeException("Wrong channel returned"); } } finally { channel.shutdown(); } groovy true import io.grpc.ClientInterceptor; import io.grpc.Metadata; import io.grpc.stub.MetadataUtils; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; import tv.pluto.ip.dal.partner.PartnerManagerGrpc; import tv.pluto.ip.dal.partner.PartnerManagerGrpc.PartnerManagerBlockingStub; import tv.pluto.ip.dal.partner.Partners.GetByIdRequest; Metadata getMetadata() { // create a custom header Metadata header = new Metadata(); Metadata.Key<String> key = Metadata.Key.of("app_name", Metadata.ASCII_STRING_MARSHALLER); header.put(key, "performance_tests"); return header; } int maxInboundMessageSize = 1024 * 1024 * 1024; // 1GB ManagedChannel channel = ManagedChannelBuilder.forTarget(vars.get("domain") + ":" + vars.get("port")) .maxInboundMessageSize(maxInboundMessageSize) .build(); ClientInterceptor CLIENT_INTERCEPTOR = MetadataUtils.newAttachHeadersInterceptor(getMetadata()); PartnerManagerBlockingStub blockingStub; blockingStub = PartnerManagerGrpc.newBlockingStub(channel); blockingStub = blockingStub.withInterceptors(CLIENT_INTERCEPTOR); String id = "5581b2ec5da69c3bfdc0a316"; GetByIdRequest request = GetByIdRequest.newBuilder() .setId(id) .build(); try { if (!blockingStub.getById(request).getDocument().getId().equals(id)) { throw new RuntimeException("Wrong channel returned"); } } finally { channel.shutdown(); } groovy true import io.grpc.ClientInterceptor; import io.grpc.Metadata; import io.grpc.stub.MetadataUtils; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; import tv.pluto.ip.dal.publishinguser.PublishingUserManagerGrpc; import tv.pluto.ip.dal.publishinguser.PublishingUserManagerGrpc.PublishingUserManagerBlockingStub; import tv.pluto.ip.dal.publishinguser.PublishingUsers.GetByIdRequest; Metadata getMetadata() { // create a custom header Metadata header = new Metadata(); Metadata.Key<String> key = Metadata.Key.of("app_name", Metadata.ASCII_STRING_MARSHALLER); header.put(key, "performance_tests"); return header; } int maxInboundMessageSize = 1024 * 1024 * 1024; // 1GB ManagedChannel channel = ManagedChannelBuilder.forTarget(vars.get("domain") + ":" + vars.get("port")) .maxInboundMessageSize(maxInboundMessageSize) .build(); ClientInterceptor CLIENT_INTERCEPTOR = MetadataUtils.newAttachHeadersInterceptor(getMetadata()); PublishingUserManagerBlockingStub blockingStub; blockingStub = PublishingUserManagerGrpc.newBlockingStub(channel); blockingStub = blockingStub.withInterceptors(CLIENT_INTERCEPTOR); String id = "5d93b9519bc293000912e04b"; GetByIdRequest request = GetByIdRequest.newBuilder() .setId(id) .build(); try { if (!blockingStub.getById(request).getDocument().getId().equals(id)) { throw new RuntimeException("Wrong channel returned"); } } finally { channel.shutdown(); } groovy true import io.grpc.ClientInterceptor; import io.grpc.Metadata; import io.grpc.stub.MetadataUtils; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; import tv.pluto.ip.dal.series.SeriesManagerGrpc; import tv.pluto.ip.dal.series.SeriesManagerGrpc.SeriesManagerBlockingStub; import tv.pluto.ip.dal.series.SeriesOuterClass.GetByIdRequest; Metadata getMetadata() { // create a custom header Metadata header = new Metadata(); Metadata.Key<String> key = Metadata.Key.of("app_name", Metadata.ASCII_STRING_MARSHALLER); header.put(key, "performance_tests"); return header; } int maxInboundMessageSize = 1024 * 1024 * 1024; // 1GB ManagedChannel channel = ManagedChannelBuilder.forTarget(vars.get("domain") + ":" + vars.get("port")) .maxInboundMessageSize(maxInboundMessageSize) .build(); ClientInterceptor CLIENT_INTERCEPTOR = MetadataUtils.newAttachHeadersInterceptor(getMetadata()); SeriesManagerBlockingStub blockingStub; blockingStub = SeriesManagerGrpc.newBlockingStub(channel); blockingStub = blockingStub.withInterceptors(CLIENT_INTERCEPTOR); String id = "55af18da27f18b7f8bc270ab"; GetByIdRequest request = GetByIdRequest.newBuilder() .setId(id) .build(); try { if (!blockingStub.getById(request).getDocument().getId().equals(id)) { throw new RuntimeException("Wrong channel returned"); } } finally { channel.shutdown(); } groovy true import io.grpc.ClientInterceptor; import io.grpc.Metadata; import io.grpc.stub.MetadataUtils; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; import tv.pluto.ip.dal.subclip.SubClipManagerGrpc; import tv.pluto.ip.dal.subclip.SubClipManagerGrpc.SubClipManagerBlockingStub; import tv.pluto.ip.dal.subclip.SubClips.GetByIdRequest; Metadata getMetadata() { // create a custom header Metadata header = new Metadata(); Metadata.Key<String> key = Metadata.Key.of("app_name", Metadata.ASCII_STRING_MARSHALLER); header.put(key, "performance_tests"); return header; } int maxInboundMessageSize = 1024 * 1024 * 1024; // 1GB ManagedChannel channel = ManagedChannelBuilder.forTarget(vars.get("domain") + ":" + vars.get("port")) .maxInboundMessageSize(maxInboundMessageSize) .build(); ClientInterceptor CLIENT_INTERCEPTOR = MetadataUtils.newAttachHeadersInterceptor(getMetadata()); SubClipManagerBlockingStub blockingStub; blockingStub = SubClipManagerGrpc.newBlockingStub(channel); blockingStub = blockingStub.withInterceptors(CLIENT_INTERCEPTOR); String id = "5cc1fcd447f054c29ccd21c7"; GetByIdRequest request = GetByIdRequest.newBuilder() .setId(id) .build(); try { if (!blockingStub.getById(request).getDocument().getId().equals(id)) { throw new RuntimeException("Wrong channel returned"); } } finally { channel.shutdown(); } groovy true import io.grpc.ClientInterceptor; import io.grpc.Metadata; import io.grpc.stub.MetadataUtils; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; import tv.pluto.ip.dal.timeline.TimelineManagerGrpc; import tv.pluto.ip.dal.timeline.TimelineManagerGrpc.TimelineManagerBlockingStub; import tv.pluto.ip.dal.timeline.Timelines.GetByIdRequest; Metadata getMetadata() { // create a custom header Metadata header = new Metadata(); Metadata.Key<String> key = Metadata.Key.of("app_name", Metadata.ASCII_STRING_MARSHALLER); header.put(key, "performance_tests"); return header; } int maxInboundMessageSize = 1024 * 1024 * 1024; // 1GB ManagedChannel channel = ManagedChannelBuilder.forTarget(vars.get("domain") + ":" + vars.get("port")) .maxInboundMessageSize(maxInboundMessageSize) .build(); ClientInterceptor CLIENT_INTERCEPTOR = MetadataUtils.newAttachHeadersInterceptor(getMetadata()); TimelineManagerBlockingStub blockingStub; blockingStub = TimelineManagerGrpc.newBlockingStub(channel); blockingStub = blockingStub.withInterceptors(CLIENT_INTERCEPTOR); String id = "6422c5a0dbdaaa0008589158"; GetByIdRequest request = GetByIdRequest.newBuilder() .setId(id) .build(); try { if (!blockingStub.getById(request).getDocument().getId().equals(id)) { throw new RuntimeException("Wrong channel returned"); } } finally { channel.shutdown(); } groovy 1 false 1 ThroughputController.percentThroughput 50.0 0.0 ${protoPath} app_name: "performance_test" ${domain} ${port} channelpackage.ChannelManager/GetChannelById ${deadline} true { "id":"62865cca72d0d700071aa879" } false 5000 4194304 8192 java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } ${protoPath} app_name: "performance_test" ${domain} ${port} sequencerpackage.SequencerManager/GetHydratedEpisode ${deadline} true { "id":"51c75f7fb6f26ba1cd001451" } false 5000 4194304 8192 java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } ${protoPath} app_name: "performance_test" ${domain} ${port} comscorepackage.ComScoreManager/GetComScoreForClip ${deadline} true { "id":"5e320a977969d1775d718a15" } false 5000 4194304 8192 java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } ${protoPath} app_name: "performance_test" ${domain} ${port} sequencerpackage.SequencerManager/GetHydratedTimeline ${deadline} true { "id":"51c75f7bb6f26ba1cd00000e" } false 5000 4194304 8192 java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } ${protoPath} {app_name: "performance_test"} ${domain} ${port} vodcategoryentrypackage.VodCategoryEntryManager/GetVodCategoryEntriesByVodCategoryId ${deadline} true false 5000 4194304 8192 { "id": "58e1e12717d972af2febfd9e" } java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } 1 false 1 ThroughputController.percentThroughput 50.0 0.0 ${protoPath} { app_name: "performance_test"} ${domain} ${port} vodcategorypackage.VodCategoryManager/GetByEpisodeId ${deadline} true false 5000 4194304 8192 { "id":"58e1ad9e91586c9d2fbe4140" } java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } ${protoPath} app_name: "performance_test" ${domain} ${port} timelinepackage.TimelineManager/GetTimelineById ${deadline} true { "id":"62c2def9d707b900073a0ff3" } false 5000 4194304 8192 java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } ${protoPath} app_name: "performance_test" ${domain} ${port} episodepackage.EpisodeManager/GetEpisodeById ${deadline} true { "id":"524dc7c23e0983ea090014d8" } false 5000 4194304 8192 java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } ${protoPath} app_name: "performance_test" ${domain} ${port} clippackage.ClipManager/GetClipById ${deadline} true { "id":"51c75f7bb6f26ba1cd00005c" } false 5000 4194304 8192 java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } ${protoPath} app_name: "performance_test" ${domain} ${port} subclippackage.SubClipManager/GetSubClipById ${deadline} true { "id":"5cc1f44a599ddd092a5b191f" } false 5000 4194304 8192 java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } ${protoPath} app_name: "performance_test" ${domain} ${port} seriespackage.SeriesManager/GetSeriesById ${deadline} true { "id":"55af18db27f18b7f8bc27116" } false 5000 4194304 8192 java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } ${protoPath} app_name: "performance_test" ${domain} ${port} partnerpackage.PartnerManager/GetPartnerById ${deadline} true { "id":"5581b2ec5da69c3bfdc0a316" } false 5000 4194304 8192 java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } 1 false 1 ThroughputController.percentThroughput 35.0 0.0 ${protoPath} { app_name: "performance_test"} ${domain} ${port} timelinepackage.TimelineManager/GetByEpisodeId ${deadline} true false 5000 4194304 8192 { "id": "5eb7e3ffd6ea50001a323037a", "limit": 1, "offset": 0 } java true String message = ""; String responseStatusCode = sampleResult.getResponseCode(); String responseMessage = sampleResult.getResponseMessage(); if (!sampleResult.isSuccessful()){ message = "ResponseCode: " + responseStatusCode + " ResponseMessage: " + responseMessage; log.error(message); } false saveConfig true true true true true true true true true true true true true true true true true true false true 0 true true true true true true true true true true apiKey ${__P(datadog.apiKey)} = datadogUrl https://api.datadoghq.com/api/ = logIntakeUrl https://http-intake.logs.datadoghq.com/v1/input/ = metricsMaxBatchSize 200 = logsBatchSize 500 = sendResultsAsLogs true = includeSubresults true = samplersRegex = customTags application:service-dal,appurl:${__P(app.url)} = excludeLogsResponseCodeRegex [123][0-5][0-9] = org.datadog.jmeter.plugins.DatadogBackendClient true saveConfig true true true true true true true true true false true true true true true false true true false true 0 true true true true true true true true true influxdbMetricsSender org.apache.jmeter.visualizers.backend.influxdb.HttpMetricsSender = influxdbUrl https://influxdb.grafana.pluto.tv/write?db=jmeter = application DAL-Service = measurement jmeter = summaryOnly false = samplersRegex .* = percentiles 99;95;90 = testTitle DAL Service Tests = eventTags = org.apache.jmeter.visualizers.backend.influxdb.InfluxdbBackendListenerClient