MCPcopy Index your code
hub / github.com/coder/coder / initialize

Method initialize

scaletest/taskstatus/client.go:145–159  ·  view source on GitHub ↗
(ctx context.Context, logger slog.Logger, agentToken string)

Source from the content-addressed store, hash-verified

143}
144
145func (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.
162var _ client = (*sdkClient)(nil)

Callers

nothing calls this directly

Calls 7

NewFunction · 0.92
WithFixedTokenFunction · 0.92
WithHTTPClientFunction · 0.92
WithLoggerFunction · 0.92
WithLogBodiesFunction · 0.92
ConnectRPC29WithRoleMethod · 0.65
ErrorfMethod · 0.45

Tested by

no test coverage detected