(ctx context.Context)
| 268 | } |
| 269 | |
| 270 | func (client *daggerClient) ShutdownTelemetry(ctx context.Context) error { |
| 271 | slog := slog.With("client", client.clientID) |
| 272 | var errs error |
| 273 | if client.tracerProvider != nil { |
| 274 | slog.ExtraDebug("force flushing client traces") |
| 275 | errs = errors.Join(errs, client.tracerProvider.Shutdown(ctx)) |
| 276 | } |
| 277 | if client.loggerProvider != nil { |
| 278 | slog.ExtraDebug("force flushing client logs") |
| 279 | errs = errors.Join(errs, client.loggerProvider.Shutdown(ctx)) |
| 280 | } |
| 281 | if client.meterProvider != nil { |
| 282 | slog.ExtraDebug("force flushing client metrics") |
| 283 | errs = errors.Join(errs, client.meterProvider.Shutdown(ctx)) |
| 284 | } |
| 285 | return errs |
| 286 | } |
| 287 | |
| 288 | func (client *daggerClient) getMainClientCaller(ctx context.Context) (engineutil.SessionCaller, error) { |
| 289 | return client.getClientCaller(ctx, client.daggerSession.mainClientCallerID) |
no test coverage detected