test/plugin/base_test.rb in fluent-plugin-google-cloud-0.6.5 vs test/plugin/base_test.rb in fluent-plugin-google-cloud-0.6.6
- old
+ new
@@ -950,50 +950,9 @@
assert_nil get_fields(entry['jsonPayload'])['httpRequest'], entry
end
end
end
- def test_labels_from_record
- setup_gce_metadata_stubs
- setup_logging_stubs do
- d = create_driver
- d.emit(DEFAULT_LABELS_KEY => CUSTOM_LABELS_MESSAGE)
- d.run
- end
- labels = COMPUTE_PARAMS[:labels].merge(CUSTOM_LABELS_MESSAGE)
- params = COMPUTE_PARAMS.merge(labels: labels)
- verify_log_entries(1, params, 'labels') do |entry|
- assert_nil get_fields(entry['jsonPayload'])[DEFAULT_LABELS_KEY], entry
- end
- end
-
- def test_labels_from_record_conflict
- setup_gce_metadata_stubs
- setup_logging_stubs do
- d = create_driver
- d.emit(DEFAULT_LABELS_KEY => { CONFLICTING_LABEL_KEY => 'a_string' })
- d.run
- end
- verify_log_entries(1, COMPUTE_PARAMS, 'jsonPayload') do |entry|
- fields = get_fields(entry['jsonPayload'])
- labels = get_fields(get_struct(fields[DEFAULT_LABELS_KEY]))
- assert_equal('a_string', get_string(labels[CONFLICTING_LABEL_KEY]), entry)
- end
- end
-
- def test_labels_from_record_when_not_hash
- setup_gce_metadata_stubs
- setup_logging_stubs do
- d = create_driver
- d.emit(DEFAULT_LABELS_KEY => 'a_string')
- d.run
- end
- verify_log_entries(1, COMPUTE_PARAMS, 'jsonPayload') do |entry|
- fields = get_fields(entry['jsonPayload'])
- assert_equal 'a_string', get_string(fields[DEFAULT_LABELS_KEY]), entry
- end
- end
-
def test_log_entry_trace_field
setup_gce_metadata_stubs
message = log_entry(0)
trace = 'projects/project-1/traces/1234567890abcdef1234567890abcdef'
[