test/plugin/test_out_google_cloud_grpc.rb
# Create a Fluentd output test driver with the Google Cloud Output plugin with
# grpc enabled. The signature of this method is different between the grpc
# path and the non-grpc path. For grpc, an additional grpc stub class can be
# passed in to construct the mock used by the test driver.
Create a Fluentd output test driver with the Google Cloud Output plugin with
grpc enabled. The signature of this method is different between the grpc
path and the non-grpc path. For grpc, an additional grpc stub class can be
passed in to construct the mock used by the test driver.
Create a Fluentd output test driver with the Google Cloud Output plugin with grpc enabled . The signature of this method is different between the grpc path and the non - grpc path . For grpc an additional grpc stub class can be passed in to construct the mock used by the test driver .
def create_driver(conf = APPLICATION_DEFAULT_CONFIG,
                    tag = 'test',
                    multi_tags = false)
    conf += USE_GRPC_CONFIG
    driver = if multi_tags
               Fluent::Test::MultiTagBufferedOutputTestDriver.new(
                 GoogleCloudOutputWithGRPCMock.new(@grpc_stub))
             else
               Fluent::Test::BufferedOutputTestDriver.new(
                 GoogleCloudOutputWithGRPCMock.new(@grpc_stub), tag)
             end
    driver.configure(conf, true)
  end
def create_driver ( conf = APPLICATION_DEFAULT_CONFIG , tag = 'test' , multi_tags = false ) conf += USE_GRPC_CONFIG driver = if multi_tags Fluent :: Test :: MultiTagBufferedOutputTestDriver . new ( GoogleCloudOutputWithGRPCMock . new ( @grpc_stub ) ) else Fluent :: Test :: BufferedOutputTestDriver . new ( GoogleCloudOutputWithGRPCMock . new ( @grpc_stub ) , tag ) end driver . configure ( conf , true ) end
Create a Fluentd output test driver with the Google Cloud Output plugin with
grpc enabled.
Create a Fluentd output test driver with the Google Cloud Output plugin with grpc enabled .
conf
<not_specific>
tag
<not_specific>
multi_tags
<not_specific>