Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

otel, loki: support dynamic headers() #334

Merged
merged 13 commits into from
Oct 21, 2024
Merged

otel, loki: support dynamic headers() #334

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
2d1db77
logthrdest: fix leaking worker_partition_key template
alltilla Oct 11, 2024
695ef4a
grpc/metrics: fix leaking stats cluster key
alltilla Oct 11, 2024
61d2134
grpc: add missing worker super deinit()
alltilla Oct 11, 2024
e246b5f
grpc/loki: flush on worker-partition-key change
alltilla Oct 10, 2024
fc7423d
grpc: add worker_partition_key related functions to base class
alltilla Oct 10, 2024
ce6b2d9
grpc: factor out loki::Label class as grpc::NameValueTemplatePair
alltilla Oct 11, 2024
9dff07f
grpc/bigquery: use NameValueTemplatePair in Field
alltilla Oct 11, 2024
090118e
grpc: support template_options for all destinations
alltilla Oct 11, 2024
1237e18
grpc: add support for templated header() values
alltilla Oct 11, 2024
885051d
grpc/otel: support dynamic headers
alltilla Oct 11, 2024
96ec7a2
grpc/loki: support dynamic headers
alltilla Oct 11, 2024
c26fddc
grpc: use local subchannel pool
alltilla Oct 11, 2024
a12a4a8
news: add entry for #334
alltilla Oct 11, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 7 additions & 2 deletions modules/grpc/loki/loki-dest.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -93,9 +93,14 @@ DestinationDriver::init()
}

if (log_template_is_literal_string(worker_partition_key))
log_template_unref(worker_partition_key);
{
log_template_unref(worker_partition_key);
}
else
log_threaded_dest_driver_set_worker_partition_key_ref(&this->super->super.super.super, worker_partition_key);
{
log_threaded_dest_driver_set_worker_partition_key_ref(&this->super->super.super.super, worker_partition_key);
log_threaded_dest_driver_set_flush_on_worker_key_change(&this->super->super.super.super, TRUE);
MrAnno marked this conversation as resolved.
Show resolved Hide resolved
}

return syslogng::grpc::DestDriver::init();
}
Expand Down