upstream/kubernetes
1
0
Fork 0
mirror of https://github.com/kubernetes/kubernetes.git synced 2026-06-10 17:35:44 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

kubelet: DRA: plugin: set logging prefix

Browse source
This commit is contained in:
Ed Bartosh 2026-01-26 17:41:33 +02:00
parent 1c913f6e9c
commit 3b4e56e09c
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
pkg/kubelet/cm/dra/plugin/dra_plugin.go
View file

@ -74,7 +74,7 @@ func (p *DRAPlugin) NodePrepareResources(
req *drapbv1.NodePrepareResourcesRequest,
opts ...grpc.CallOption,
) (*drapbv1.NodePrepareResourcesResponse, error) {
logger := klog.FromContext(ctx)
logger := klog.FromContext(ctx).WithName("dra-plugin")
logger = klog.LoggerWithValues(logger, "driverName", p.driverName, "endpoint", p.endpoint)
ctx = klog.NewContext(ctx, logger)
logger.V(4).Info("Calling NodePrepareResources rpc", "request", req)
@ -105,11 +105,12 @@ func (p *DRAPlugin) NodeUnprepareResources(
req *drapbv1.NodeUnprepareResourcesRequest,
opts ...grpc.CallOption,
) (*drapbv1.NodeUnprepareResourcesResponse, error) {
logger := klog.FromContext(ctx)
logger.V(4).Info("Calling NodeUnprepareResource rpc", "request", req)
logger := klog.FromContext(ctx).WithName("dra-plugin")
logger = klog.LoggerWithValues(logger, "driverName", p.driverName, "endpoint", p.endpoint)
ctx = klog.NewContext(ctx, logger)
logger.V(4).Info("Calling NodeUnprepareResource rpc", "request", req)
ctx, cancel := context.WithTimeout(ctx, p.clientCallTimeout)
defer cancel()
@ -157,9 +158,10 @@ func (p *DRAPlugin) HealthStreamCancel() context.CancelFunc {
// NodeWatchResources establishes a stream to receive health updates from the DRA plugin.
func (p *DRAPlugin) NodeWatchResources(ctx context.Context) (drahealthv1alpha1.DRAResourceHealth_NodeWatchResourcesClient, error) {
logger := klog.FromContext(ctx).WithName("dra-plugin")
logger = klog.LoggerWithValues(logger, "driverName", p.driverName, "endpoint", p.endpoint)
healthClient := drahealthv1alpha1.NewDRAResourceHealthClient(p.conn)
logger := klog.FromContext(ctx).WithValues("pluginName", p.driverName)
logger.V(4).Info("Starting WatchResources stream")
stream, err := healthClient.NodeWatchResources(ctx, &drahealthv1alpha1.NodeWatchResourcesRequest{})
if err != nil {