INNER CODE UNIT · Go

client

yaklang/yaklang · cmd/legion-smoke-node/main.go:369

	client := &http.Client{Timeout: 10 * time.Second}
	return func(session node.SessionState) {
		finish := startStartupStage(true, "sessionmgr_register")
		body, err := json.Marshal(map[string]string{
			"node_id":         session.NodeID,
			"node_session_id": session.SessionID,
		})
		if err != nil {
			finish(err)
			log.Printf("ai_session register marshal: %v", err)
			return
		}
		url := strings.TrimRight(sessionmgrURL, "/") + "/v1/sessionmgr/sessions/" + sessionID + "/register"
		resp, err := client.Post(url, "application/json", bytes.NewReader(body))
		if err != nil {
			finish(err)
			log.Printf("ai_session register callback to %s: %v", url, err)
			return

View source record →