(ctx context.Context, logger slog.Logger, agentToken string)
| 143 | } |
| 144 | |
| 145 | func (u *sdkAppStatusUpdater) initialize(ctx context.Context, logger slog.Logger, agentToken string) error { |
| 146 | agentClient := agentsdk.New( |
| 147 | u.url, |
| 148 | agentsdk.WithFixedToken(agentToken), |
| 149 | codersdk.WithHTTPClient(u.httpClient), |
| 150 | codersdk.WithLogger(logger), |
| 151 | codersdk.WithLogBodies(), |
| 152 | ) |
| 153 | drpcClient, _, err := agentClient.ConnectRPC29WithRole(ctx, "") |
| 154 | if err != nil { |
| 155 | return xerrors.Errorf("connect to agent dRPC endpoint: %w", err) |
| 156 | } |
| 157 | u.drpcClient = drpcClient |
| 158 | return nil |
| 159 | } |
| 160 | |
| 161 | // Ensure sdkClient implements the client interface. |
| 162 | var _ client = (*sdkClient)(nil) |
nothing calls this directly
no test coverage detected