test/plugin/base_test.rb in fluent-plugin-google-cloud-0.6.18 vs test/plugin/base_test.rb in fluent-plugin-google-cloud-0.6.19

- old
+ new

@@ -1308,77 +1308,84 @@ def test_k8s_monitored_resource_fallback [ # k8s_container. # When enable_metadata_agent is false. { - enable_metadata_agent: false, + config: APPLICATION_DEFAULT_CONFIG, setup_metadata_agent_stub: false, setup_k8s_stub: false, log_entry: k8s_container_log_entry(log_entry(0)), expected_params: COMPUTE_PARAMS }, { - enable_metadata_agent: false, + config: APPLICATION_DEFAULT_CONFIG, setup_metadata_agent_stub: true, setup_k8s_stub: false, log_entry: k8s_container_log_entry(log_entry(0)), expected_params: COMPUTE_PARAMS }, { - enable_metadata_agent: false, + config: APPLICATION_DEFAULT_CONFIG, setup_metadata_agent_stub: true, setup_k8s_stub: true, log_entry: k8s_container_log_entry(log_entry(0)), expected_params: COMPUTE_PARAMS }, { - enable_metadata_agent: false, + config: APPLICATION_DEFAULT_CONFIG, setup_metadata_agent_stub: false, setup_k8s_stub: true, log_entry: k8s_container_log_entry(log_entry(0)), expected_params: COMPUTE_PARAMS }, # When enable_metadata_agent is true. { - enable_metadata_agent: true, + config: ENABLE_METADATA_AGENT_CONFIG, setup_metadata_agent_stub: false, setup_k8s_stub: false, log_entry: k8s_container_log_entry(log_entry(0)), expected_params: COMPUTE_PARAMS }, { - enable_metadata_agent: true, + config: ENABLE_METADATA_AGENT_CONFIG, setup_metadata_agent_stub: false, setup_k8s_stub: true, log_entry: k8s_container_log_entry(log_entry(0)), expected_params: K8S_CONTAINER_PARAMS_FROM_LOCAL }, { - enable_metadata_agent: true, + config: CUSTOM_K8S_ENABLE_METADATA_AGENT_CONFIG, + setup_metadata_agent_stub: false, + setup_k8s_stub: false, + log_entry: k8s_container_log_entry(log_entry(0)), + expected_params: K8S_CONTAINER_PARAMS_CUSTOM + }, + { + config: ENABLE_METADATA_AGENT_CONFIG, setup_metadata_agent_stub: true, setup_k8s_stub: false, log_entry: k8s_container_log_entry(log_entry(0)), expected_params: K8S_CONTAINER_PARAMS }, { - enable_metadata_agent: true, + config: ENABLE_METADATA_AGENT_CONFIG, setup_metadata_agent_stub: true, setup_k8s_stub: true, log_entry: k8s_container_log_entry(log_entry(0)), expected_params: K8S_CONTAINER_PARAMS }, # When local_resource_id is not present or does not match k8s regexes. { - enable_metadata_agent: true, + config: ENABLE_METADATA_AGENT_CONFIG, setup_metadata_agent_stub: true, setup_k8s_stub: true, log_entry: k8s_container_log_entry( log_entry(0)).reject { |k, _| k == LOCAL_RESOURCE_ID_KEY }, expected_params: COMPUTE_PARAMS }, { - enable_metadata_agent: true, + config: ENABLE_METADATA_AGENT_CONFIG, setup_metadata_agent_stub: true, setup_k8s_stub: true, log_entry: k8s_container_log_entry( log_entry(0), local_resource_id: RANDOM_LOCAL_RESOURCE_ID), @@ -1386,25 +1393,32 @@ # not added. expected_params: COMPUTE_PARAMS }, # Specific cases for k8s_node. { - enable_metadata_agent: false, + config: APPLICATION_DEFAULT_CONFIG, setup_metadata_agent_stub: true, setup_k8s_stub: true, log_entry: k8s_node_log_entry(log_entry(0)), expected_params: COMPUTE_PARAMS }, { - enable_metadata_agent: true, - setup_metadata_agent_stub: true, + config: ENABLE_METADATA_AGENT_CONFIG, + setup_metadata_agent_stub: false, setup_k8s_stub: true, log_entry: k8s_node_log_entry(log_entry(0)), - expected_params: K8S_NODE_PARAMS + expected_params: K8S_NODE_PARAMS_FROM_LOCAL }, { - enable_metadata_agent: true, + config: CUSTOM_K8S_ENABLE_METADATA_AGENT_CONFIG, + setup_metadata_agent_stub: false, + setup_k8s_stub: false, + log_entry: k8s_node_log_entry(log_entry(0)), + expected_params: K8S_NODE_PARAMS_CUSTOM + }, + { + config: ENABLE_METADATA_AGENT_CONFIG, setup_metadata_agent_stub: true, setup_k8s_stub: true, log_entry: k8s_node_log_entry(log_entry(0)), expected_params: K8S_NODE_PARAMS } @@ -1420,15 +1434,10 @@ setup_k8s_metadata_stubs else setup_no_k8s_metadata_stubs end setup_logging_stubs do - config = if test_params[:enable_metadata_agent] - ENABLE_METADATA_AGENT_CONFIG - else - APPLICATION_DEFAULT_CONFIG - end - d = create_driver(config) + d = create_driver(test_params[:config]) d.emit(test_params[:log_entry]) d.run end verify_log_entries(1, test_params[:expected_params], 'jsonPayload') do |entry|